Function decodeRequestMessage

packages/standard-server-peer/src/codec.ts:251–264

(raw: EncodedMessage)

}

export async function decodeRequestMessage(raw: EncodedMessage): Promise<DecodedRequestMessage> {
  const { json: message, buffer } = await decodeRawMessage(raw)

  const [id, type, payload] = deserializeRequestMessage(message)

  if (type === MessageType.EVENT_ITERATOR || type === MessageType.ABORT_SIGNAL) {
    return [id, type, payload as any]
  }

  const request = payload as RequestMessageMap[MessageType.REQUEST]
  const body = await deserializeBody(request.headers, request.body, buffer)

  return [id, type, { ...request, body }]
}

export async function encodeResponseMessage<T extends keyof ResponseMessageMap>(
  id: string,