fix http request step (#55)

* fix http request step

* fix errors

* better codegen

Author: ctate

lib/codegen-templates/http-request.ts

@@ -3,19 +3,45 @@
  * This is a string template used for code generation - keep as string export
  */
 export default `export async function httpRequestStep(input: {
-  url: string;
-  method: string;
-  headers: Record<string, string>;
-  body: unknown;
+  endpoint: string;
+  httpMethod: string;
+  httpHeaders?: string;
+  httpBody?: string;
 }) {
   "use step";
   
-  const response = await fetch(input.url, {
-    method: input.method,
-    headers: input.headers,
-    body: JSON.stringify(input.body),
+  let headers = {};
+  if (input.httpHeaders) {
+    try {
+      headers = JSON.parse(input.httpHeaders);
+    } catch {
+      // If parsing fails, use empty headers
+    }
+  }
+  
+  let body: string | undefined;
+  if (input.httpMethod !== "GET" && input.httpBody) {
+    try {
+      const parsedBody = JSON.parse(input.httpBody);
+      if (Object.keys(parsedBody).length > 0) {
+        body = JSON.stringify(parsedBody);
+      }
+    } catch {
+      if (input.httpBody.trim() && input.httpBody.trim() !== "{}") {
+        body = input.httpBody;
+      }
+    }
+  }
+  
+  const response = await fetch(input.endpoint, {
+    method: input.httpMethod,
+    headers,
+    body,
   });
   
-  const data = await response.json();
-  return data;
+  const contentType = response.headers.get("content-type");
+  if (contentType?.includes("application/json")) {
+    return await response.json();
+  }
+  return await response.text();
 }`;

lib/steps/http-request.ts

@@ -9,19 +9,60 @@ type HttpRequestResult =
   | { success: true; data: unknown; status: number }
   | { success: false; error: string; status?: number };
 
+function parseHeaders(httpHeaders?: string): Record<string, string> {
+  if (!httpHeaders) {
+    return {};
+  }
+  try {
+    return JSON.parse(httpHeaders);
+  } catch {
+    return {};
+  }
+}
+
+function parseBody(httpMethod: string, httpBody?: string): string | undefined {
+  if (httpMethod === "GET" || !httpBody) {
+    return;
+  }
+  try {
+    const parsedBody = JSON.parse(httpBody);
+    return Object.keys(parsedBody).length > 0
+      ? JSON.stringify(parsedBody)
+      : undefined;
+  } catch {
+    const trimmed = httpBody.trim();
+    return trimmed && trimmed !== "{}" ? httpBody : undefined;
+  }
+}
+
+function parseResponse(response: Response): Promise<unknown> {
+  const contentType = response.headers.get("content-type");
+  if (contentType?.includes("application/json")) {
+    return response.json();
+  }
+  return response.text();
+}
+
 export async function httpRequestStep(input: {
-  url: string;
-  method: string;
-  headers: Record<string, string>;
-  body: unknown;
+  endpoint: string;
+  httpMethod: string;
+  httpHeaders?: string;
+  httpBody?: string;
 }): Promise<HttpRequestResult> {
   "use step";
 
+  if (!input.endpoint) {
+    return {
+      success: false,
+      error: "HTTP request failed: URL is required",
+    };
+  }
+
   try {
-    const response = await fetch(input.url, {
-      method: input.method,
-      headers: input.headers,
-      body: input.body ? JSON.stringify(input.body) : undefined,
+    const response = await fetch(input.endpoint, {
+      method: input.httpMethod,
+      headers: parseHeaders(input.httpHeaders),
+      body: parseBody(input.httpMethod, input.httpBody),
     });
 
     if (!response.ok) {
@@ -33,7 +74,7 @@ export async function httpRequestStep(input: {
       };
     }
 
-    const data = await response.json();
+    const data = await parseResponse(response);
     return { success: true, data, status: response.status };
   } catch (error) {
     return {