chore: Upgrade jsforce to 3.6.2 and use jsforce-node

apps/api/v2/package.json

@@ -59,6 +59,7 @@
     "googleapis": "^84.0.0",
     "helmet": "^7.1.0",
     "ioredis": "^5.3.2",
+    "jsforce": "^1.11.0",
     "luxon": "^3.4.4",
     "nest-winston": "^1.9.4",
     "next-auth": "^4.22.1",

help/mint.json

@@ -68,14 +68,11 @@
           ]
         },
         {
-  "group": "Calendars",
-  "icon": "<i class='fa-light fa-calendar' style='color: #cfd2d8;'></i>",
-  "iconType": "custom",
-  "pages": [
-    "calendars/how-to-add-google-calendar",
-    "calendars/how-to-add-apple-calendar"
-  ]
-},
+          "group": "Calendars",
+          "icon": "<i class='fa-light fa-calendar' style='color: #cfd2d8;'></i>",
+          "iconType": "custom",
+          "pages": ["calendars/how-to-add-google-calendar", "calendars/how-to-add-apple-calendar"]
+        },
         {
           "group": "Event Types",
           "icon": "calendar",
@@ -135,11 +132,7 @@
           "group": "Bookings",
           "icon": "calendar-check",
           "iconType": "solid",
-          "pages": [
-            "bookings/no-show",
-            "bookings/paid-bookings",
-            "bookings/prefill-fields"
-          ]
+          "pages": ["bookings/no-show", "bookings/paid-bookings", "bookings/prefill-fields"]
         },
         {
           "group": "Embedding",
@@ -158,10 +151,7 @@
           "group": "Auth and Provisioning",
           "icon": "user-lock",
           "iconType": "solid",
-          "pages": [
-            "auth-and-provision/scim-okta",
-            "auth-and-provision/oidc-with-okta"
-          ]
+          "pages": ["auth-and-provision/scim-okta", "auth-and-provision/oidc-with-okta"]
         },
         {
           "group": "Apps and Integrations",
@@ -176,7 +166,7 @@
             "apps-and-integrations/how-to-build-an-app",
             "apps-and-integrations/syncing-third-party"
           ]
-        },
+        }
       ]
     }
   ],
@@ -185,4 +175,4 @@
     "linkedin": "https://www.linkedin.com/company/cal-com/",
     "discord": "https://discord.com/invite/calcom"
   }
-}
+}

packages/app-store/salesforce/api/add.ts

@@ -1,4 +1,4 @@
-import jsforce from "jsforce";
+import jsforce from "@jsforce/jsforce-node";
 import type { NextApiRequest, NextApiResponse } from "next";
 
 import { WEBAPP_URL_FOR_OAUTH } from "@calcom/lib/constants";
@@ -16,13 +16,17 @@ export default async function handler(req: NextApiRequest, res: NextApiResponse)
   if (!consumer_key) return res.status(400).json({ message: "Salesforce client id missing." });
 
   const salesforceClient = new jsforce.Connection({
-    clientId: consumer_key,
-    redirectUri: `${WEBAPP_URL_FOR_OAUTH}/api/integrations/salesforce/callback`,
+    oauth2: {
+      clientId: consumer_key,
+      redirectUri: `${WEBAPP_URL_FOR_OAUTH}/api/integrations/salesforce/callback`,
+    },
   });
 
+  const state = encodeOAuthState(req);
+
   const url = salesforceClient.oauth2.getAuthorizationUrl({
     scope: "refresh_token full",
-    state: encodeOAuthState(req),
+    ...(state && { state }),
   });
   res.status(200).json({ url });
 }

packages/app-store/salesforce/api/callback.ts

@@ -1,4 +1,4 @@
-import jsforce from "jsforce";
+import jsforce from "@jsforce/jsforce-node";
 import type { NextApiRequest, NextApiResponse } from "next";
 
 import { WEBAPP_URL_FOR_OAUTH } from "@calcom/lib/constants";
@@ -33,9 +33,11 @@ export default async function handler(req: NextApiRequest, res: NextApiResponse)
   if (!consumer_secret) return res.status(400).json({ message: "Salesforce consumer secret missing." });
 
   const conn = new jsforce.Connection({
-    clientId: consumer_key,
-    clientSecret: consumer_secret,
-    redirectUri: `${WEBAPP_URL_FOR_OAUTH}/api/integrations/salesforce/callback`,
+    oauth2: {
+      clientId: consumer_key,
+      clientSecret: consumer_secret,
+      redirectUri: `${WEBAPP_URL_FOR_OAUTH}/api/integrations/salesforce/callback`,
+    },
   });
 
   const salesforceTokenInfo = await conn.oauth2.requestToken(code as string);

