Function serializeResponseMessage

packages/standard-server-peer/src/codec.ts:160–191

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

}

export function serializeResponseMessage<T extends keyof ResponseMessageMap>(
  id: string,
  type: T,
  payload: ResponseMessageMap[T],
): BaseMessageFormat {
  if (type === MessageType.EVENT_ITERATOR) {
    const eventPayload = payload as EventIteratorPayload
    const serializedPayload: SerializedEventIteratorPayload = {
      e: eventPayload.event,
      d: eventPayload.data,
      m: eventPayload.meta,
    }
    return { i: id, t: type, p: serializedPayload }
  }

  if (type === MessageType.ABORT_SIGNAL) {
    return { i: id, t: type, p: undefined }
  }

  const response = payload as StandardResponse

  const serializedPayload: SerializedResponsePayload = {
    s: response.status === 200 ? undefined : response.status,
    h: Object.keys(response.headers).length > 0 ? response.headers : undefined,
    b: response.body,
  }

  return {
    i: id,
    p: serializedPayload,
  }
}

export function deserializeResponseMessage(message: BaseMessageFormat): DecodedResponseMessage {
  const id: string = message.i