capturing requests

.gitignore

@@ -0,0 +1,3 @@
+__pycache__
+*.json
+uv.lock

Dockerfile

@@ -0,0 +1,23 @@
+FROM debian:latest AS puppy
+
+# prep
+RUN apt-get update \
+    && apt-get install -y curl \
+    && apt-get clean
+RUN useradd -m -u 1000 user
+USER user
+
+ENV PATH=/home/user/.pixi/bin:$PATH
+RUN mkdir $HOME/puppy
+WORKDIR $HOME/puppy
+
+# install puppy
+RUN curl -fsSL https://raw.githubusercontent.com/liquidcarbon/puppy/main/pup.sh | bash -s 3.12
+RUN pup
+RUN pup add appenv fastapi[standard]
+WORKDIR appenv
+
+COPY --chown=user *.py .
+
+EXPOSE 7860
+CMD .venv/bin/fastapi run fetch.py --host 0.0.0.0 --port 7860

fetch.py

@@ -0,0 +1,64 @@
+from datetime import datetime
+from fastapi import FastAPI, Request
+from fastapi.responses import Response, FileResponse
+from typing import Any
+
+import json
+import subprocess
+
+
+class PrettyJSONResponse(Response):
+    media_type = "application/json"
+
+    def render(self, content: Any) -> bytes:
+        return json.dumps(content, indent=2).encode("utf-8")
+
+
+app = FastAPI()
+
+
+@app.middleware("http")
+async def log_request(request: Request, call_next: Any):
+    ts = datetime.now().strftime("%y%m%d%H%M%S%f")
+    data = {
+        "day": int(ts[:6]),
+        "dt": int(ts[:-3]),
+        "url": request.url,
+        "query_params": request.query_params,
+        "client": request.client.host,
+        "method": request.method,
+        "headers": dict(request.headers),
+    }
+    output = json.dumps(
+        obj=data,
+        default=str,
+        indent=None,
+        separators=(", ", ":"),
+    )
+    with open("a.json", "a") as f:
+        separator = "\n" if f.tell() else ""
+        f.write(separator + output)
+
+    response = await call_next(request)
+    return response
+
+
+@app.get("/")
+def read_root(request: Request):
+    return {"Hello": request.client.host}
+
+
+@app.get("/a", response_class=PrettyJSONResponse)
+def get_analytics(n: int = 5):
+    if n == 0:
+        cmd = "cat a.json"
+    else:
+        cmd = f"tail -{n} a.json"
+    json_lines = subprocess.run(cmd.split(), capture_output=True).stdout
+    content = json.loads(f"[{json_lines.replace(b"\n", b",").decode()}]")
+    return content
+
+
+@app.api_route("/qa", response_class=FileResponse, methods=["GET", "HEAD"])
+def query_analytics():
+    return "a.json"

pyproject.toml

@@ -0,0 +1,12 @@
+[project]
+name = "fetch"
+version = "0.1.0"
+description = "Puppy installer"
+authors = [
+    { name = "Alex Kislukhin" }
+]
+readme = "README.md"
+requires-python = ">=3.12"
+dependencies = [
+    "fastapi[standard]>=0.115.6",
+]