Roadmap

import { CausetClient } from '@causet/sdk'; // or '@causet/sdk-node'
 
const client = new CausetClient({
  apiUrl: 'https://api.causet.cloud',
  platformSlug: 'my-platform',
  appSlug: 'my-app',
  apiKey: process.env.CAUSET_API_KEY,
});
await client.init();
 
const result = await client.emit('ticket_stream', 'tkt_1', 'CREATE_TICKET', {
  customer_id: 'cust_1',
  subject: 'Help',
});
 
const rows = await client.runQuery('open_tickets', { status: 'open' }, { limit: 20 });
 
await client.connectStream('ticket_stream', { channels: [{ channel: 'ledger' }, { channel: 'state' }] });
client.on('patch_op', (ev) => console.log(ev.ops));
 
client.destroy();

'use client';
import { useCausetQuery, useCausetIntent } from '@causet/sdk-next';
 
function TicketList() {
  const { data, loading, refresh } = useCausetQuery('open_tickets', { status: 'open' }, { limit: 20 });
  const { emit, pending } = useCausetIntent();
 
  return (
    <ul>
      {data?.items.map((row) => <li key={String(row.id)}>{String(row.subject)}</li>)}
      <button disabled={pending} onClick={() => emit('ticket_stream', 'tkt_1', 'CLOSE_TICKET', {}).then(refresh)}>
        Close first ticket
      </button>
    </ul>
  );
}

from causet_sdk import CausetClient
 
client = CausetClient(
    api_url="https://api.causet.cloud",
    platform_slug="my-platform",
    app_slug="my-app",
    api_key="ck_live_xxx.secret",
)
await client.init()
 
result = await client.emit("ticket_stream", "tkt_1", "CREATE_TICKET", {
    "customer_id": "cust_1", "subject": "Help",
})
rows = await client.run_query("open_tickets", {"status": "open"}, limit=20)
await client.connect_stream("ticket_stream")
client.destroy()

use Causet\Laravel\Facades\Causet;
 
Causet::init();
 
$result = Causet::emit('ticket_stream', 'tkt_1', 'CREATE_TICKET', [
    'customer_id' => 'cust_1',
    'subject' => 'Billing question',
]);
 
$rows = Causet::runQuery('open_tickets', ['status' => 'open'], limit: 20);

client := causet.NewClient(causet.Config{
    APIURL: "https://api.causet.cloud",
    PlatformSlug: "my-platform",
    AppSlug: "my-app",
    APIKey: os.Getenv("CAUSET_API_KEY"),
})
result, _ := client.Emit("ticket_stream", "tkt_1", "CREATE_TICKET", map[string]any{"subject": "Help"})
rows, _ := client.RunQuery("open_tickets", map[string]any{"status": "open"}, causet.QueryOptions{Limit: 20})
client.ConnectStream(ctx, "ticket_stream", causet.StreamConnectOptions{}, onEvent)
client.On("patch_op", func(ev any) { fmt.Println(ev) })

CausetConfig cfg = new CausetConfig();
cfg.apiUrl = "https://api.causet.cloud";
cfg.platformSlug = "my-platform";
cfg.appSlug = "my-app";
cfg.apiKey = System.getenv("CAUSET_API_KEY");
CausetClient client = new CausetClient(cfg);
 
JsonNode result = client.emit("ticket_stream", "tkt_1", "CREATE_TICKET", Map.of("subject", "Help"));
JsonNode rows = client.runQuery("open_tickets", Map.of("status", "open"), opts);
client.connectStream("ticket_stream", null, event -> System.out.println(event));