All files / src/message-bus message-bus.controller.ts

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
6x
6x
6x
 
 
 
6x
6x
 
 
6x
 
 
 
 
 
6x
 
 
 
 
 
import { Body, Controller, Get, Post } from '@nestjs/common';
import { MessageBusService } from './message-bus.service';
import { SubmitMessageDto } from './dto/submit-message.dto';
import { WebSocketEvent } from '../events/websocket.events';
 
@Controller('message-bus')
export class MessageBusController {
  constructor(private readonly messageBusService: MessageBusService) {}
 
  @Post('submit')
  submit(@Body() submitMessageDto: SubmitMessageDto): { status: string } {
    this.messageBusService.submit(submitMessageDto.message);
    return { status: 'ok' };
  }
 
  @Get('poll')
  poll(): { message: WebSocketEvent | null } {
    const message = this.messageBusService.poll();
    return { message };
  }
}