expect(payload?.ok).toBe(true);

const broadcastPayload = lastBroadcastPayload(context);

expect(broadcastPayload?.state).toBe("final");

expect(getMessage(broadcastPayload)).toBeDefined();

if (!getMessage(broadcastPayload)) {

throw new Error("Expected broadcast message");

}

expect(extractFirstTextBlock(broadcastPayload)).toBe("");

});

expect(payload?.runId).toBe("idem-directive-only");

expect(payload?.state).toBe("final");

expect(getMessage(payload)).toBeDefined();

if (!getMessage(payload)) {

throw new Error("Expected directive-only final message");

}

expect(extractFirstTextBlock(payload)).toBe("");

});

expect(payload?.runId).toBe("idem-telegram-final");

expect(payload?.sessionKey).toBe(sessionKey);

expect(payload?.state).toBe("final");

expect(getMessage(payload)).toBeDefined();

if (!getMessage(payload)) {

throw new Error("Expected Telegram final message");

}

expect(extractFirstTextBlock(payload)).toBe("telegram ok");

const nodeSend = lastNodeSendCall(context);

expect(nodeSend?.[0]).toBe(sessionKey);

await waitForAssertion(() => {

expect((context.broadcast as unknown as ReturnType<typeof vi.fn>).mock.calls.length).toBe(1);

expect(findUserUpdate()?.message).toBeDefined();

if (findUserUpdate()?.message === undefined) {

throw new Error("Expected streamed user transcript update message");

}

});

});