Merge pull request #34 from fog/vpnaas

Integrate VPNaaS endpoints

Author: seanhandley

lib/fog/openstack/models/network/ike_policies.rb

@@ -0,0 +1,32 @@
+require 'fog/openstack/models/collection'
+require 'fog/openstack/models/network/ike_policy'
+
+module Fog
+  module Network
+    class OpenStack
+      class IkePolicies < Fog::OpenStack::Collection
+        attribute :filters
+
+        model Fog::Network::OpenStack::IkePolicy
+
+        def initialize(attributes)
+          self.filters ||= {}
+          super
+        end
+
+        def all(filters_arg = filters)
+          filters = filters_arg
+          load_response(service.list_ike_policies(filters), 'ikepolicies')
+        end
+
+        def get(ike_policy_id)
+          if ike_policy = service.get_ike_policy(ike_policy_id).body['ikepolicy']
+            new(ike_policy)
+          end
+        rescue Fog::Network::OpenStack::NotFound
+          nil
+        end
+      end
+    end
+  end
+end

lib/fog/openstack/models/network/ike_policy.rb

@@ -0,0 +1,43 @@
+require 'fog/openstack/models/model'
+
+module Fog
+  module Network
+    class OpenStack
+      class IkePolicy < Fog::OpenStack::Model
+        identity :id
+
+        attribute :name
+        attribute :description
+        attribute :status
+        attribute :admin_state_up
+        attribute :tenant_id
+        attribute :auth_algorithm
+        attribute :encryption_algorithm
+        attribute :pfs
+        attribute :phase1_negotiation_mode
+        attribute :lifetime
+        attribute :ike_version
+
+        def create
+          requires :name, :auth_algorithm, :encryption_algorithm, :ike_version,
+                   :lifetime, :pfs, :phase1_negotiation_mode
+          merge_attributes(service.create_ike_policy(attributes).body['ikepolicy'])
+          self
+        end
+
+        def update
+          requires :id, :name, :auth_algorithm, :encryption_algorithm, :ike_version,
+                   :lifetime, :pfs, :phase1_negotiation_mode
+          merge_attributes(service.update_ike_policy(id, attributes).body['ikepolicy'])
+          self
+        end
+
+        def destroy
+          requires :id
+          service.delete_ike_policy(id)
+          true
+        end
+      end
+    end
+  end
+end

lib/fog/openstack/models/network/ipsec_policies.rb

@@ -0,0 +1,32 @@
+require 'fog/openstack/models/collection'
+require 'fog/openstack/models/network/ipsec_policy'
+
+module Fog
+  module Network
+    class OpenStack
+      class IpsecPolicies < Fog::OpenStack::Collection
+        attribute :filters
+
+        model Fog::Network::OpenStack::IpsecPolicy
+
+        def initialize(attributes)
+          self.filters ||= {}
+          super
+        end
+
+        def all(filters_arg = filters)
+          filters = filters_arg
+          load_response(service.list_ipsec_policies(filters), 'ipsecpolicies')
+        end
+
+        def get(ipsec_policy_id)
+          if ipsec_policy = service.get_ipsec_policy(ipsec_policy_id).body['ipsecpolicy']
+            new(ipsec_policy)
+          end
+        rescue Fog::Network::OpenStack::NotFound
+          nil
+        end
+      end
+    end
+  end
+end

lib/fog/openstack/models/network/ipsec_policy.rb

@@ -0,0 +1,45 @@
+require 'fog/openstack/models/model'
+
+module Fog
+  module Network
+    class OpenStack
+      class IpsecPolicy < Fog::OpenStack::Model
+        identity :id
+
+        attribute :name
+        attribute :description
+        attribute :status
+        attribute :admin_state_up
+        attribute :tenant_id
+        attribute :auth_algorithm
+        attribute :encryption_algorithm
+        attribute :pfs
+        attribute :transform_protocol
+        attribute :encapsulation_mode
+        attribute :lifetime
+
+        def create
+          requires :name, :auth_algorithm, :encryption_algorithm,
+                   :lifetime, :pfs, :transform_protocol,
+                   :encapsulation_mode
+          merge_attributes(service.create_ipsec_policy(attributes).body['ipsecpolicy'])
+          self
+        end
+
+        def update
+          requires :id, :name, :auth_algorithm, :encryption_algorithm,
+                   :lifetime, :pfs, :transform_protocol,
+                   :encapsulation_mode
+          merge_attributes(service.update_ipsec_policy(id, attributes).body['ipsecpolicy'])
+          self
+        end
+
+        def destroy
+          requires :id
+          service.delete_ipsec_policy(id)
+          true
+        end
+      end
+    end
+  end
+end

lib/fog/openstack/models/network/ipsec_site_connection.rb

@@ -0,0 +1,51 @@
+require 'fog/openstack/models/model'
+
+module Fog
+  module Network
+    class OpenStack
+      class IpsecSiteConnection < Fog::OpenStack::Model
+        identity :id
+
+        attribute :name
+        attribute :description
+        attribute :status
+        attribute :admin_state_up
+        attribute :tenant_id
+        attribute :vpnservice_id
+        attribute :ikepolicy_id
+        attribute :ipsecpolicy_id
+        attribute :peer_address
+        attribute :peer_id
+        attribute :peer_cidrs
+        attribute :psk
+        attribute :mtu
+        attribute :dpd
+        attribute :initiator
+
+        def create
+          requires :name, :vpnservice_id, :ikepolicy_id, :ipsecpolicy_id,
+                   :peer_address, :peer_id, :peer_cidrs, :psk
+          merge_attributes(service.create_ipsec_site_connection(vpnservice_id,
+                                                                ikepolicy_id,
+                                                                ipsecpolicy_id,
+                                                                attributes).body['ipsec_site_connection'])
+          self
+        end
+
+        def update
+          requires :id, :name, :vpnservice_id, :ikepolicy_id, :ipsecpolicy_id,
+                   :peer_address, :peer_id, :peer_cidrs, :psk
+          merge_attributes(service.update_ipsec_site_connection(id,
+                                                                attributes).body['ipsec_site_connection'])
+          self
+        end
+
+        def destroy
+          requires :id
+          service.delete_ipsec_site_connection(id)
+          true
+        end
+      end
+    end
+  end
+end

