Function encodeResponseMessage

packages/standard-server-peer/src/codec.ts:266–294

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

}

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

  const response = payload as StandardResponse
  const { body: processedBody, headers: processedHeaders } = await serializeBodyAndHeaders(
    response.body,
    response.headers,
  )

  const modifiedResponse: StandardResponse = {
    ...response,
    body: processedBody instanceof Blob ? undefined : processedBody,
    headers: processedHeaders,
  }

  const baseMessage = serializeResponseMessage(id, MessageType.RESPONSE, modifiedResponse)

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

  return encodeRawMessage(baseMessage)
}

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