Function encodeRequestMessage

packages/standard-server-peer/src/codec.ts:220–249

(
  id: string,
  type: T,
  payload: RequestMessageMap[T],
)

 */

export async function encodeRequestMessage<T extends keyof RequestMessageMap>(
  id: string,
  type: T,
  payload: RequestMessageMap[T],
): Promise<EncodedMessage> {
  if (type === MessageType.EVENT_ITERATOR || type === MessageType.ABORT_SIGNAL) {
    return encodeRawMessage(serializeRequestMessage(id, type, payload))
  }

  const request = payload as RequestMessageMap[MessageType.REQUEST]

  const { body: processedBody, headers: processedHeaders } = await serializeBodyAndHeaders(
    request.body,
    request.headers,
  )

  const modifiedRequest: RequestMessageMap[MessageType.REQUEST] = {
    ...request,
    body: processedBody instanceof Blob ? undefined : processedBody,
    headers: processedHeaders,
  }

  const baseMessage = serializeRequestMessage(id, MessageType.REQUEST, modifiedRequest)

  if (processedBody instanceof Blob) {
    return encodeRawMessage(baseMessage, processedBody)
  }

  return encodeRawMessage(baseMessage)
}

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