alexy4744 / packages Goto Github PK

import { Controller, Get } from '@nestjs/common'
import { AppService } from './app.service'
import { EventPattern, Payload, Ctx, MessagePattern } from '@nestjs/microservices'
import { NatsContext, NatsClient } from '@alexy4744/nestjs-nats-jetstream-transporter'
import { Observable } from 'rxjs'
import { tap } from 'rxjs/operators'
import { StringCodec } from 'nats'

@Controller()
export class AppController {
  private readonly client = new NatsClient({ codec: StringCodec() })

  constructor(private readonly appService: AppService) {}

  @Get()
  getHello(): Observable<string> {
    console.log('getHello')
    const value = this.client.send<string>({ cmd: 'sayHi' }, 'Leo').pipe(
      tap((obj) => {
        console.log('TAPPED', obj)
      }),
    )
    return value
  }

  @EventPattern('hello.>')
  handleHello(@Payload() data: string, @Ctx() context: NatsContext): void {
    console.log(data)
    console.log(context)
  }

  @MessagePattern({ cmd: 'sayHi' })
  sayHi(@Payload() data: string): string {
    console.log('sayHi ', data)
    return `Hi ${data}`
  }
}