require 'http' require 'active_support/core_ext/object/blank' class HTTP::MimeType::JSON def decode(str) ::JSON.parse(str, symbolize_names: true) end end class Revo::LoansApi::Client attr_reader :session_token, :loan_request_token Result = Struct.new(:success?, :response, keyword_init: true) def initialize(base_url:, login: nil, password: nil, session_token: nil) @base_url = base_url @login = login @password = password @session_token = session_token end def create_session make_request( :post, 'sessions', user: { login: login, password: password } ).tap do |result| @session_token = result.response.dig(:user, :authentication_token) if result&.success? end end def create_loan_request(options) response = make_request(:post, 'loan_requests', loan_request_params(options)) return response unless response.success? @loan_request_token = response.response.dig(:loan_request, :token) terms = loan_request_terms return terms unless terms.success? Result.new(success?: true, response: { token: loan_request_token, insurance_available: response.response.dig(:loan_request, :insurance_available), terms: terms.response[:loan_request] }) end def update_loan_request(token:, options:) update_params = { loan_request: options } response = make_request(:put, "loan_requests/#{token}", update_params) return response unless response.success? @loan_request_token = token terms = loan_request_terms return terms unless terms.success? Result.new( success?: true, response: { terms: terms.response[:loan_request] } ) end def get_loan_request_info(token:, amount:) result = make_request(:get, "loan_requests/#{token}?amount=#{amount}") result.success? ? result.response[:loan_request] : [] end # prerequisite: a client with the LR's phone number should already exist def document(token:, type:, format: 'html') make_request(:get, "loan_requests/#{token}/documents/#{type}.#{format}") end def send_loan_confirmation_message(token:) make_request(:post, "loan_requests/#{token}/client/confirmation") end def complete_loan_request(token:, code:) make_request(:post, "loan_requests/#{token}/confirmation", code: code) end def create_loan(token:, term_id:) make_request(:post, "loan_requests/#{token}/loan", term_id: term_id) end def finalize_loan(token:, code:, sms_info: '0') loan_params = { agree_processing: '1', confirmation_code: code, agree_sms_info: sms_info } make_request(:post, "loan_requests/#{token}/loan/finalization", loan: loan_params) end # returns def orders(store_id:, filters: {}) make_request(:get, 'orders', store_id: store_id, filters: filters) end def send_return_confirmation_code(order_id:) make_request(:post, "orders/#{order_id}/send_return_confirmation_code") end def create_return(order_id:, code:, amount:, store_id:) params = { return: { order_id: order_id, confirmation_code: code, amount: amount, store_id: store_id } } make_request(:post, 'returns', params) end def confirm_return(return_id:) make_request(:post, "returns/#{return_id}/confirm") end def cancel_return(return_id:) make_request(:post, "returns/#{return_id}/cancel") end def start_self_registration(token:, mobile_phone:) make_request(:post, "loan_requests/#{token}/client/self_registration", mobile_phone: mobile_phone) end def check_client_code(token:, code:) make_request(:post, "loan_requests/#{token}/client/check_code", code: code) end def create_client(token:, client_params:, provider_data: {}) make_request(:post, "loan_requests/#{token}/client", client: client_params, provider_data: provider_data) end def update_client(id:, client_params:) make_request(:patch, "/clients/#{id}", client: client_params) end def create_virtual_card(token:) make_request(:post, "loan_requests/#{token}/virtual_card") end def create_card_loan(token:, term_id:) make_request(:post, "loan_requests/#{token}/card_loan", term_id: term_id) end private API_CONTENT_TYPE = 'application/json'.freeze attr_reader :base_url, :login, :password def connection @connection ||= HTTP.persistent(base_url) end def loan_request_terms(&block) result = make_request(:get, "loan_requests/#{loan_request_token}", &block) return result if result.success? Result.new(success?: false, response: { errors: { loan_request_terms: [:cant_fetch] } }) end def make_request(method, endpoint, params = {}, &block) headers = { Authorization: session_token }.compact response = connection.public_send(method, url_for(endpoint), json: params, headers: headers) handle_response(response, &block) rescue HTTP::Error => e handle_error(e) end def handle_response(response) if response.status.success? if block_given? yield response else response end Result.new(success?: true, response: parse(response)) else handle_error(response) end end def handle_error(response_or_exception) response = response_or_exception if response_or_exception.respond_to?(:status) if response if response.status.unauthorized? raise Revo::LoansApi::InvalidAccessTokenError else Result.new(success?: false, response: parse_errors(response)) end else raise Revo::LoansApi::UnexpectedResponseError, response_or_exception end end def parse(response) response.parse if response.body.present? rescue HTTP::Error response.to_s.presence end def parse_errors(response) if response.content_type.mime_type == API_CONTENT_TYPE parse(response) else { errors: { base: [:unexpected_response] } } end end def url_for(endpoint) [base_url, endpoint].join('/') end def loan_request_params(options) { loan_request: options } end end