Upload main.py

main.py

@@ -12,7 +12,20 @@ PHONE_NUMBER_ID = os.getenv("PHONE_NUMBER_ID", "")
 WHATSAPP_API_TOKEN = os.getenv("WHATSAPP_API_TOKEN", "")
 RUMAS_API_URL = os.getenv("RUMAS_API_URL", "")
 
-processed_message_ids = set()
+# Persistent deduplication using a file
+DEDUP_FILE = "processed_message_ids.txt"
+def load_processed_ids():
+    try:
+        with open(DEDUP_FILE, "r") as f:
+            return set(line.strip() for line in f if line.strip())
+    except FileNotFoundError:
+        return set()
+
+def save_processed_id(msg_id):
+    with open(DEDUP_FILE, "a") as f:
+        f.write(msg_id + "\n")
+
+processed_message_ids = load_processed_ids()
 
 async def forward_to_rumas(b64_str: str, wa_id: str):
     """Fire-and-forget call to RUMAS /api/process_id."""
@@ -126,6 +139,7 @@ async def receive_update(req: Request):
         print(f"Duplicate message {msg_id}, skipping.")
         return JSONResponse({"status": "duplicate", "id": msg_id})
     processed_message_ids.add(msg_id)
+    save_processed_id(msg_id)
 
     # IMAGE: if user sent an image, convert to Base64 preview
     if msg["type"] == "image":