fog/fog-radosgw

module Fog
  module Radosgw
    class Provisioning
      class Real
        include Utils

        def create_user(user_id, display_name, email, options = {})
          if get_user(user_id).status != 404
            raise Fog::Radosgw::Provisioning::UserAlreadyExists, "User with user_id #{user_id} already exists."
          end

          path         = "admin/user"
          user_id      = escape(user_id)
          display_name = escape(display_name)
          email        = escape(email)
          query        = "?uid=#{user_id}&display-name=#{display_name}&email=#{email}&format=json"
          params       = {
            :method => 'PUT',
            :path => path,
          }

          begin
            response = Excon.put("#{@scheme}://#{@host}/#{path}#{query}",
                                 :headers => signed_headers(params))
            if !response.body.empty?
              case response.headers['Content-Type']
              when 'application/json'
                response.body = Fog::JSON.decode(response.body)
              end
            end
            response
          rescue Excon::Errors::Conflict => e
            raise Fog::Radosgw::Provisioning::UserAlreadyExists.new
          rescue Excon::Errors::BadRequest => e
            raise Fog::Radosgw::Provisioning::ServiceUnavailable.new
          end
        end
      end

      class Mock
        def user_exists?(user_id)
          data.find do |key, value|
            value[:user_id] == user_id
          end
        end

        def create_user(user_id, display_name, email, options = {})
          if user_exists?(user_id)
            raise Fog::Radosgw::Provisioning::UserAlreadyExists, "User with user_id #{user_id} already exists."
          end

          secret_key   = rand(1000).to_s
          data[user_id] = {
            :email        => email, 
            :user_id      => user_id, 
            :display_name => display_name,
            :suspended    => 0, 
            :secret_key   => secret_key,
          }

          Excon::Response.new.tap do |response|
            response.status = 200
            response.headers['Content-Type'] = 'application/json'
            response.body = {
              "email"        => email,
              "user_id"      => user_id,
              "display_name" => display_name,
              "suspended"    => 0,
              "keys"         =>
              [
               {
                 "access_key" => "XXXXXXXXXXXXXXXXXXXX",
                 "secret_key" => secret_key,
                 "user"       => user_id,
               }
              ],
            }
          end
        end
      end
    end
  end
end