feat(sdk-package): call apis directly from client sdk (#14699)

Currently, the Pipedream Connect SDK only supports calling API endpoints from the server. This means that all client side calls need to be proxied by a trusted server.

This PR adds support for calling most API endpoints directly from the client.

Author: TheBestMoshe

packages/sdk/CHANGELOG.md

@@ -1,6 +1,14 @@
 <!-- markdownlint-disable MD024 -->
 # Changelog
 
+## [1.0.6] - 2024-11-20
+
+### Changed
+
+- Use client Connect tokens to make api calls directly from the client.
+- Deprecated the `environments` property on `createFrontendClient` since it is now
+  stored in the token
+
 ## [1.0.5] - 2024-11-18
 
 ### Changed

packages/sdk/package-lock.json

@@ -1,17 +1,27 @@
 {
   "name": "@pipedream/sdk",
-  "version": "1.0.5",
+  "version": "1.0.6",
   "description": "Pipedream SDK",
-  "main": "dist/server/index.js",
-  "module": "dist/server/index.js",
-  "types": "dist/server/index.d.ts",
-  "browser": "./dist/browser/index.js",
+  "main": "dist/server/server/index.js",
+  "module": "dist/server/server/index.js",
+  "types": "dist/server/server/index.d.ts",
+  "browser": "./dist/browser/browser/index.js",
   "exports": {
     ".": {
-      "browser": "./dist/browser/index.js",
-      "import": "./dist/server/index.js",
-      "require": "./dist/server/index.js",
-      "default": "./dist/server/index.js"
+      "browser": "./dist/browser/browser/index.js",
+      "import": "./dist/server/server/index.js",
+      "require": "./dist/server/server/index.js",
+      "default": "./dist/server/server/index.js"
+    },
+    "./server": {
+      "import": "./dist/server/server/index.js",
+      "require": "./dist/server/server/index.js",
+      "types": "./dist/server/server/index.d.ts"
+    },
+    "./browser": {
+      "import": "./dist/browser/browser/index.js",
+      "require": "./dist/browser/browser/index.js",
+      "types": "./dist/browser/browser/index.d.ts"
     }
   },
   "engines": {
@@ -25,28 +35,35 @@
     "access": "public"
   },
   "scripts": {
+    "lint": "eslint --fix --ext .ts src",
     "prepublish": "rm -rf dist && npm run build",
     "build": "npm run build:node && npm run build:browser",
     "build:node": "tsc -p tsconfig.node.json",
     "build:browser": "tsc -p tsconfig.browser.json",
     "test": "jest",
-    "watch": "nodemon --watch src --ext ts --exec 'npm run build'"
+    "watch": "nodemon --watch src --ext ts --exec 'npm run build'",
+    "cli": "node dist/server/server/cli.js"
   },
   "files": [
     "dist"
   ],
   "devDependencies": {
     "@types/fetch-mock": "^7.3.8",
     "@types/jest": "^29.5.13",
-    "@types/node": "^20.14.9",
+    "@types/node": "^20.17.6",
+    "@types/rails__actioncable": "^6.1.11",
     "@types/simple-oauth2": "^5.0.7",
+    "@types/ws": "^8.5.13",
     "jest": "^29.7.0",
     "jest-fetch-mock": "^3.0.3",
     "nodemon": "^3.1.7",
     "ts-jest": "^29.2.5",
     "typescript": "^5.5.2"
   },
   "dependencies": {
-    "simple-oauth2": "^5.1.0"
+    "@rails/actioncable": "^8.0.0",
+    "commander": "^12.1.0",
+    "simple-oauth2": "^5.1.0",
+    "ws": "^8.18.0"
   }
 }

packages/sdk/package.json

@@ -0,0 +1,24 @@
+import { AsyncResponseManager } from "../shared/async";
+import type { AsyncResponseManagerOpts } from "../shared/async";
+
+export type BrowserAsyncResponseManagerOpts = {
+  apiHost: string;
+  getConnectToken: () => Promise<string>;
+};
+
+export class BrowserAsyncResponseManager extends AsyncResponseManager {
+  private browserOpts: BrowserAsyncResponseManagerOpts;
+
+  constructor(opts: BrowserAsyncResponseManagerOpts) {
+    super();
+    this.browserOpts = opts;
+  }
+
+  protected override async getOpts(): Promise<AsyncResponseManagerOpts> {
+    const token = await this.browserOpts.getConnectToken();
+    const url = `wss://${this.browserOpts.apiHost}/websocket?ctok=${token}`;
+    return {
+      url,
+    };
+  }
+}