let splitReasoningOnNextStream = false;

let skipNextAnswerMessageStartRotation = false;

let pendingCompactionReplayBoundary = false;

let discardAnswerPreviewOnNextRotation = false;

let draftLaneEventQueue = Promise.resolve();

const reasoningStepState = createTelegramReasoningStepState();

const enqueueDraftLaneEvent = (task: () => Promise<void>): Promise<void> => {

const materializedId = await answerLane.stream?.materialize?.();

const previewMessageId = materializedId ?? answerLane.stream?.messageId();

if (

!discardAnswerPreviewOnNextRotation &&

typeof previewMessageId === "number" &&

activePreviewLifecycleByLane.answer === "transient"

) {

answerLane.stream?.forceNewMessage();

didForceNewMessage = true;

}

discardAnswerPreviewOnNextRotation = false;

resetDraftLaneState(answerLane);

answerLaneHasAssistantContent = false;

if (didForceNewMessage) {

if (isDispatchSuperseded()) {

return;

}

const clearPendingCompactionReplayBoundaryOnVisibleBoundary = (

didDeliver: boolean,

) => {

const markVisibleNonPreviewBoundary = (didDeliver: boolean) => {

if (didDeliver && info.kind !== "final") {

pendingCompactionReplayBoundary = false;

if (answerLane.hasStreamedMessage) {

discardAnswerPreviewOnNextRotation = true;

}

}

};

if (payload.isError === true) {

});

if (info.kind === "final") {

emitPreviewFinalizedHook(result);

} else if (segment.lane === "answer" && result.kind === "sent") {

markVisibleNonPreviewBoundary(true);

}

if (segment.lane === "reasoning") {

if (result.kind !== "skipped") {

if (reply.hasMedia) {

const payloadWithoutSuppressedReasoning =

typeof payload.text === "string" ? { ...payload, text: "" } : payload;

clearPendingCompactionReplayBoundaryOnVisibleBoundary(

markVisibleNonPreviewBoundary(

await sendPayload(payloadWithoutSuppressedReasoning),

);

}

}

return;

}

clearPendingCompactionReplayBoundaryOnVisibleBoundary(

await sendPayload(payload),

);

markVisibleNonPreviewBoundary(await sendPayload(payload));

if (info.kind === "final") {

await flushBufferedFinalAnswer();

pendingCompactionReplayBoundary = false;