Create app.py

app.py

@@ -0,0 +1,76 @@
+from fastapi import FastAPI, Request
+from fastapi.middleware.cors import CORSMiddleware
+import uvicorn
+import logging
+import requests
+import json
+
+# Configure logging
+logging.basicConfig(level=logging.INFO)
+logger = logging.getLogger(__name__)
+
+app = FastAPI()
+
+# CORS (Cross-Origin Resource Sharing) middleware
+app.add_middleware(
+    CORSMiddleware,
+    allow_origins=["*"],  # Allow requests from any origin
+    allow_credentials=True,
+    allow_methods=["*"],  # Allow all HTTP methods
+    allow_headers=["*"],  # Allow all headers
+)
+
+@app.api_route("/{full_path:path}", methods=["GET", "POST", "PUT", "DELETE", "OPTIONS", "HEAD", "PATCH"])
+async def logging_proxy(request: Request, full_path: str):
+    """
+    Logs all incoming requests and their details, then forwards the request.
+    """
+
+    # Log the request details
+    log_data = {
+        "method": request.method,
+        "url": str(request.url),
+        "headers": dict(request.headers),
+        "query_params": dict(request.query_params),
+        "client_host": request.client.host,
+    }
+
+    try:
+        # Get the request body (if any) and log it as well
+        body = await request.body()
+        if body:
+            try:
+                # Attempt to decode JSON body for better logging
+                json_body = json.loads(body.decode())
+                log_data["body"] = json_body
+            except json.JSONDecodeError:
+                # Log the raw body if it's not JSON
+                log_data["body"] = body.decode()
+
+        logger.info(f"Incoming request: {json.dumps(log_data, indent=2)}")
+
+        # Forward the request (replace with your desired forwarding logic)
+        # In this example, we just log the request and return a simple response.
+        # You can modify this part to forward to a specific URL or service.
+        # Example (modify as needed):
+        # target_url = f"https://some-backend-service.com/{full_path}"
+        # response = requests.request(
+        #     method=request.method,
+        #     url=target_url,
+        #     headers=dict(request.headers),
+        #     params=dict(request.query_params),
+        #     data=body
+        # )
+        # return Response(content=response.content, status_code=response.status_code)
+
+        return {
+            "message": "Request logged successfully",
+            "logged_data": log_data
+        }
+
+    except Exception as e:
+        logger.error(f"Error processing request: {e}")
+        return {"error": "An error occurred while processing the request"}
+
+if __name__ == "__main__":
+    uvicorn.run(app, host="0.0.0.0", port=8000)