fix(cli publish): fix namespace resolution and add Content-Type header

.changeset/fast-numbers-prove.md

@@ -0,0 +1,5 @@
+---
+"@codemod-com/backend": patch
+---
+
+Fix receiving the namespace in the publish route

.changeset/slimy-drinks-roll.md

@@ -0,0 +1,5 @@
+---
+"codemod": patch
+---
+
+Add content type for publish request header

apps/backend/package.json

@@ -4,7 +4,8 @@
   "scripts": {
     "build": "tsc && node esbuild.config.js",
     "start": "node build/index.js",
-    "test": "vitest --run"
+    "test": "vitest --run",
+    "dev": "nodemon --exec tsx watch src/index.ts"
   },
   "author": "Codemod inc.",
   "private": true,

apps/backend/src/publishHandler.ts

@@ -71,20 +71,23 @@ export const publishHandler: RouteHandler<{
     let codemodTarArchiveBuffer: Buffer | null = null;
     let codemodZipArchiveBuffer: Buffer | null = null;
 
-    for await (const multipartFile of request.files({
-      limits: { fileSize: 1024 * 1024 * 100 },
+    let namespace: string | null = null;
+    for await (const part of request.parts({
+      limits: {
+        fileSize: 1024 * 1024 * 100,
+      },
     })) {
-      const buffer = await multipartFile.toBuffer();
-
-      if (multipartFile.fieldname === "codemod.tar.gz") {
-        codemodTarArchiveBuffer = buffer;
-      }
-
-      if (multipartFile.fieldname === "codemod.zip") {
-        codemodZipArchiveBuffer = buffer;
+      if (part.fieldname === "namespace" && "value" in part) {
+        namespace = part.value as string;
+      } else if (part.fieldname === "codemod.tar.gz" && "file" in part) {
+        codemodTarArchiveBuffer = await (part as any).toBuffer();
+      } else if (part.fieldname === "codemod.zip" && "file" in part) {
+        codemodZipArchiveBuffer = await (part as any).toBuffer();
       }
     }
 
+    console.log(namespace, "namespace");
+
     let codemodArchiveBuffer: Buffer;
     if (codemodTarArchiveBuffer !== null) {
       codemodArchiveBuffer = codemodTarArchiveBuffer;
@@ -176,14 +179,6 @@ export const publishHandler: RouteHandler<{
       ? `${name}-${randomBytes(4).toString("hex")}`
       : name;
 
-    let namespace: string | null = null;
-    try {
-      const formData = await request.formData();
-      namespace = formData.get("namespace")?.toString() ?? null;
-    } catch (err) {
-      //
-    }
-
     let isPrivate = false;
 
     if (!namespace) {

apps/backend/src/util.ts

@@ -1,5 +1,8 @@
+import { configDotenv } from "dotenv";
 import { parseEnvironment } from "./schemata/env.js";
 
+configDotenv();
+
 export const buildTimeoutPromise = (ms: number) =>
   new Promise<void>((resolve) => {
     setTimeout(() => {

apps/cli/src/api.ts

@@ -128,7 +128,9 @@ export const publish = async (
       },
   formData: FormData,
 ): Promise<void> => {
-  const headers: RawAxiosRequestHeaders = {};
+  const headers: RawAxiosRequestHeaders = {
+    "Content-Type": "multipart/form-data",
+  };
   if (credentials.accessToken) {
     headers.Authorization = `Bearer ${credentials.accessToken}`;
   } else if (credentials.apiKey) {

apps/cli/test/api.test.ts

@@ -289,7 +289,10 @@ describe("API Client Tests", () => {
         "http://api.example.com/publish",
         mockFormData,
         {
-          headers: { Authorization: `Bearer ${mockAccessToken}` },
+          headers: {
+            "Content-Type": "multipart/form-data",
+            Authorization: `Bearer ${mockAccessToken}`,
+          },
           timeout: 10000,
         },
       );
@@ -304,7 +307,10 @@ describe("API Client Tests", () => {
         "http://api.example.com/publish",
         mockFormData,
         {
-          headers: { "X-API-Key": mockApiKey },
+          headers: {
+            "Content-Type": "multipart/form-data",
+            "X-API-Key": mockApiKey,
+          },
           timeout: 10000,
         },
       );