module Homeflow module API YAML::ENGINE.yamler = "syck" class Request attr_accessor :resource_class, :request_specification def initialize(request_specification) @request_specification = request_specification end def perform begin response = perform_request rescue Errno::ECONNREFUSED => e raise Homeflow::API::Exceptions::APIConnectionError, "Connection error. Homeflow might be down?" end response end def perform_request if request_specification.is_a? Query url = "#{Homeflow::API.config.source}/#{request_specification.resource_class.resource_uri}" else url = "#{Homeflow::API.config.source}/#{request_specification.resource_uri}" end query_params = @request_specification.to_params.merge(constant_params) post_params = (@request_specification.respond_to?(:post_params) ? @request_specification.post_params : {}) if Homeflow::API.config.show_debug puts "****************************************************************************************" puts "HESTIA CALL" puts "===========" puts "Destination - #{url}" puts "Request params:\n#{query_params.to_json}\n" puts "Post params:\n#{post_params.to_json}\n" puts "request_specification:\n#{request_specification.to_json}\n" puts "@request_specification:\n#{@request_specification.to_json}\n" puts "****************************************************************************************" end if request_specification.is_a? Query return (HTTParty.get(url, :query => query_params)).body elsif request_specification.is_a? ResourceIdentifier return (HTTParty.get(url, :query => query_params)).body elsif request_specification.is_a? Delete return (HTTParty.delete(url, :query => query_params)).body elsif request_specification.is_a? Put return (HTTParty.put(url, :query => query_params, :body => post_params)).body elsif request_specification.is_a? Post return (HTTParty.pos(url, :query => query_params, :body => post_params)).body end end def constant_params {:api_key=> Homeflow::API.config.api_key} end class << self def run_for(request_specification) r = Request.new(request_specification) Response.new_from_json(r.perform) end end end end end