Build an AI socialmedia agent in 2026

import { TypeSafeClient, noul, score } from '@typesafe-ai/sdk';

const client = new TypeSafeClient({ timeout: 4000 });

const QUESTIONS = {
  strength: score(
    'How far will this post travel compared to a typical post from the same author?',
    [
      'Flops. Gets less attention than a typical post from the same account.',
      'Typical. Performs about the same as the account usually does.',
      'Above typical. Noticeably more reach and replies than usual.',
      'Strong. Several times the usual reach. Spreads past the existing audience.',
      'Breakout. Orders of magnitude beyond usual.',
    ]
  ),
  slop: noul('This reads like it was generated by an AI rather than written by a person.'),
  bait: noul('This post explicitly asks the reader for likes, reposts, replies, follows, or bookmarks.'),
  toxicity: noul('This text contains slurs, harassment, sexual content, or abuse targeted at a person or group.'),
} as const;

export interface Verdict {
  strength: number;      // 0 to 4, probability weighted across the five levels
  confidence: number;    // 0 to 1, how concentrated that distribution is
  slop: number;          // 0 to 1
  bait: number;          // 0 to 1
  toxicity: number;      // 0 to 1
}

export async function judge(draft: string): Promise<Verdict> {
  const { answers } = await client.systemOne({
    state: { draft_post: draft, platform: 'X (Twitter)' },
    questions: QUESTIONS,
  });

  return {
    strength: answers.strength.score,
    confidence: answers.strength.confidence,
    slop: answers.slop.noul,
    bait: answers.bait.noul,
    toxicity: answers.toxicity.noul,
  };
}

const OPENTWEET = 'https://opentweet.io/api/v1/posts';

export interface NetworkResult {
  platform: 'x' | 'bluesky' | 'linkedin';
  status: string;
  url: string | null;
  error: string | null;
  skip_reason: string | null;
}

export interface Published {
  id: string;
  status: 'draft' | 'scheduled' | 'posted' | 'failed' | 'evergreen';
  results: NetworkResult[];
}

/**
 * at:  ISO 8601 with an explicit offset. A bare local string is read in server time.
 * now: publish synchronously and return the real outcome.
 * Neither one saves the post as a draft for a human to approve.
 */
export async function publish(
  text: string,
  opts: { at?: string; now?: boolean; key?: string } = {}
): Promise<Published> {
  const body: Record<string, unknown> = {
    text,
    platforms: ['x', 'bluesky', 'linkedin'],
    category: 'Agent',
  };
  if (opts.at) body.scheduled_date = opts.at;
  else if (opts.now) body.publish_now = true;

  const headers: Record<string, string> = {
    Authorization: 'Bearer ' + process.env.OPENTWEET_API_KEY,
    'Content-Type': 'application/json',
  };
  if (opts.key) headers['Idempotency-Key'] = opts.key;

  const res = await fetch(OPENTWEET, { method: 'POST', headers, body: JSON.stringify(body) });
  const data = await res.json();

  if (!res.ok) {
    // { error, code, details? } on this route. 502 publish_failed still carries results[].
    throw new Error((data.code || res.status) + ': ' + data.error);
  }

  const post = data.posts[0];
  return { id: post.id, status: post.status, results: post.results || [] };
}