lib/fog/openstack/models/network/ipsec_site_connections.rb

@@ -0,0 +1,33 @@
+require 'fog/openstack/models/collection'
+require 'fog/openstack/models/network/ipsec_site_connection'
+
+module Fog
+  module Network
+    class OpenStack
+      class IpsecSiteConnections < Fog::OpenStack::Collection
+        attribute :filters
+
+        model Fog::Network::OpenStack::IpsecSiteConnection
+
+        def initialize(attributes)
+          self.filters ||= {}
+          super
+        end
+
+        def all(filters_arg = filters)
+          filters = filters_arg
+          load_response(service.list_ipsec_site_connections(filters), 'ipsec_site_connections')
+        end
+
+        def get(ipsec_site_connection_id)
+          connection = service.get_ipsec_site_connection(ipsec_site_connection_id).body['ipsec_site_connection']
+          if connection
+            new(connection)
+          end
+        rescue Fog::Network::OpenStack::NotFound
+          nil
+        end
+      end
+    end
+  end
+end

lib/fog/openstack/models/network/vpn_service.rb

@@ -0,0 +1,42 @@
+require 'fog/openstack/models/model'
+
+module Fog
+  module Network
+    class OpenStack
+      class VpnService < Fog::OpenStack::Model
+        identity :id
+
+        attribute :subnet_id
+        attribute :router_id
+        attribute :name
+        attribute :description
+        attribute :status
+        attribute :admin_state_up
+        attribute :tenant_id
+        attribute :external_v4_ip
+        attribute :external_v6_ip
+
+        def create
+          requires :subnet_id, :router_id, :name, :admin_state_up
+          merge_attributes(service.create_vpn_service(subnet_id,
+                                                      router_id,
+                                                      attributes).body['vpnservice'])
+          self
+        end
+
+        def update
+          requires :id, :subnet_id, :router_id, :name, :admin_state_up
+          merge_attributes(service.update_vpn_service(id,
+                                                      attributes).body['vpnservice'])
+          self
+        end
+
+        def destroy
+          requires :id
+          service.delete_vpn_service(id)
+          true
+        end
+      end
+    end
+  end
+end

lib/fog/openstack/models/network/vpn_services.rb

@@ -0,0 +1,32 @@
+require 'fog/openstack/models/collection'
+require 'fog/openstack/models/network/vpn_service'
+
+module Fog
+  module Network
+    class OpenStack
+      class VpnServices < Fog::OpenStack::Collection
+        attribute :filters
+
+        model Fog::Network::OpenStack::VpnService
+
+        def initialize(attributes)
+          self.filters ||= {}
+          super
+        end
+
+        def all(filters_arg = filters)
+          filters = filters_arg
+          load_response(service.list_vpn_services(filters), 'vpnservices')
+        end
+
+        def get(vpn_service_id)
+          if vpn_service = service.get_vpn_service(vpn_service_id).body['vpnservice']
+            new(vpn_service)
+          end
+        rescue Fog::Network::OpenStack::NotFound
+          nil
+        end
+      end
+    end
+  end
+end

lib/fog/openstack/network.rb

@@ -38,6 +38,14 @@ class OpenStack < Fog::Service
       collection  :lb_health_monitors
       model       :lb_vip
       collection  :lb_vips
+      model       :vpn_service
+      collection  :vpn_services
+      model       :ike_policy
+      collection  :ike_policies
+      model       :ipsec_policy
+      collection  :ipsec_policies
+      model       :ipsec_site_connection
+      collection  :ipsec_site_connections
       model       :security_group
       collection  :security_groups
       model       :security_group_rule
@@ -116,6 +124,34 @@ class OpenStack < Fog::Service
       request :get_lb_vip
       request :update_lb_vip
 
+      # VPNaaS VPN Service CRUD
+      request :list_vpn_services
+      request :create_vpn_service
+      request :delete_vpn_service
+      request :get_vpn_service
+      request :update_vpn_service
+
+      # VPNaaS VPN IKE Policy CRUD
+      request :list_ike_policies
+      request :create_ike_policy
+      request :delete_ike_policy
+      request :get_ike_policy
+      request :update_ike_policy
+
+      # VPNaaS VPN IPSec Policy CRUD
+      request :list_ipsec_policies
+      request :create_ipsec_policy
+      request :delete_ipsec_policy
+      request :get_ipsec_policy
+      request :update_ipsec_policy
+
+      # VPNaaS VPN IPSec Site Connection CRUD
+      request :list_ipsec_site_connections
+      request :create_ipsec_site_connection
+      request :delete_ipsec_site_connection
+      request :get_ipsec_site_connection
+      request :update_ipsec_site_connection
+
       # Security Group
       request :create_security_group
       request :delete_security_group
@@ -180,6 +216,10 @@ def self.data
               :lb_members => {},
               :lb_health_monitors => {},
               :lb_vips => {},
+              :vpn_services           => {},
+              :ike_policies           => {},
+              :ipsec_policies         => {},
+              :ipsec_site_connections => {},
               :quota => {
                 "subnet" => 10,
                 "router" => 10,