Sending messages

IDEMPOTENCY_KEY=$(uuidgen) # Store it with your record of the message: reuse it to retry.

curl -sS https://api.isnap.ai/v1/messages \
  -H "Authorization: Bearer $ISNAP_API_KEY" \
  -H "Content-Type: application/json" \
  -H "Idempotency-Key: $IDEMPOTENCY_KEY" \
  -d '{
    "line_id": "line_8Xk2mQ4vTn7Bw9Rz3Lc6Yp1Hd",
    "to": "+14155550123",
    "body": "Your order has shipped.",
    "metadata": { "order_id": "ord_20931" }
  }'

import { randomUUID } from 'node:crypto'
import { APIError, ISnapClient, QuotaExceededError, RateLimitError } from '@isnap/sdk'

const client = new ISnapClient({ apiKey: process.env.ISNAP_API_KEY ?? '', maxRetries: 2 })

// One key per message.
const idempotencyKey = randomUUID() // Store it with your record of the message: reuse it to retry.

try {
  // The SDK reuses the key on its own retries of this call.
  const message = await client.messages.send(
    {
      line_id: 'line_8Xk2mQ4vTn7Bw9Rz3Lc6Yp1Hd',
      to: '+14155550123',
      body: 'Your order has shipped.',
      metadata: { order_id: 'ord_20931' }
    },
    { idempotencyKey }
  )
  if (message.status === 'scheduled') {
    console.log(`${message.id} is held until ${message.scheduled_for} (${message.schedule_reason})`)
  } else {
    console.log(`${message.id} is ${message.status}`)
  }
} catch (err) {
  if (err instanceof QuotaExceededError || err instanceof RateLimitError) {
    // A sending limit of a line set to refuse, a full line, or the request-rate limit.
    console.error(`${err.code}: retry after ${err.retryAfter} seconds`)
  } else if (err instanceof APIError && err.code === 'outbound_first_forbidden') {
    console.error('This inbound-only line can write to this contact only after the contact wrote to it.')
  } else if (err instanceof APIError && err.code === 'bad_request') {
    console.error('`to` is not a valid phone number.')
  } else {
    throw err
  }
}

import os
import time
import uuid

import requests

API = "https://api.isnap.ai"
HEADERS = {"Authorization": f"Bearer {os.environ['ISNAP_API_KEY']}"}


def send_message(payload, idempotency_key):
    """POST /v1/messages. Retry a 500, a 503 or a lost response up to 2 times, one after the other, with the same key."""
    headers = {**HEADERS, "Idempotency-Key": idempotency_key}
    for attempt in range(3):
        try:
            response = requests.post(f"{API}/v1/messages", headers=headers, json=payload, timeout=30)
        except (requests.ConnectionError, requests.Timeout):
            # No response: iSnap may have accepted the message. The same key makes the retry safe.
            if attempt == 2:
                raise
        else:
            if response.status_code not in (500, 503) or attempt == 2:
                return response
        time.sleep(2**attempt)


# One key per message.
idempotency_key = str(uuid.uuid4())  # Store it with your record of the message: reuse it to retry.
response = send_message(
    {
        "line_id": "line_8Xk2mQ4vTn7Bw9Rz3Lc6Yp1Hd",
        "to": "+14155550123",
        "body": "Your order has shipped.",
        "metadata": {"order_id": "ord_20931"},
    },
    idempotency_key,
)
body = response.json()

if response.status_code == 202:
    message = body["data"]
    if message["status"] == "scheduled":
        print(f"{message['id']} is held until {message['scheduled_for']} ({message['schedule_reason']})")
    else:
        print(f"{message['id']} is {message['status']}")
elif response.status_code == 429:
    error = body["error"]
    print(f"{error['code']}: retry after {error['retry_after']} seconds")
else:
    error = body["error"]
    raise SystemExit(
        f"{error['status']} {error['code']}: {error['message']} "
        f"(trace_id={body['trace_id']}, request_id={body['request_id']})"
    )

curl -sS -X DELETE https://api.isnap.ai/v1/messages/msg_3Lc6Yp1Hd8Xk2mQ4vTn7Bw9Rz \
  -H "Authorization: Bearer $ISNAP_API_KEY"

import { ConflictError, ISnapClient } from '@isnap/sdk'

const client = new ISnapClient({ apiKey: process.env.ISNAP_API_KEY ?? '', maxRetries: 2 })

const messageId = 'msg_3Lc6Yp1Hd8Xk2mQ4vTn7Bw9Rz'

try {
  const message = await client.messages.cancel(messageId)
  console.log(`${message.id} canceled at ${message.cancelled_at}`)
} catch (err) {
  if (err instanceof ConflictError && err.code === 'too_late_to_cancel') {
    // The device has the message, or the message already reached a later status.
    const message = await client.messages.get(messageId)
    console.log(`Too late to cancel: ${message.id} is ${message.status}`)
  } else {
    throw err
  }
}

import os

import requests

API = "https://api.isnap.ai"
HEADERS = {"Authorization": f"Bearer {os.environ['ISNAP_API_KEY']}"}

message_id = "msg_3Lc6Yp1Hd8Xk2mQ4vTn7Bw9Rz"
response = requests.delete(f"{API}/v1/messages/{message_id}", headers=HEADERS, timeout=30)

if response.status_code == 409 and response.json()["error"]["code"] == "too_late_to_cancel":
    # The device has the message, or the message already reached a later status.
    current = requests.get(f"{API}/v1/messages/{message_id}", headers=HEADERS, timeout=30)
    current.raise_for_status()
    print("Too late to cancel:", current.json()["data"]["status"])
else:
    response.raise_for_status()
    message = response.json()["data"]
    print(message["id"], "canceled at", message["cancelled_at"])