Add DEBUG mode

Author: jsendo

package.json

@@ -41,9 +41,11 @@
   "devDependencies": {
     "@eslint/eslintrc": "^3.2.0",
     "@eslint/js": "^9.15.0",
+    "@next/eslint-plugin-next": "^14.2.5",
     "@pipedream/types": "0.1.4",
     "@tsconfig/node14": "^1.0.1",
     "@types/jest": "^27.4.1",
+    "@types/node": "^20.17.6",
     "@typescript-eslint/eslint-plugin": "^8",
     "@typescript-eslint/parser": "^8",
     "eslint": "^8",
@@ -59,7 +61,6 @@
     "husky": "^7.0.4",
     "jest": "^29.7.0",
     "lint-staged": "^12.3.4",
-    "@next/eslint-plugin-next": "^14.2.5",
     "pnpm": "9.14.2",
     "putout": ">=36",
     "renamer": "^4.0.0",
@@ -77,7 +78,6 @@
     "@actions/core": "^1.10.0",
     "@pipedream/platform": "^1.5.1",
     "@sentry/node": "^7.7.0",
-    "@types/node": "^20.17.6",
     "crypto": "^1.0.1",
     "linkup-sdk": "^1.0.3",
     "uuid": "^8.3.2",

packages/sdk/src/shared/index.ts

@@ -847,6 +847,17 @@ export interface AsyncRequestOptions extends RequestOptions {
   body: { async_handle: string; } & Required<RequestOptions["body"]>;
 }
 
+export function DEBUG(...args: any[]) {
+  if (
+    typeof process !== "undefined" &&
+    typeof process.env !== "undefined" &&
+    process.env.DEBUG === "true"
+  ) {
+    console.log("[DEBUG]", ...args);
+  }
+}
+
+
 /**
  * A client for interacting with the Pipedream Connect API on the server-side.
  */
@@ -905,6 +916,8 @@ export abstract class BaseClient {
       ...fetchOpts
     } = opts;
 
+
+
     const url = new URL(`${baseURL}${path}`);
 
     if (params) {
@@ -958,10 +971,13 @@ export abstract class BaseClient {
     ) {
       requestOptions.body = processedBody;
     }
+    DEBUG("makeRequest")
+    DEBUG("url: ", url.toString())
+    DEBUG("requestOptions: ", requestOptions)
 
     const response: Response = await fetch(url.toString(), requestOptions);
 
-    if (!response.ok) {
+/*    if (!response.ok) {
       const errorBody = await response.text();
       throw new Error(
         `HTTP error! status: ${response.status}, body: ${errorBody}`,
@@ -974,7 +990,27 @@ export abstract class BaseClient {
       return (await response.json()) as T;
     }
 
-    return (await response.text()) as unknown as T;
+    return (await response.text()) as unknown as T;*/
+    const rawBody = await response.text();
+    DEBUG("Response status:", response.status);
+    DEBUG("Response body:", rawBody);
+
+    if (!response.ok) {
+      throw new Error(`HTTP error! status: ${response.status}, body: ${rawBody}`);
+    }
+
+    const contentType = response.headers.get("Content-Type");
+    if (contentType && contentType.includes("application/json")) {
+      try {
+        const json = JSON.parse(rawBody);
+        DEBUG("Parsed JSON:", json);
+        return json as T;
+      } catch (err) {
+        DEBUG("Failed to parse JSON, returning raw body as fallback.");
+      }
+    }
+
+    return rawBody as unknown as T;
   }
 
   protected abstract authHeaders(): string | Promise<string>;

packages/sdk/src/shared/shims.d.ts

@@ -0,0 +1,6 @@
+
+declare const process: {
+  env?: {
+    [key: string]: string | undefined;
+  };
+} | undefined;

packages/sdk/tsconfig.browser.json

@@ -14,6 +14,7 @@
     "allowJs": true
   },
   "include": [
+    "src/shared/shims.d.ts",
     "src/browser/**/*"
   ],
   "exclude": [