Function decodeRawMessage

packages/standard-server-peer/src/codec.ts:396–417

(raw: EncodedMessage)

}

async function decodeRawMessage(raw: EncodedMessage): Promise<{ json: any, buffer?: Uint8Array }> {
  if (typeof raw === 'string') {
    return { json: JSON.parse(raw) }
  }

  const buffer = raw instanceof Uint8Array ? raw : new Uint8Array(raw)

  const delimiterIndex = buffer.indexOf(JSON_AND_BINARY_DELIMITER)

  if (delimiterIndex === -1) {
    const jsonPart = new TextDecoder().decode(buffer)
    return { json: JSON.parse(jsonPart) }
  }

  const jsonPart = new TextDecoder().decode(buffer.subarray(0, delimiterIndex))
  const bufferPart = buffer.subarray(delimiterIndex + 1)

  return {
    json: JSON.parse(jsonPart),
    buffer: bufferPart,
  }
}