Support authentication with Connect tokens

* Fix the `/browser` imports so that they can be used in Node.js (for
testing purposes for example)
* Define `TokenProvider` interface so that we can authenticate via
multiple methods
* Clean up the browser client by using the new SDK types, renaming the
client class, and removing the duplicate logic re: making HTTP
requests
* Implement `StaticTokenProvider` to support access tokens that don't
expire
* Implement `ConnectTokenProvider` to support Connect tokens that can
be refreshed
* Export types directly instead of nested under `Pipedream`
* Fix the indentation in our custom files

Author: jverce

.fernignore

@@ -25,6 +25,10 @@ src/browser/index.ts
 src/index.ts
 src/wrapper
 
+# Ideally, we shouldn't. But until Fern supports the changes that we've made we
+# have to override some parts.
+src/Client.ts
+
 # Custom Proxy files
 src/api/resources/proxy/client/requests/ProxyPutRequest.ts
 src/api/resources/proxy/client/requests/ProxyGetRequest.ts

.prettierrc.yml

@@ -3,3 +3,5 @@ printWidth: 120
 singleAttributePerLine: true
 tabWidth: 4
 trailingComma: all
+semi: true
+singleQuote: false

package.json

@@ -27,7 +27,14 @@
         },
         "./browser": {
             "types": "./dist/esm/browser/index.d.mts",
-            "import": "./dist/esm/browser/index.mjs",
+            "import": {
+                "types": "./dist/esm/browser/index.d.mts",
+                "default": "./dist/esm/browser/index.mjs"
+            },
+            "require": {
+                "types": "./dist/cjs/browser/index.d.ts",
+                "default": "./dist/cjs/browser/index.js"
+            },
             "default": "./dist/esm/browser/index.mjs"
         },
         "./serialization": {

src/Client.ts

@@ -26,6 +26,7 @@ export declare namespace PipedreamClient {
         baseUrl?: core.Supplier<string>;
         clientId?: core.Supplier<string>;
         clientSecret?: core.Supplier<string>;
+        tokenProvider?: core.TokenProvider;
         projectId: string;
         /** Override the x-pd-environment header */
         projectEnvironment?: core.Supplier<Pipedream.ProjectEnvironment | undefined>;
@@ -51,7 +52,7 @@ export declare namespace PipedreamClient {
 
 export class PipedreamClient {
     protected readonly _options: PipedreamClient.Options;
-    protected readonly _oauthTokenProvider: core.OAuthTokenProvider;
+    protected readonly _tokenProvider: core.TokenProvider;
     protected _appCategories: AppCategories | undefined;
     protected _apps: Apps | undefined;
     protected _accounts: Accounts | undefined;
@@ -82,6 +83,10 @@ export class PipedreamClient {
             ),
         };
 
+        this._tokenProvider = this._options.tokenProvider ?? this.newOAuthTokenProvider();
+    }
+
+    private newOAuthTokenProvider(): core.OAuthTokenProvider {
         const clientId = this._options.clientId ?? process.env["PIPEDREAM_CLIENT_ID"];
         if (clientId == null) {
             throw new Error(
@@ -96,7 +101,7 @@ export class PipedreamClient {
             );
         }
 
-        this._oauthTokenProvider = new core.OAuthTokenProvider({
+        return new core.OAuthTokenProvider({
             clientId,
             clientSecret,
             authClient: new OauthTokens({
@@ -109,84 +114,84 @@ export class PipedreamClient {
     public get appCategories(): AppCategories {
         return (this._appCategories ??= new AppCategories({
             ...this._options,
-            token: async () => await this._oauthTokenProvider.getToken(),
+            token: async () => await this._tokenProvider.getToken(),
         }));
     }
 
     public get apps(): Apps {
         return (this._apps ??= new Apps({
             ...this._options,
-            token: async () => await this._oauthTokenProvider.getToken(),
+            token: async () => await this._tokenProvider.getToken(),
         }));
     }
 
     public get accounts(): Accounts {
         return (this._accounts ??= new Accounts({
             ...this._options,
-            token: async () => await this._oauthTokenProvider.getToken(),
+            token: async () => await this._tokenProvider.getToken(),
         }));
     }
 
     public get users(): Users {
         return (this._users ??= new Users({
             ...this._options,
-            token: async () => await this._oauthTokenProvider.getToken(),
+            token: async () => await this._tokenProvider.getToken(),
         }));
     }
 
     public get components(): Components {
         return (this._components ??= new Components({
             ...this._options,
-            token: async () => await this._oauthTokenProvider.getToken(),
+            token: async () => await this._tokenProvider.getToken(),
         }));
     }
 
     public get actions(): Actions {
         return (this._actions ??= new Actions({
             ...this._options,
-            token: async () => await this._oauthTokenProvider.getToken(),
+            token: async () => await this._tokenProvider.getToken(),
         }));
     }
 
     public get triggers(): Triggers {
         return (this._triggers ??= new Triggers({
             ...this._options,
-            token: async () => await this._oauthTokenProvider.getToken(),
+            token: async () => await this._tokenProvider.getToken(),
         }));
     }
 
     public get deployedTriggers(): DeployedTriggers {
         return (this._deployedTriggers ??= new DeployedTriggers({
             ...this._options,
-            token: async () => await this._oauthTokenProvider.getToken(),
+            token: async () => await this._tokenProvider.getToken(),
         }));
     }
 
     public get projects(): Projects {
         return (this._projects ??= new Projects({
             ...this._options,
-            token: async () => await this._oauthTokenProvider.getToken(),
+            token: async () => await this._tokenProvider.getToken(),
         }));
     }
 
     public get proxy(): Proxy {
         return (this._proxy ??= new Proxy({
             ...this._options,
-            token: async () => await this._oauthTokenProvider.getToken(),
+            token: async () => await this._tokenProvider.getToken(),
         }));
     }
 
     public get tokens(): Tokens {
         return (this._tokens ??= new Tokens({
             ...this._options,
-            token: async () => await this._oauthTokenProvider.getToken(),
+            token: async () => await this._tokenProvider.getToken(),
         }));
     }
 
     public get oauthTokens(): OauthTokens {
         return (this._oauthTokens ??= new OauthTokens({
             ...this._options,
-            token: async () => await this._oauthTokenProvider.getToken(),
+            token: async () => await this._tokenProvider.getToken(),
         }));
     }
 }