Upload main.py

main.py

@@ -12,20 +12,7 @@ PHONE_NUMBER_ID = os.getenv("PHONE_NUMBER_ID", "")
 WHATSAPP_API_TOKEN = os.getenv("WHATSAPP_API_TOKEN", "")
 RUMAS_API_URL = os.getenv("RUMAS_API_URL", "")
 
-# 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()
+processed_message_ids = set()
 
 async def forward_to_rumas(b64_str: str, wa_id: str):
     """Fire-and-forget call to RUMAS /api/process_id."""
@@ -139,7 +126,6 @@ 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":