Function importPacket

packages/core/src/v3/utils/ioSerialization.ts:162–191

(packet: IOPacket, span?: Span)

}

async function importPacket(packet: IOPacket, span?: Span): Promise<IOPacket> {
  if (!packet.data) {
    return packet;
  }

  if (!apiClientManager.client) {
    return packet;
  }

  const presignedResponse = await apiClientManager.client.getPayloadUrl(packet.data);

  const response = await fetch(presignedResponse.presignedUrl);

  if (!response.ok) {
    throw new Error(
      `Failed to import packet ${presignedResponse.presignedUrl}: ${response.statusText}`
    );
  }

  const data = await response.text();

  span?.setAttribute("size", Buffer.byteLength(data, "utf8"));

  return {
    data,
    dataType: response.headers.get("content-type") ?? "application/json",
  };

  return packet;
}

export async function createPacketAttributes(
  packet: IOPacket,