class Application

# File lib/rks/application.rb, line 13
def avro_registry
  @avro ||= AvroTurf::Messaging.new(
    schemas_path: "./app/schemas",
    registry_url: Application.config.avro_registry_url
  )
end

# File lib/rks/application.rb, line 9
def logger
  @logger ||= RKS::Logger.init
end

# File lib/rks/application.rb, line 20
def run
  Application.logger.info message: "Application started"
  
  RKS::Event::Handler.router.routes.keys.each do |event_name|
    topic = [config.env,event_name].join("-")
    Kafka.consumer.subscribe(topic)
  end
  # This will loop indefinitely, yielding each message in turn.
  Kafka.consumer.each_message do |message|
    RKS::Event::Processor.process(correlation_id: message.key, event: sanitized_event_name(message.topic), payload: message.value)
  end
end

# File lib/rks/application.rb, line 33
def sanitized_event_name(topic)
  topic.gsub("#{config.env}-", "")
end