Class: Chef::Provider::Route

Inherits:
Chef::Provider show all
Defined in:
lib/chef/provider/route.rb

Constant Summary collapse

MASK = 
{ "0.0.0.0" => "0",
"128.0.0.0" => "1",
"192.0.0.0" => "2",
"224.0.0.0" => "3",
"240.0.0.0" => "4",
"248.0.0.0" => "5",
"252.0.0.0" => "6",
"254.0.0.0" => "7",
"255.0.0.0" => "8",
"255.128.0.0" => "9",
"255.192.0.0" => "10",
"255.224.0.0" => "11",
"255.240.0.0" => "12",
"255.248.0.0" => "13",
"255.252.0.0" => "14",
"255.254.0.0" => "15",
"255.255.0.0" => "16",
"255.255.128.0" => "17",
"255.255.192.0" => "18",
"255.255.224.0" => "19",
"255.255.240.0" => "20",
"255.255.248.0" => "21",
"255.255.252.0" => "22",
"255.255.254.0" => "23",
"255.255.255.0" => "24",
"255.255.255.128" => "25",
"255.255.255.192" => "26",
"255.255.255.224" => "27",
"255.255.255.240" => "28",
"255.255.255.248" => "29",
"255.255.255.252" => "30",
"255.255.255.254" => "31",
"255.255.255.255" => "32" }.freeze

Instance Attribute Summary collapse

Attributes inherited from Chef::Provider

#action, #after_resource, #current_resource, #logger, #new_resource, #run_context

Instance Method Summary collapse

Methods inherited from Chef::Provider

action, action_description, action_descriptions, #action_nothing, #check_resource_semantics!, #cleanup_after_converge, #compile_and_converge_action, #converge_by, #converge_if_changed, #cookbook_name, #define_resource_requirements, #description, #events, include_resource_dsl?, include_resource_dsl_module, #initialize, #introduced, #load_after_resource, #node, #process_resource_requirements, provides, provides?, #recipe_name, #requirements, #resource_collection, #resource_updated?, #run_action, #set_updated_status, supports?, use, use_inline_resources, #validate_required_properties!, #whyrun_mode?, #whyrun_supported?

Methods included from Mixin::Provides

#provided_as, #provides, #provides?

Methods included from Mixin::DescendantsTracker

#descendants, descendants, direct_descendants, #direct_descendants, find_descendants_by_name, #find_descendants_by_name, #inherited, store_inherited

Methods included from Mixin::LazyModuleInclude

#descendants, #include, #included

Methods included from Mixin::PowershellOut

#powershell_out, #powershell_out!

Methods included from Mixin::WindowsArchitectureHelper

#assert_valid_windows_architecture!, #disable_wow64_file_redirection, #forced_32bit_override_required?, #is_i386_process_on_x86_64_windows?, #node_supports_windows_architecture?, #node_windows_architecture, #restore_wow64_file_redirection, #valid_windows_architecture?, #with_os_architecture, #wow64_architecture_override_required?, #wow64_directory

Methods included from DSL::Secret

#default_secret_config, #default_secret_service, #secret, #with_secret_config, #with_secret_service

Methods included from DSL::RenderHelpers

#render_json, #render_toml, #render_yaml

Methods included from DSL::ReaderHelpers

#parse_file, #parse_json, #parse_toml, #parse_yaml

Methods included from DSL::Powershell

#ps_credential

Methods included from DSL::RegistryHelper

#registry_data_exists?, #registry_get_subkeys, #registry_get_values, #registry_has_subkeys?, #registry_key_exists?, #registry_value_exists?

Methods included from DSL::ChefVault

#chef_vault, #chef_vault_item, #chef_vault_item_for_environment

Methods included from DSL::DataQuery

#data_bag, #data_bag_item, #search, #tagged?

Methods included from EncryptedDataBagItem::CheckEncrypted

#encrypted?

Methods included from DSL::PlatformIntrospection

#older_than_win_2012_or_8?, #platform?, #platform_family?, #value_for_platform, #value_for_platform_family

Methods included from DSL::Recipe

#exec, #have_resource_class_for?, #resource_class_for

Methods included from DSL::Definitions

add_definition, #evaluate_resource_definition, #has_resource_definition?

Methods included from DSL::Resources

add_resource_dsl, remove_resource_dsl

Methods included from DSL::Cheffish

load_cheffish

Methods included from DSL::RebootPending

#reboot_pending?

Methods included from DSL::IncludeRecipe

#include_recipe, #load_recipe

Methods included from Mixin::NotifyingBlock

#notifying_block, #subcontext_block

Methods included from DSL::DeclareResource

#build_resource, #declare_resource, #delete_resource, #delete_resource!, #edit_resource, #edit_resource!, #find_resource, #find_resource!, #resources, #with_run_context

Methods included from DSL::Compliance

#include_input, #include_profile, #include_waiver

Constructor Details

This class inherits a constructor from Chef::Provider

Instance Attribute Details

#is_running ⇒ Object

Returns the value of attribute is_running.



30
31
32
 
# File 'lib/chef/provider/route.rb', line 30

def is_running
  @is_running
end

Instance Method Details

#config_file_contents(action, options = {}) ⇒ Object 



231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
 
# File 'lib/chef/provider/route.rb', line 231

def config_file_contents(action, options = {})
  content = ""
  case action
  when :add
    content << "# #{options[:comment]}\n" if options[:comment]
    content << (options[:target]).to_s
    content << "/#{MASK[options[:netmask].to_s]}" if options[:netmask]
    content << " via #{options[:gateway]}" if options[:gateway]
    content << " dev #{options[:device]}" if options[:device]
    content << " metric #{options[:metric]}" if options[:metric]
    content << "\n"
  end

  content
