(
envelope: Envelope.Envelope.Encoded,
message_id: string | null,
deliver_at: number | null
)
| 50 | const repliesTableSql = sql(repliesTable) |
| 51 | |
| 52 | const envelopeToRow = ( |
| 53 | envelope: Envelope.Envelope.Encoded, |
| 54 | message_id: string | null, |
| 55 | deliver_at: number | null |
| 56 | ): MessageRow => { |
| 57 | switch (envelope._tag) { |
| 58 | case "Request": |
| 59 | return { |
| 60 | id: envelope.requestId, |
| 61 | message_id, |
| 62 | shard_id: ShardId.toString(envelope.address.shardId), |
| 63 | entity_type: envelope.address.entityType, |
| 64 | entity_id: envelope.address.entityId, |
| 65 | kind: messageKind.Request, |
| 66 | tag: envelope.tag, |
| 67 | payload: JSON.stringify(envelope.payload), |
| 68 | headers: JSON.stringify(envelope.headers), |
| 69 | trace_id: envelope.traceId ?? null, |
| 70 | span_id: envelope.spanId ?? null, |
| 71 | sampled: envelope.sampled === undefined |
| 72 | ? null |
| 73 | : supportsBooleans |
| 74 | ? envelope.sampled |
| 75 | : envelope.sampled |
| 76 | ? 1 |
| 77 | : 0, |
| 78 | request_id: envelope.requestId, |
| 79 | reply_id: null, |
| 80 | deliver_at |
| 81 | } |
| 82 | case "AckChunk": |
| 83 | return { |
| 84 | id: envelope.id, |
| 85 | message_id, |
| 86 | shard_id: ShardId.toString(envelope.address.shardId), |
| 87 | entity_type: envelope.address.entityType, |
| 88 | entity_id: envelope.address.entityId, |
| 89 | kind: messageKind.AckChunk, |
| 90 | tag: null, |
| 91 | payload: null, |
| 92 | headers: null, |
| 93 | trace_id: null, |
| 94 | span_id: null, |
| 95 | sampled: null, |
| 96 | request_id: envelope.requestId, |
| 97 | reply_id: envelope.replyId, |
| 98 | deliver_at |
| 99 | } |
| 100 | case "Interrupt": |
| 101 | return { |
| 102 | id: envelope.id, |
| 103 | message_id, |
| 104 | shard_id: ShardId.toString(envelope.address.shardId), |
| 105 | entity_type: envelope.address.entityType, |
| 106 | entity_id: envelope.address.entityId, |
| 107 | kind: messageKind.Interrupt, |
| 108 | payload: null, |
| 109 | tag: null, |
no test coverage detected