(message: BaseMessageFormat)
| 134 | } |
| 135 | |
| 136 | export function deserializeRequestMessage(message: BaseMessageFormat): DecodedRequestMessage { |
| 137 | const id: string = message.i |
| 138 | const type: MessageType = message.t ?? MessageType.REQUEST |
| 139 | |
| 140 | if (type === MessageType.EVENT_ITERATOR) { |
| 141 | const payload = message.p as SerializedEventIteratorPayload |
| 142 | |
| 143 | return [id, type, { event: payload.e, data: payload.d, meta: payload.m }] |
| 144 | } |
| 145 | |
| 146 | if (type === MessageType.ABORT_SIGNAL) { |
| 147 | return [id, type, message.p as undefined] |
| 148 | } |
| 149 | |
| 150 | const payload = message.p as SerializedRequestPayload |
| 151 | |
| 152 | return [id, MessageType.REQUEST, { |
| 153 | url: payload.u.startsWith('/') ? new URL(`${SHORTABLE_ORIGIN}${payload.u}`) : new URL(payload.u), |
| 154 | headers: payload.h ?? {}, |
| 155 | method: payload.m ?? 'POST', |
| 156 | body: payload.b, |
| 157 | }] |
| 158 | } |
| 159 | |
| 160 | export function serializeResponseMessage<T extends keyof ResponseMessageMap>( |
| 161 | id: string, |
no outgoing calls
no test coverage detected