fix: use raw fetch for v2/images upload to decouple from schema types

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: sigmachirality

src/lib/images/upload.ts

@@ -10,9 +10,40 @@ import chalk from "chalk";
 import cliProgress from "cli-progress";
 import cliSpinners from "cli-spinners";
 import ora, { type Ora } from "ora";
-import { apiClient } from "../../apiClient.ts";
+import { getAuthToken, loadConfig } from "../../helpers/config.ts";
 import { logAndQuit } from "../../helpers/errors.ts";
 
+// V2 API types (hardcoded to avoid schema.ts coupling)
+
+type V2CreateImageRequest = {
+  name: string;
+};
+
+type V2CreateImageResponse = {
+  object: "image";
+  id: string;
+  upload_status: string;
+};
+
+type V2UploadPartRequest = {
+  part_id: number;
+};
+
+type V2UploadPartResponse = {
+  url: string;
+  expires_at: string;
+};
+
+type V2CompleteUploadRequest = {
+  sha256: string;
+};
+
+type V2CompleteUploadResponse = {
+  object: "image";
+  upload_status: string;
+  id: string;
+};
+
 async function readChunk(
   filePath: string,
   start: number,
@@ -75,23 +106,30 @@ const upload = new Command("upload")
     let progressBar: cliProgress.SingleBar | undefined;
 
     try {
-      const client = await apiClient();
+      const config = await loadConfig();
+      const token = await getAuthToken();
+      const apiHeaders = {
+        Authorization: `Bearer ${token}`,
+        "Content-Type": "application/json",
+      };
 
       preparingSpinner = ora(`Preparing upload for ${name}...`).start();
 
       // Create image via v2 API
-      const startResponse = await client.POST("/v2/images", {
-        body: { name },
+      const startResponse = await fetch(`${config.api_url}/v2/images`, {
+        method: "POST",
+        headers: apiHeaders,
+        body: JSON.stringify({ name } satisfies V2CreateImageRequest),
       });
 
-      if (!startResponse.response.ok || !startResponse.data) {
-        const errorText = await startResponse.response.text().catch(() => "");
+      if (!startResponse.ok) {
         throw new Error(
-          `Failed to start upload: ${startResponse.response.status} ${startResponse.response.statusText}${errorText ? ` - ${errorText}` : ""}`,
+          `Failed to start upload: ${startResponse.status} ${startResponse.statusText}`,
         );
       }
 
-      const imageId = startResponse.data.id;
+      const startData = (await startResponse.json()) as V2CreateImageResponse;
+      const imageId = startData.id;
 
       preparingSpinner.succeed(
         `Started upload for image ${chalk.cyan(name)} (${chalk.blackBright(
@@ -231,16 +269,19 @@ const upload = new Command("upload")
             }
 
             // Get presigned URL via v2 API
-            const partResponse = await client.POST("/v2/images/{id}/parts", {
-              params: { path: { id: imageId } },
-              body: { part_id: part },
-            });
+            const partResponse = await fetch(
+              `${config.api_url}/v2/images/${imageId}/parts`,
+              {
+                method: "POST",
+                headers: apiHeaders,
+                body: JSON.stringify({
+                  part_id: part,
+                } satisfies V2UploadPartRequest),
+              },
+            );
 
-            if (!partResponse.response.ok || !partResponse.data) {
-              const status = partResponse.response.status;
-              const errorText = await partResponse.response
-                .text()
-                .catch(() => "");
+            if (!partResponse.ok) {
+              const status = partResponse.status;
 
               if (
                 status >= 400 &&
@@ -250,18 +291,20 @@ const upload = new Command("upload")
               ) {
                 bail(
                   new Error(
-                    `Failed to get upload URL for part ${part}: ${status} ${partResponse.response.statusText} - ${errorText}`,
+                    `Failed to get upload URL for part ${part}: ${status} ${partResponse.statusText}`,
                   ),
                 );
                 return;
               }
 
               throw new Error(
-                `Failed to get upload URL for part ${part}: ${status} ${partResponse.response.statusText} - ${errorText}`,
+                `Failed to get upload URL for part ${part}: ${status} ${partResponse.statusText}`,
               );
             }
 
-            const url = partResponse.data.url;
+            const partData =
+              (await partResponse.json()) as V2UploadPartResponse;
+            const url = partData.url;
 
             // Read chunk from disk with progress tracking
             const payload = await readChunk(
@@ -353,21 +396,30 @@ const upload = new Command("upload")
       const sha256Hash = hash.digest("hex");
 
       // Complete upload via v2 API
-      const completeResponse = await client.POST("/v2/images/{id}/complete", {
-        params: { path: { id: imageId } },
-        body: { sha256: sha256Hash },
-      });
+      const completeResponse = await fetch(
+        `${config.api_url}/v2/images/${imageId}/complete`,
+        {
+          method: "POST",
+          headers: apiHeaders,
+          body: JSON.stringify({
+            sha256: sha256Hash,
+          } satisfies V2CompleteUploadRequest),
+        },
+      );
 
-      if (!completeResponse.response.ok || !completeResponse.data) {
+      if (!completeResponse.ok) {
         throw new Error(
-          `Failed to complete upload: ${completeResponse.response.status} ${completeResponse.response.statusText}${completeResponse.error ? ` - ${JSON.stringify(completeResponse.error)}` : ""}`,
+          `Failed to complete upload: ${completeResponse.status} ${completeResponse.statusText}`,
         );
       }
 
+      const completeData =
+        (await completeResponse.json()) as V2CompleteUploadResponse;
+
       finalizingSpinner.succeed("Image uploaded and verified");
 
       console.log(chalk.gray("\nNext steps:"));
-      console.log(`  sf images get ${chalk.cyan(completeResponse.data.id)}`);
+      console.log(`  sf images get ${chalk.cyan(completeData.id)}`);
     } catch (err) {
       if (spinnerTimer) {
         clearInterval(spinnerTimer);