ANS

curl -s -X POST "$ANS_API/topics" \
  -H "Authorization: Bearer $ANS_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "name": "order-events",
    "region": "us-east-1",
    "retention_hours": 168
  }'

import os
import requests

API = "https://anything.solutions/v1/ans"
headers = {"Authorization": f"Bearer {os.environ['ANS_API_KEY']}"}

response = requests.post(
    f"{API}/topics",
    headers=headers,
    json={
        "name": "order-events",
        "region": "us-east-1",
        "retention_hours": 168,
    },
    timeout=30,
)
response.raise_for_status()
print(response.json()["topic"]["id"])

const API = "https://anything.solutions/v1/ans";
const headers = {
  Authorization: `Bearer ${process.env.ANS_API_KEY}`,
  "Content-Type": "application/json",
};

const response = await fetch(`${API}/topics`, {
  method: "POST",
  headers,
  body: JSON.stringify({
    name: "order-events",
    region: "us-east-1",
    retention_hours: 168,
  }),
});
if (!response.ok) throw new Error(await response.text());
const {topic} = await response.json();
console.log(topic.id);

curl -s -X POST "$ANS_API/topics/tpc_4f8c.../publish" \
  -H "Authorization: Bearer $ANS_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "event": "order.created",
    "data": {
      "order_id": "12345",
      "total": 49.99,
      "currency": "USD"
    },
    "attributes": {"tenant": "acme"}
  }'

import os
import requests

API = "https://anything.solutions/v1/ans"
headers = {"Authorization": f"Bearer {os.environ['ANS_API_KEY']}"}

response = requests.post(
    f"{API}/topics/tpc_4f8c.../publish",
    headers=headers,
    json={
        "event": "order.created",
        "data": {
            "order_id": "12345",
            "total": 49.99,
            "currency": "USD",
        },
        "attributes": {"tenant": "acme"},
    },
    timeout=30,
)
response.raise_for_status()
print(response.json()["message_id"])

const API = "https://anything.solutions/v1/ans";
const headers = {
  Authorization: `Bearer ${process.env.ANS_API_KEY}`,
  "Content-Type": "application/json",
};

const response = await fetch(
  `${API}/topics/tpc_4f8c.../publish`,
  {
    method: "POST",
    headers,
    body: JSON.stringify({
      event: "order.created",
      data: {order_id: "12345", total: 49.99, currency: "USD"},
      attributes: {tenant: "acme"},
    }),
  },
);
if (!response.ok) throw new Error(await response.text());
const {message_id} = await response.json();
console.log(message_id);

curl -s -X POST "$ANS_API/topics/tpc_4f8c.../publish" \
  -H "Authorization: Bearer $ANS_API_KEY" \
  -H "Idempotency-Key: order-12345-created" \
  -H "Content-Type: application/json" \
  -d '{"event":"order.created","data":{"order_id":"12345"}}'

import os
import requests

API = "https://anything.solutions/v1/ans"
response = requests.post(
    f"{API}/topics/tpc_4f8c.../publish",
    headers={
        "Authorization": f"Bearer {os.environ['ANS_API_KEY']}",
        "Idempotency-Key": "order-12345-created",
    },
    json={"event": "order.created", "data": {"order_id": "12345"}},
    timeout=30,
)
response.raise_for_status()

const response = await fetch(
  "https://anything.solutions/v1/ans/topics/tpc_4f8c.../publish",
  {
    method: "POST",
    headers: {
      Authorization: `Bearer ${process.env.ANS_API_KEY}`,
      "Content-Type": "application/json",
      "Idempotency-Key": "order-12345-created",
    },
    body: JSON.stringify({
      event: "order.created",
      data: {order_id: "12345"},
    }),
  },
);
if (!response.ok) throw new Error(await response.text());

curl -s -X POST "$ANS_API/topics/tpc_4f8c.../publish/batch" \
  -H "Authorization: Bearer $ANS_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "messages": [
      {"event":"order.created","data":{"order_id":"A-1"},"idempotency_key":"A-1"},
      {"event":"order.created","data":{"order_id":"A-2"},"idempotency_key":"A-2"}
    ]
  }'

import os
import requests

API = "https://anything.solutions/v1/ans"
headers = {"Authorization": f"Bearer {os.environ['ANS_API_KEY']}"}

response = requests.post(
    f"{API}/topics/tpc_4f8c.../publish/batch",
    headers=headers,
    json={
        "messages": [
            {"event": "order.created", "data": {"order_id": "A-1"}},
            {"event": "order.created", "data": {"order_id": "A-2"}},
        ]
    },
    timeout=30,
)
response.raise_for_status()
for item in response.json()["results"]:
    print(item["index"], item["accepted"], item.get("message", {}).get("id"))

