Function remote_reply

api/remote.py:254–298

Send the MCP's answer back to the bound phone/chat, with any images the model captured along the way (e.g. capture_screen). Charges that channel's quota once, regardless of image count. Image delivery is best-effort — a failed upload/send is logged, not fatal.

(request_data: RemoteReplyRequest, current_user: AuthUser)

@remote_router.post("/remote/reply", tags=["Remote"])
async def remote_reply(request_data: RemoteReplyRequest, current_user: AuthUser):
    """Send the MCP's answer back to the bound phone/chat, with any images the model captured
    along the way (e.g. capture_screen). Charges that channel's quota once, regardless of
    image count. Image delivery is best-effort — a failed upload/send is logged, not fatal."""
    # Imported here: both modules import this one for their webhooks.
    from messaging import assert_content_allowed, save_temp_image, send_whatsapp_text
    from tools_router import send_telegram_photo, send_telegram_text
    from quota_manager import try_consume_for

    code = await _require_owner(request_data.code, current_user.id)
    r = await get_redis()
    address = await r.get(_bind_key(code, request_data.channel))
    if not address:
        raise HTTPException(status_code=404, detail=f"No {request_data.channel} linked to this code.")

    assert_content_allowed(request_data.text)

    allowed, _usage_count, _reason = await try_consume_for(current_user, request_data.channel)
    if not allowed:
        raise HTTPException(
            status_code=429,
            detail={
                "message": f"Daily {request_data.channel} quota has been exceeded.",
                "quota_type": request_data.channel,
            },
        )

    images = (request_data.images or [])[:MAX_REPLY_IMAGES]

    if request_data.channel == "whatsapp":
        media_urls = []
        for i, image_b64 in enumerate(images):
            try:
                media_urls.append(await save_temp_image(image_b64))
            except Exception as e:
                logger.warning(f"Remote reply: failed to host image {i+1} for WhatsApp: {e}")
        await send_whatsapp_text(address, request_data.text[:1600], media_urls or None)
    else:
        for i, image_b64 in enumerate(images):
            try:
                await send_telegram_photo(address, image_b64)
            except Exception as e:
                logger.warning(f"Remote reply: failed to send image {i+1} to Telegram: {e}")
        await send_telegram_text(address, request_data.text[:4096])
    return {"success": True}