Class SalesforceCRMService

packages/app-store/salesforce/lib/CrmService.ts:122–2064

});

class SalesforceCRMService implements CRM {
  private integrationName = "";
  private conn!: Promise<Connection>;
  private log: typeof logger;
  private calWarnings: string[] = [];
  private appOptions: z.infer<typeof appDataSchema>;
  private doNotCreateEvent = false;
  private fallbackToContact = false;
  private accessToken: string;
  private instanceUrl: string;
  private hasAttemptedRefresh = false;
  private credentialId: number;
  private describeCache = new Map<string, Set<string>>();

  constructor(credential: CredentialPayload, appOptions: z.infer<typeof appDataSchema>, testMode = false) {
    this.integrationName = "salesforce_other_calendar";
    this.credentialId = credential.id;
    if (!testMode) {
      this.conn = this.getClient(credential).then((c) => c);
    }
    this.log = logger.getSubLogger({ prefix: [`[[lib] ${this.integrationName}`] });
    this.appOptions = appOptions;
    const credentialKey = credential.key as unknown as ExtendedTokenResponse;
    this.accessToken = credentialKey.access_token;
    this.instanceUrl = credentialKey.instance_url;
  }

  public getAppOptions() {
    return this.appOptions;
  }

  /**
   * Refreshes the Salesforce access token and optionally introspects to get/update token_lifetime.
   * @param forceIntrospection - If true, always introspect to recalibrate token_lifetime (e.g., after unexpected expiry)
   * @param existingTokenLifetime - The current token_lifetime to reuse if not forcing introspection
   */
  private refreshAccessToken = async ({
    refreshToken,
    forceIntrospection,
    existingTokenLifetime,
  }: {
    refreshToken: string;
    forceIntrospection: boolean;
    existingTokenLifetime?: number;
  }) => {
    const { consumer_key, consumer_secret } = await getSalesforceAppKeys();

    const response = await fetch("https://login.salesforce.com/services/oauth2/token", {
      method: "POST",
      headers: {
        "Content-Type": "application/x-www-form-urlencoded",
      },
      body: new URLSearchParams({
        grant_type: "refresh_token",
        client_id: consumer_key,
        client_secret: consumer_secret,
        refresh_token: refreshToken,
      }),