MCPcopy
hub / github.com/triggerdotdev/trigger.dev / exportPacket

Function exportPacket

packages/core/src/v3/utils/ioSerialization.ts:107–133  ·  view source on GitHub ↗
(packet: IOPacket, pathPrefix: string)

Source from the content-addressed store, hash-verified

105}
106
107async function exportPacket(packet: IOPacket, pathPrefix: string): Promise<IOPacket> {
108 // Offload the output
109 const filename = `${pathPrefix}.${getPacketExtension(packet.dataType)}`;
110
111 const presignedResponse = await apiClientManager.client!.createUploadPayloadUrl(filename);
112
113 const uploadResponse = await fetch(presignedResponse.presignedUrl, {
114 method: "PUT",
115 headers: {
116 "Content-Type": packet.dataType,
117 },
118 body: packet.data,
119 });
120
121 if (!uploadResponse.ok) {
122 throw new Error(
123 `Failed to upload output to ${presignedResponse.presignedUrl}: ${uploadResponse.statusText}`
124 );
125 }
126
127 return {
128 data: filename,
129 dataType: "application/store",
130 };
131
132 return packet;
133}
134
135export async function conditionallyImportPacket(
136 packet: IOPacket,

Callers 1

Calls 3

getPacketExtensionFunction · 0.85
fetchFunction · 0.50

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…