Contents

module Mautic
  module Connections
    class Oauth2 < Mautic::Connection

      def client
        @client ||= OAuth2::Client.new(client_id, secret, {
          site: url,
          authorize_url: '/oauth/v2/authorize',
          token_url: '/oauth/v2/token',
          raise_errors: false
        })
      end

      def authorize
        client.auth_code.authorize_url(redirect_uri: callback_url)
      end

      def get_code(code)
        client.auth_code.get_token(code, redirect_uri: callback_url)
      end

      def connection
        @connection ||= OAuth2::AccessToken.new(client, token, { refresh_token: refresh_token })
      end

      def refresh!
        @connection = connection.refresh!
        update(token: @connection.token, refresh_token: @connection.refresh_token)
        @connection
      end

      def request(type, path, params = {})
        json = JSON.parse connection.request(type, path, params).body
        Array(json['errors']).each do |error|
          case error['code']
          when 400
            # Validation error
          when 401
            raise Mautic::TokenExpiredError.new(error['message']) if @try_to_refresh
            @try_to_refresh = true
            refresh!
            json = request(type, path, params)
          else
            raise Mautic::AuthorizeError.new("#{error['code']} - #{error['message']}")
          end
        end
        json
      end

      private

      def callback_url
        # return Mautic.config.oauth2_callback_url if Mautic.config.oauth2_callback_url
        uri = URI.parse(Mautic.config.base_url)
        uri.path = Mautic::Engine.routes.url_helpers.oauth2_connection_path(self)
        uri.to_s
      end

    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
mautic-1.0.1	app/models/mautic/connections/oauth2.rb
mautic-0.1.3	app/models/mautic/connections/oauth2.rb
mautic-0.1.2	app/models/mautic/connections/oauth2.rb
mautic-0.1.1	app/models/mautic/connections/oauth2.rb