3rdparty/modules/neutron/lib/puppet/provider/neutron_network/neutron.rb

   1 require File.join(File.dirname(__FILE__), '..','..','..',
   2                   'puppet/provider/neutron')
   3
   4 Puppet::Type.type(:neutron_network).provide(
   5   :neutron,
   6   :parent => Puppet::Provider::Neutron
   7 ) do
   8   desc <<-EOT
   9     Neutron provider to manage neutron_network type.
  10
  11     Assumes that the neutron service is configured on the same host.
  12   EOT
  13
  14   commands :neutron => 'neutron'
  15
  16   mk_resource_methods
  17
  18   def self.neutron_type
  19     'net'
  20   end
  21
  22   def self.instances
  23     list_neutron_resources(neutron_type).collect do |id|
  24       attrs = get_neutron_resource_attrs(neutron_type, id)
  25       new(
  26         :ensure                    => :present,
  27         :name                      => attrs['name'],
  28         :id                        => attrs['id'],
  29         :admin_state_up            => attrs['admin_state_up'],
  30         :provider_network_type     => attrs['provider:network_type'],
  31         :provider_physical_network => attrs['provider:physical_network'],
  32         :provider_segmentation_id  => attrs['provider:segmentation_id'],
  33         :router_external           => attrs['router:external'],
  34         :shared                    => attrs['shared'],
  35         :tenant_id                 => attrs['tenant_id']
  36       )
  37     end
  38   end
  39
  40   def self.prefetch(resources)
  41     networks = instances
  42     resources.keys.each do |name|
  43       if provider = networks.find{ |net| net.name == name }
  44         resources[name].provider = provider
  45       end
  46     end
  47   end
  48
  49   def exists?
  50     @property_hash[:ensure] == :present
  51   end
  52
  53   def create
  54     network_opts = Array.new
  55
  56     if @resource[:shared]
  57       network_opts << '--shared'
  58     end
  59
  60     if @resource[:tenant_name]
  61       tenant_id = self.class.get_tenant_id(model.catalog,
  62                                            @resource[:tenant_name])
  63       network_opts << "--tenant_id=#{tenant_id}"
  64     elsif @resource[:tenant_id]
  65       network_opts << "--tenant_id=#{@resource[:tenant_id]}"
  66     end
  67
  68     if @resource[:provider_network_type]
  69       network_opts << \
  70         "--provider:network_type=#{@resource[:provider_network_type]}"
  71     end
  72
  73     if @resource[:provider_physical_network]
  74       network_opts << \
  75         "--provider:physical_network=#{@resource[:provider_physical_network]}"
  76     end
  77
  78     if @resource[:provider_segmentation_id]
  79       network_opts << \
  80         "--provider:segmentation_id=#{@resource[:provider_segmentation_id]}"
  81     end
  82
  83     if @resource[:router_external] == 'True'
  84       network_opts << '--router:external'
  85     end
  86
  87     results = auth_neutron('net-create', '--format=shell',
  88                            network_opts, resource[:name])
  89
  90     if results =~ /Created a new network:/
  91       attrs = self.class.parse_creation_output(results)
  92       @property_hash = {
  93         :ensure                    => :present,
  94         :name                      => resource[:name],
  95         :id                        => attrs['id'],
  96         :admin_state_up            => attrs['admin_state_up'],
  97         :provider_network_type     => attrs['provider:network_type'],
  98         :provider_physical_network => attrs['provider:physical_network'],
  99         :provider_segmentation_id  => attrs['provider:segmentation_id'],
 100         :router_external           => attrs['router:external'],
 101         :shared                    => attrs['shared'],
 102         :tenant_id                 => attrs['tenant_id'],
 103       }
 104     else
 105       fail("did not get expected message on network creation, got #{results}")
 106     end
 107   end
 108
 109   def destroy
 110     auth_neutron('net-delete', name)
 111     @property_hash[:ensure] = :absent
 112   end
 113
 114   def admin_state_up=(value)
 115     auth_neutron('net-update', "--admin_state_up=#{value}", name)
 116   end
 117
 118   def shared=(value)
 119     auth_neutron('net-update', "--shared=#{value}", name)
 120   end
 121
 122   def router_external=(value)
 123     if value == 'False'
 124       auth_neutron('net-update', "--router:external=#{value}", name)
 125     else
 126       auth_neutron('net-update', "--router:external", name)
 127     end
 128   end
 129
 130   [
 131    :provider_network_type,
 132    :provider_physical_network,
 133    :provider_segmentation_id,
 134    :tenant_id,
 135   ].each do |attr|
 136      define_method(attr.to_s + "=") do |value|
 137        fail("Property #{attr.to_s} does not support being updated")
 138      end
 139   end
 140
 141 end