Spaces:
Paused
Paused
File size: 2,612 Bytes
7d4338a | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 | """WhatsApp QR code pairing endpoint."""
from helpers.api import ApiHandler, Request
from helpers.errors import format_error
from helpers import plugins
PLUGIN_NAME = "_whatsapp_integration"
class QrCode(ApiHandler):
async def process(self, input: dict, request: Request) -> dict:
config = plugins.get_plugin_config(PLUGIN_NAME) or {}
port = int(config.get("bridge_port", 3100))
mode = config.get("mode", "self-chat")
from plugins._whatsapp_integration.helpers.bridge_manager import (
ensure_bridge_http_up,
get_bridge_url,
is_process_alive,
)
from plugins._whatsapp_integration.helpers.storage_paths import (
get_bridge_media_dir,
get_bridge_session_dir,
)
from plugins._whatsapp_integration.helpers.wa_client import get_qr
session_dir = get_bridge_session_dir()
cache_dir = get_bridge_media_dir()
base_url = get_bridge_url(port)
# Start bridge if not running
if not is_process_alive():
try:
ok = await ensure_bridge_http_up(
port, session_dir, cache_dir, mode=mode,
)
if not ok:
return {
"status": "error",
"message": "Failed to start bridge",
"qr": None,
}
except Exception as e:
return {
"status": "error",
"message": format_error(e),
"qr": None,
}
# Fetch QR status from bridge
try:
data = await get_qr(base_url)
status = data.get("status", "error")
qr = data.get("qr")
if status == "connected":
return {
"status": "connected",
"message": "WhatsApp is already connected",
"qr": None,
}
if status == "waiting_scan" and qr:
return {
"status": "waiting_scan",
"message": "Scan the QR code with WhatsApp",
"qr": qr,
}
return {
"status": "waiting_qr",
"message": "Generating QR code...",
"qr": None,
}
except Exception as e:
return {
"status": "error",
"message": f"Bridge not reachable: {format_error(e)}",
"qr": None,
}
|