All files / src/modules/common/event/services custom-kafka.service.ts

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
import { Inject, Injectable } from '@nestjs/common';
import { EVENT_SDK_PRODUCER_TOKEN, IKafka } from 'src/packages/event-sdk';
import { KafkaTopicEnum } from '../shared/event.const';
import { EmitMessageDto } from '../shared/event.dto';
import { IKafkaService } from '../shared/event.interface';
 
@Injectable()
export class CustomKafkaService implements IKafkaService {
  constructor(
    @Inject(EVENT_SDK_PRODUCER_TOKEN) private readonly eventSdkProducer: IKafka.IEventSdkProducer,
  ) {}
 
  emitMessage(payload: EmitMessageDto) {
    return this.eventSdkProducer.emit({
      topic: KafkaTopicEnum.Base,
      key: payload.id,
      data: payload,
    });
  }
}