end

#generate_command(action) ⇒ Object 



213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
 
# File 'lib/chef/provider/route.rb', line 213

def generate_command(action)
  target = new_resource.target
  target = "#{target}/#{MASK[new_resource.netmask.to_s]}" if new_resource.netmask

  case action
  when :add
    command = [ "ip", "route", "replace", target ]
    command += [ "via", new_resource.gateway ] if new_resource.gateway
    command += [ "dev", new_resource.device ] if new_resource.device
    command += [ "metric", new_resource.metric ] if new_resource.metric
  when :delete
    command = [ "ip", "route", "delete", target ]
    command += [ "via", new_resource.gateway ] if new_resource.gateway
  end

  command
end

#generate_config ⇒ Object 



162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
 
# File 'lib/chef/provider/route.rb', line 162

def generate_config
  if platform_family?("rhel", "amazon", "fedora")
    conf = {}
    # FIXME FIXME FIXME FIXME: whatever this walking-the-run-context API is, it needs to be removed.
    # walk the collection
    rc = run_context.parent_run_context || run_context
    rc.resource_collection.each do |resource|
      next unless resource.is_a? Chef::Resource::Route

      # default to eth0
      dev = resource.device || "eth0"

      conf[dev] = "" if conf[dev].nil?
      case @action
      when :add
        conf[dev] << config_file_contents(:add, comment: resource.comment, device: resource.device, target: resource.target, metric: resource.metric, netmask: resource.netmask, gateway: resource.gateway) if resource.action == [:add]
      when :delete
        # need to do this for the case when the last route on an int
        # is removed
        conf[dev] << config_file_contents(:delete)
      end
    end
    conf.each_key do |k|
      if new_resource.target == "default"
        network_file_name = "/etc/sysconfig/network"
        converge_by("write route default route to #{network_file_name}") do
          logger.trace("#{new_resource} writing default route #{new_resource.gateway} to #{network_file_name}")
          if ::TargetIO::File.exist?(network_file_name)
            network_file = ::Chef::Util::FileEdit.new(network_file_name)
            network_file.search_file_replace_line(/^GATEWAY=/, "GATEWAY=#{new_resource.gateway}")
            network_file.insert_line_if_no_match(/^GATEWAY=/, "GATEWAY=#{new_resource.gateway}")
            network_file.write_file
          else
            ::TargetIO::File.open(network_file_name, "w") do |network_file|
              network_file.puts("GATEWAY=#{new_resource.gateway}")
            end
          end
        end
      else
        network_file_name = "/etc/sysconfig/network-scripts/route-#{k}"
        converge_by("write route route.#{k}\n#{conf[k]} to #{network_file_name}") do
          ::TargetIO::File.open(network_file_name, "w") do |network_file|
            network_file.puts(conf[k])
          end
          logger.trace("#{new_resource} writing route.#{k}\n#{conf[k]}")
        end
      end
    end
  end
end

#hex2ip(hex_data) ⇒ Object 



66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
 
# File 'lib/chef/provider/route.rb', line 66

def hex2ip(hex_data)
  # Cleanup hex data
  hex_ip = hex_data.to_s.downcase.gsub(/[^0-9a-f]/, "")

  # Check hex data format (IP is a 32bit integer, so should be 8 chars long)
  return nil if hex_ip.length != hex_data.length || hex_ip.length != 8

  # Extract octets from hex data
  octets = hex_ip.scan(/../).reverse.collect { |octet| [octet].pack("H2").unpack("C").first }

  # Validate IP
  ip = octets.join(".")
  begin
    IPAddr.new(ip, Socket::AF_INET).to_s
  rescue ArgumentError
    logger.trace("Invalid IP address data: hex=#{hex_ip}, ip=#{ip}")
    nil
  end
end

#load_current_resource ⇒ Object 



86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
 
# File 'lib/chef/provider/route.rb', line 86

def load_current_resource
  self.is_running = false

  # cidr or quad dot mask
  new_ip = if new_resource.target == "default"
             IPAddr.new(new_resource.gateway)
           elsif new_resource.netmask
             IPAddr.new("#{new_resource.target}/#{new_resource.netmask}")
           else
             IPAddr.new(new_resource.target)
           end

  # For linux, we use /proc/net/route file to read proc table info
  return unless linux?

  route_file = ::TargetIO::File.open("/proc/net/route", "r")

  # Read all routes
  while (line = route_file.gets)
    # Get all the fields for a route
    _, destination, gateway, _, _, _, _, mask = line.split

    # Convert hex-encoded values to quad-dotted notation (e.g. 0064A8C0 => 192.168.100.0)
    destination = hex2ip(destination)
    gateway = hex2ip(gateway)
    mask = hex2ip(mask)

    # Skip formatting lines (header, etc)
    next unless destination && gateway && mask

    logger.trace("#{new_resource} system has route: dest=#{destination} mask=#{mask} gw=#{gateway}")

    # check if what were trying to configure is already there
    # use an ipaddr object with ip/mask this way we can have
    # a new resource be in cidr format (i don't feel like
    # expanding bitmask by hand.
    #
    running_ip = IPAddr.new("#{destination}/#{mask}")
    logger.trace("#{new_resource} new ip: #{new_ip.inspect} running ip: #{running_ip.inspect}")
    self.is_running = true if running_ip == new_ip && gateway == new_resource.gateway
  end

  route_file.close
end