Function envelopeFromDoc

packages/infra/src/ClusterCosmos.ts:240–299

(
  doc: MessageDoc,
  lastSentReply: Option.Option<Reply.Encoded>
)

}

const envelopeFromDoc = (
  doc: MessageDoc,
  lastSentReply: Option.Option<Reply.Encoded>
): {
  readonly envelope: Envelope.Encoded
  readonly lastSentReply: Option.Option<Reply.Encoded>
} => {
  switch (doc.kind) {
    case "Request": {
      const envelope: Envelope.PartialRequestEncoded = {
        _tag: "Request",
        requestId: doc.requestId,
        address: {
          shardId: shardIdFromString(doc.shardId),
          entityType: doc.entityType,
          entityId: doc.entityId
        },
        tag: doc.tag ?? "",
        payload: doc.payload,
        headers: doc.headers ?? {},
        ...(doc.traceId !== undefined && { traceId: doc.traceId }),
        ...(doc.spanId !== undefined && { spanId: doc.spanId }),
        ...(doc.sampled !== undefined && { sampled: doc.sampled })
      }
      return {
        envelope,
        lastSentReply
      }
    }
    case "AckChunk":
      return {
        envelope: {
          _tag: "AckChunk",
          id: doc.rowid,
          requestId: doc.requestId,
          replyId: doc.replyId ?? "",
          address: {
            shardId: shardIdFromString(doc.shardId),
            entityType: doc.entityType,
            entityId: doc.entityId
          }
        },
        lastSentReply: Option.none()
      }
    case "Interrupt":
      return {
        envelope: {
          _tag: "Interrupt",
          id: doc.rowid,
          requestId: doc.requestId,
          address: {
            shardId: shardIdFromString(doc.shardId),
            entityType: doc.entityType,
            entityId: doc.entityId
          }
        },
        lastSentReply: Option.none()
      }