Two-Way Messaging Patterns

{
  "type": "message.received",
  "data": {
    "id": "msg_01jav96823f9x9054d6gyzpp16",
    "blast_id": null,
    "body": "Is the 3pm slot still available?",
    "metadata": {},
    "attachments": [],
    "received_at": "2024-10-21T23:29:43Z",
    "conversation": {
      "id": "cnv_01jav8xy7fe4nsay3c9deqxge9",
      "phone_number": {
        "id": "pn_01jsjwe4d9fx3tpymgtg958d9w",
        "number": "+18015556789",
        "type": "local"
      },
      "contact": {
        "id": "ctc_01ja88cboqffhswjx8zbak3ykk",
        "first_name": "Dominic",
        "last_name": "Toretto",
        "phone_number": "+18015551234"
      }
    }
  }
}

@app.post("/webhooks/surge")
async def surge_webhook(request: Request):
    payload = wh.verify(await request.body(), request.headers)

    if payload["type"] == "message.received":
        data = payload["data"]
        conversation_id = data["conversation"]["id"]

        # Send a reply into the same conversation thread
        await surge_client.post(
            f"/accounts/{account_id}/messages",
            json={
                "conversation": conversation_id,
                "body": "Yes, 3pm is still available. Want me to book it?"
            }
        )

    return Response(status_code=200)

case "contact.opted_out":
    contact = payload["data"]
    await db.contacts.update(contact["id"], {"sms_opted_out": True})

if await db.processed_events.exists(message_id=data["id"]):
    return Response(status_code=200)  # already handled

await db.processed_events.insert(message_id=data["id"])
# ... process the message