Create app.py

app.py

@@ -0,0 +1,205 @@
+import gradio as gr
+import requests
+import csv
+import time
+import mimetypes
+import os
+import tempfile
+from datetime import datetime
+from concurrent.futures import ThreadPoolExecutor, as_completed
+import threading
+import schedule
+
+log_dir = tempfile.mkdtemp()
+
+def upload_media(file_path, access_token, phone_number_id):
+    mime_type = mimetypes.guess_type(file_path)[0] or "application/octet-stream"
+    with open(file_path, "rb") as f:
+        files = {
+            'file': (os.path.basename(file_path), f, mime_type),
+            'type': (None, mime_type),
+            'messaging_product': (None, 'whatsapp')
+        }
+        headers = {
+            'Authorization': f'Bearer {access_token}'
+        }
+        url = f"https://graph.facebook.com/v19.0/{phone_number_id}/media"
+        try:
+            res = requests.post(url, headers=headers, files=files)
+            res.raise_for_status()
+            return res.json().get("id")
+        except Exception:
+            return None
+
+def send_message(phone, payload, headers, retries=3, backoff_intervals=[5, 15, 30]):
+    for attempt in range(retries):
+        try:
+            response = requests.post(payload['url'], json=payload['data'], headers=headers)
+            if response.status_code == 200:
+                return f"{phone} → ✅ {response.text}"
+            elif response.status_code == 400 and 'Service temporarily unavailable' in response.text:
+                if attempt < len(backoff_intervals):
+                    time.sleep(backoff_intervals[attempt])
+                    continue
+            return f"{phone} → ❌ {response.text}"
+        except Exception as e:
+            if attempt < len(backoff_intervals):
+                time.sleep(backoff_intervals[attempt])
+                continue
+            return f"{phone} → ❌ Error: {str(e)}"
+
+def execute_campaign(params):
+    log_file = os.path.join(log_dir, f"log_{datetime.now().strftime('%Y%m%d_%H%M%S')}.txt")
+    with open(log_file, 'w') as logfile:
+        with ThreadPoolExecutor(max_workers=10) as executor:
+            futures = {
+                executor.submit(send_message, phone, {
+                    "url": params['api_url'],
+                    "data": {
+                        "messaging_product": "whatsapp",
+                        "to": phone,
+                        "type": "template",
+                        "template": {
+                            "name": params['template_name'],
+                            "language": {"code": params['language_code']},
+                            "components": params['components']
+                        }
+                    }
+                }, params['headers']): phone for phone in params['phones']
+            }
+
+            for future in as_completed(futures):
+                result = future.result()
+                logfile.write(result + "\n")
+                logfile.flush()
+
+def schedule_campaign(
+    access_token, phone_number_id, template_name, language_code, header_type,
+    api_url, csv_file, media_file, existing_media_id, media_link,
+    schedule_date, schedule_time, body_texts,
+    button_sub_types, button_indexes, button_param_types, button_param_values
+):
+
+    if csv_file is None:
+        return "❌ CSV file is required."
+
+    phones = []
+    with tempfile.NamedTemporaryFile(delete=False, suffix=".csv") as tmp_csv:
+        tmp_csv.write(csv_file.read())
+        tmp_csv_path = tmp_csv.name
+
+    with open(tmp_csv_path, "r", encoding="utf-8-sig") as f:
+        reader = csv.reader(f)
+        next(reader, None)
+        for row in reader:
+            if not row or not row[0].strip():
+                continue
+            num = row[0].strip()
+            if num.isdigit():
+                if len(num) == 10:
+                    phones.append("91" + num)
+                elif len(num) == 12 and num.startswith("91"):
+                    phones.append(num)
+
+    if not phones:
+        return "❌ No valid phone numbers found."
+
+    media_id = existing_media_id.strip() if existing_media_id else None
+    if media_file and not media_id:
+        with tempfile.NamedTemporaryFile(delete=False, suffix=os.path.splitext(media_file.name)[1]) as tmp_media:
+            tmp_media.write(media_file.read())
+            media_path = tmp_media.name
+        media_id = upload_media(media_path, access_token, phone_number_id)
+        if not media_id:
+            return "❌ Media upload failed."
+
+    headers = {
+        "Authorization": f"Bearer {access_token}",
+        "Content-Type": "application/json"
+    }
+
+    components = []
+    if media_id:
+        header_obj = {"id": media_id}
+        if media_link:
+            header_obj["link"] = media_link
+        components.append({"type": "header", "parameters": [{header_type: header_obj, "type": header_type}]})
+
+    components.append({"type": "body", "parameters": [{"type": "text", "text": t} for t in body_texts.splitlines() if t]})
+
+    try:
+        buttons = []
+        for stype, idx, ptype, pval in zip(
+            button_sub_types.split(","),
+            button_indexes.split(","),
+            button_param_types.split(","),
+            button_param_values.split(",")
+        ):
+            buttons.append({
+                "type": "button",
+                "sub_type": stype.strip(),
+                "index": int(idx.strip()),
+                "parameters": [{"type": ptype.strip(), ptype.strip(): pval.strip()}]
+            })
+        components += buttons
+    except:
+        pass
+
+    scheduled_datetime = datetime.strptime(f"{schedule_date} {schedule_time}", "%Y-%m-%d %H:%M:%S")
+
+    def job():
+        now = datetime.now()
+        if now >= scheduled_datetime:
+            schedule.clear()
+            execute_campaign({
+                "phones": phones,
+                "api_url": api_url,
+                "template_name": template_name,
+                "language_code": language_code,
+                "components": components,
+                "headers": headers
+            })
+
+    schedule.every(1).minutes.do(job)
+
+    def scheduler_loop():
+        while True:
+            schedule.run_pending()
+            time.sleep(1)
+
+    threading.Thread(target=scheduler_loop, daemon=True).start()
+
+    return f"✅ Campaign scheduled for {scheduled_datetime.strftime('%Y-%m-%d %H:%M:%S')}."
+
+# --- Gradio Interface ---
+
+demo = gr.Interface(
+    fn=schedule_campaign,
+    inputs=[
+        gr.Textbox(label="Access Token", type="password"),
+        gr.Textbox(label="Phone Number ID"),
+        gr.Textbox(label="Template Name"),
+        gr.Textbox(label="Language Code", value="en"),
+        gr.Dropdown(["image", "video"], label="Header Type"),
+
+        gr.Textbox(label="WhatsApp API URL"),
+        gr.File(label="CSV File with Phone Numbers", file_types=[".csv"]),
+        gr.File(label="(Optional) Media File", file_types=[".jpg", ".jpeg", ".png", ".mp4"]),
+        gr.Textbox(label="(Optional) Existing Media ID"),
+        gr.Textbox(label="(Optional) Media Link"),
+
+        gr.Textbox(label="Schedule Date (YYYY-MM-DD)"),
+        gr.Textbox(label="Schedule Time (HH:MM:SS)"),
+
+        gr.Textbox(label="Body Text Parameters (one per line)", lines=5),
+        gr.Textbox(label="Button Sub Types (comma-separated)"),
+        gr.Textbox(label="Button Indexes (comma-separated)"),
+        gr.Textbox(label="Button Param Types (comma-separated)"),
+        gr.Textbox(label="Button Param Values (comma-separated)")
+    ],
+    outputs="text",
+    title="Temple Dekho WhatsApp Promo Scheduler"
+)
+
+if __name__ == "__main__":
+    demo.launch()