maestro/src/modules/customers/customers.controller.ts

import { DadosferaLogger } from '@dadosfera/dadosfera-logs';
import {
  Body,
  Controller,
  Get,
  HttpCode,
  HttpStatus,
  Inject,
  Param,
  Put,
  Query,
  UseFilters,
} from '@nestjs/common';
import { ApiOkResponse, ApiProduces, ApiTags } from '@nestjs/swagger';
import { PERMISSIONS_GROUPS } from 'src/authentication/permissions.enum';
import {
  Authenticated,
  RequireAllPermissions,
} from 'src/decorators/authentication.decorator';
import { GrpcToHttpExceptionFilter } from 'src/error/grpc-to-http-exception.filter';
import { CustomersService } from './customers.service';
import { CustomerLinkRequest, CustomerLinksResponse } from './dtos/customers';
import { RequestUser, User } from 'src/decorators/user.decorator';
import type { StringValue } from 'ms';
import { PackTheMetadata } from 'src/utils/ PackTheMetadata';

@ApiTags('Customers')
@Controller('customers')
@UseFilters(GrpcToHttpExceptionFilter)
export class CustomersController {
  logger: DadosferaLogger;

  constructor(
    @Inject(DadosferaLogger)
    dadosferaLogger: DadosferaLogger,
    private customersService: CustomersService,
  ) {
    this.logger = dadosferaLogger.logger;
  }

  @Get(':id/links')
  @Authenticated()
  @ApiOkResponse({ type: CustomerLinksResponse })
  async getCustomerLinks(@Param('id') id: string) {
    this.logger.info('getCustomerLinks', { id });
    const links = await this.customersService.getLinks(id);
    return { links };
  }

  @Put(':id/links')
  @Authenticated()
  @RequireAllPermissions(PERMISSIONS_GROUPS.USERS.permissions.ADMIN)
  @ApiOkResponse()
  @HttpCode(HttpStatus.OK)
  async setCustomerLinks(
    @Body() body: CustomerLinkRequest,
    @Param('id') id: string,
  ) {
    const { links } = body;
    this.logger.info('setCustomerLinks', { id, links });
    await this.customersService.setLinks(id, links);
  }

  @Get('token')
  @Authenticated()
  @RequireAllPermissions(PERMISSIONS_GROUPS.AUTH.permissions.GENERATE_TOKEN)
  @ApiProduces('text/plain')
  async getCustomerToken(
    @Query('exp') exp: StringValue,
    @User() user: RequestUser,
  ): Promise<string> {
    this.logger.info('getCustomerToken', { exp, user });
    const data = {
      customerId: user.customer_id,
      userId: user.user_id,
      customerName: user.customer_name,
    };
    return this.customersService.generateToken(exp, data);
  }

  @Get('monitoring-dashboard')
  @Authenticated()
  @RequireAllPermissions(
    PERMISSIONS_GROUPS.CUSTOMER.permissions.MONITORING_DASHBOARD,
  )
  async getCustomerMonitoringDashboard(
    @User() user: RequestUser,
  ): Promise<{ url: string }> {
    this.logger.info('getCustomerMonitoringDashboard');

    const metadata = PackTheMetadata(user);
    return this.customersService.getMonitoringDashboardUrl(metadata);
  }
}