How to classify social media repliesand publish the answer

export interface InboundReply {
  id: string;
  text: string;
  inReplyToText: string;
  authorHandle: string;
  authorFollowers: number;
  createdAt: string;   // ISO 8601, compared in code, never by the model
  platform: 'x' | 'bluesky' | 'linkedin';
}

export async function classify(reply) {
  const { answers, usage } = await client.systemOne({
    state: {
      reply_text: reply.text,
      in_reply_to: reply.inReplyToText,
      author_handle: reply.authorHandle,
      author_followers: reply.authorFollowers,
      platform: reply.platform,
    },
    questions: QUESTIONS,
  });

  return {
    bucket: answers.bucket.choice,
    bucketConfidence: answers.bucket.confidence,
    bucketProbabilities: answers.bucket.probabilities,
    urgency: answers.urgency.score,
    urgencyConfidence: answers.urgency.confidence,
    needsHumanReply: answers.needs_human_reply.noul,
    isPayingCustomer: answers.is_paying_customer.noul,
    mentionsMoney: answers.mentions_money.noul,
    isSpam: answers.is_spam.noul,
    model: 'jev-1.13.0',
    inputTokens: usage.input_tokens,
  };
}

const MIN_BUCKET_CONFIDENCE = 0.5;
const SPAM_CUTOFF = 0.85;
const REPLY_CUTOFF = 0.6;

type Destination =
  | 'drop'
  | 'human_queue'
  | 'support_ticket'
  | 'sales_queue'
  | 'draft_reply'
  | 'archive'
  | 'escalate';

export function route(scores): Destination {
  // Independent flags are checked before the bucket, because they are independent.
  if (scores.isSpam > SPAM_CUTOFF) return 'drop';
  if (scores.urgency !== null && scores.urgency >= 3.5) return 'escalate';

  // A bucket you are not confident about is not a bucket. Send it to a person.
  if (scores.bucketConfidence < MIN_BUCKET_CONFIDENCE) return 'human_queue';

  switch (scores.bucket) {
    case 'support':
      return scores.mentionsMoney > 0.5 ? 'escalate' : 'support_ticket';
    case 'sales':
      return 'sales_queue';
    case 'question':
      return scores.needsHumanReply > REPLY_CUTOFF ? 'draft_reply' : 'archive';
    case 'praise':
      return scores.needsHumanReply > REPLY_CUTOFF ? 'draft_reply' : 'archive';
    case 'hostile':
      return 'archive';
    default:
      return 'human_queue';
  }
}

curl -X POST https://opentweet.io/api/v1/posts \
  -H "Authorization: Bearer ot_your_key" \
  -H "Content-Type: application/json" \
  -H "Idempotency-Key: billing-reply-cluster-2026-09-18" \
  -d '{
    "text": "Nine of you asked about the double charge on Tuesday. It was a retry in our billing worker. Refunds went out automatically this morning and nothing needs to be requested.",
    "is_thread": true,
    "thread_tweets": [
      "If you want the detail: the worker retried without the idempotency key it is supposed to carry, so a handful of charges went through twice.",
      "214 accounts were affected and every one has already been refunded. If your statement still looks wrong, reply here and we will check it by hand."
    ],
    "platforms": ["x", "bluesky", "linkedin"],
    "publish_now": true
  }'

const res = await fetch('https://opentweet.io/api/v1/posts', {
  method: 'POST',
  headers: {
    Authorization: 'Bearer ot_your_key',
    'Content-Type': 'application/json',
    'Idempotency-Key': 'billing-reply-cluster-2026-09-18',
  },
  body: JSON.stringify({
    text: 'Nine of you asked about the double charge on Tuesday. Refunds went out this morning.',
    is_thread: true,
    thread_tweets: [
      'The detail: a retry in our billing worker ran without its idempotency key.',
      '214 accounts affected, all already refunded. Reply here if your statement still looks wrong.',
    ],
    platforms: ['x', 'bluesky', 'linkedin'],
    publish_now: true,
  }),
});

const data = await res.json();
if (!res.ok) {
  // v1 errors are { error, code, details? } on this route.
  throw new Error((data.code ?? res.status) + ': ' + data.error);
}

console.log(data.posts[0].id, data.posts[0].status, data.posts[0].url);