maestro/src/modules/oauth/oauth.controller.ts

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`;
    }
  }
  @Get('hubspot')
  @UseGuards(AuthGuard('hubspot'))
  async oauthHubspot() {
    return true;
  }

  @Get('hubspot/callback')
  @UseGuards(AuthGuard('hubspot'))
  @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}` };
  }
}