API ל-SMS

import os
import httpx

API_BASE = "https://aicall.co.il/api/v1"
API_KEY = os.environ["API_KEY"]


def send_sms(from_number: str, to: str, body: str) -> dict:
    res = httpx.post(
        f"{API_BASE}/sms",
        headers={
            "Authorization": f"Bearer {API_KEY}",
            "Content-Type": "application/json",
        },
        json={
            "from": from_number,
            "body": body,
            "recipients": [{"phone": to}],
        },
        timeout=30,
    )
    res.raise_for_status()
    return res.json()["data"]


if __name__ == "__main__":
    result = send_sms(
        from_number="+972501111111",
        to="+972502222222",
        body="Hi! Your appointment is confirmed for tomorrow at 10:00.",
    )
    print(f"Sent message #{result['messageId']} in thread {result['threadId']}")
    print(f"  {result['segments']} segment(s), {result['encoding']}")
    print(f"  Charged: ${result['priceUsd']:.4f}")

import os
import httpx

API_BASE = "https://aicall.co.il/api/v1"
API_KEY = os.environ["API_KEY"]


def send_batch(from_number: str, body_template: str, recipients: list[dict]) -> dict:
    res = httpx.post(
        f"{API_BASE}/sms",
        headers={
            "Authorization": f"Bearer {API_KEY}",
            "Content-Type": "application/json",
        },
        json={
            "from": from_number,
            "body": body_template,
            "recipients": recipients,
        },
        timeout=30,
    )
    res.raise_for_status()
    return res.json()["data"]


if __name__ == "__main__":
    result = send_batch(
        from_number="+972501111111",
        body_template="Hi {{name}}, your link is {{link}}",
        recipients=[
            {"phone": "+972502222222", "variables": {"name": "Dana", "link": "https://example.com/d"}},
            {"phone": "+972503333333", "variables": {"name": "Avi",  "link": "https://example.com/a"}},
            {"phone": "+972504444444", "variables": {"name": "Noa",  "link": "https://example.com/n"}},
        ],
    )
    print(f"Queued batch job #{result['jobId']}")
    print(f"  {result['recipientCount']} recipients")
    print(f"  Estimated cost: ${result['estimatedPriceUsd']:.4f}")
    print(f"  Per country: {result['perCountry']}")

import os
import time
import httpx

API_BASE = "https://aicall.co.il/api/v1"
API_KEY = os.environ["API_KEY"]
POLL_SEC = 2


def wait_for_batch(job_id: int) -> dict:
    while True:
        res = httpx.get(
            f"{API_BASE}/sms/jobs/{job_id}",
            headers={"Authorization": f"Bearer {API_KEY}"},
            timeout=15,
        )
        res.raise_for_status()
        job = res.json()["data"]
        terminal = job["status"] in ("completed", "failed", "partial")
        print(f"  [{job['status']}] {job['sentCount']}/{job['totalRecipients']} sent, {job['failedCount']} failed")
        if terminal:
            return job
        time.sleep(POLL_SEC)


if __name__ == "__main__":
    job_id = int(os.environ.get("JOB_ID", "0"))
    job = wait_for_batch(job_id)
    print(f"Batch #{job_id} finished as: {job['status']}")
    for r in job["recipients"]:
        if r["status"] in ("sent", "delivered"):
            print(f"  ✓ #{r['id']}  ${float(r['priceUsd']):.4f}  {r['segments']}s")
        else:
            print(f"  ✗ #{r['id']}  {r.get('errorMessage') or r['status']}")

import os
import httpx

API_BASE = "https://aicall.co.il/api/v1"
API_KEY = os.environ["API_KEY"]
HEADERS = {"Authorization": f"Bearer {API_KEY}"}


def list_threads(limit: int = 50) -> list[dict]:
    res = httpx.get(f"{API_BASE}/sms/threads", headers=HEADERS, params={"limit": limit}, timeout=15)
    res.raise_for_status()
    return res.json()["data"]["threads"]


def read_thread(thread_id: int) -> dict:
    res = httpx.get(f"{API_BASE}/sms/threads/{thread_id}", headers=HEADERS, timeout=15)
    res.raise_for_status()
    return res.json()["data"]


def reply(thread_id: int, body: str) -> dict:
    res = httpx.post(
        f"{API_BASE}/sms/threads/{thread_id}/reply",
        headers={**HEADERS, "Content-Type": "application/json"},
        json={"body": body},
        timeout=30,
    )
    res.raise_for_status()
    return res.json()["data"]


if __name__ == "__main__":
    # Show open conversations and auto-reply to anything new from a known contact.
    for th in list_threads(limit=20):
        marker = " (NEW)" if th["unreadCount"] > 0 else ""
        print(f"#{th['id']}  {th['remotePhone']}  via {th['ownedNumber']}{marker}")
        if th["unreadCount"] > 0 and th["remotePhone"] == "+972509999999":
            sent = reply(th["id"], "Got it — I'll get back to you within the hour.")
            print(f"  → auto-replied as message #{sent['messageId']}")