trigger_webhook.py

import urllib.parse
from uuid import uuid4
import os, json, hmac, hashlib, httpx, asyncio
from dotenv import load_dotenv

load_dotenv(".env")

# Must match test user exactly
sender_id = "3b691c11-2fb8-431b-85d3-b58092f3b932"
message_id = str(uuid4())

payload = {
  "sender_id": sender_id,
  "message_id": message_id,
  "text": "Find me the latest email that mentions Apple",
  "history": []
}

body_bytes = json.dumps(payload, separators=(',', ':')).encode('utf-8')
secret = os.environ.get("WEBHOOK_SECRET", "").encode('utf-8')
signature = hmac.new(secret, body_bytes, hashlib.sha256).hexdigest()

print(f"Sending webhook with signature: {signature}")

# Send the request natively to avoid bash escaping issues
# Using httpx since we know it's installed
async def main():
    async with httpx.AsyncClient() as client:
        resp = await client.post(
            "http://localhost:5001/webhook",
            json=payload,
            headers={"x-agent-signature": signature, "x-user-id": sender_id}
        )
        print(f"Status: {resp.status_code}")
        print(f"Body: {resp.text}")

asyncio.run(main())