Elgato_dark/ToolJet
1
0
Fork 0
mirror of https://github.com/ToolJet/ToolJet synced 2026-05-24 09:28:31 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Feature: Re-authenticate to Oauth services manually

Browse source
This commit is contained in:
navaneeth 2021-05-12 20:37:59 +05:30
parent ca2f7be194
commit e73c85a223
1 changed files with 23 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

41
app/controllers/data_sources_controller.rb
View file

@ -4,23 +4,7 @@ class DataSourcesController < ApplicationController
end end
def create def create
options = params[:options] options = fetch_oauth_options(params[:options])
# Fetch necessary access token if OAuth2 based data source
if options.find { |option| option['key'] == 'oauth2' }
provider = options.find { |option| option['key'] === 'provider' } ['value']
service_class = "#{provider.capitalize}OauthService".constantize
access_info = service_class.fetch_access_token(options.find { |option| option['key'] === 'code' } ['value'])
options.reject! { |option| option['key'] == 'code' }
access_info.each do |info|
option = {}
option['key'] = info[0]
option['value'] = info[1]
option['encrypted'] = true
options << option
end
end
options_to_save = {} options_to_save = {}
options.each do |option| options.each do |option|
@ -50,7 +34,7 @@ class DataSourcesController < ApplicationController
def update def update
@data_source = DataSource.find params[:id] @data_source = DataSource.find params[:id]
options = params[:options] options = fetch_oauth_options(params[:options])
options_to_save = {} options_to_save = {}
options.each do |option| options.each do |option|
@ -121,4 +105,25 @@ class DataSourcesController < ApplicationController
render json: { url: url } render json: { url: url }
end end
private
def fetch_oauth_options(options)
# Fetch necessary access token if OAuth2 based data source
if options.find { |option| option['key'] == 'oauth2' }
provider = options.find { |option| option['key'] === 'provider' } ['value']
service_class = "#{provider.capitalize}OauthService".constantize
access_info = service_class.fetch_access_token(options.find { |option| option['key'] === 'code' } ['value'])
options.reject! { |option| option['key'] == 'code' }
access_info.each do |info|
option = {}
option['key'] = info[0]
option['value'] = info[1]
option['encrypted'] = true
options << option
end
end
options
end
end end