Reply to incoming SMS from your application

import json
import logging
import os
from uuid import NAMESPACE_URL, uuid5

from bird import Bird, APIError
from receiver import database

# Sample business content belongs to this application.
REPLY = "Our demo studio is open Monday to Friday, 09:00 to 17:00."
owned_number = os.environ["BIRD_SMS_FROM"]
db = database()
db.execute("""CREATE TABLE IF NOT EXISTS replies (
    inbound_id TEXT PRIMARY KEY, request_key TEXT, recipient TEXT, body TEXT,
    state TEXT, message_id TEXT)""")
db.commit()
try:
    for (raw,) in db.execute("SELECT body FROM events").fetchall():
        event = json.loads(raw)
        if event["type"] != "sms.received":
            continue
        data = event["data"]
        if data["to"] != owned_number or data.get("text", "").strip().upper() != "HOURS":
            continue
        inbound_id = data["workspace_id"] + ":" + data["sms_id"]
        request_key = str(uuid5(NAMESPACE_URL, "bird-sms-hours:" + inbound_id))
        with db:
            added = db.execute("INSERT OR IGNORE INTO replies VALUES (?, ?, ?, ?, 'pending', NULL)",
                               (inbound_id, request_key, data["from"], REPLY)).rowcount
        if not added:
            continue
        with db:
            db.execute("UPDATE replies SET state='sending' WHERE inbound_id=?", (inbound_id,))
        try:
            with Bird(api_key=os.environ["BIRD_API_KEY"]) as bird:
                message = bird.sms.send(
                    from_=owned_number, to=data["from"], text=REPLY,
                    category="service", options={"idempotency_key": request_key},
                )
        except APIError:
            logging.exception("SMS reply failed; reconcile the saved attempt")
            with db:
                db.execute("UPDATE replies SET state='review' WHERE inbound_id=?", (inbound_id,))
            continue
        with db:
            db.execute("UPDATE replies SET state='accepted', message_id=? WHERE inbound_id=?",
                       (message.id, inbound_id))
finally:
    db.close()