Class PipedriveCrmService

packages/app-store/pipedrive-crm/lib/CrmService.ts:46–371

};

class PipedriveCrmService implements CRM {
  private credential: CredentialPayload;
  private log: typeof logger;
  private auth: OAuthManager;
  private apiDomain: string;

  constructor(credential: CredentialPayload) {
    this.credential = credential;
    this.log = logger.getSubLogger({ prefix: [`[[lib] ${appConfig.slug}`] });

    const tokenResponse = getTokenObjectFromCredential(credential);
    // Pipedrive stores api_domain in the token object
    const key = credential.key as { api_domain?: string };
    this.apiDomain = key.api_domain || "";

    this.auth = new OAuthManager({
      credentialSyncVariables: {
        APP_CREDENTIAL_SHARING_ENABLED: APP_CREDENTIAL_SHARING_ENABLED,
        CREDENTIAL_SYNC_ENDPOINT: CREDENTIAL_SYNC_ENDPOINT,
        CREDENTIAL_SYNC_SECRET: CREDENTIAL_SYNC_SECRET,
        CREDENTIAL_SYNC_SECRET_HEADER_NAME: CREDENTIAL_SYNC_SECRET_HEADER_NAME,
      },
      resourceOwner: {
        type: credential.teamId ? "team" : "user",
        id: credential.teamId ?? credential.userId,
      },
      appSlug: appConfig.slug,
      currentTokenObject: tokenResponse,
      fetchNewTokenObject: async ({ refreshToken }: { refreshToken: string | null }) => {
        if (!refreshToken) {
          return null;
        }
        const { client_id, client_secret } = await getPipedriveAppKeys();
        const authHeader = `Basic ${Buffer.from(`${client_id}:${client_secret}`).toString("base64")}`;
        return fetch("https://oauth.pipedrive.com/oauth/token", {
          method: "POST",
          headers: {
            Authorization: authHeader,
            "Content-Type": "application/x-www-form-urlencoded",
          },
          body: new URLSearchParams({
            grant_type: "refresh_token",
            refresh_token: refreshToken,
          }),
        });
      },
      isTokenObjectUnusable: async function (response) {
        const myLog = logger.getSubLogger({ prefix: ["pipedrive-crm:isTokenObjectUnusable"] });
        myLog.debug(safeStringify({ status: response.status, ok: response.ok }));
        if (!response.ok) {
          let responseBody;
          try {
            responseBody = await response.clone().json();
          } catch {
            return null;
          }
          myLog.debug(safeStringify({ responseBody }));
          // Pipedrive returns "invalid_grant" when refresh token is invalid