Class: Signet::OAuth2::Client

Inherits:
Object
  • Object
show all
Defined in:
lib/googleauth/signet.rb

Overview

Signet::OAuth2::Client creates an OAuth2 client

This reopens Client to add #apply and #apply! methods which update a hash with the fetched authentication token.

Instance Method Summary collapse

Instance Method Details

#apply(a_hash, opts = {}) ⇒ Object

Returns a clone of a_hash updated with the authentication token



42
43
44
45
46
# File 'lib/googleauth/signet.rb', line 42

def apply a_hash, opts = {}
  a_copy = a_hash.clone
  apply! a_copy, opts
  a_copy
end

#apply!(a_hash, opts = {}) ⇒ Object

Updates a_hash updated with the authentication token



33
34
35
36
37
38
39
# File 'lib/googleauth/signet.rb', line 33

def apply! a_hash, opts = {}
  # fetch the access token there is currently not one, or if the client
  # has expired
  token_type = target_audience ? :id_token : :access_token
  fetch_access_token! opts if send(token_type).nil? || expires_within?(60)
  a_hash[AUTH_METADATA_KEY] = "Bearer #{send token_type}"
end

#build_default_connectionObject



79
80
81
82
83
84
85
86
87
# File 'lib/googleauth/signet.rb', line 79

def build_default_connection
  if !defined?(@connection_info)
    nil
  elsif @connection_info.respond_to? :call
    @connection_info.call
  else
    @connection_info
  end
end

#configure_connection(options) ⇒ Object



26
27
28
29
30
# File 'lib/googleauth/signet.rb', line 26

def configure_connection options
  @connection_info =
    options[:connection_builder] || options[:default_connection]
  self
end

#fetch_access_token!(options = {}) ⇒ Object



60
61
62
63
64
65
66
67
68
69
70
# File 'lib/googleauth/signet.rb', line 60

def fetch_access_token! options = {}
  unless options[:connection]
    connection = build_default_connection
    options = options.merge connection: connection if connection
  end
  info = retry_with_error do
    orig_fetch_access_token! options
  end
  notify_refresh_listeners
  info
end

#notify_refresh_listenersObject



72
73
74
75
76
77
# File 'lib/googleauth/signet.rb', line 72

def notify_refresh_listeners
  listeners = defined?(@refresh_listeners) ? @refresh_listeners : []
  listeners.each do |block|
    block.call self
  end
end

#on_refresh(&block) ⇒ Object



54
55
56
57
# File 'lib/googleauth/signet.rb', line 54

def on_refresh &block
  @refresh_listeners = [] unless defined? @refresh_listeners
  @refresh_listeners << block
end

#orig_fetch_access_token!Object



59
# File 'lib/googleauth/signet.rb', line 59

alias orig_fetch_access_token! fetch_access_token!

#retry_with_error(max_retry_count = 5) ⇒ Object



89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
# File 'lib/googleauth/signet.rb', line 89

def retry_with_error max_retry_count = 5
  retry_count = 0

  begin
    yield
  rescue StandardError => e
    raise e if e.is_a?(Signet::AuthorizationError) || e.is_a?(Signet::ParseError)

    if retry_count < max_retry_count
      retry_count += 1
      sleep retry_count * 0.3
      retry
    else
      msg = "Unexpected error: #{e.inspect}"
      raise Signet::AuthorizationError, msg
    end
  end
end

#updater_procObject

Returns a reference to the #apply method, suitable for passing as a closure



50
51
52
# File 'lib/googleauth/signet.rb', line 50

def updater_proc
  proc { |a_hash, opts = {}| apply a_hash, opts }
end