(message: BaseMessageFormat)
| 191 | } |
| 192 | |
| 193 | export function deserializeResponseMessage(message: BaseMessageFormat): DecodedResponseMessage { |
| 194 | const id: string = message.i |
| 195 | const type: MessageType | undefined = message.t |
| 196 | |
| 197 | if (type === MessageType.EVENT_ITERATOR) { |
| 198 | const payload = message.p as SerializedEventIteratorPayload |
| 199 | |
| 200 | return [id, type, { event: payload.e, data: payload.d, meta: payload.m }] |
| 201 | } |
| 202 | |
| 203 | if (type === MessageType.ABORT_SIGNAL) { |
| 204 | return [id, type, message.p as undefined] |
| 205 | } |
| 206 | |
| 207 | const payload = message.p as SerializedResponsePayload |
| 208 | |
| 209 | return [id, MessageType.RESPONSE, { |
| 210 | status: payload.s ?? 200, |
| 211 | headers: payload.h ?? {}, |
| 212 | body: payload.b, |
| 213 | }] |
| 214 | } |
| 215 | |
| 216 | /** |
| 217 | * Original encode/decode functions now using the new serialize/deserialize functions |
no outgoing calls
no test coverage detected