forked from External/greenlight
103 lines
3.1 KiB
Ruby
Executable File
103 lines
3.1 KiB
Ruby
Executable File
#!/usr/bin/ruby
|
|
|
|
##################################################################
|
|
# Make sure the dependencies of gems are met
|
|
#
|
|
# gem install jwt
|
|
# gem install java_properties
|
|
##################################################################
|
|
|
|
#
|
|
# Example of a post publish script to send an event to GreenLight
|
|
# whenever a recording is published in the BigBlueButton server.
|
|
#
|
|
# Uses the same data format and checksum calculation method used by
|
|
# the webhooks module.
|
|
#
|
|
|
|
require "trollop"
|
|
require "net/http"
|
|
require "jwt"
|
|
require "java_properties"
|
|
require "json"
|
|
require "digest/sha1"
|
|
require "uri"
|
|
require File.expand_path('../../../lib/recordandplayback', __FILE__)
|
|
|
|
logger = Logger.new("/var/log/bigbluebutton/post_process.log", 'weekly')
|
|
logger.level = Logger::INFO
|
|
BigBlueButton.logger = logger
|
|
|
|
opts = Trollop::options do
|
|
opt :meeting_id, "Meeting id to archive", :type => String
|
|
end
|
|
meeting_id = opts[:meeting_id]
|
|
|
|
meeting_metadata = BigBlueButton::Events.get_meeting_metadata("/var/bigbluebutton/recording/raw/#{meeting_id}/events.xml")
|
|
|
|
BigBlueButton.logger.info("Post Process: Recording Notify for [#{meeting_id}] starts")
|
|
|
|
begin
|
|
callback_url = meeting_metadata["gl-webhooks-callback-url"]
|
|
|
|
unless callback_url.nil?
|
|
BigBlueButton.logger.info("Making callback for recording ready notification")
|
|
|
|
props = JavaProperties::Properties.new("/var/lib/tomcat7/webapps/bigbluebutton/WEB-INF/classes/bigbluebutton.properties")
|
|
secret = props[:securitySalt]
|
|
|
|
timestamp = Time.now.to_i
|
|
event = {
|
|
"header": {
|
|
"name": "publish_ended"
|
|
},
|
|
"payload":{
|
|
"metadata": meeting_metadata,
|
|
"meeting_id": meeting_id
|
|
}
|
|
}
|
|
payload = {
|
|
event: event,
|
|
timestamp: timestamp
|
|
}
|
|
|
|
checksum_str = "#{callback_url}#{payload.to_json}#{secret}"
|
|
checksum = Digest::SHA1.hexdigest(checksum_str)
|
|
BigBlueButton.logger.info("Got checksum #{checksum} for #{checksum_str}")
|
|
|
|
separator = URI.parse(callback_url).query ? "&" : "?"
|
|
uri = URI.parse("#{callback_url}#{separator}checksum=#{checksum}")
|
|
http = Net::HTTP.new(uri.host, uri.port)
|
|
http.use_ssl = (uri.scheme == 'https')
|
|
|
|
request = Net::HTTP::Post.new(uri.request_uri, 'Content-Type' => 'application/json')
|
|
request.body = payload.to_json
|
|
BigBlueButton.logger.info("Posted event to #{callback_url}")
|
|
|
|
response = http.request(request)
|
|
code = response.code.to_i
|
|
|
|
if code == 410
|
|
BigBlueButton.logger.info("Notified for deleted meeting: #{meeting_id}")
|
|
# TODO: should we automatically delete the recording here?
|
|
elsif code == 404
|
|
BigBlueButton.logger.warn("404 error when notifying for recording: #{meeting_id}, ignoring")
|
|
elsif code < 200 || code >= 300
|
|
BigBlueButton.logger.debug("Callback HTTP request failed: #{response.code} #{response.message} (code #{code})")
|
|
else
|
|
BigBlueButton.logger.debug("Recording notifier successful: #{meeting_id} (code #{code})")
|
|
end
|
|
|
|
else
|
|
BigBlueButton.logger.info("Blank callback URL, aborting.")
|
|
end
|
|
|
|
rescue => e
|
|
BigBlueButton.logger.info("Rescued")
|
|
BigBlueButton.logger.info(e.to_s)
|
|
end
|
|
|
|
BigBlueButton.logger.info("Post Process: Recording Notify ends")
|
|
|
|
exit 0
|
|
|