removing meta shite

components/gateways/headlines_to_wa.py

@@ -2,8 +2,6 @@ import datetime  # Import datetime for dynamic date
 import json
 import logging
 import os
-import re
-import time
 from typing import Dict, List, Optional
 
 import redis
@@ -21,23 +19,6 @@ def getenv_strip(name: str, default: Optional[str] = None) -> Optional[str]:
     return v.strip() if isinstance(v, str) else v
 
 
-def only_digits(s: Optional[str]) -> Optional[str]:
-    """Keep only digits from a string (useful for Meta Phone Number ID)."""
-    if not s:
-        return s
-    return re.sub(r"\D+", "", s)
-
-
-def _mask_identifier(value: Optional[str]) -> str:
-    """Mask sensitive identifiers in logs."""
-    if not value:
-        return "<unset>"
-    trimmed = value.strip()
-    if len(trimmed) <= 6:
-        return f"***{trimmed[-3:]}"
-    return f"***{trimmed[-4:]}"
-
-
 # -----------------------------------------
 # 🌐 Configuration from Environment Vars
 # -----------------------------------------
@@ -51,17 +32,6 @@ WHATSAPP_TO_NUMBER = getenv_strip("WHATSAPP_TO_NUMBER", "353899495777")
 GUPSHUP_SOURCE_NUMBER = getenv_strip("GUPSHUP_SOURCE_NUMBER")
 GUPSHUP_APP_NAME = getenv_strip("GUPSHUP_APP_NAME")
 
-# Meta (Cloud API) configuration (used for typing + mark-as-read when provider == "meta_cloud")
-META_GRAPH_VERSION = getenv_strip("META_GRAPH_VERSION", getenv_strip("WHATSAPP_CLOUD_GRAPH_VERSION", "v23.0"))
-META_PHONE_NUMBER_ID = only_digits(
-    getenv_strip("WHATSAPP_CLOUD_PHONE_NUMBER_ID") or getenv_strip("META_PHONE_NUMBER_ID")
-)
-# IMPORTANT: Do NOT default to WHATSAPP_TOKEN (that is Gupshup).
-META_ACCESS_TOKEN = getenv_strip("WHATSAPP_CLOUD_TOKEN") or getenv_strip("META_ACCESS_TOKEN")
-
-# Global backoff state for typing indicator attempts
-_META_TYPING_SUPPRESS_UNTIL: Optional[float] = None
-
 
 # ✅ Redis connection
 try:
@@ -131,66 +101,6 @@ def _base_payload(destination_number: str) -> Dict[str, object]:
     }
 
 
