fog--fog/lib/fog/bluebox.rb

module Fog
  module Bluebox
    extend Fog::Service

    requires :bluebox_api_key, :bluebox_customer_id

    model_path 'fog/bluebox/models'
    model 'flavor'
    model 'flavors'
    model 'images'
    model 'server'
    model 'servers'

    request_path 'fog/bluebox/requests'
    request 'create_block'
    request 'destroy_block'
    request 'get_block'
    request 'get_blocks'
    request 'get_product'
    request 'get_products'
    request 'get_template'
    request 'get_templates'
    request 'reboot_block'

    class Mock
      include Collections

      def self.data
        @data ||= Hash.new do |hash, key|
          hash[key] = {}
        end
      end

      def self.reset_data(keys=data.keys)
        for key in [*keys]
          data.delete(key)
        end
      end

      def initialize(options={})
        @bluebox_api_key = options[:bluebox_api_key]
        @data = self.class.data[@bluebox_api_key]
      end

    end

    class Real
      include Collections

      def initialize(options={})
        @bluebox_api_key      = options[:bluebox_api_key]
        @bluebox_customer_id  = options[:bluebox_customer_id]
        @host   = options[:bluebox_host]    || "boxpanel.blueboxgrp.com"
        @port   = options[:bluebox_port]    || 443
        @scheme = options[:bluebox_scheme]  || 'https'
        @connection = Fog::Connection.new("#{@scheme}://#{@host}:#{@port}", options[:persistent])
      end

      def reload
        @connection.reset
      end

      def request(params)
        params[:headers] ||= {}
        params[:headers].merge!({
          'Authorization' => "Basic #{Base64.encode64([@bluebox_customer_id, @bluebox_api_key].join(':')).delete("\r\n")}"
        })

        begin
          response = @connection.request(params.merge!({:host => @host}))
        rescue Excon::Errors::Error => error
          raise case error
          when Excon::Errors::NotFound
            Fog::Bluebox::NotFound.slurp(error)
          else
            error
          end
        end
        unless response.body.empty?
          response.body = JSON.parse(response.body)
        end
        response
      end

    end
  end
end