File size: 1,534 Bytes
fc93158 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 | export type SessionTranscriptUpdate = {
sessionFile: string;
sessionKey?: string;
message?: unknown;
messageId?: string;
};
type SessionTranscriptListener = (update: SessionTranscriptUpdate) => void;
const SESSION_TRANSCRIPT_LISTENERS = new Set<SessionTranscriptListener>();
export function onSessionTranscriptUpdate(listener: SessionTranscriptListener): () => void {
SESSION_TRANSCRIPT_LISTENERS.add(listener);
return () => {
SESSION_TRANSCRIPT_LISTENERS.delete(listener);
};
}
export function emitSessionTranscriptUpdate(update: string | SessionTranscriptUpdate): void {
const normalized =
typeof update === "string"
? { sessionFile: update }
: {
sessionFile: update.sessionFile,
sessionKey: update.sessionKey,
message: update.message,
messageId: update.messageId,
};
const trimmed = normalized.sessionFile.trim();
if (!trimmed) {
return;
}
const nextUpdate: SessionTranscriptUpdate = {
sessionFile: trimmed,
...(typeof normalized.sessionKey === "string" && normalized.sessionKey.trim()
? { sessionKey: normalized.sessionKey.trim() }
: {}),
...(normalized.message !== undefined ? { message: normalized.message } : {}),
...(typeof normalized.messageId === "string" && normalized.messageId.trim()
? { messageId: normalized.messageId.trim() }
: {}),
};
for (const listener of SESSION_TRANSCRIPT_LISTENERS) {
try {
listener(nextUpdate);
} catch {
/* ignore */
}
}
}
|