Sha256: b7cd826389c0922cf3ddc6dc0ac7c8a256cde204b99a252d70c5239bad455ac9
Contents?: true
Size: 1.76 KB
Versions: 13
Compression:
Stored size: 1.76 KB
Contents
module Rudy; module Routines; module Handlers;
module Depends
include Rudy::Routines::Handlers::Base
extend self
## NOTE: Dependencies don't use Rudy::Routines.add_handler but we
## define them ehere anyway so raise_early_exceptions passes.
Rudy::Routines.add_handler :before, self
Rudy::Routines.add_handler :after, self
def raise_early_exceptions(type, depends, rset, lbox, argv=nil)
unless depends.kind_of? Array
raise Rudy::Error, "#{type} must be a kind of Array (#{depends.class})"
end
raise Rudy::Routines::EmptyDepends, type if depends.nil? || depends.empty?
depends.flatten.compact.each do |name|
raise Rudy::Routines::NoRoutine, name unless valid_routine?(name)
end
end
# A simple wrapper for executing a routine.
#
# * +routine_name+ should be a Symbol representing a routine
# available to the current machine group.
#
# This method finds the handler for the given routine,
# creates an instance, calls raise_early_exceptions,
# and finally executes the routine.
def execute(routine_name, argv=[])
routine_obj = Rudy::Routines.get_routine routine_name
ld "Executing dependency: #{routine_name} (#{routine_obj}) (argv: #{argv})"
routine = routine_obj.new routine_name, {}, argv
routine.raise_early_exceptions
routine.execute
end
# Calls execute for each routine name in +depends+ (an Array).
# Does nothing if given an empty Array or nil.
def execute_all(depends, argv=[])
return if depends.nil? || depends.empty?
depends = depends.flatten.compact
ld "Found depenencies: #{depends.join(', ')}"
depends.each { |routine| execute(routine, argv) }
end
end
end; end; end
Version data entries
13 entries across 13 versions & 1 rubygems