import { IncomingEvent, IncomingRequest } from '../interfaces'; import { KafkaRequest } from '../serializers/kafka-request.serializer'; import { IncomingRequestDeserializer } from './incoming-request.deserializer'; export class KafkaRequestDeserializer extends IncomingRequestDeserializer { mapToSchema( data: KafkaRequest, options?: Record, ): IncomingRequest | IncomingEvent { if (!options) { return { pattern: undefined, data: undefined, }; } return { pattern: options.channel, data: data?.value ?? data, }; } }