refactor(SDK): refactor artifact upload inside tg_deploy TS SDK

Author: destifo

typegraph/node/sdk/src/tg_deploy.ts

@@ -61,87 +61,15 @@ export async function tgDeploy(
   }
 
   // upload the artifacts
-  const suffix = `${typegraph.name}/artifacts/upload-urls`;
-  const createUploadUrlEndpoint = new URL(suffix, baseUrl);
-
-  const artifacts = refArtifacts.map(({ path, hash, size }) => {
-    return {
-      typegraphName: typegraph.name,
-      relativePath: path,
-      hash: hash,
-      sizeInBytes: size,
-    };
-  });
-
-  const res = await fetch(createUploadUrlEndpoint, {
-    method: "POST",
+  const artifactUploader = new ArtifactUploader(
+    baseUrl,
+    refArtifacts,
+    typegraph.name,
+    auth,
     headers,
-    body: JSON.stringify(artifacts),
-  } as RequestInit);
-
-  if (!res.ok) {
-    const err = await res.text();
-    throw new Error(`Failed to get upload URLs for all artifacts: ${err}`);
-  }
-
-  const uploadUrls: Array<string | null> = await res.json();
-  if (uploadUrls.length !== artifacts.length) {
-    const diff =
-      `array length mismatch: ${uploadUrls.length} !== ${artifacts.length}`;
-    throw new Error(`Failed to get upload URLs for all artifacts: ${diff}`);
-  }
-
-  const uploadHeaders = new Headers({
-    // TODO match to file extension??
-    "Content-Type": "application/octet-stream",
-  });
-
-  if (auth) {
-    uploadHeaders.append("Authorization", auth.asHeaderValue());
-  }
-
-  const results = await Promise.allSettled(uploadUrls.map(async (url, i) => {
-    if (url == null) {
-      console.log(`Skipping upload for artifact: ${artifacts[i].relativePath}`);
-      return;
-    }
-    const meta = artifacts[i];
-
-    const path = join(dirname(params.typegraphPath), meta.relativePath);
-    // TODO: stream
-    const content = await fsp.readFile(path);
-    const res = await fetch(url, {
-      method: "POST",
-      headers: uploadHeaders,
-      body: new Uint8Array(content),
-    } as RequestInit);
-    if (!res.ok) {
-      const err = await res.text();
-      throw new Error(
-        `Failed to upload artifact '${path}' (${res.status}): ${err}`,
-      );
-    }
-    return res.json();
-  }));
-
-  let errors = 0;
-
-  for (let i = 0; i < results.length; i++) {
-    const result = results[i];
-    const meta = artifacts[i];
-    if (result.status === "rejected") {
-      console.error(
-        `Failed to upload artifact '${meta.relativePath}': ${result.reason}`,
-      );
-      errors++;
-    } else {
-      console.log(`Successfully uploaded artifact '${meta.relativePath}'`);
-    }
-  }
-
-  if (errors > 0) {
-    throw new Error(`Failed to upload ${errors} artifacts`);
-  }
+    params.typegraphPath,
+  );
+  await artifactUploader.uploadArtifacts();
 
   // deploy the typegraph
   const response = await execRequest(new URL("/typegate", baseUrl), {