79 lines
2.5 KiB
Ruby
79 lines
2.5 KiB
Ruby
|
# frozen_string_literal: true
|
||
|
|
|
||
|
|
module BbbApi
|
||
|
|
RETURNCODE_SUCCESS = "SUCCESS"
|
||
|
|
|
||
|
|
def bbb_endpoint
|
||
|
|
Rails.configuration.bigbluebutton_endpoint
|
||
|
|
end
|
||
|
|
|
||
|
|
def bbb_secret
|
||
|
|
Rails.configuration.bigbluebutton_secret
|
||
|
|
end
|
||
|
|
|
||
|
|
# Sets a BigBlueButtonApi object for interacting with the API.
|
||
|
|
def bbb(user_provider)
|
||
|
|
if Rails.configuration.loadbalanced_configuration
|
||
|
|
user_domain = retrieve_provider_info(user_provider)
|
||
|
|
|
||
|
|
BigBlueButton::BigBlueButtonApi.new(remove_slash(user_domain["apiURL"]), user_domain["secret"], "0.8")
|
||
|
|
else
|
||
|
|
BigBlueButton::BigBlueButtonApi.new(remove_slash(bbb_endpoint), bbb_secret, "0.8")
|
||
|
|
end
|
||
|
|
end
|
||
|
|
|
||
|
|
# Rereives info from the loadbalanced in regards to a Provider (or tenant).
|
||
|
|
def retrieve_provider_info(provider, api = 'api', route = 'getUser')
|
||
|
|
# Include Omniauth accounts under the Greenlight provider.
|
||
|
|
raise "Provider not included." if !provider || provider.empty?
|
||
|
|
|
||
|
|
cached_provider = Rails.cache.fetch("#{provider}/#{route}")
|
||
|
|
# Return cached result if the value exists and cache is enabled
|
||
|
|
return cached_provider if !cached_provider.nil? && Rails.configuration.enable_cache
|
||
|
|
|
||
|
|
# Build the URI.
|
||
|
|
uri = encode_bbb_url(
|
||
|
|
"#{Rails.configuration.loadbalancer_endpoint}#{api}/",
|
||
|
|
Rails.configuration.loadbalancer_secret,
|
||
|
|
{ name: provider },
|
||
|
|
route
|
||
|
|
)
|
||
|
|
|
||
|
|
logger.info uri
|
||
|
|
|
||
|
|
# Make the request.
|
||
|
|
http = Net::HTTP.new(uri.host, uri.port)
|
||
|
|
http.use_ssl = (uri.scheme == 'https')
|
||
|
|
response = http.get(uri.request_uri)
|
||
|
|
|
||
|
|
# Parse XML.
|
||
|
|
doc = XmlSimple.xml_in(response.body, 'ForceArray' => false)
|
||
|
|
|
||
|
|
raise doc['message'] unless response.is_a?(Net::HTTPSuccess)
|
||
|
|
|
||
|
|
# Return the user credentials if the request succeeded on the loadbalancer.
|
||
|
|
Rails.cache.fetch("#{provider}/#{route}", expires_in: 1.hours) do
|
||
|
|
doc['user']
|
||
|
|
end
|
||
|
|
|
||
|
|
return doc['user'] if doc['returncode'] == 'SUCCESS'
|
||
|
|
|
||
|
|
raise "User with provider #{provider} does not exist." if doc['messageKey'] == 'noSuchUser'
|
||
|
|
raise "API call #{url} failed with #{doc['messageKey']}."
|
||
|
|
end
|
||
|
|
|
||
|
|
# Builds a request to retrieve credentials from the load balancer.
|
||
|
|
def encode_bbb_url(base_url, secret, params, route = 'getUser')
|
||
|
|
encoded_params = params.to_param
|
||
|
|
string = route + encoded_params + secret
|
||
|
|
checksum = OpenSSL::Digest.digest('sha1', string).unpack1('H*')
|
||
|
|
|
||
|
|
URI.parse("#{base_url}#{route}?#{encoded_params}&checksum=#{checksum}")
|
||
|
|
end
|
||
|
|
|
||
|
|
# Removes trailing forward slash from a URL.
|
||
|
|
def remove_slash(s)
|
||
|
|
s.nil? ? nil : s.chomp("/")
|
||
|
|
end
|
||
|
|
end
|