Contents

require "securerandom"

module CC
  module Analyzer
    class EnginesRunner
      InvalidEngineName = Class.new(StandardError)
      NoEnabledEngines = Class.new(StandardError)

      def initialize(registry, formatter, source_dir, config, container_label = nil)
        @registry = registry
        @formatter = formatter
        @source_dir = source_dir
        @config = config
        @container_label = container_label
      end

      def run
        raise NoEnabledEngines if engines.empty?

        Analyzer.logger.info("running #{engines.size} engines")

        @formatter.started

        engines.each { |engine| run_engine(engine) }

        @formatter.finished
      ensure
        @formatter.close
      end

      private

      def run_engine(engine)
        Analyzer.logger.info("starting engine #{engine.name}")

        Analyzer.statsd.time("engines.time") do
          Analyzer.statsd.time("engines.names.#{engine.name}.time") do
            @formatter.engine_running(engine) do
              engine.run(@formatter)
            end
          end
        end

        Analyzer.logger.info("finished engine #{engine.name}")
      end

      def engines
        @engines ||= enabled_engines.map do |name, config|
          metadata = registry_lookup(name)
          label = @container_label || SecureRandom.uuid
          engine_config = config.merge!(exclude_paths: exclude_paths)

          Engine.new(name, metadata, @source_dir, engine_config, label)
        end
      end

      def enabled_engines
        {}.tap do |ret|
          @config.engines.each do |name, config|
            if config.enabled?
              ret[name] = config
            end
          end
        end
      end

      def registry_lookup(engine_name)
        if (metadata = @registry[engine_name])
          metadata
        else
          raise InvalidEngineName, "unknown engine name: #{engine_name}"
        end
      end

      def exclude_paths
        PathPatterns.new(@config.exclude_paths || []).expanded
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
codeclimate-0.2.2	lib/cc/analyzer/engines_runner.rb
codeclimate-0.2.1	lib/cc/analyzer/engines_runner.rb
codeclimate-0.2	lib/cc/analyzer/engines_runner.rb
codeclimate-0.1.5	lib/cc/analyzer/engines_runner.rb