Function replayBufferedInitKey

src/node/orpc/replayBufferedStreamMessageRelay.ts:65–85

(message: ReplayBufferedInitMessage)

}

function replayBufferedInitKey(message: ReplayBufferedInitMessage): string {
  switch (message.type) {
    case "init-start":
      return JSON.stringify([message.type, message.hookPath, message.timestamp]);
    case "init-output":
      return JSON.stringify([
        message.type,
        message.lineNumber ?? null,
        message.line,
        message.isError === true,
        message.timestamp,
      ]);
    case "init-end":
      return JSON.stringify([
        message.type,
        message.exitCode,
        message.truncatedLines ?? null,
        message.timestamp,
      ]);
  }
}

export function createReplayBufferedStreamMessageRelay(
  push: (message: WorkspaceChatMessage) => void