apps/api/src/app/activity/activity.controller.ts - next - githubmirror/novu

apps/api/src/app/activity/activity.controller.ts
141 строка6 KB
Adam Chmara
chore(api,worker,dashboard): remove context feature flag fixes NV-6874 (#9636)
19 дек 2025, 00:37
19 дек 2025, 00:3787fc1e7
import { ClassSerializerInterceptor, Controller, Get, Param, Query, UseInterceptors } from '@nestjs/common';
import { ApiOperation } from '@nestjs/swagger';
import { RequirePermissions, UserSession } from '@novu/application-generic';
import { PermissionsEnum, UserSessionData } from '@novu/shared';
import { RequireAuthentication } from '../auth/framework/auth.decorator';
import { SdkGroupName, SdkMethodName } from '../shared/framework/swagger/sdk.decorators';
import { GetChartsRequestDto } from './dtos/get-charts.request.dto';
import { GetChartsResponseDto } from './dtos/get-charts.response.dto';
import { GetRequestResponseDto } from './dtos/get-request.response.dto';
import { GetRequestsDto } from './dtos/get-requests.dto';
import { GetRequestsResponseDto } from './dtos/get-requests.response.dto';
import { GetWorkflowRunResponseDto } from './dtos/workflow-run-response.dto';
import { GetWorkflowRunsRequestDto } from './dtos/workflow-runs-request.dto';
import { GetWorkflowRunsResponseDto } from './dtos/workflow-runs-response.dto';
import { GetChartsCommand } from './usecases/get-charts/get-charts.command';
import { GetCharts } from './usecases/get-charts/get-charts.usecase';
import { GetRequestCommand } from './usecases/get-request/get-request.command';
import { GetRequest } from './usecases/get-request/get-request.usecase';
import { GetRequestsCommand } from './usecases/get-requests/get-requests.command';
import { GetRequests } from './usecases/get-requests/get-requests.usecase';
import { GetWorkflowRunCommand } from './usecases/get-workflow-run/get-workflow-run.command';
import { GetWorkflowRun } from './usecases/get-workflow-run/get-workflow-run.usecase';
import { GetWorkflowRunsCommand } from './usecases/get-workflow-runs/get-workflow-runs.command';
import { GetWorkflowRuns } from './usecases/get-workflow-runs/get-workflow-runs.usecase';

@Controller('/activity')
@UseInterceptors(ClassSerializerInterceptor)
@RequireAuthentication()
@SdkGroupName('Activity')
export class ActivityController {
  constructor(
    private getRequestsUsecase: GetRequests,
    private getWorkflowRunsUsecase: GetWorkflowRuns,
    private getWorkflowRunUsecase: GetWorkflowRun,
    private getRequestUsecase: GetRequest,
    private getChartsUsecase: GetCharts
  ) {}

  @Get('requests')
  @RequirePermissions(PermissionsEnum.NOTIFICATION_READ)
  @SdkGroupName('Activity.Requests')
  @SdkMethodName('list')
  @ApiOperation({
    summary: 'List activity requests',
    description: 'Retrieve a list of activity requests with optional filtering and pagination.',
  })
  async getLogs(@UserSession() user: UserSessionData, @Query() query: GetRequestsDto): Promise<GetRequestsResponseDto> {
    return this.getRequestsUsecase.execute(
      GetRequestsCommand.create({
        ...query,
        organizationId: user.organizationId,
        environmentId: user.environmentId,
        createdGte: query.createdGte,
      })
    );
  }

  @Get('requests/:requestId')
  @RequirePermissions(PermissionsEnum.NOTIFICATION_READ)
  @SdkGroupName('Activity.Requests')
  @SdkMethodName('retrieve')
  @ApiOperation({
    summary: 'Retrieve activity request',
    description: 'Retrieve detailed traces and information for a specific activity request by ID.',
  })
  async getRequestTraces(@UserSession() user, @Param('requestId') requestId: string): Promise<GetRequestResponseDto> {
    return this.getRequestUsecase.execute(
      GetRequestCommand.create({
        requestId,
        organizationId: user.organizationId,
        environmentId: user.environmentId,
      })
    );
  }

  @Get('workflow-runs')
  @RequirePermissions(PermissionsEnum.NOTIFICATION_READ)
  @SdkGroupName('Activity.WorkflowRuns')
  @SdkMethodName('list')
  @ApiOperation({
    summary: 'List workflow runs',
    description: 'Retrieve a list of workflow runs with optional filtering and pagination.',
  })
  async getWorkflowRuns(
    @UserSession() user: UserSessionData,
    @Query() query: GetWorkflowRunsRequestDto
  ): Promise<GetWorkflowRunsResponseDto> {
    return this.getWorkflowRunsUsecase.execute(
      GetWorkflowRunsCommand.create({
        ...query,
        organizationId: user.organizationId,
        environmentId: user.environmentId,
        userId: user._id,
        contextKeys: query.contextKeys,
      })
    );
  }

  @Get('workflow-runs/:workflowRunId')
  @RequirePermissions(PermissionsEnum.NOTIFICATION_READ)
  @SdkGroupName('Activity.WorkflowRuns')
  @SdkMethodName('retrieve')
  @ApiOperation({
    summary: 'Retrieve workflow run',
    description: 'Retrieve detailed information for a specific workflow run by ID.',
  })
  async getWorkflowRun(
    @UserSession() user: UserSessionData,
    @Param('workflowRunId') workflowRunId: string
  ): Promise<GetWorkflowRunResponseDto> {
    return this.getWorkflowRunUsecase.execute(
      GetWorkflowRunCommand.create({
        workflowRunId,
        organizationId: user.organizationId,
        environmentId: user.environmentId,
        userId: user._id,
      })
    );
  }

  @Get('charts')
  @RequirePermissions(PermissionsEnum.NOTIFICATION_READ)
  @SdkGroupName('Activity.Charts')
  @SdkMethodName('retrieve')
  @ApiOperation({
    summary: 'Retrieve activity charts',
    description: 'Retrieve chart data for activity analytics and metrics visualization.',
  })
  async getCharts(
    @UserSession() user: UserSessionData,
    @Query() query: GetChartsRequestDto
  ): Promise<GetChartsResponseDto> {
    return this.getChartsUsecase.execute(
      GetChartsCommand.create({
        ...query,
        organizationId: user.organizationId,
        environmentId: user.environmentId,
      })
    );
  }
}