Contents

module Knapsack
  module Distributors
    class BaseDistributor
      attr_reader :report, :node_specs

      DEFAULT_CI_NODE_TOTAL = 1
      DEFAULT_CI_NODE_INDEX = 0

      def initialize(args={})
        @report = args[:report] || default_report
        @ci_node_total = args[:ci_node_total] || DEFAULT_CI_NODE_TOTAL
        @ci_node_index = args[:ci_node_index] || DEFAULT_CI_NODE_INDEX
        post_initialize(args)
      end

      def default_report
        Knapsack.report.open
      end

      def ci_node_total
        @ci_node_total.to_i
      end

      def ci_node_index
        @ci_node_index.to_i
      end

      def specs_for_current_node
        specs_for_node(ci_node_index)
      end

      def specs_for_node(node_index)
        assign_spec_files_to_node
        post_specs_for_node(node_index)
      end

      def assign_spec_files_to_node
        default_node_specs
        @node_index = 0
        post_assign_spec_files_to_node
      end

      protected

      def post_initialize(args)
        nil
      end

      def post_specs_for_node(node_index)
        raise NotImplementedError
      end

      def post_assign_spec_files_to_node
        raise NotImplementedError
      end

      def default_node_specs
        raise NotImplementedError
      end

      def update_node_index
        @node_index += 1
        @node_index = 0 if @node_index == ci_node_total
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
knapsack-0.1.1	lib/knapsack/distributors/base_distributor.rb
knapsack-0.1.0	lib/knapsack/distributors/base_distributor.rb