86 lines
2.1 KiB
Ruby
86 lines
2.1 KiB
Ruby
class OauthCallbackController < ApplicationController
|
|
def show
|
|
@response = oauth_client.auth_code.get_token(
|
|
oauth_code,
|
|
redirect_uri: "#{base_url}/#{provider_name}/callback"
|
|
)
|
|
|
|
handle_response
|
|
::Redis::Alfred.delete(users_data['email'].downcase)
|
|
rescue StandardError => e
|
|
ChatwootExceptionTracker.new(e).capture_exception
|
|
redirect_to '/'
|
|
end
|
|
|
|
private
|
|
|
|
def find_or_create_inbox
|
|
channel_email = Channel::Email.find_by(email: users_data['email'], account: account)
|
|
# we need this value to know where to redirect on sucessful processing of the callback
|
|
channel_exists = channel_email.present?
|
|
|
|
channel_email ||= create_channel_with_inbox
|
|
update_channel(channel_email)
|
|
|
|
# reauthorize channel, this code path only triggers when microsoft auth is successful
|
|
# reauthorized will also update cache keys for the associated inbox
|
|
channel_email.reauthorized!
|
|
|
|
[channel_email.inbox, channel_exists]
|
|
end
|
|
|
|
def provider_name
|
|
raise NotImplementedError
|
|
end
|
|
|
|
def oauth_client
|
|
raise NotImplementedError
|
|
end
|
|
|
|
def update_channel(channel_email)
|
|
raise NotImplementedError
|
|
end
|
|
|
|
def create_channel_with_inbox
|
|
ActiveRecord::Base.transaction do
|
|
channel_email = Channel::Email.create!(email: users_data['email'], account: account)
|
|
account.inboxes.create!(
|
|
account: account,
|
|
channel: channel_email,
|
|
name: users_data['name'] || fallback_name
|
|
)
|
|
channel_email
|
|
end
|
|
end
|
|
|
|
def users_data
|
|
decoded_token = JWT.decode parsed_body[:id_token], nil, false
|
|
decoded_token[0]
|
|
end
|
|
|
|
def account_id
|
|
::Redis::Alfred.get(users_data['email'].downcase)
|
|
end
|
|
|
|
def account
|
|
@account ||= Account.find(account_id)
|
|
end
|
|
|
|
# Fallback name, for when name field is missing from users_data
|
|
def fallback_name
|
|
users_data['email'].split('@').first.parameterize.titleize
|
|
end
|
|
|
|
def oauth_code
|
|
params[:code]
|
|
end
|
|
|
|
def base_url
|
|
ENV.fetch('FRONTEND_URL', 'http://localhost:3000')
|
|
end
|
|
|
|
def parsed_body
|
|
@parsed_body ||= @response.response.parsed
|
|
end
|
|
end
|