Elgato_dark/ToolJet
1
0
Fork 0
mirror of https://github.com/ToolJet/ToolJet synced 2026-05-23 17:08:34 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

[Google sheets] Refresh access token if expired

Browse source
This commit is contained in:
navaneeth 2021-05-13 10:29:37 +05:30
parent 3b87d0e26c
commit 3aa2b962fc
2 changed files with 29 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
app/services/google_oauth_service.rb
View file

@ -31,4 +31,30 @@ class GoogleOauthService
[['access_token', access_token], ['refresh_token', refresh_token]]
end
def self.refresh_access_token(refresh_token, data_source)
access_token_url = 'https://oauth2.googleapis.com/token'
client_id = ENV.fetch('GOOGLE_CLIENT_ID')
client_secret = ENV.fetch('GOOGLE_CLIENT_SECRET')
grant_type = 'refresh_token'
response = HTTParty.post(access_token_url,
body: { refresh_token: refresh_token,
client_id: client_id,
client_secret: client_secret,
grant_type: grant_type,
redirect_uri: "#{ENV.fetch('TOOLJET_HOST')}/oauth2/authorize"
}.to_json,
headers: { 'Content-Type' => 'application/json' })
result = JSON.parse(response.body)
access_token = result['access_token']
credential_id = data_source.options["access_token"]["credential_id"]
credential = Credential.find(credential_id)
credential.update(value: access_token)
access_token
end
end

6
app/services/googlesheets_query_service.rb
View file

@ -18,7 +18,7 @@ class GooglesheetsQueryService
result = read_data(access_token)
if result.code === 401
refresh_access_token
access_token = refresh_access_token
result = read_data(access_token)
end
@ -33,7 +33,7 @@ class GooglesheetsQueryService
headers.each_with_index do |header, index|
row[header] = value[index]
end
parsed_values << row
data << row
end
else
@ -62,6 +62,6 @@ class GooglesheetsQueryService
end
def refresh_access_token
GoogleOauthService.refresh_access_token(source_options['refresh_token'], @source )
end
end