Function decodeResponseMessage

packages/standard-server-peer/src/codec.ts:296–309

(raw: EncodedMessage)

}

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

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

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

  const response = payload as StandardResponse
  const body = await deserializeBody(response.headers, response.body, buffer)

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

/**
 * Helper to deal with body and headers