Contents

# frozen_string_literal: true

class Async::App
  include Component

  class << self
    def instance = @instance = instances(self).first

    def instances(klass) = ObjectSpace.each_object(klass)
  end

  def init!
    raise "only one instance of #{self.class} is allowed" if instances(self.class).count > 1

    @parent = Async::Task.current
    set_traps!
    init_container!
    super
  rescue StandardError => e
    fatal { e }
    stop!
    exit(1)
  end

  def stop!
    @parent&.stop(true)
    super
  end

  def container = @container ||= Dry::Container.new
  def instances(klass) = self.class.instances(klass)
  def components = instances(Class).select { _1.included_modules.include?(Component) }.reject { _1 <= self.class }
  def autoloadable_components = components.select { _1.included_modules.include?(AutoloadComponent) }
  def timer_components = components.select { _1.included_modules.include?(TimerComponent) }

  private

  def container_config = {}
  def async_app_name = :async_app

  def run!
    start_event_logger!
    start_web_server!

    autoload_components!
    super
    bus.publish("health.updated", true)
  end

  def set_traps!
    trap("INT") do
      force_exit! if @stopping
      @stopping = true
      warn { "Interrupted, stopping. Press ^C once more to force exit." }
      stop!
    end

    trap("TERM") { stop! }
  end

  def init_container!
    container.register(:bus, Async::Bus.new)
    container.register(:async_app_name, async_app_name)

    container_config.each { container.register(_1, _2) }
  end

  def force_exit!
    fatal { "Forced exit" }
    exit(1)
  end

  def autoload_components! = autoloadable_components.each { _1.new.start! }
  def start_web_server! = WebServer.new.start!
  def start_event_logger! = EventLogger.new.start!
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
async-tools-0.2.10	lib/async/app.rb