require 'time'
require "mixlib/authentication"
require "mixlib/authentication/signedheaderauth"
require 'digest/sha1'
require 'openssl'
require 'net/http'

module Lambom
    class ApiClient
        API_URL = {
            :production => "http://riyic.com/api/v1",
            :development => "http://10.0.3.1:3000/api/v1"
        }

        def initialize(conf)
            @server_id = conf.server or raise "Required parameter \"server\" not found"
            @private_key_file = conf.private_key_file or raise "Required parameter \"private_key_file\" not found"
            @env = conf.environment

            @api_url = (@env == "production")?
                API_URL[:production]:
                API_URL[:development]
        end

        def get_server_config
            get('servers',"#{@server_id}/generate_config");

        end



        def get(controller, action='',params={})
            uri = build_uri(controller,action)
            req = Net::HTTP::Get.new(uri.request_uri)
            req.body=generate_body_string(params)
            send(uri,req)

        end

        def post(controller, action='',params={})
            uri = build_uri(controller,action)
            req = Net::HTTP::Post.new(uri.request_uri)
            #req.set_form_data(params)
            req.body=generate_body_string(params)
            send(uri,req)
        end

        def send(uri,req)
            
            ## agregamos os headers da signature
            headers = generate_headers(@server_id, @private_key_file, req)
            puts headers.inspect if $debug
            
            headers.each do |header,value|
                req[header] = value
            end
            
            http = Net::HTTP.new(uri.host, uri.port)
            #http.use_ssl = true

            response = http.request(req)
            puts response.body if $debug

            if response.is_a?(Net::HTTPSuccess)
                return response.body
            else
                puts "code:#{response.code}, message:#{response.message}" if $debug
                raise "api error: #{response.body}"
            end

            #puts resp.inspect if @debug
            #response = Oj.load(response.body)

            #if response["status"] == "OK" 
            #    return response
            #else
            #    raise response.body
            #end
                
        end


        private

        def build_uri(controller, action='')
            URI("#{@api_url}/#{controller}/#{action}")
        end

        def generate_body_string(h={})
            r = ""

            h.each do |k,v|
                r << "&#{k}=#{v}"
            end

            r
        end


        def generate_headers(server_id, private_key_file, request)
            
            args = {
              :body => request.body.to_s,
              :user_id => server_id.to_s,
              :http_method => request.method.to_s,
              :timestamp => Time.now.iso8601,
              #:file => MockFile.new,
              :path => request.path.to_s,
              :proto_version => 1.1
            }
            
            # cargamos a private key do ficheiro
            key = IO::read(private_key_file)
            private_key = OpenSSL::PKey::RSA.new(key)
            
            Mixlib::Authentication::SignedHeaderAuth.signing_object(args).sign(private_key)
        end


    end
end