packages/app-store/salesforce/lib/CrmService.ts

@@ -1,5 +1,5 @@
-import type { TokenResponse } from "jsforce";
-import jsforce from "jsforce";
+import type { TokenResponse, Connection, Field } from "@jsforce/jsforce-node";
+import jsforce from "@jsforce/jsforce-node";
 import { RRule } from "rrule";
 import { z } from "zod";
 
@@ -64,7 +64,7 @@ const salesforceTokenSchema = z.object({
 
 export default class SalesforceCRMService implements CRM {
   private integrationName = "";
-  private conn!: Promise<jsforce.Connection>;
+  private conn!: Promise<Connection>;
   private log: typeof logger;
   private calWarnings: string[] = [];
   private appOptions: any;
@@ -87,6 +87,10 @@ export default class SalesforceCRMService implements CRM {
   private getClient = async (credential: CredentialPayload) => {
     const { consumer_key, consumer_secret } = await getSalesforceAppKeys();
     const credentialKey = credential.key as unknown as ExtendedTokenResponse;
+
+    if (!credentialKey.refresh_token)
+      throw new Error(`Refresh token is missing for credential ${credential.id}`);
+
     try {
       /* XXX: This code results in 'Bad Request', which indicates something is wrong with our salesforce integration.
               Needs further investigation ASAP */
@@ -121,9 +125,11 @@ export default class SalesforceCRMService implements CRM {
     }
 
     return new jsforce.Connection({
-      clientId: consumer_key,
-      clientSecret: consumer_secret,
-      redirectUri: `${WEBAPP_URL}/api/integrations/salesforce/callback`,
+      oauth2: {
+        clientId: consumer_key,
+        clientSecret: consumer_secret,
+        redirectUri: `${WEBAPP_URL}/api/integrations/salesforce/callback`,
+      },
       instanceUrl: credentialKey.instance_url,
       accessToken: credentialKey.access_token,
       refreshToken: credentialKey.refresh_token,
@@ -768,7 +774,7 @@ export default class SalesforceCRMService implements CRM {
     const conn = await this.conn;
 
     const fieldSet = new Set(fieldsToTest);
-    const foundFields: jsforce.Field[] = [];
+    const foundFields: Field[] = [];
 
     try {
       const salesforceEntity = await conn.describe(sobject);
@@ -953,7 +959,7 @@ export default class SalesforceCRMService implements CRM {
     organizerEmail,
     calEventResponses,
   }: {
-    existingFields: jsforce.Field[];
+    existingFields: Field[];
     personRecord: Record<string, any>;
     onBookingWriteToRecordFields: Record<string, any>;
     startTime: string;
@@ -1113,7 +1119,7 @@ export default class SalesforceCRMService implements CRM {
 
   private async fetchPersonRecord(
     contactId: string,
-    existingFields: jsforce.Field[],
+    existingFields: Field[],
     personRecordType: SalesforceRecordEnum
   ): Promise<Record<string, any> | null> {
     const conn = await this.conn;

packages/app-store/salesforce/package.json

@@ -7,10 +7,9 @@
   "dependencies": {
     "@calcom/lib": "*",
     "@calcom/prisma": "*",
-    "jsforce": "^1.11.0"
+    "@jsforce/jsforce-node": "^3.6.3"
   },
   "devDependencies": {
-    "@calcom/types": "*",
-    "@types/jsforce": "^1.11.0"
+    "@calcom/types": "*"
   }
 }

packages/platform/libraries/vite.config.js

@@ -66,6 +66,7 @@ export default defineConfig({
         "lru-cache",
         "next-auth/jwt",
         "memory-cache",
+        "@jsforce/jsforce-node",
         "jsforce",
         "axios",
         "qs",
@@ -137,6 +138,7 @@ export default defineConfig({
           "lru-cache": "lru-cache",
           "next-auth/jwt": "next-auth/jwt",
           "memory-cache": "memory-cache",
+          "@jsforce-node": "@jsforce/jsforce-node",
           jsforce: "jsforce",
           axios: "axios",
           qs: "qs",