Class: Rubu::Flow

Inherits:
Action show all
Includes:
FlowRun
Defined in:
lib/rubu.rb

Overview

Action Flow with name. Action Flow is a collection of build steps.

Direct Known Subclasses

Fork, Walk

Constant Summary collapse

@@flows =

Flow hash.

{}

Instance Attribute Summary collapse

Attributes inherited from Action

#errmsg, #output, #status, #subs

Class Method Summary collapse

Instance Method Summary collapse

Methods included from FlowRun

#parallel_run, #serial_run

Methods inherited from Action

#display, #error, #host, #host_in, #host_out, #pick, #use

Constructor Details

#initialize(name = nil, &blk) ⇒ Flow

Returns a new instance of Flow.



650
651
652
653
654
655
656
657
658
659
 
# File 'lib/rubu.rb', line 650

def initialize( name = nil, &blk )
    super()
    @name = name
    host_in
    instance_eval &blk
    host_out
    if @name
        @@flows[ @name ] = self
    end
end

Instance Attribute Details

#name ⇒ Object (readonly)

Returns the value of attribute name.



648
649
650
 
# File 'lib/rubu.rb', line 648

def name
  @name
end

Class Method Details

.[](name) ⇒ Object

Reference Flow by name.



643
644
645
 
# File 'lib/rubu.rb', line 643

def self.[]( name )
    @@flows[ name ]
end

.form(name = nil, &blk) ⇒ Object

Replacement for new method.



637
638
639
 
# File 'lib/rubu.rb', line 637

def self.form( name = nil, &blk )
    self.new( name, &blk )
end

.load_setup(setup) ⇒ Object 



666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
 
# File 'lib/rubu.rb', line 666

def Flow.load_setup( setup )

    if File.exist? setup

        conf = YAML.load_file( setup )

        conf.each do |k,v|

            scope = nil

            case k
            when :var; scope = Var
            when :order; scope = Order
            when :info; scope = Info
            end

            v.each do |k2,v2|
                scope[ k2 ] = v2
            end
        end
    end
end

.run(flows) ⇒ Object

Run selected flow(s).



717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
 
# File 'lib/rubu.rb', line 717

def Flow.run( flows )

    flows.each do |name|

        begin

            ret = Flow[ name ].run
            if ret.status == :error
                STDERR.puts "Rubu FAILURE..."
                exit false
            end

        rescue

            STDERR.puts "Broken flow: \"#{name}\"..."
            exit false

        end

    end

    State.save

    exit true
end

.setup(spec) ⇒ Object

Apply configuration options if any.



690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
 
# File 'lib/rubu.rb', line 690

def Flow.setup( spec )

    load_setup( "#{ENV['HOME']}/.rubu.yml" )
    load_setup( ENV['RUBU_CONF'] ) if ENV['RUBU_CONF']
    load_setup( ".rubu.yml" )

    State.load

    # Apply options from Como.
    if spec[ :como ]
        como = spec[ :como ]
        if Opt[ como ].given
            Opt[ como ].value.each do |conf|
                name, value = conf.split( '=' )
                value = case value
                        when 'true'; true
                        when 'false'; false
                        else value
                        end
                Var[ name.to_sym ] = value
            end
        end
    end

end

Instance Method Details

#run ⇒ Object

Default run style for Flow.



662
663
664
 
# File 'lib/rubu.rb', line 662

def run
    serial_run
end