Function handleSessionMessage

src/node/orpc/replayBufferedStreamMessageRelay.ts:138–157

(message: WorkspaceChatMessage)

  };

  const handleSessionMessage = (message: WorkspaceChatMessage) => {
    if (isReplaying && isReplayBufferedSessionMessage(message)) {
      if (!isReplayMessage(message)) {
        // Preserve live ordering during replay buffering. Init events need the same isolation as
        // stream events so reconnect replay cannot blank the row or drop lines due to reordering.
        bufferedLiveSessionMessages.push(message);
        return;
      }

      // Track replayed deltas/init events so buffered live events from the same window do not
      // double-apply after `caught-up`.
      if (isReplayBufferedDeltaMessage(message)) {
        noteReplayedDelta(message);
      } else if (isReplayBufferedInitMessage(message)) {
        noteReplayedInit(message);
      }
    }

    push(message);
  };

  const finishReplay = () => {
    // Flush buffered live session messages after replay (`caught-up` already queued by replayHistory).