feat: demo app

Author: aitect

Dockerfile

@@ -1 +1,31 @@
-FROM nginx
+# Use the official Python base image
+FROM python:3.12-slim
+
+# Set environment variables
+ENV PYTHONDONTWRITEBYTECODE=1
+ENV PYTHONUNBUFFERED=1
+
+# Set work directory
+WORKDIR /app
+
+# Install system dependencies
+RUN apt-get update && \
+    apt-get install -y --no-install-recommends \
+    build-essential \
+    && rm -rf /var/lib/apt/lists/*
+
+# Copy requirements file
+COPY requirements.txt .
+
+# Install Python dependencies
+RUN pip install --upgrade pip && \
+    pip install --no-cache-dir -r requirements.txt
+
+# Copy project files
+COPY . .
+
+# Expose port (change if your app uses a different port)
+EXPOSE 8010
+
+# Default command (change as needed)
+CMD ["python", "app.py"]

app.py

@@ -0,0 +1,110 @@
+import os
+import io
+import json
+import html
+import requests
+from flask import Flask, request, Response
+
+TELEGRAM_CHAT_ID = -4947069491
+TOKEN = os.environ.get("TELEGRAM_BOT_TOKEN")
+if not TOKEN:
+    raise RuntimeError("Set TELEGRAM_BOT_TOKEN env var")
+TG_BASE = f"https://api.telegram.org/bot{TOKEN}"
+
+app = Flask(__name__)
+
+def _chunk(s: str, n: int = 3900):
+    for i in range(0, len(s), n):
+        yield s[i:i+n]
+
+def send_text(text: str):
+    for part in _chunk(text):
+        r = requests.post(
+            f"{TG_BASE}/sendMessage",
+            data={
+                "chat_id": TELEGRAM_CHAT_ID,
+                "text": f"<pre>{html.escape(part)}</pre>",
+                "parse_mode": "HTML",
+                "disable_web_page_preview": True,
+            },
+            timeout=15,
+        )
+        r.raise_for_status()
+
+def send_document(fileobj, filename: str, caption: str = None, mime: str = None):
+    data = {"chat_id": TELEGRAM_CHAT_ID}
+    if caption:
+        data["caption"] = caption[:1024]
+    files = {"document": (filename, fileobj, mime or "application/octet-stream")}
+    r = requests.post(f"{TG_BASE}/sendDocument", data=data, files=files, timeout=120)
+    r.raise_for_status()
+
+@app.get("/")
+def root_ok():
+    return Response("ok", mimetype="text/plain")
+
+@app.post("/post")
+def post_handler():
+    try:
+        lines = []
+        ctype = request.content_type or "-"
+        lines.append(f"POST /post")
+        lines.append(f"Content-Type: {ctype}")
+
+        if request.args:
+            lines.append("Query:")
+            lines.append(json.dumps(request.args.to_dict(flat=False), ensure_ascii=False, indent=2))
+
+        files_sent = 0
+        body_summary = ""
+
+        if request.is_json:
+            data = request.get_json(silent=True)
+            if data is None:
+                body_summary = (request.get_data(as_text=True) or "").strip()
+            else:
+                body_summary = json.dumps(data, ensure_ascii=False, indent=2)
+
+        elif request.mimetype == "application/x-www-form-urlencoded":
+            form = request.form.to_dict(flat=False)
+            body_summary = json.dumps(form, ensure_ascii=False, indent=2)
+
+        elif request.mimetype and request.mimetype.startswith("multipart/"):
+            form = request.form.to_dict(flat=False)
+            if form:
+                body_summary = json.dumps(form, ensure_ascii=False, indent=2)
+            for key in request.files:
+                for storage in request.files.getlist(key):
+                    f = storage.stream
+                    f.seek(0)
+                    caption = f"{storage.filename or key} ({storage.content_type or 'application/octet-stream'})"
+                    send_document(f, storage.filename or key, caption=caption, mime=storage.content_type)
+                    files_sent += 1
+
+        else:
+            raw = request.get_data()
+            try:
+                txt = raw.decode("utf-8")
+                if len(txt) > 4000:
+                    body_summary = txt[:4000] + "\n...[truncated]"
+                    send_document(io.BytesIO(raw), "payload.txt", caption="Raw payload")
+                else:
+                    body_summary = txt
+            except UnicodeDecodeError:
+                send_document(io.BytesIO(raw), "payload.bin", caption="Binary payload")
+                body_summary = "(binary payload sent as document)"
+
+        if body_summary:
+            lines.append("Body:")
+            lines.append(body_summary)
+
+        send_text("\n\n".join(lines))
+        return Response("ok", mimetype="text/plain", status=200)
+
+    except requests.HTTPError:
+        return Response("ok", mimetype="text/plain", status=502)
+    except Exception:
+        return Response("ok", mimetype="text/plain", status=500)
+
+if __name__ == "__main__":
+    app.run(host="0.0.0.0", port=8080)

requirements.txt

@@ -0,0 +1 @@
+flask==3.1.2