[cloudsigma] Add CloudSigma compute provider

Author: Kaloyan Kanev

lib/fog.rb

@@ -42,3 +42,5 @@
 require 'fog/voxel'
 require 'fog/xenserver'
 require 'fog/zerigo'
+require 'fog/cloudsigma'
+

lib/fog/bin.rb

@@ -94,3 +94,4 @@ def collections
 require 'fog/bin/voxel'
 require 'fog/bin/xenserver'
 require 'fog/bin/zerigo'
+require 'fog/bin/cloudsigma'

lib/fog/bin/cloudsigma.rb

@@ -0,0 +1,29 @@
+class CloudSigma < Fog::Bin
+  class << self
+
+    def class_for(key)
+      case key
+        when :compute
+          Fog::Compute::CloudSigma
+        else
+          raise ArgumentError, "Unrecognized service: #{key}"
+      end
+    end
+
+    def [](service)
+      @@connections ||= Hash.new do |hash, key|
+        hash[key] = case key
+                      when :compute
+                        Fog::Compute.new(:provider => 'CloudSigma')
+                      else
+                        raise ArgumentError, "Unrecognized service: #{key.inspect}"
+                    end
+      end
+      @@connections[service]
+    end
+
+    def services
+      Fog::CloudSigma.services
+    end
+  end
+end

lib/fog/cloudsigma.rb

@@ -0,0 +1,9 @@
+require 'fog/core'
+
+module Fog
+  module CloudSigma
+    extend Fog::Provider
+
+    service(:compute, 'cloudsigma/compute', 'Compute')
+  end
+end

lib/fog/cloudsigma/compute.rb

@@ -0,0 +1,221 @@
+require 'fog/compute'
+require 'fog/cloudsigma/connection'
+
+
+module Fog
+  module Compute
+    class CloudSigma < Fog::Service
+      requires :cloudsigma_password, :cloudsigma_username
+      recognizes :cloudsigma_password, :cloudsigma_username
+
+      model_path 'fog/cloudsigma/models'
+      request_path 'fog/cloudsigma/requests'
+
+      model :volume
+      collection :volumes
+      request :create_volume
+      request :get_volume
+      request :list_volumes
+      request :update_volume
+      request :delete_volume
+      request :clone_volume
+
+      model :lib_volume
+      collection :lib_volumes
+      request :get_lib_volume
+      request :list_lib_volumes
+
+      model :ipconf
+      model :nic
+      model :mountpoint
+      model :server
+      collection :servers
+      request :create_server
+      request :get_server
+      request :list_servers
+      request :update_server
+      request :delete_server
+      request :start_server
+      request :stop_server
+      request :open_vnc
+      request :close_vnc
+      request :clone_server
+
+      model :ip
+      collection :ips
+      request :list_ips
+      request :get_ip
+
+      model :vlan
+      collection :vlans
+      request :list_vlans
+      request :get_vlan
+      request :update_vlan
+
+      model :subscription
+      collection :subscriptions
+      request :list_subscriptions
+      request :get_subscription
+      request :create_subscription
+      request :extend_subscription
+
+      model :price_calculation
+      request :calculate_subscription_price
+
+      model :profile
+      request :get_profile
+      request :update_profile
+
+      model :balance
+      request :get_balance
+
+      model :current_usage
+      request :get_current_usage
+
+      model :pricing
+      request :get_pricing
+
+
+      module CommonMockAndReal
+        def initialize(options={})
+          @init_options = options
+
+          setup_connection(options)
+        end
+
+        def profile
+          response = get_profile
+          Profile.new(response.body)
+        end
+
+        def balance
+          response = get_balance
+
+          Balance.new(response.body)
+        end
+
+        def current_usage
+          response = get_current_usage
+
+          CurrentUsage.new(response.body['usage'])
+        end
+
+        def currency
+          # Cache since currency does not change
+          @currency ||= profile.currency
+
+        end
+
+        def pricing
+          resp = get_princing(currency)
+
+          resp.body['objects']
+        end
+
+        def current_pricing_levels
+          resp = get_pricing(currency)
+
+          resp.body['current']
+        end
+
+        def next_pricing_levels
+          resp = get_pricing(currency)
+
+          resp.body['next']
+        end
+
+        def subscription_pricing
+          resp = get_pricing(currency, true)
+
+          current_levels = resp.body['current']
+          current_prices = resp.body['objects']
+
+          current_pricing_pairs = current_levels.map do |resource, level|
+            price_for_resource_and_level = current_prices.detect do |price|
+              price['resource'] == resource
+            end
+            price_for_resource_and_level ||= {}
+
+            [resource, price_for_resource_and_level]
+          end
+
+          Pricing.new(Hash[current_pricing_pairs])
+        end
+
+        def current_pricing
+          resp = get_pricing(currency)
+
+          current_levels = resp.body['current']
+          current_prices = resp.body['objects']
+
+          current_pricing_pairs = current_levels.map do |resource, level|
+            price_for_resource_and_level = current_prices.detect do |price|
+              price['level'] == level && price['resource'] == resource
+            end
+            price_for_resource_and_level ||= {}
+
+            [resource, price_for_resource_and_level]
+          end
+
+          Pricing.new(Hash[current_pricing_pairs])
+        end
+
+        def next_pricing
+          resp = get_pricing(currency)
+
+          current_levels = resp.body['next']
+          current_prices = resp.body['objects']
+
+          current_pricing_pairs = current_levels.map do |resource, level|
+            price_for_resource_and_level = current_prices.detect do |price|
+              price['level'] == level && price['resource'] == resource
+            end
+            price_for_resource_and_level ||= {}
+
+            [resource, price_for_resource_and_level]
+          end
+
+          Pricing.new(Hash[current_pricing_pairs])
+        end
+
+      end
+
+      class Mock
+        include Collections
+        include CommonMockAndReal
+        include Fog::CloudSigma::CloudSigmaConnection::Mock
+        require 'fog/cloudsigma/mock_data'
+
+        def self.data
+          @data ||= Hash.new do |hash, key|
+            hash[key] = mock_data
+          end
+        end
+
+        def self.random_uuid
+          # Insert '4' at 13th position and 'a' at 17th as per uuid4 spec
+          hex = Fog::Mock.random_hex(30).insert(12,'4').insert(16, 'a')
+          # Add dashes
+          "#{hex[0...8]}-#{hex[8...12]}-#{hex[12...16]}-#{hex[16...20]}-#{hex[20..32]}"
+        end
+
+        def self.random_mac
+          (0..5).map{Fog::Mock.random_hex(2)}.join(':')
+        end
+
+        def data
+          self.class.data[:test]
+        end
+      end
+
+      class Real
+        include Collections
+        include CommonMockAndReal
+        include Fog::CloudSigma::CloudSigmaConnection::Real
+
+      end
+
+    end
+  end
+
+end