(
envelope: Envelope.Encoded,
message_id: string | null,
deliver_at: number | null
)
| 118 | const mayHaveLegacyRow = (primaryKey: string): boolean => !messageIdEnforcesWidth && primaryKey.length > 255 |
| 119 | |
| 120 | const envelopeToRow = ( |
| 121 | envelope: Envelope.Encoded, |
| 122 | message_id: string | null, |
| 123 | deliver_at: number | null |
| 124 | ): MessageRow => { |
| 125 | switch (envelope._tag) { |
| 126 | case "Request": |
| 127 | return { |
| 128 | id: envelope.requestId, |
| 129 | message_id, |
| 130 | shard_id: ShardId.toString(envelope.address.shardId), |
| 131 | entity_type: envelope.address.entityType, |
| 132 | entity_id: envelope.address.entityId, |
| 133 | kind: messageKind.Request, |
| 134 | tag: envelope.tag, |
| 135 | payload: JSON.stringify(envelope.payload), |
| 136 | headers: JSON.stringify(envelope.headers), |
| 137 | trace_id: envelope.traceId ?? null, |
| 138 | span_id: envelope.spanId ?? null, |
| 139 | sampled: envelope.sampled === undefined |
| 140 | ? null |
| 141 | : supportsBooleans |
| 142 | ? envelope.sampled |
| 143 | : envelope.sampled |
| 144 | ? 1 |
| 145 | : 0, |
| 146 | request_id: envelope.requestId, |
| 147 | reply_id: null, |
| 148 | deliver_at |
| 149 | } |
| 150 | case "AckChunk": |
| 151 | return { |
| 152 | id: envelope.id, |
| 153 | message_id, |
| 154 | shard_id: ShardId.toString(envelope.address.shardId), |
| 155 | entity_type: envelope.address.entityType, |
| 156 | entity_id: envelope.address.entityId, |
| 157 | kind: messageKind.AckChunk, |
| 158 | tag: null, |
| 159 | payload: null, |
| 160 | headers: null, |
| 161 | trace_id: null, |
| 162 | span_id: null, |
| 163 | sampled: null, |
| 164 | request_id: envelope.requestId, |
| 165 | reply_id: envelope.replyId, |
| 166 | deliver_at |
| 167 | } |
| 168 | case "Interrupt": |
| 169 | return { |
| 170 | id: envelope.id, |
| 171 | message_id, |
| 172 | shard_id: ShardId.toString(envelope.address.shardId), |
| 173 | entity_type: envelope.address.entityType, |
| 174 | entity_id: envelope.address.entityId, |
| 175 | kind: messageKind.Interrupt, |
| 176 | payload: null, |
| 177 | tag: null, |
no test coverage detected