add projectId

Author: jsendo

packages/sdk/examples/next-app/app/server.ts

@@ -5,6 +5,7 @@ import { createClient } from "../../../src";
 const {
   PIPEDREAM_PROJECT_SECRET_KEY,
   NEXT_PUBLIC_PIPEDREAM_APP_SLUG,
+  PIPEDREAM_PROJECT_ID,
 } = process.env;
 
 if (!PIPEDREAM_PROJECT_SECRET_KEY) throw new Error("PIPEDREAM_PROJECT_SECRET_KEY not set in environment");
@@ -13,6 +14,7 @@ if (!NEXT_PUBLIC_PIPEDREAM_APP_SLUG) throw new Error("NEXT_PUBLIC_PIPEDREAM_APP_
 const pd = createClient({
   secretKey: PIPEDREAM_PROJECT_SECRET_KEY,
   apiHost: process.env.PIPEDREAM_API_HOST,
+  projectId: PIPEDREAM_PROJECT_ID,
 });
 
 export async function serverConnectTokenCreate(clientUserId: string) {

packages/sdk/src/index.ts

@@ -2,6 +2,7 @@ type CreateServerClientOpts = {
   environment?: string;
   secretKey: string;
   apiHost?: string;
+  projectId?: string;
 };
 
 type ConnectTokenCreateOpts = {
@@ -22,16 +23,18 @@ export function createClient(opts: CreateServerClientOpts) {
 class ServerClient {
   environment?: string;
   secretKey: string;
+  projectId: string;
   baseURL: string;
 
   constructor(opts: CreateServerClientOpts) {
     this.environment = opts.environment;
     this.secretKey = opts.secretKey;
+    this.projectId = opts.projectId;
     this.baseURL = `https://${opts.apiHost || "pipedream.com"}`;
   }
 
   private _authorizonHeader(): string {
-    return "Basic " + Buffer.from(this.secretKey + ":").toString("base64");
+    return "Basic " + Buffer.from(`${this.projectId}:${this.secretKey}`).toString("base64");
   }
 
   // XXX move to REST API endpoint
@@ -43,17 +46,20 @@ class ServerClient {
       },
       body: JSON.stringify({
         query: `mutation sdkConnectTokenCreate(
+          $projectId: String!
           $secretKey: String!
           $clientUserId: String!
         ) {
           connectTokenCreate(
+            projectId: $projectId
             secretKey: $secretKey
             clientUserId: $clientUserId
           ) {
             token
           }
         }`,
         variables: {
+          projectId: this.projectId,
           secretKey: this.secretKey,
           clientUserId: opts.clientUserId,
         },