Class: Bcome::Node::Inventory::Defined

Inherits:
Base
  • Object
show all
Defined in:
lib/objects/node/inventory/defined.rb

Constant Summary collapse

MACHINES_CACHE_PATH = 
'machines-cache.yml'.freeze

Constants inherited from Base

Base::DEFAULT_IDENTIFIER

Constants included from LocalMetaDataFactory

LocalMetaDataFactory::META_DATA_FILE_PATH_PREFIX

Instance Attribute Summary collapse

Attributes inherited from Base

#params

Class Method Summary collapse

Instance Method Summary collapse

Methods inherited from Base

#cloud_matches, #direct_invoke_server, #inventory?, #list_key, #machine_by_identifier, #machines, #matches_for, #meta_matches, #override_server_identifier?, #resources, #ssh, #tags

Methods inherited from Base

#bootstrap?, #close_ssh_connections, #collection?, const_missing, #data_print_from_hash, #execute_local, #execute_script, #has_parent?, #has_proxy?, #inventory?, #invoke, #is_top_level_node?, #keyed_namespace, #list_attributes, #list_key, #namespace, #no_nodes?, #nodes_loaded?, #open_ssh_connections, #prompt_breadcrumb, #proxy, #put, #recurse_resource_for_identifier, #requires_description?, #requires_type?, #resource_for_identifier, #resources, #rsync, #scp, #server?, #validate_attributes, #validate_identifier

Methods included from RegistryManagement

#registry, #user_command_wrapper

Methods included from LocalMetaDataFactory

#do_create_metadata, #meta, #metadata, #metadata_for_namespace, #raw_metadata

Methods included from WorkspaceMenu

#item_spacing, #menu, #menu_item_spacing_length, #mode, #tab_spacing

Methods included from Attributes

#description, #filters, #identifier, #network_data, #network_driver, #recurse_hash_data_for_instance_var, #ssh_data, #ssh_driver, #type

Methods included from WorkspaceCommands

#back, #cd, #clear!, #disable, #disable!, #enable, #enable!, #interactive, #is_node_level_method?, #list_in_tree, #ls, #lsa, #method_in_registry?, #method_is_available_on_node?, #method_missing, #new_line, #parents, #ping, #pretty_description, #print_tree_view_for_resource, #resource_identifiers, #run, #tree, #tree_descriptions, #visual_hierarchy, #workon

Methods included from Context

#irb_workspace=, #is_current_context?, #previous_irb_workspace=

Constructor Details

#initialize(*params) ⇒ Defined

Returns a new instance of Defined.



11
12
13
14
15
 
# File 'lib/objects/node/inventory/defined.rb', line 11

def initialize(*params)
  @load_machines_from_cache = false
  @cache_handler = ::Bcome::Node::CacheHandler.new(self)
  super
end

Dynamic Method Handling

This class handles dynamic methods through the method_missing method in the class Bcome::WorkspaceCommands

Instance Attribute Details

#dynamic_nodes_loaded ⇒ Object (readonly)

Returns the value of attribute dynamic_nodes_loaded.



9
10
11
 
# File 'lib/objects/node/inventory/defined.rb', line 9

def dynamic_nodes_loaded
  @dynamic_nodes_loaded
end

Class Method Details

.to_s ⇒ Object 



5
6
7
 
# File 'lib/objects/node/inventory/defined.rb', line 5

def self.to_s
  'inventory'
end

Instance Method Details

#cache_nodes_in_memory ⇒ Object 



86
87
88
 
# File 'lib/objects/node/inventory/defined.rb', line 86

def cache_nodes_in_memory
  @cache_handler.do_cache_nodes!
end

#do_reload ⇒ Object 



90
91
92
93
 
# File 'lib/objects/node/inventory/defined.rb', line 90

def do_reload
  resources.unset!
  load_dynamic_nodes
end

#enabled_menu_items ⇒ Object 



17
18
19
 
