TypeScript / JavaScript SDK

npm install @causet/sdk-node   # Node.js backends (recommended for retrofit)
# or
npm install @causet/sdk        # browser / Vite / React (non-Next)

import { CausetClient } from '@causet/sdk'; // or '@causet/sdk-node'
 
const client = new CausetClient({
  apiUrl: 'https://api.causet.cloud',   // local dev: http://localhost:8085
  platformSlug: 'my-platform',
  appSlug: 'my-app',
  forkId: 'sandbox',
  apiKey: 'ck_live_xxx.secret',          // server-side only
});
 
await client.init();

import { createCausetClient } from '@causet/sdk-node';
 
const client = createCausetClient({
  apiUrl: process.env.CAUSET_API_URL ?? 'http://localhost:8085',
  platformSlug: process.env.CAUSET_PLATFORM,
  appSlug: process.env.CAUSET_APPLICATION,
  forkId: process.env.CAUSET_FORK ?? 'sandbox',
  apiKey: process.env.CAUSET_API_KEY,
});
await client.init();

const result = await client.submitIntent(
  'ticket_stream',
  'tkt_1',
  'CREATE_TICKET',
  { customer_id: 'cust_1', subject: 'Help', body: 'Need assistance' },
  'optional-idempotency-key',
);
// { accepted, executionId?, error?, statePatch? }

await client.submitIntentStream(
  'ticket_stream', 'tkt_1', 'CREATE_TICKET', payload,
  (ev) => console.log(ev.event, ev.data),
  'optional-idempotency-key',
  abortSignal,
);

await client.subscribe('stream_id', 'entity_id');
const state = client.getState('stream_id', 'entity_id');
await client.fetchState('stream_id', 'entity_id'); // one-shot, no cache
await client.listEntities({ streamName: 'orders', limit: 50 });

const { items, next_cursor } = await client.runQuery(
  'urgent_tickets',
  { status: 'open' },
  { limit: 20, cursor: 'abc', includeTotal: true },
);
 
await client.listQueries();
await client.getQueryDefinition('urgent_tickets');
await client.listProjections();

import { CausetApiError, CausetAuthError, CausetError } from '@causet/sdk-core';
 
try {
  await client.submitIntent('ticket_stream', 'tkt_1', 'CREATE_TICKET', {});
} catch (e) {
  if (e instanceof CausetApiError) {
    console.error(e.statusCode, e.body);
  } else if (e instanceof CausetAuthError) {
    console.error('Auth failed:', e.message);
  }
}

await client.submitIntent(
  'refund_stream', refundId, 'REFUND_REQUESTED', payload, refundId,
);

const connId = await client.connectStream('ticket_stream', {
  fromCursor: 0,
  channels: [{ channel: 'ledger' }, { channel: 'state' }],
});
 
client.on('stream_event', (ev) => console.log(ev));
client.disconnectStream();