Traces and tool calls

import uuid
from maximem_synap import MaximemSynapSDK

sdk = MaximemSynapSDK()  # reads SYNAP_API_KEY
await sdk.initialize()
await sdk.instance.listen()  # once per process

# The ids your turn events carry. On a B2C instance, leave customer_id out.
ids = {
    "conversation_id": str(uuid.uuid4()),
    "user_id": "user_789",
    "customer_id": "cust_456",
}

import { randomUUID } from 'node:crypto';
import { SynapClient } from '@maximem/synap-js-sdk';

const sdk = new SynapClient(); // reads SYNAP_API_KEY
await sdk.initialize();
await sdk.instance.listen(); // once per process

// The ids your turn events carry. On a B2C instance, leave customer_id out.
const ids = {
  conversation_id: randomUUID(),
  user_id: 'user_789',
  customer_id: 'cust_456',
};

await sdk.instance.record_thinking(
    content="The user asked about a refund. Check the order status before quoting the policy.",
    step_index=1,
    thought_type="plan",
    **ids,
)

await sdk.instance.record_thinking({
  content: 'The user asked about a refund. Check the order status before quoting the policy.',
  step_index: 1,
  thought_type: 'plan',
  ...ids,
});

await sdk.instance.record_tool_call(
    "lookup_order",
    {"order_id": "A-1042"},
    tool_call_id="call_1",
    **ids,
)

await sdk.instance.record_tool_call({
  tool_name: 'lookup_order',
  tool_args: { order_id: 'A-1042' },
  tool_call_id: 'call_1',
  ...ids,
});

await sdk.instance.record_tool_result(
    {"status": "shipped", "eta": "2026-10-02"},
    tool_name="lookup_order",
    tool_call_id="call_1",
    **ids,
)

await sdk.instance.record_tool_result({
  result: { status: 'shipped', eta: '2026-10-02' },
  tool_name: 'lookup_order',
  tool_call_id: 'call_1',
  ...ids,
});

async def lookup_order(order_id: str) -> dict:
    return {"order_id": order_id, "status": "shipped", "eta": "2026-10-02"}

async def call_tool(name: str, args: dict, run):
    call_id = str(uuid.uuid4())
    await sdk.instance.record_tool_call(name, args, tool_call_id=call_id, **ids)
    result = await run(**args)
    await sdk.instance.record_tool_result(result, tool_name=name, tool_call_id=call_id, **ids)
    return result

await sdk.instance.send_message(
    content="Where is order A-1042?", role="user", event_type="user_message", **ids,
)
await sdk.instance.record_thinking(
    content="Look up the order before answering.", step_index=1, thought_type="plan", **ids,
)
order = await call_tool("lookup_order", {"order_id": "A-1042"}, lookup_order)
reply = f"Order A-1042 has shipped and arrives on {order['eta']}."
await sdk.instance.send_message(
    content=reply, role="assistant", event_type="assistant_message", **ids,
)

async function lookupOrder(args: { order_id: string }) {
  return { order_id: args.order_id, status: 'shipped', eta: '2026-10-02' };
}

async function callTool<A extends Record<string, unknown>, R>(
  name: string,
  args: A,
  run: (args: A) => Promise<R>,
): Promise<R> {
  const callId = randomUUID();
  await sdk.instance.record_tool_call({ tool_name: name, tool_args: args, tool_call_id: callId, ...ids });
  const result = await run(args);
  await sdk.instance.record_tool_result({ result, tool_name: name, tool_call_id: callId, ...ids });
  return result;
}

await sdk.instance.send_message({
  content: 'Where is order A-1042?', role: 'user', event_type: 'user_message', ...ids,
});
await sdk.instance.record_thinking({
  content: 'Look up the order before answering.', step_index: 1, thought_type: 'plan', ...ids,
});
const order = await callTool('lookup_order', { order_id: 'A-1042' }, lookupOrder);
const reply = `Order A-1042 has shipped and arrives on ${order.eta}.`;
await sdk.instance.send_message({
  content: reply, role: 'assistant', event_type: 'assistant_message', ...ids,
});

sdk.archive_tool_result(
    ids["conversation_id"],
    {"status": "shipped", "eta": "2026-10-02"},
    tool_name="lookup_order",
)

sdk.archive_tool_result(
  ids.conversation_id,
  { status: 'shipped', eta: '2026-10-02' },
  { tool_name: 'lookup_order' },
);