Class: Convection::Control::Cloud

Inherits:
Object
  • Object
show all
Defined in:
lib/convection/control/cloud.rb

Overview

Control tour Clouds

Instance Method Summary collapse

Instance Method Details

#configure(cloudfile) ⇒ Object 



10
11
12
 
# File 'lib/convection/control/cloud.rb', line 10

def configure(cloudfile)
  @cloudfile = Model::Cloudfile.new(cloudfile)
end

#converge(to_stack, options = {}, &block) ⇒ Object 



52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
 
# File 'lib/convection/control/cloud.rb', line 52

def converge(to_stack, options = {}, &block)
  if to_stack && !stacks.include?(to_stack)
    block.call(Model::Event.new(:error, "Undefined Stack #{ to_stack }", :error)) if block
    return
  end

  filter_deck(options, &block).each_value do |stack|
    block.call(Model::Event.new(:converge, "Stack #{ stack.name }", :info)) if block
    stack.apply(&block)

    if stack.error?
      block.call(Model::Event.new(:error, "Error converging stack #{ stack.name }", :error), stack.errors) if block
      break
    end

    ## Stop on converge error
    break unless stack.success?

    ## Stop here
    break if !to_stack.nil? && stack.name == to_stack
    sleep rand @cloudfile.splay || 2
  end
end

#diff(to_stack, options = {}, &block) ⇒ Object 



76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
 
# File 'lib/convection/control/cloud.rb', line 76

def diff(to_stack, options = {}, &block)
  if to_stack && !stacks.include?(to_stack)
    block.call(Model::Event.new(:error, "Undefined Stack #{ to_stack }", :error)) if block
    return
  end

  filter_deck(options, &block).each_value do |stack|
    block.call(Model::Event.new(:compare, "Compare local state of stack #{ stack.name } (#{ stack.cloud_name }) with remote template", :info))

    difference = stack.diff
    if difference.empty?
      difference << Model::Event.new(:unchanged, "Stack #{ stack.cloud_name } has no changes", :info)
    end

    difference.each { |diff| block.call(diff) }

    break if !to_stack.nil? && stack.name == to_stack
    sleep rand @cloudfile.splay || 2
  end
end

#filter_deck(options = {}, &block) ⇒ Object 



23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
 
# File 'lib/convection/control/cloud.rb', line 23

def filter_deck(options = {}, &block)
  # throw an error if the user specifies both a stack group and list of stacks
  if options[:stack_group] && options[:stacks]
    block.call(Model::Event.new(:error, 'Cannot specify --stack-group and --stack-list at the same time', :error)) if block
    return {}
  end

  # throw an error if the user specifies a nonexistent stack groups
  if options[:stack_group] && !stack_groups.key?(options[:stack_group])
    block.call(Model::Event.new(:error, "Unknown stack group: #{options[:stack_group]}", :error)) if block
    return {}
  end

  # throw an error if the user specifies nonexistent stacks
  if Array(options[:stacks]).any? { |name| !@cloudfile.stacks.key?(name) }
    bad_stack_names = options[:stacks].reject { |name| @cloudfile.stacks.key?(name) }
    block.call(Model::Event.new(:error, "Undefined Stack(s) #{bad_stack_names.join(', ')}", :error)) if block
    return {}
  end

  filter = Array(stack_groups[options[:stack_group]] || options[:stacks])

  # if no filter is specified, return the entire deck
  return stacks if filter.empty?
  filter.reduce({}) do |result, stack_name|
    result.merge(stack_name => @cloudfile.stacks[stack_name])
  end
end

#stack_groups ⇒ Object 



19
20
21
 
# File 'lib/convection/control/cloud.rb', line 19

def stack_groups
  @cloudfile.stack_groups
end

#stacks ⇒ Object

See Also:



15
16
17
 
# File 'lib/convection/control/cloud.rb', line 15

def stacks
  @cloudfile.stacks
end