/
githubmirror
/
novu
Обзор
Документация
Войти
/
githubmirror
/
novu
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
next
apps/api/src/app/internal/internal.controller.ts
33 строки
1 KB
Himanshu Garg
refactor(api, worker): remove Cloudflare Scheduler integration and related configurations fixes NV-8518 (#12216)
04 авг 2026, 15:17
Не верифицирован
04 авг 2026, 15:17
7d0c0bd
Код
Авторство
О чём код?
import { Body, Controller, HttpCode, HttpStatus, Post, UseGuards } from '@nestjs/common'; import { AuthGuard } from '@nestjs/passport'; import { ApiExcludeController } from '@nestjs/swagger'; import { SubscriberSession } from '../shared/framework/user.decorator'; import { UpdateSubscriberOnlineStateRequestDto, UpdateSubscriberOnlineStateResponseDto, } from './dtos/subscriber-online-state.dto'; import { UpdateSubscriberOnlineStateCommand } from './usecases/update-subscriber-online-state/update-subscriber-online-state.command'; import { UpdateSubscriberOnlineState } from './usecases/update-subscriber-online-state/update-subscriber-online-state.usecase'; @Controller('/internal') @ApiExcludeController() export class InternalController { constructor(private readonly updateSubscriberOnlineStateUsecase: UpdateSubscriberOnlineState) {} @Post('/subscriber-online-state') @UseGuards(AuthGuard('subscriberJwt')) @HttpCode(HttpStatus.OK) async updateSubscriberOnlineState( @Body() body: UpdateSubscriberOnlineStateRequestDto, @SubscriberSession() subscriberSession: SubscriberSession ): Promise<UpdateSubscriberOnlineStateResponseDto> { const command = UpdateSubscriberOnlineStateCommand.create({ subscriberId: subscriberSession.subscriberId, environmentId: subscriberSession._environmentId, isOnline: body.isOnline, timestamp: body.timestamp ?? Date.now(), }); return await this.updateSubscriberOnlineStateUsecase.execute(command); } }