-def _missing_meta_config(destination_number: Optional[str] = None) -> Optional[Dict[str, str]]:
-    missing = []
-    if not META_PHONE_NUMBER_ID:
-        missing.append("WHATSAPP_CLOUD_PHONE_NUMBER_ID (or META_PHONE_NUMBER_ID)")
-    if not META_ACCESS_TOKEN:
-        missing.append("WHATSAPP_CLOUD_TOKEN (or META_ACCESS_TOKEN)")
-    if not destination_number:
-        missing.append("destination_number")
-    if missing:
-        msg = "❌ Missing Meta Cloud API config: " + ", ".join(missing)
-        logging.error(msg)
-        return {"status": "failed", "error": msg, "code": 500}
-    return None
-
-
-# Optional early sanity hints in logs
-if META_PHONE_NUMBER_ID and not META_PHONE_NUMBER_ID.isdigit():
-    logging.warning("META_PHONE_NUMBER_ID looks non-numeric after cleanup. Check your env value.")
-if META_ACCESS_TOKEN and not META_ACCESS_TOKEN.startswith("EAA"):
-    logging.warning("META_ACCESS_TOKEN doesn't look like a typical Graph token (often starts with 'EAA').")
-
-
-# -----------------------------
-# HTTP helpers
-# -----------------------------
-def _post_to_meta_messages(payload: Dict[str, object]) -> Dict[str, object]:
-    """POST to Meta WhatsApp Cloud `/messages` endpoint with detailed diagnostics."""
-    url = f"https://graph.facebook.com/{META_GRAPH_VERSION}/{META_PHONE_NUMBER_ID}/messages"
-    logging.debug("Meta POST URL: %s", url)
-    try:
-        response = requests.post(
-            url,
-            json=payload,
-            headers={
-                "Authorization": f"Bearer {META_ACCESS_TOKEN}",
-                "Content-Type": "application/json",
-            },
-            timeout=10,
-        )
-        text = response.text  # capture before raise_for_status for logging
-        if response.status_code >= 400:
-            logging.error("Meta POST %s failed: %s | %s", url, response.status_code, text)
-            try:
-                body = response.json()
-            except ValueError:
-                body = {"raw": text}
-            return {"status": "failed", "code": response.status_code, "error": text, "details": body}
-        try:
-            return {"status": "success", "details": response.json() if text else {}}
-        except ValueError:
-            return {"status": "success", "details": {"raw": text}}
-    except requests.exceptions.RequestException as exc:
-        logging.error("Meta POST error: %s", exc)
-        return {
-            "status": "failed",
-            "error": str(exc),
-            "code": getattr(getattr(exc, "response", None), "status_code", 500),
-        }
-
-
 def _post_to_gupshup(payload: Dict[str, object], action: str) -> Dict[str, object]:
     try:
         logging.info(
@@ -306,123 +216,19 @@ def send_to_whatsapp(message_text: str, destination_number: str) -> Dict[str, ob
 
 
 def send_seen_receipt(destination_number: str, message_id: Optional[str]) -> Dict[str, object]:
-    """Mark an inbound message as read via the WhatsApp Cloud API."""
-    if not message_id:
-        logging.debug("Skipping seen receipt for %s due to missing message id", destination_number)
-        return {"status": "skipped", "reason": "missing_message_id"}
-
-    logging.info(
-        "Seen receipt intent (Meta Cloud): msg_id=%s | phone_id=%s | token_prefix=%s",
+    """Stub for mark-as-read; Meta integration disabled."""
+    logging.debug(
+        "Seen receipt skipped for %s (Meta integration disabled). message_id=%s",
+        destination_number,
         message_id,
-        _mask_identifier(META_PHONE_NUMBER_ID),
-        (META_ACCESS_TOKEN[:3] if META_ACCESS_TOKEN else "<none>"),
     )
-
-    if not META_PHONE_NUMBER_ID or not META_ACCESS_TOKEN:
-        error_msg = (
-            "❌ Missing WhatsApp Cloud API credentials for mark-as-read. "
-            "Set WHATSAPP_CLOUD_PHONE_NUMBER_ID (or META_PHONE_NUMBER_ID) and "
-            "WHATSAPP_CLOUD_TOKEN (or META_ACCESS_TOKEN)."
-        )
-        logging.error(error_msg)
-        return {"status": "failed", "error": error_msg, "code": 500}
-
-    url = f"https://graph.facebook.com/{META_GRAPH_VERSION}/{META_PHONE_NUMBER_ID}/messages"
-    logging.debug("Meta mark-as-read URL: %s", url)
-    payload = {
-        "messaging_product": "whatsapp",
-        "status": "read",
-        "message_id": message_id,
-        "typing_indicator": {"type": "text"},
-    }
-
-    try:
-        response = requests.post(
-            url,
-            json=payload,
-            headers={
-                "Authorization": f"Bearer {META_ACCESS_TOKEN}",
-                "Content-Type": "application/json",
-            },
-            timeout=10,
-        )
-        text = response.text
-        if response.status_code >= 400:
-            logging.error("Meta mark-as-read failed: %s | %s", response.status_code, text)
-            try:
-                body = response.json()
-            except ValueError:
-                body = {"raw": text}
-            return {"status": "failed", "details": body, "code": response.status_code}
-
-        try:
-            body = response.json()
-        except ValueError:
-            body = {"raw": text}
-        return {"status": "success", "details": body}
-    except requests.exceptions.RequestException as exc:
-        logging.error("❌ Meta mark-as-read error: %s", exc)
-        return {
-            "status": "failed",
-            "error": str(exc),
-            "code": getattr(getattr(exc, "response", None), "status_code", 500),
-        }
+    return {"status": "skipped", "reason": "meta_disabled"}
 
 
 def send_typing_indicator(destination_number: str, status: str = "typing") -> Dict[str, object]:
-    """Send typing hints via Meta's WhatsApp Cloud API (per official docs)."""
-    global _META_TYPING_SUPPRESS_UNTIL
-
-    if _META_TYPING_SUPPRESS_UNTIL:
-        remaining = _META_TYPING_SUPPRESS_UNTIL - time.time()
-        if remaining > 0:
-            logging.debug(
-                "Meta typing indicator suppressed for %.1fs; skipping send for %s",
-                remaining,
-                destination_number,
-            )
-            return {"status": "skipped", "reason": "meta_typing_suppressed"}
-        _META_TYPING_SUPPRESS_UNTIL = None
-
-    normalized = (status or "typing").strip().lower()
-    if normalized in {"typing_on", "start"}:
-        normalized = "typing"
-    elif normalized in {"typing_off", "stop", "stopped"}:
-        normalized = "paused"
-    elif normalized not in {"typing", "paused"}:
-        logging.debug("Unknown typing status '%s'; defaulting to 'typing'", status)
-        normalized = "typing"
-
-    config_error = _missing_meta_config(destination_number)
-    if config_error:
-        return config_error
-
     logging.debug(
-        "Typing indicator config: meta_phone_number_id=%s | gupshup_source_number=%s | whatsapp_to_number=%s",
-        _mask_identifier(META_PHONE_NUMBER_ID),
-        _mask_identifier(GUPSHUP_SOURCE_NUMBER),
-        _mask_identifier(WHATSAPP_TO_NUMBER),
+        "Typing indicator '%s' skipped for %s (Meta integration disabled).",
+        status,
+        destination_number,
     )
-
-    payload = {
-        "messaging_product": "whatsapp",
-        "to": destination_number,
-        "type": "typing",
-        "typing": {"status": normalized},
-    }
-
-    logging.info("Sending typing indicator (%s) to %s via Meta Cloud API", normalized, destination_number)
-    result = _post_to_meta_messages(payload)
-
-    if result.get("status") != "success":
-        _META_TYPING_SUPPRESS_UNTIL = time.time() + 300  # back off for 5 minutes
-        logging.warning(
-            "Meta typing indicator failed; suppressing attempts for 5 minutes (%s)",
-            result.get("error"),
-        )
-        if not META_PHONE_NUMBER_ID and not META_ACCESS_TOKEN:
-            logging.warning(
-                "Meta typing disabled until credentials are set (WHATSAPP_CLOUD_PHONE_NUMBER_ID / META_PHONE_NUMBER_ID, WHATSAPP_CLOUD_TOKEN / META_ACCESS_TOKEN)."
-            )
-
-    return result
+    return {"status": "skipped", "reason": "meta_disabled"}