Update app.py

app.py

@@ -72,13 +72,29 @@ async def extract_and_transform_proxies(input_text):
 
     return "\n".join(transformed_proxies) if transformed_proxies else "未找到有效的SS或Trojan代理配置"
 
+async def log_request(request, response):
+    timestamp = datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')
+    client_ip = request.remote
+    request_line = f"{request.method} {request.path}"
+    if request.query_string:
+        request_line += f"?{request.query_string}"
+    status_code = response.status
+    content_length = response.content_length
+
+    log_message = f"{timestamp} - {client_ip} - \"{request_line}\" {status_code} {content_length}"
+    print(log_message, flush=True)
+
+@web.middleware
+async def logging_middleware(request, handler):
+    response = await handler(request)
+    await log_request(request, response)
+    return response
+
 async def handle_request(request):
     if request.path == '/':
         query_params = parse_qs(request.query_string)
         if 'url' in query_params:
             url = query_params['url'][0]
-            timestamp = datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')
-            print(f"{timestamp} - {request.remote} - GET /?url={url}")
             try:
                 async with aiohttp.ClientSession() as session:
                     input_text = await fetch_url(url, session)
@@ -101,11 +117,11 @@ async def handle_request(request):
         return web.Response(text="Not Found", status=404)
 
 async def init_app():
-    app = web.Application()
+    app = web.Application(middlewares=[logging_middleware])
     app.router.add_get('/', handle_request)
     return app
 
 if __name__ == "__main__":
     print(f"===== Application Startup at {datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')} =====")
     print("Server running on port 8080")
-    web.run_app(init_app(), port=8080)
+    web.run_app(init_app(), port=8080, print=lambda _: None)  # Disable default startup message