nest/packages/microservices/deserializers/kafka-request.deserializer.ts

import { IncomingEvent, IncomingRequest } from '../interfaces';
import { KafkaRequest } from '../serializers/kafka-request.serializer';
import { IncomingRequestDeserializer } from './incoming-request.deserializer';

/**
 * @publicApi
 */
export class KafkaRequestDeserializer extends IncomingRequestDeserializer {
  mapToSchema(
    data: KafkaRequest,
    options?: Record<string, any>,
  ): IncomingRequest | IncomingEvent {
    if (!options) {
      return {
        pattern: undefined,
        data: undefined,
      };
    }
    return {
      pattern: options.channel,
      data: data?.value ?? data,
    };
  }
}