module NulogyMessageBusConsumer
  module Steps
    class LogMessages
      def initialize(logger)
        @logger = logger
      end

      def call(message:, **_)
        @logger.info(JSON.dump({
          event: "message_received",
          kafka_message_id: message.id,
          message: "Received #{message.id}",
        }))

        result = yield

        @logger.info(JSON.dump({
          event: "message_processed",
          kafka_message_id: message.id,
          message: "Processed #{message.id}",
          result: result,
        }))

        result
      end
    end
  end
end