const response = await fetch(
  "https://anything.solutions/v1/ans/topics/tpc_4f8c.../publish/batch",
  {
    method: "POST",
    headers: {
      Authorization: `Bearer ${process.env.ANS_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({
      messages: [
        {event: "order.created", data: {order_id: "A-1"}},
        {event: "order.created", data: {order_id: "A-2"}},
      ],
    }),
  },
);
if (!response.ok) throw new Error(await response.text());
const {results} = await response.json();
for (const item of results) {
  console.log(item.index, item.accepted, item.message?.id);
}

curl -s -X POST "$ANS_API/topics/tpc_4f8c.../subscriptions" \
  -H "Authorization: Bearer $ANS_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "name": "warehouse-hook",
    "kind": "webhook",
    "endpoint_url": "https://example.com/ans/events",
    "headers": {"X-Environment": "production"},
    "filter_policy": {"event": ["order.*"]},
    "max_attempts": 8,
    "base_delay_seconds": 5,
    "max_delay_seconds": 3600,
    "timeout_seconds": 10,
    "dead_letter_queue_id": 12
  }'

import os
import requests

API = "https://anything.solutions/v1/ans"
headers = {"Authorization": f"Bearer {os.environ['ANS_API_KEY']}"}

response = requests.post(
    f"{API}/topics/tpc_4f8c.../subscriptions",
    headers=headers,
    json={
        "name": "warehouse-hook",
        "kind": "webhook",
        "endpoint_url": "https://example.com/ans/events",
        "headers": {"X-Environment": "production"},
        "filter_policy": {"event": ["order.*"]},
        "max_attempts": 8,
        "base_delay_seconds": 5,
        "max_delay_seconds": 3600,
        "timeout_seconds": 10,
        "dead_letter_queue_id": 12,
    },
    timeout=30,
)
response.raise_for_status()
subscription = response.json()["subscription"]
secret = response.json()["secret"]  # shown once

const response = await fetch(
  "https://anything.solutions/v1/ans/topics/tpc_4f8c.../subscriptions",
  {
    method: "POST",
    headers: {
      Authorization: `Bearer ${process.env.ANS_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({
      name: "warehouse-hook",
      kind: "webhook",
      endpoint_url: "https://example.com/ans/events",
      headers: {"X-Environment": "production"},
      filter_policy: {event: ["order.*"]},
      max_attempts: 8,
      base_delay_seconds: 5,
      max_delay_seconds: 3600,
      timeout_seconds: 10,
      dead_letter_queue_id: 12,
    }),
  },
);
if (!response.ok) throw new Error(await response.text());
const {subscription, secret} = await response.json(); // secret shown once

import hashlib
import hmac
import time

def verify_ans_signature(raw_body: bytes, header: str, secret: str) -> bool:
    parts = dict(part.split("=", 1) for part in header.split(",") if "=" in part)
    timestamp = parts.get("t", "")
    signature = parts.get("v1", "")
    try:
        if abs(time.time() - int(timestamp)) > 300:
            return False
    except ValueError:
        return False
    expected = hmac.new(
        secret.encode(), timestamp.encode() + b"." + raw_body, hashlib.sha256
    ).hexdigest()
    return hmac.compare_digest(expected, signature)

import crypto from "node:crypto";
import express from "express";

export function verifyAnsSignature(rawBody, signatureHeader, secret) {
  const parts = Object.fromEntries(
    signatureHeader.split(",").map((part) => part.split("=", 2)),
  );
  const timestamp = Number(parts.t);
  if (!Number.isFinite(timestamp)) return false;
  if (Math.abs(Date.now() / 1000 - timestamp) > 300) return false;
  const expected = crypto
    .createHmac("sha256", secret)
    .update(`${parts.t}.${rawBody}`)
    .digest("hex");
  return crypto.timingSafeEqual(
    Buffer.from(expected, "hex"),
    Buffer.from(parts.v1 || "", "hex"),
  );
}

const app = express();
app.post(
  "/ans/events",
  express.raw({ type: "application/json" }),
  (req, res) => {
    const raw = req.body.toString("utf8");
    if (!verifyAnsSignature(raw, req.get("X-ANS-Signature") || "", process.env.ANS_SECRET)) {
      return res.status(401).send("invalid signature");
    }
    const event = JSON.parse(raw);
    if (event.type === "ans.subscription.verification") {
      return res.status(204).end();
    }
    // At-least-once delivery: deduplicate on event.delivery.id.
    console.log(event.event, event.data);
    res.status(204).end();
  },
);

curl -s -X POST "$ANS_API/topics/tpc_4f8c.../subscriptions" \
  -H "Authorization: Bearer $ANS_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "name": "fulfilment-worker",
    "kind": "worker",
    "worker_id": 9
  }'

import os
import requests

API = "https://anything.solutions/v1/ans"
response = requests.post(
    f"{API}/topics/tpc_4f8c.../subscriptions",
    headers={"Authorization": f"Bearer {os.environ['ANS_API_KEY']}"},
    json={
        "name": "fulfilment-worker",
        "kind": "worker",
        "worker_id": 9,
    },
    timeout=30,
)
response.raise_for_status()

const response = await fetch(
  "https://anything.solutions/v1/ans/topics/tpc_4f8c.../subscriptions",
  {
    method: "POST",
    headers: {
      Authorization: `Bearer ${process.env.ANS_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({
      name: "fulfilment-worker",
      kind: "worker",
      worker_id: 9,
    }),
  },
);
if (!response.ok) throw new Error(await response.text());

curl -s -X POST "$ANS_API/topics/tpc_4f8c.../subscriptions" \
  -H "Authorization: Bearer $ANS_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "name": "fulfilment-queue",
    "kind": "queue",
    "queue_id": 12,
    "filter_policy": {"event": "order.created"}
  }'

import os
import requests

API = "https://anything.solutions/v1/ans"
response = requests.post(
    f"{API}/topics/tpc_4f8c.../subscriptions",
    headers={"Authorization": f"Bearer {os.environ['ANS_API_KEY']}"},
    json={
        "name": "fulfilment-queue",
        "kind": "queue",
        "queue_id": 12,
        "filter_policy": {"event": "order.created"},
    },
    timeout=30,
)
response.raise_for_status()

const response = await fetch(
  "https://anything.solutions/v1/ans/topics/tpc_4f8c.../subscriptions",
  {
    method: "POST",
    headers: {
      Authorization: `Bearer ${process.env.ANS_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({
      name: "fulfilment-queue",
      kind: "queue",
      queue_id: 12,
      filter_policy: {event: "order.created"},
    }),
  },
);
if (!response.ok) throw new Error(await response.text());

curl -s -X POST "https://anything.solutions/queue/v1/fulfilment/consume" \
  -H "Authorization: Bearer $AQS_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{"max_messages": 10, "visibility_seconds": 30}'

import os
import requests

response = requests.post(
    "https://anything.solutions/queue/v1/fulfilment/consume",
    headers={"Authorization": f"Bearer {os.environ['AQS_TOKEN']}"},
    json={"max_messages": 10, "visibility_seconds": 30},
    timeout=30,
)
response.raise_for_status()

const response = await fetch(
  "https://anything.solutions/queue/v1/fulfilment/consume",
  {
    method: "POST",
    headers: {
      Authorization: `Bearer ${process.env.AQS_TOKEN}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({max_messages: 10, visibility_seconds: 30}),
  },
);
if (!response.ok) throw new Error(await response.text());

curl -s -X POST "$ANS_API/topics/tpc_4f8c.../subscriptions" \
  -H "Authorization: Bearer $ANS_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "name": "order-receipt",
    "kind": "email",
    "sender_id": 4,
    "to": "[email protected]",
    "subject": "Order {{ data.order_id }} confirmed",
    "text": "Thanks. Your total is {{ data.currency }} {{ data.total }}.",
    "html": "<p>Your order <strong>{{ data.order_id }}</strong> is confirmed.</p>"
  }'

import os
import requests

API = "https://anything.solutions/v1/ans"
response = requests.post(
    f"{API}/topics/tpc_4f8c.../subscriptions",
    headers={"Authorization": f"Bearer {os.environ['ANS_API_KEY']}"},
    json={
        "name": "order-receipt",
        "kind": "email",
        "sender_id": 4,
        "to": "[email protected]",
        "subject": "Order {{ data.order_id }} confirmed",
        "text": "Thanks. Your total is {{ data.currency }} {{ data.total }}.",
        "html": "<p>Your order <strong>{{ data.order_id }}</strong> is confirmed.</p>",
    },
    timeout=30,
)
response.raise_for_status()

const response = await fetch(
  "https://anything.solutions/v1/ans/topics/tpc_4f8c.../subscriptions",
  {
    method: "POST",
    headers: {
      Authorization: `Bearer ${process.env.ANS_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({
      name: "order-receipt",
      kind: "email",
      sender_id: 4,
      to: "[email protected]",
      subject: "Order {{ data.order_id }} confirmed",
      text: "Thanks. Your total is {{ data.currency }} {{ data.total }}.",
      html: "<p>Your order <strong>{{ data.order_id }}</strong> is confirmed.</p>",
    }),
  },
);
if (!response.ok) throw new Error(await response.text());

curl -s -X POST "$ANS_API/deliveries/dlv_9b2c.../retry" \
  -H "Authorization: Bearer $ANS_API_KEY"

import os
import requests

response = requests.post(
    "https://anything.solutions/v1/ans/deliveries/dlv_9b2c.../retry",
    headers={"Authorization": f"Bearer {os.environ['ANS_API_KEY']}"},
    timeout=30,
)
response.raise_for_status()

const response = await fetch(
  "https://anything.solutions/v1/ans/deliveries/dlv_9b2c.../retry",
  {
    method: "POST",
    headers: {Authorization: `Bearer ${process.env.ANS_API_KEY}`},
  },
);
if (!response.ok) throw new Error(await response.text());

curl -s -X POST "$ANS_API/topics/tpc_4f8c.../hosts" \
  -H "Authorization: Bearer $ANS_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"root_id": 3, "label": "events"}'

import os
import requests

API = "https://anything.solutions/v1/ans"
response = requests.post(
    f"{API}/topics/tpc_4f8c.../hosts",
    headers={"Authorization": f"Bearer {os.environ['ANS_API_KEY']}"},
    json={"root_id": 3, "label": "events"},
    timeout=30,
)
response.raise_for_status()

const response = await fetch(
  "https://anything.solutions/v1/ans/topics/tpc_4f8c.../hosts",
  {
    method: "POST",
    headers: {
      Authorization: `Bearer ${process.env.ANS_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({root_id: 3, label: "events"}),
  },
);
if (!response.ok) throw new Error(await response.text());

curl -s -X POST "https://events.example.com/publish" \
  -H "Authorization: Bearer $ANS_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"event":"order.created","data":{"order_id":"12345"}}'

import os
import requests

response = requests.post(
    "https://events.example.com/publish",
    headers={"Authorization": f"Bearer {os.environ['ANS_API_KEY']}"},
    json={"event": "order.created", "data": {"order_id": "12345"}},
    timeout=30,
)
response.raise_for_status()

const response = await fetch("https://events.example.com/publish", {
  method: "POST",
  headers: {
    Authorization: `Bearer ${process.env.ANS_API_KEY}`,
    "Content-Type": "application/json",
  },
  body: JSON.stringify({
    event: "order.created",
    data: {order_id: "12345"},
  }),
});
if (!response.ok) throw new Error(await response.text());

curl -s -X POST "$ANS_API/topics" \
  -H "Authorization: Bearer $ANS_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"name":"order-events","region":"us-east-1"}'

import os
import requests

response = requests.post(
    "https://anything.solutions/v1/ans/topics",
    headers={"Authorization": f"Bearer {os.environ['ANS_API_KEY']}"},
    json={"name": "order-events", "region": "us-east-1"},
    timeout=30,
)
response.raise_for_status()

const response = await fetch("https://anything.solutions/v1/ans/topics", {
  method: "POST",
  headers: {
    Authorization: `Bearer ${process.env.ANS_API_KEY}`,
    "Content-Type": "application/json",
  },
  body: JSON.stringify({name: "order-events", region: "us-east-1"}),
});
if (!response.ok) throw new Error(await response.text());

curl -s -X POST "$ANS_API/topics/tpc_4f8c.../subscriptions" \
  -H "Authorization: Bearer $ANS_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"name":"fulfilment-worker","kind":"worker","worker_id":9}'

import os
import requests

response = requests.post(
    "https://anything.solutions/v1/ans/topics/tpc_4f8c.../subscriptions",
    headers={"Authorization": f"Bearer {os.environ['ANS_API_KEY']}"},
    json={"name": "fulfilment-worker", "kind": "worker", "worker_id": 9},
    timeout=30,
)
response.raise_for_status()

const response = await fetch(
  "https://anything.solutions/v1/ans/topics/tpc_4f8c.../subscriptions",
  {
    method: "POST",
    headers: {
      Authorization: `Bearer ${process.env.ANS_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({
      name: "fulfilment-worker",
      kind: "worker",
      worker_id: 9,
    }),
  },
);
if (!response.ok) throw new Error(await response.text());

curl -s -X POST "$ANS_API/topics/tpc_4f8c.../subscriptions" \
  -H "Authorization: Bearer $ANS_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"name":"order-queue","kind":"queue","queue_id":12}'

import os
import requests

response = requests.post(
    "https://anything.solutions/v1/ans/topics/tpc_4f8c.../subscriptions",
    headers={"Authorization": f"Bearer {os.environ['ANS_API_KEY']}"},
    json={"name": "order-queue", "kind": "queue", "queue_id": 12},
    timeout=30,
)
response.raise_for_status()

const response = await fetch(
  "https://anything.solutions/v1/ans/topics/tpc_4f8c.../subscriptions",
  {
    method: "POST",
    headers: {
      Authorization: `Bearer ${process.env.ANS_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({name: "order-queue", kind: "queue", queue_id: 12}),
  },
);
if (!response.ok) throw new Error(await response.text());

curl -s -X POST "$ANS_API/topics/tpc_4f8c.../subscriptions" \
  -H "Authorization: Bearer $ANS_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "name":"order-receipt",
    "kind":"email",
    "sender_id":4,
    "to":"[email protected]",
    "subject":"Order {{ data.order_id }} confirmed",
    "text":"Thanks. Total: {{ data.currency }} {{ data.total }}."
  }'

import os
import requests

response = requests.post(
    "https://anything.solutions/v1/ans/topics/tpc_4f8c.../subscriptions",
    headers={"Authorization": f"Bearer {os.environ['ANS_API_KEY']}"},
    json={
        "name": "order-receipt",
        "kind": "email",
        "sender_id": 4,
        "to": "[email protected]",
        "subject": "Order {{ data.order_id }} confirmed",
        "text": "Thanks. Total: {{ data.currency }} {{ data.total }}.",
    },
    timeout=30,
)
response.raise_for_status()

const response = await fetch(
  "https://anything.solutions/v1/ans/topics/tpc_4f8c.../subscriptions",
  {
    method: "POST",
    headers: {
      Authorization: `Bearer ${process.env.ANS_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({
      name: "order-receipt",
      kind: "email",
      sender_id: 4,
      to: "[email protected]",
      subject: "Order {{ data.order_id }} confirmed",
      text: "Thanks. Total: {{ data.currency }} {{ data.total }}.",
    }),
  },
);
if (!response.ok) throw new Error(await response.text());

curl -s -X POST "$ANS_API/topics/tpc_4f8c.../publish" \
  -H "Authorization: Bearer $ANS_API_KEY" \
  -H "Idempotency-Key: order-12345-created" \
  -H "Content-Type: application/json" \
  -d '{
    "event":"order.created",
    "data":{"order_id":"12345","total":49.99,"currency":"USD"},
    "attributes":{"tenant":"acme"}
  }'

import os
import requests

response = requests.post(
    "https://anything.solutions/v1/ans/topics/tpc_4f8c.../publish",
    headers={
        "Authorization": f"Bearer {os.environ['ANS_API_KEY']}",
        "Idempotency-Key": "order-12345-created",
    },
    json={
        "event": "order.created",
        "data": {"order_id": "12345", "total": 49.99, "currency": "USD"},
        "attributes": {"tenant": "acme"},
    },
    timeout=30,
)
response.raise_for_status()
print(response.json()["message_id"])

const response = await fetch(
  "https://anything.solutions/v1/ans/topics/tpc_4f8c.../publish",
  {
    method: "POST",
    headers: {
      Authorization: `Bearer ${process.env.ANS_API_KEY}`,
      "Content-Type": "application/json",
      "Idempotency-Key": "order-12345-created",
    },
    body: JSON.stringify({
      event: "order.created",
      data: {order_id: "12345", total: 49.99, currency: "USD"},
      attributes: {tenant: "acme"},
    }),
  },
);
if (!response.ok) throw new Error(await response.text());
const result = await response.json();
console.log(result.message_id, result.deliveries);

curl -s "$ANS_API/topics" \
  -H "Authorization: Bearer $ANS_API_KEY"

import os
import requests

API = "https://anything.solutions/v1/ans"
headers = {"Authorization": f"Bearer {os.environ['ANS_API_KEY']}"}

topics = requests.get(f"{API}/topics", headers=headers, timeout=30).json()
for topic in topics["items"]:
    print(topic["id"], topic["arn"])

const API = "https://anything.solutions/v1/ans";
const headers = {
  Authorization: `Bearer ${process.env.ANS_API_KEY}`,
  "Content-Type": "application/json",
};

const topics = await fetch(`${API}/topics`, {headers}).then((r) => r.json());
for (const topic of topics.items) console.log(topic.id, topic.arn);