get credentials from AWS secrets manager

src/modules/inputs/dtos/input.model.ts

@@ -170,6 +170,8 @@ export class TestConnectionRes {
   database_tables: string[];
 }
 export class CreateInputReq {
+  @ApiPropertyOptional()
+  id: string;
   @ApiProperty()
   plugin: string;
   @ApiProperty()

src/modules/inputs/inputs.controller.ts

@@ -46,8 +46,7 @@ export class InputsController {
   async testConnection(@Body() data: TestConnectionReq) {
     console.log(`/test-connection`, 'ON TEST CONNECTION ROUTE');
 
-    const inputService = new InputsService(this.inputsClientService);
-    const response = await inputService.testConnection(data);
+    const response = await this.inputService.testConnection(data);
 
     return response;
   }
@@ -60,8 +59,7 @@ export class InputsController {
       'ON TEST CONNECTION GET COLUMNS ROUTE',
     );
 
-    const inputService = new InputsService(this.inputsClientService);
-    const response = await inputService.getColumns(data);
+    const response = await this.inputService.getColumns(data);
 
     return response;
   }
@@ -71,8 +69,18 @@ export class InputsController {
   async create(@Body() createInputDto: CreateInputReq) {
     console.log(`/input`, 'ON CREATE ROUTE');
 
-    const inputService = new InputsService(this.inputsClientService);
-    const response = await inputService.create(createInputDto);
+    const response = await this.inputService.create(createInputDto);
+
+    return response;
+  }
+
+  @Post(':id')
+  @ApiOkResponse({ type: Input })
+  async reCreate(@Param('id') id: string, @Body() input: CreateInputReq) {
+    if (!input.id) input.id = id;
+    console.log(`POST /${input.id}`, 'ON RECREATE ROUTE');
+
+    const response = await this.inputService.reCreate(input);
 
     return response;
   }
@@ -81,9 +89,7 @@ export class InputsController {
   async findAll(@Body() body) {
     console.log(`/input`, 'ON FIND ALL ROUTE');
 
-    const inputService = new InputsService(this.inputsClientService);
-
-    const response = await inputService.findAll(body);
+    const response = await this.inputService.findAll(body);
 
     return response;
   }
@@ -92,9 +98,8 @@ export class InputsController {
   async findOne(@Body() body, @Param() params) {
     const { id } = params;
     console.log(`/input/${id}`, 'ON FIND ONE ROUTE');
-    const inputService = new InputsService(this.inputsClientService);
 
-    const response = await inputService.findOne({ id, ...body });
+    const response = await this.inputService.findOne({ id, ...body });
 
     return response;
   }
@@ -106,9 +111,8 @@ export class InputsController {
     delete updateInputDto.info;
 
     console.log(`/input/${id}`, 'ON UPDATE ROUTE');
-    const inputService = new InputsService(this.inputsClientService);
 
-    const response = await inputService.update(id, updateInputDto, info);
+    const response = await this.inputService.update(id, updateInputDto, info);
 
     return response;
   }
@@ -119,9 +123,7 @@ export class InputsController {
 
     console.log(`/input/${id}`, 'ON DELETE ROUTE');
 
-    const inputService = new InputsService(this.inputsClientService);
-
-    const response = await inputService.remove({ id, ...data });
+    const response = await this.inputService.remove({ id, ...data });
 
     return response;
   }

src/modules/inputs/inputs.service.ts

@@ -75,6 +75,13 @@ export class InputsService {
     const adjustedInput = this.adjustInputPayload(response.input);
     return { ...response, input: adjustedInput };
   }
+  async reCreate(data) {
+    const { info, cron } = data;
+    if (cron) this.validateCron({ info, cron });
+    const response = await this.inputClient.createGeneric(data);
+    const adjustedInput = this.adjustInputPayload(response.input);
+    return { ...response, input: adjustedInput };
+  }
   async getAvailableEntities(data): Promise<{ entities: string[] }> {
     return await this.inputClient.getAvailableEntities(data);
   }

src/modules/oauth/oauth.controller.ts

@@ -1,20 +1,54 @@
-import { Controller, Get, Req, UseGuards } from '@nestjs/common';
+import {
+  BadRequestException,
+  Controller,
+  Get,
+  Query,
+  Redirect,
+  Req,
+  UseGuards,
+} from '@nestjs/common';
 import { ApiTags } from '@nestjs/swagger';
 import { AuthGuard } from '@nestjs/passport';
+import { InputsClientService } from 'src/clients/inputs/client.service';
+import { InputsService } from '../inputs/inputs.service';
 
 @ApiTags('oauth')
 @Controller('oauth')
 export class OauthController {
+  inputService: InputsService;
+  frontendRedirectUri = '';
+  constructor(private inputsClientService: InputsClientService) {
+    this.inputService = new InputsService(this.inputsClientService);
+    switch (process.env.ENV) {
+      case 'dev':
+      case 'stg':
+        this.frontendRedirectUri = `https://app.${process.env.ENV}.dadosfera.ai/auth-callback`;
+        break;
+      case 'prd':
+        this.frontendRedirectUri = `https://app.dadosfera.ai/auth-callback`;
+        break;
+      default:
+        this.frontendRedirectUri = `http://localhost:4200/coletix/auth-callback`;
+    }
+  }
   @UseGuards(AuthGuard('hubspot'))
   @Get('hubspot')
   async oauthHubspot(@Req() req) {
-    console.log(req);
     return true;
   }
 
   @UseGuards(AuthGuard('hubspot'))
   @Get('hubspot/callback')
-  async oauthHubspotCallback() {
-    console.log('hubspot/callback');
+  @Redirect()
+  async oauthHubspotCallback(@Req() req, @Query('state') customer_id) {
+    const { authInfo } = req;
+    if (!authInfo) throw new BadRequestException('Oauth tokens not found');
+    const { accessToken, refreshToken } = authInfo;
+    const response = await this.inputService.create({
+      info: { customer_id, customer: 'customer', user_id: 'empty' },
+      plugin: 'hubspot',
+      credentials: { access_token: accessToken, refresh_token: refreshToken },
+    });
+    return { url: `${this.frontendRedirectUri}?input_id=${response.input.id}` };
   }
 }

src/modules/oauth/passport-strategies/hubspot.ts

@@ -1,16 +1,20 @@
 import { Strategy } from 'passport-hubspot-oauth2';
 import { PassportStrategy } from '@nestjs/passport';
-import { Injectable } from '@nestjs/common';
+import { Inject, Injectable } from '@nestjs/common';
+import { OauthSecrets } from 'src/utils/OauthSecrets';
 
 @Injectable()
 export class HubspotStrategy extends PassportStrategy(Strategy) {
-  constructor() {
+  constructor(
+    @Inject('OAUTH_SECRETS')
+    private readonly oauthSecrets: OauthSecrets,
+  ) {
     super(
       {
-        clientID: 'c51bc9c9-e81c-4263-887e-7cc68ab8e185',
-        clientSecret: '99a8bb9d-b622-4ea7-a46c-77b74f98ce80',
-        callbackURL: 'http://localhost:3333/oauth/hubspot/callback',
-        redirectUri: 'http://localhost:3333/oauth/hubspot/callback',
+        clientID: oauthSecrets.hubspot.client_id,
+        clientSecret: oauthSecrets.hubspot.client_secret,
+        callbackURL: oauthSecrets.hubspot.redirect_uri,
+        redirectUri: oauthSecrets.hubspot.redirect_uri,
         scope:
           'automation business-intelligence oauth forms integration-sync sales-email-read crm.lists.read crm.objects.contacts.read crm.schemas.contacts.read crm.objects.companies.read crm.objects.deals.read crm.schemas.companies.read crm.schemas.deals.read crm.objects.owners.read crm.objects.quotes.read crm.schemas.quotes.read crm.objects.line_items.read crm.schemas.line_items.read',
         passReqToCallback: true,
@@ -22,7 +26,8 @@ export class HubspotStrategy extends PassportStrategy(Strategy) {
   }
 
   authenticate(req, options) {
-    options.state = 'customer_id';
+    const { customer_id } = req.query;
+    options.state = customer_id;
     super.authenticate(req, options);
   }
 }