JavaScript Client

npm install opensink
# or
yarn add opensink

import Opensink from 'opensink';

const client = new Opensink({
  apiKey: 'your-api-key',
});

const { data: sink } = await client.sinks.create({
  name: 'research-results',
  description: 'Summaries from research agent',
});

const { data: { items } } = await client.sinks.list();

const { data: item } = await client.sinkItems.create({
  sink_id: 'sink-id',
  title: 'Apple stock drops 3%',
  body: 'Shares fell after earnings missed expectations.',
  type: 'event',
  fields: { ticker: 'AAPL', change_percent: -3 },
});

const { data: agent } = await client.agents.create({
  name: 'research-agent',
  description: 'Gathers and summarizes research',
});

const { data: config } = await client.agentConfigurations.create({
  agent_id: 'agent-id',
  variant: 'default',
  schema: { type: 'object', properties: { model: { type: 'string' } } },
  value: { model: 'gpt-4o' },
});

const { data: session } = await client.agentSessions.create({
  agent_id: 'agent-id',
  status: 'running',
  state: { step: 'init' },
  metadata: { triggered_by: 'cron' },
});

await client.agentSessions.update('session-id', {
  status: 'completed',
});

const { data: request } = await client.agentSessionInputRequests.create({
  session_id: 'session-id',
  agent_id: 'agent-id',
  key: 'approval',
  title: 'Approve purchase',
  message: 'Agent wants to purchase 100 units. Approve?',
  schema: { type: 'object', properties: { approved: { type: 'boolean' } } },
});

const { data: activity } = await client.agentSessionActivities.create({
  session_id: 'session-id',
  agent_id: 'agent-id',
  type: 'message',
  source: 'agent',
  message: 'Started processing batch',
});

// First page
const { data: page1 } = await client.sinkItems.list({ $limit: 20 });

// Next page
if (page1.trail) {
  const { data: page2 } = await client.sinkItems.list({
    $limit: 20,
    $trail: page1.trail,
  });
}