-
Notifications
You must be signed in to change notification settings - Fork 196
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
15 changed files
with
560 additions
and
27 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,10 +1,10 @@ | ||
| version: 2 | ||
| authtoken: | ||
| authtoken: NGROK_TOKEN | ||
| log_level: debug | ||
| log: stdout | ||
|
|
||
| tunnels: | ||
| api-tunnel: | ||
| proto: http | ||
| addr: 3000 | ||
| domain: | ||
| domain: NGROK_DOMAIN |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
31 changes: 31 additions & 0 deletions
31
packages/api/src/@core/connections/management/management.connection.module.ts
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,31 @@ | ||
| import { Module } from '@nestjs/common'; | ||
| import { PrismaService } from '@@core/prisma/prisma.service'; | ||
| import { LoggerService } from '@@core/logger/logger.service'; | ||
| import { WebhookService } from '@@core/webhook/webhook.service'; | ||
| import { WebhookModule } from '@@core/webhook/webhook.module'; | ||
| import { EnvironmentService } from '@@core/environment/environment.service'; | ||
| import { EncryptionService } from '@@core/encryption/encryption.service'; | ||
| import { ConnectionsStrategiesService } from '@@core/connections-strategies/connections-strategies.service'; | ||
| import { ManagementConnectionsService } from './services/management.connection.service'; | ||
| import { ServiceRegistry } from './services/registry.service'; | ||
| import { ConnectionUtils } from '../@utils'; | ||
| import { NotionConnectionService } from './services/notion/notion.service'; | ||
| import { SlackConnectionService } from './services/slack/slack.service'; | ||
| @Module({ | ||
| imports: [WebhookModule], | ||
| providers: [ | ||
| ManagementConnectionsService, | ||
| LoggerService, | ||
| WebhookService, | ||
| EnvironmentService, | ||
| EncryptionService, | ||
| ServiceRegistry, | ||
| ConnectionsStrategiesService, | ||
| ConnectionUtils, | ||
| //PROVIDERS SERVICES | ||
| NotionConnectionService, | ||
| SlackConnectionService, | ||
| ], | ||
| exports: [ManagementConnectionsService], | ||
| }) | ||
| export class ManagementConnectionsModule {} |
114 changes: 114 additions & 0 deletions
114
packages/api/src/@core/connections/management/services/management.connection.service.ts
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,114 @@ | ||
| import { Injectable } from '@nestjs/common'; | ||
| import { ConnectionsError, throwTypedError } from '@@core/utils/errors'; | ||
| import { LoggerService } from '@@core/logger/logger.service'; | ||
| import { WebhookService } from '@@core/webhook/webhook.service'; | ||
| import { connections as Connection } from '@prisma/client'; | ||
| import { PrismaService } from '@@core/prisma/prisma.service'; | ||
| import { v4 as uuidv4 } from 'uuid'; | ||
| import { ServiceRegistry } from './registry.service'; | ||
| import { CallbackParams, RefreshParams } from '@@core/connections/@utils/types'; | ||
|
|
||
| @Injectable() | ||
| export class ManagementConnectionsService { | ||
| constructor( | ||
| private serviceRegistry: ServiceRegistry, | ||
| private webhook: WebhookService, | ||
| private logger: LoggerService, | ||
| private prisma: PrismaService, | ||
| ) { | ||
| this.logger.setContext(ManagementConnectionsService.name); | ||
| } | ||
| //STEP 1:[FRONTEND STEP] | ||
| //create a frontend SDK snippet in which an authorization embedded link is set up so when users click | ||
| // on it to grant access => they grant US the access and then when confirmed | ||
| /*const authUrl = | ||
| 'https://app.hubspot.com/oauth/authorize' + | ||
| `?client_id=${encodeURIComponent(CLIENT_ID)}` + | ||
| `&scope=${encodeURIComponent(SCOPES)}` + | ||
| `&redirect_uri=${encodeURIComponent(REDIRECT_URI)}`;*/ //oauth/callback | ||
|
|
||
| // oauth server calls this redirect callback | ||
| // WE WOULD HAVE CREATED A DEV ACCOUNT IN THE 5 CRMs (Panora dev account) | ||
| // we catch the tmp token and swap it against oauth2 server for access/refresh tokens | ||
| // to perform actions on his behalf | ||
| // this call pass 1. integrationID 2. CustomerId 3. Panora Api Key | ||
| async handleManagementCallBack( | ||
| providerName: string, | ||
| callbackOpts: CallbackParams, | ||
| type_strategy: 'oauth' | 'apikey' | 'basic', | ||
| ) { | ||
| try { | ||
| const serviceName = providerName.toLowerCase(); | ||
|
|
||
| const service = this.serviceRegistry.getService(serviceName); | ||
|
|
||
| if (!service) { | ||
| throw new ReferenceError(`Unknown provider, found ${providerName}`); | ||
| } | ||
| const data: Connection = await service.handleCallback(callbackOpts); | ||
| const event = await this.prisma.events.create({ | ||
| data: { | ||
| id_event: uuidv4(), | ||
| status: 'success', | ||
| type: 'connection.created', | ||
| method: 'GET', | ||
| url: `/${type_strategy}/callback`, | ||
| provider: providerName.toLowerCase(), | ||
| direction: '0', | ||
| timestamp: new Date(), | ||
| id_linked_user: callbackOpts.linkedUserId, | ||
| }, | ||
| }); | ||
| //directly send the webhook | ||
| await this.webhook.handlePriorityWebhook( | ||
| data, | ||
| 'connection.created', | ||
| callbackOpts.projectId, | ||
| event.id_event, | ||
| ); | ||
| } catch (error) { | ||
| throwTypedError( | ||
| new ConnectionsError({ | ||
| name: 'HANDLE_OAUTH_CALLBACK_CRM', | ||
| message: | ||
| 'ManagementConnectionsService.handleManagementOAuthCallBack() call failed', | ||
| cause: error, | ||
| }), | ||
| this.logger, | ||
| ); | ||
| } | ||
| } | ||
|
|
||
| async handleManagementTokensRefresh( | ||
| connectionId: string, | ||
| providerName: string, | ||
| refresh_token: string, | ||
| id_project: string, | ||
| account_url?: string, | ||
| ) { | ||
| try { | ||
| const serviceName = providerName.toLowerCase(); | ||
| const service = this.serviceRegistry.getService(serviceName); | ||
| if (!service) { | ||
| throw new ReferenceError(`Unknown provider, found ${providerName}`); | ||
| } | ||
| const refreshOpts: RefreshParams = { | ||
| connectionId: connectionId, | ||
| refreshToken: refresh_token, | ||
| account_url: account_url, | ||
| projectId: id_project, | ||
| }; | ||
| const data = await service.handleTokenRefresh(refreshOpts); | ||
| } catch (error) { | ||
| throwTypedError( | ||
| new ConnectionsError({ | ||
| name: 'HANDLE_OAUTH_REFRESH_MARKETINGAUTOMATION', | ||
| message: | ||
| 'ManagementConnectionsService.handleManagementTokensRefresh() call failed', | ||
| cause: error, | ||
| }), | ||
| this.logger, | ||
| ); | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.