# File 'lib/objects/node/inventory/defined.rb', line 17

def enabled_menu_items
  super + i[save reload]
end

#fetch_server_list ⇒ Object 



107
108
109
110
 
# File 'lib/objects/node/inventory/defined.rb', line 107

def fetch_server_list
  return [] unless network_driver
  network_driver.fetch_server_list(filters)
end

#load_dynamic_nodes ⇒ Object 



100
101
102
103
104
105
 
# File 'lib/objects/node/inventory/defined.rb', line 100

def load_dynamic_nodes
  raw_servers = fetch_server_list
  raw_servers.each do |raw_server|
    resources << ::Bcome::Node::Server::Dynamic.new_from_fog_instance(raw_server, self)
  end
end

#load_machines_config ⇒ Object 



77
78
79
80
81
82
83
84
 
# File 'lib/objects/node/inventory/defined.rb', line 77

def load_machines_config
  config = YAML.load_file(machines_cache_path).deep_symbolize_keys
  return config
rescue ArgumentError, Psych::SyntaxError
  raise Bcome::Exception::InvalidMachinesCacheConfig, 'Invalid yaml in config'
rescue Errno::ENOENT
  return {}
end

#load_nodes ⇒ Object 



95
96
97
98
 
# File 'lib/objects/node/inventory/defined.rb', line 95

def load_nodes
  set_static_servers
  load_dynamic_nodes unless @load_machines_from_cache
end

#machines_cache_path ⇒ Object 



48
49
50
 
# File 'lib/objects/node/inventory/defined.rb', line 48

def machines_cache_path
  "#{::Bcome::Node::Factory::CONFIG_PATH}/#{MACHINES_CACHE_PATH}"
end

#mark_as_cached! ⇒ Object 



52
53
54
55
56
 
# File 'lib/objects/node/inventory/defined.rb', line 52

def mark_as_cached!
  data = ::Bcome::Node::Factory.instance.load_estate_config
  data[namespace.to_sym][:load_machines_from_cache] = true
  ::Bcome::Node::Factory.instance.rewrite_estate_config(data)
end

#menu_items ⇒ Object 



21
22
23
24
25
26
27
28
29
 
# File 'lib/objects/node/inventory/defined.rb', line 21

def menu_items
  base_items = super.dup

  base_items[:reload] = {
    description: "Restock this inventory from remote (hit 'save' after to persist)",
    console_only: true
  }
  base_items
end

#raw_static_machines_from_cache ⇒ Object 



44
45
46
 
# File 'lib/objects/node/inventory/defined.rb', line 44

def raw_static_machines_from_cache
  load_machines_config[namespace.to_sym]
end

#reload ⇒ Object 



31
32
33
34
 
# File 'lib/objects/node/inventory/defined.rb', line 31

def reload
  do_reload
  puts "\nDone. Hit 'ls' to see the refreshed inventory.\n".informational
end

#save ⇒ Object 



58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
 
# File 'lib/objects/node/inventory/defined.rb', line 58

def save
  @answer = ::Bcome::Interactive::Session.run(self,
                                              :capture_input, terminal_prompt: "\nAre you sure you want to cache these machines (saving will overwrite any previous selections) [Y|N] ? ")

  if @answer && @answer == 'Y'
    cache_nodes_in_memory
    data = load_machines_config
    data[namespace] = views[:static_servers]

    File.open(machines_cache_path, 'w') do |file|
      file.write data.to_yaml
    end
    mark_as_cached!
    puts "Machines have been cached for node #{namespace}".informational
  else
    puts 'Nothing saved'.warning
  end
end

#set_static_servers ⇒ Object 



36
37
38
39
40
41
42
 
# File 'lib/objects/node/inventory/defined.rb', line 36

def set_static_servers
  if raw_static_machines_from_cache
    raw_static_machines_from_cache.each do |server_config|
      resources << ::Bcome::Node::Server::Static.new(views: server_config, parent: self)
    end
  end
end