45 lines
1.3 KiB
JavaScript
Executable File
45 lines
1.3 KiB
JavaScript
Executable File
var request = require('request'),
|
|
redis = require("redis"),
|
|
subscriber = redis.createClient(),
|
|
client = redis.createClient();
|
|
|
|
subscriber.on("subscribe", function (channel, count) {
|
|
console.log("subscribed to " + channel);
|
|
});
|
|
|
|
subscriber.on("message", function (channel, message) {
|
|
var properties;
|
|
|
|
try {
|
|
properties = JSON.parse(message);
|
|
} catch (e) {
|
|
// An error has occured, handle it, by e.g. logging it
|
|
console.log(e);
|
|
}
|
|
|
|
if(properties != undefined){
|
|
client.lrange("meeting:" + properties.meetingID + ":subscriptions:" + properties.event, 0, -1, function(error,reply){
|
|
reply.forEach(function (sid, index) {
|
|
console.log(sid);
|
|
client.hgetall("meeting:" + properties.meetingID + ":subscription:" + sid, function(err,rep){
|
|
if(rep.active == "true"){
|
|
var post_options = {
|
|
uri: rep.callbackURL,
|
|
method: 'POST',
|
|
json: properties
|
|
};
|
|
|
|
request(post_options, function (error, response, body) {
|
|
if (!error && response.statusCode == 200) {
|
|
console.log(body.id) // Print the shortened url.
|
|
}
|
|
});
|
|
}
|
|
});
|
|
});
|
|
});
|
|
}
|
|
|
|
});
|
|
|
|
subscriber.subscribe("bigbluebutton:events"); |