Function replyToDoc

packages/infra/src/ClusterCosmos.ts:301–324

(reply: Reply.Encoded)

}

const replyToDoc = (reply: Reply.Encoded): ReplyDoc =>
  reply._tag === "WithExit"
    ? {
      id: cosmosId(reply.id),
      _partitionKey: replyPartition(reply.requestId),
      type: "reply",
      rowid: reply.id,
      kind: "WithExit",
      requestId: reply.requestId,
      payload: reply.exit,
      sequence: null,
      acked: false
    }
    : {
      id: cosmosId(reply.id),
      _partitionKey: replyPartition(reply.requestId),
      type: "reply",
      rowid: reply.id,
      kind: "Chunk",
      requestId: reply.requestId,
      payload: reply.values,
      sequence: reply.sequence,
      acked: false
    }

const replyFromDoc = (doc: ReplyDoc): Reply.Encoded =>
  doc.kind === "WithExit"