Upload 3 files

Dockerfile

@@ -0,0 +1,9 @@
+FROM python:3.10
+
+WORKDIR /app
+
+COPY . .
+
+RUN pip install --no-cache-dir -r requirements.txt
+
+CMD ["uvicorn", "app:app", "--host", "0.0.0.0", "--port", "7860"]

app.py

@@ -0,0 +1,96 @@
+from fastapi import FastAPI, Request, UploadFile, File
+from fastapi.responses import FileResponse
+import threading
+import os
+import zipfile
+import time
+
+app = FastAPI()
+lock = threading.Lock()
+
+# -------- OLD (keep unchanged) --------
+channels = {}
+update_ids = {}
+
+# -------- NEW STORAGE --------
+file_channels = {}  # channel অনুযায়ী file list
+
+UPLOAD_DIR = "uploads"
+os.makedirs(UPLOAD_DIR, exist_ok=True)
+
+
+# -------- OLD TEXT --------
+@app.post("/sendMessage/{channel}")
+async def send_message(channel: str, req: Request):
+    data = await req.body()
+    text = data.decode("utf-8").strip()
+
+    with lock:
+        if channel not in channels:
+            channels[channel] = []
+            update_ids[channel] = 0
+
+        update_ids[channel] += 1
+
+        channels[channel].append({
+            "update_id": update_ids[channel],
+            "text": text
+        })
+
+    return {"ok": True}
+
+
+# -------- NEW FILE UPLOAD --------
+@app.post("/sendFile/{channel}")
+async def send_file(channel: str, files: list[UploadFile] = File(...)):
+    with lock:
+        if channel not in file_channels:
+            file_channels[channel] = []
+
+    saved_files = []
+
+    for file in files:
+        filename = f"{int(time.time())}_{file.filename}"
+        filepath = os.path.join(UPLOAD_DIR, filename)
+
+        with open(filepath, "wb") as f:
+            f.write(await file.read())
+
+        with lock:
+            file_channels[channel].append(filepath)
+
+        saved_files.append(filename)
+
+    return {"ok": True, "files": saved_files}
+
+
+# -------- MODIFIED GET (text + file zip) --------
+@app.get("/getUpdates/{channel}")
+def get_updates(channel: str):
+    with lock:
+        # text messages
+        msgs = channels.get(channel, []).copy()
+        channels[channel] = []
+
+        # files
+        files = file_channels.get(channel, []).copy()
+        file_channels[channel] = []
+
+    # যদি file থাকে → zip বানাও
+    if files:
+        zip_name = f"{channel}_files.zip"
+        zip_path = os.path.join(UPLOAD_DIR, zip_name)
+
+        with zipfile.ZipFile(zip_path, "w") as zipf:
+            for file_path in files:
+                if os.path.exists(file_path):
+                    zipf.write(file_path, os.path.basename(file_path))
+
+        return FileResponse(
+            zip_path,
+            media_type="application/zip",
+            filename=zip_name
+        )
+
+    # না থাকলে text return
+    return {"ok": True, "result": msgs}

requirements.txt

@@ -0,0 +1,2 @@
+fastapi
+uvicorn