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.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)).body elsif request_specification.is_a? ResourceIdentifier return (HTTParty.get (url, :query => query)).body elsif request_specification.is_a? Delete return (HTTParty.delete(url, :query => query)).body elsif request_specification.is_a? Put return (HTTParty.put (url, :query => query, :body => post_params)).body elsif request_specification.is_a? Post return (HTTParty.post (url, :query => query, :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