Threads SDK

const { threads } = await rt.threads.list({ limit: 20 });

// A snapshot: thread metadata + its durable events
const snapshot = await rt.threads.get(threadId);
console.log(snapshot.thread.title, snapshot.events?.length);

// Just the events, paginated
const { events, hasMore, nextCursor } = await rt.threads.getEvents(threadId, { limit: 100 });

// Each run appends a rollout to the thread
const { rollouts } = await rt.threads.listRollouts(threadId);

await rt.threads.rename(threadId, 'Auth refactor');
await rt.threads.archive(threadId);
await rt.threads.compact(threadId);   // summarize older turns to reclaim context
await rt.threads.delete(threadId);    // permanent

const { events } = await rt.threads.activity(threadId, { limit: 50 });

const unsubscribe = rt.threads.subscribe(threadId, (frame) => {
  console.log(frame.type, frame);
});
// later: unsubscribe();

const stop = rt.threads.subscribeStreaming(threadId, {
  onMessageDelta: (f) => process.stdout.write(f.delta),
  onThinkingDelta: (f) => {/* reasoning tokens: f.delta */},
  onToolCallStarted: (f) => console.log('tool:', f.toolName),
  onToolOutputDelta: (f) => {/* streamed tool output: f.delta on f.stream */},
  onMessageComplete: (f) => console.log('\n[done]', f.message.id),
  onRunCompleted: () => stop(),
  onError: (f) => console.error(f.code, f.message),
});