cartodb/lib/carto/oauth/client.rb

module Carto
  module Oauth
    class Client

      include ::LoggerHelper

      attr_reader :state

      def initialize(auth_url:, token_url:, client_id:, client_secret:, state:, redirect_uri:, scopes:)
        @auth_url = auth_url
        @token_url = token_url
        @client_id = client_id
        @client_secret = client_secret
        @state = state
        @redirect_uri = redirect_uri
        @scopes = scopes
      end

      def authorize_url
        escaped_state = Rack::Utils.escape(@state)
        "#{@auth_url}?response_type=code&client_id=#{@client_id}&state=#{escaped_state}" \
          "&scope=#{@scopes.join(' ')}&redirect_uri=#{CGI.escape(@redirect_uri)}"
      end

      def exchange_code_for_token(code)
        body = {
          client_id: @client_id,
          client_secret: @client_secret,
          code: code,
          state: @state,
          grant_type: 'authorization_code',
          redirect_uri: @redirect_uri
        }

        response = request('POST', @token_url, body: body)
        if response && response['access_token']
          response['access_token']
        else
          log_error(message: 'Error obtaining Oauth access token', error_detail: response.inspect)
          nil
        end
      end

      def request(method, url, body: nil, headers: {})
        headers['Accept'] = 'application/json'

        response = Typhoeus::Request.new(
          url,
          method: method,
          ssl_verifypeer: true,
          timeout: 5,
          headers: headers,
          body: body
        ).run
        JSON.parse(response.body)
      rescue StandardError => e
        log_error(
          message: 'Error in Oauth request',
          exception: e,
          request: { method: method, url: url, body: body, headers: headers },
          response: { code: response.code, headers: response.headers, body: response.body, status: response.code },
        )
        nil
      end
    end
  end
end