Events

import { SYNAPSE_REALTIME_EVENTS } from "@eka-care/medassist-core";

function onChunk(evt) {
  appendToCurrentMessage(evt.data.text);
}

// Register
sdk.on(SYNAPSE_REALTIME_EVENTS.MESSAGE_CHUNK, onChunk);

// Remove (pass the same function reference)
sdk.off(SYNAPSE_REALTIME_EVENTS.MESSAGE_CHUNK, onChunk);

type SynapseRealTimeEventData = {
  data: {
    text?: string;     // message / chunk text
    tips?: string[];   // suggested follow-ups
    name?: string;     // tool or entity name
  } & Partial<ToolCallData>; // tool fields on TOOL_CALL events
  messageId?: string;
  timestamp?: number;
};

let buffer = "";

sdk.on(SYNAPSE_REALTIME_EVENTS.MESSAGE_CHUNK, (evt) => {
  buffer += evt.data.text ?? "";
  renderStreaming(buffer);
});

sdk.on(SYNAPSE_REALTIME_EVENTS.END_OF_STREAM, (evt) => {
  commitMessage(buffer, evt.messageId);
  buffer = "";
});

sdk.on(SYNAPSE_REALTIME_EVENTS.PROGRESS_MESSAGE, (evt) => {
  showTypingIndicator(evt.data.text);
});