module Delayed
  class InvalidCallback < RuntimeError; end

  class Lifecycle
    EVENTS = {
      execute: [nil],
      enqueue: [:job],
      perform: %i(worker job),
      error: %i(worker job),
      failure: %i(worker job),
      thread: %i(worker job),
      invoke_job: [:job],
    }.freeze

    def initialize
      @callbacks = EVENTS.keys.each_with_object({}) do |e, hash|
        hash[e] = Callback.new
      end
    end

    def before(event, &block)
      add(:before, event, &block)
    end

    def after(event, &block)
      add(:after, event, &block)
    end

    def around(event, &block)
      add(:around, event, &block)
    end

    def run_callbacks(event, *args, &block)
      missing_callback(event) unless @callbacks.key?(event)

      unless EVENTS[event].size == args.size
        raise ArgumentError, "Callback #{event} expects #{EVENTS[event].size} parameter(s): #{EVENTS[event].join(', ')}"
      end

      @callbacks[event].execute(*args, &block)
    end

    private

    def add(type, event, &block)
      missing_callback(event) unless @callbacks.key?(event)
      @callbacks[event].add(type, &block)
    end

    def missing_callback(event)
      raise InvalidCallback, "Unknown callback event: #{event}"
    end
  end

  class Callback
    def initialize
      @before = []
      @after = []

      # Identity proc. Avoids special cases when there is no existing around chain.
      @around = lambda { |*args, &block| block.call(*args) }
    end

    def execute(*args, &block)
      @before.each { |c| c.call(*args) }
      result = @around.call(*args, &block)
      @after.each { |c| c.call(*args) }
      result
    end

    def add(type, &callback)
      case type
        when :before
          @before << callback
        when :after
          @after << callback
        when :around
          chain = @around # use a local variable so that the current chain is closed over in the following lambda
          @around = lambda { |*a, &block| chain.call(*a) { |*b| callback.call(*b, &block) } }
        else
          raise InvalidCallback, "Invalid callback type: #{type}"
      end
    end
  end
end