curl -X POST "https://api.orbit.devotel.io/api/v1/inbox/social-mentions/ingest" \
  -H "X-API-Key: dv_live_sk_your_key_here" \
  -H "Content-Type: application/json" \
  -d '{
    "platform": "twitter",
    "external_id": "1823412345678901234",
    "permalink": "https://x.com/acme_user/status/1823412345678901234",
    "author_handle": "acme_user",
    "text": "@acme the new dashboard is gorgeous — shipped a week early too",
    "matched_keyword": "acme",
    "sentiment": "positive",
    "reach": 12500,
    "posted_at": "2026-08-29T14:21:10Z"
  }'
# first delivery -> 201 created

# re-delivery of the same external_id -> 200
{
  "data": {
    "conversation_id": "conv_x9w",
    "message_id": null,
    "deduped": true,
    "conversation_created": false
  }
}

// poller.mjs — run with: ORBIT_API_KEY=... node poller.mjs
const ORBIT_API = "https://api.orbit.devotel.io/api/v1";
const ORBIT_KEY = process.env.ORBIT_API_KEY; // admin-scoped key
const PROVIDER_TOKEN = process.env.X_BEARER_TOKEN;
const KEYWORD = "acme"; // your listening keyword

async function getNewPosts() {
  const url = new URL("https://api.x.com/2/tweets/search/recent");
  url.searchParams.set("query", `@acme OR acme -is:retweet`);
  url.searchParams.set("tweet.fields", "created_at,public_metrics");
  const res = await fetch(url, {
    headers: { Authorization: `Bearer ${PROVIDER_TOKEN}` },
  });
  if (!res.ok) throw new Error(`provider ${res.status}`);
  const json = await res.json();
  return json.data ?? [];
}

async function ingest(mention) {
  const res = await fetch(`${ORBIT_API}/inbox/social-mentions/ingest`, {
    method: "POST",
    headers: {
      "X-API-Key": ORBIT_KEY,
      "Content-Type": "application/json",
    },
    body: JSON.stringify(mention),
  });
  // 201 = new conversation, 200 = deduped; both are success.
  if (res.status !== 201 && res.status !== 200) {
    throw new Error(`ingest ${res.status}: ${await res.text()}`);
  }
  return res.json();
}

const posts = await getNewPosts();
for (const post of posts) {
  await ingest({
    platform: "twitter",
    external_id: post.id, // the provider's stable id — the dedup key
    permalink: `https://x.com/i/status/${post.id}`,
    author_handle: post.author_id ?? "unknown",
    text: post.text,
    matched_keyword: KEYWORD,
    reach: post.public_metrics?.like_count ?? undefined,
    posted_at: post.created_at,
  });
}

// trustpilot-webhook.mjs — POST /trustpilot hook receiver
import express from "express";

const ORBIT_API = "https://api.orbit.devotel.io/api/v1";
const ORBIT_KEY = process.env.ORBIT_API_KEY;

const app = express();
app.use(express.json());

function toSentiment(stars) {
  if (stars <= 2) return "negative";
  if (stars === 3) return "neutral";
  return "positive";
}

app.post("/trustpilot", async (req, res) => {
  const events = req.body?.events ?? [];
  for (const event of events) {
    if (event.eventName !== "new-review") continue;
    const review = event.review;
    const response = await fetch(
      `${ORBIT_API}/inbox/social-mentions/ingest`,
      {
        method: "POST",
        headers: {
          "X-API-Key": ORBIT_KEY,
          "Content-Type": "application/json",
        },
        body: JSON.stringify({
          platform: "trustpilot",
          external_id: review.id, // Trustpilot review id — stable per review
          permalink: review.reviewUrl,
          author_handle: review.consumer?.id ?? "unknown",
          author_display_name: review.consumer?.displayName,
          text: review.text,
          sentiment: toSentiment(review.stars),
          posted_at: review.createdAt,
        }),
      },
    );
    if (![200, 201].includes(response.status)) {
      // 4xx is a payload bug; answer the webhook fast, log, and let a
      // re-delivery or a manual replay recover once the bug is fixed.
      console.error(`ingest ${response.status}: ${await response.text()}`);
    }
  }
  res.status(204).end();
});

app.listen(8080);

curl -X POST "https://api.orbit.devotel.io/api/v1/inbox/routing-rules" \
  -H "X-API-Key: dv_live_sk_your_key_here" \
  -H "Content-Type: application/json" \
  -d '{
    "name": "Negative mention -> senior agent",
    "priority": 100,
    "conditions": {
      "sentiment": ["negative"]
    },
    "action": { "type": "assign_user", "target_id": "<senior-user-id>" }
  }'

curl -X POST "https://api.orbit.devotel.io/api/v1/inbox/routing-rules" \
  -H "X-API-Key: dv_live_sk_your_key_here" \
  -H "Content-Type: application/json" \
  -d '{
    "name": "Campaign hashtag -> marketing team",
    "priority": 200,
    "conditions": {
      "keyword": ["#OrbitLaunch", "/acme[- ]?launch/"]
    },
    "action": { "type": "assign_team", "target_id": "<marketing-team-id>" }
  }'

curl -X POST "https://api.orbit.devotel.io/api/v1/inbox/sla/policies" \
  -H "X-API-Key: dv_live_sk_your_key_here" \
  -H "Content-Type: application/json" \
  -d '{
    "name": "Social mentions SLA",
    "scope": "per_channel",
    "channel_filter": "social_mention",
    "first_response_target_minutes": 240,
    "resolution_target_minutes": 1440,
    "next_response_target_minutes": 480,
    "business_hours_only": true,
    "breach_action_type": "notify",
    "breach_action_config": { "user_ids": ["<on-call-manager-id>"] },
    "breach_action_tiers": []
  }'