playlists/mongo driver

.gitignore

@@ -6,6 +6,7 @@ lib-cov
 *.out
 *.pid
 *.gz
+*~
 
 pids
 logs

config.json

@@ -1,3 +1,3 @@
 {
-
+    "playlist_server": "mongo"
 }

drivers/playlists/conf/mongo-driver.json

@@ -0,0 +1,3 @@
+{
+    "load_time": 120
+}

drivers/playlists/db.js

@@ -0,0 +1,11 @@
+var db;
+exports.db = function(config) {
+    //var conf = require('config').MediaDB;
+    var conf = {
+        dbName: "mediadb",
+        dbHost: "localhost",
+        dbPort: 27017
+    };
+    db = require('mongoskin').db(conf.dbHost + ':' + conf.dbPort + '/' + conf.dbName + '?auto_reconnect', {safe:true});
+    return db;
+}

drivers/playlists/mongo-driver.js

@@ -0,0 +1,114 @@
+var config   = require("./conf/mongo-driver"),
+    Playlist = require('../../api/Playlist'),
+    Media    = require('../../api/Media'),
+    mubsub   = require("mubsub"),
+    moment   = require("moment");
+
+function mongo_driver() {
+    var self = this;
+
+    this.newPlaylistCallback    = undefined;
+    this.updatePlaylistCallback = undefined;
+    this.removePlaylistCallback = undefined;
+
+    console.log("mbc-mosto: [INFO] Creating mongodb playlists driver");
+
+    mongo_driver.prototype.start = function(config) {
+        var db = require('./db').db(config && config.db);
+        var client = mubsub(db);
+
+        var channel = client.channel('messages', { size: 10000000, max: 5000 });
+
+        self.scheds = db.collection('scheds');
+        self.lists = db.collection('lists');
+        self.readPlaylists();
+
+        channel.subscribe({channel: 'schedbackend', method: 'create'}, function(msg) {
+            if( self.inTime(msg.model) ) {
+                self.createPlaylist(msg.model, self.newPlaylistCallback);
+            }
+        });
+        channel.subscribe({channel: 'schedbackend', method: 'update'}, function(msg) {
+            self.createPlaylist(msg.model, self.updatePlaylistCallback);
+        });
+        channel.subscribe({channel: 'schedbackend', method: 'delete'}, function(msg) {
+            self.deletePlaylistCallback(msg.model._id);
+        });
+    };
+
+    mongo_driver.prototype.registerNewPlaylistListener = function(newPlaylistCallback) {
+        self.newPlaylistCallback = newPlaylistCallback;
+    };
+    mongo_driver.prototype.registerUpdatePlaylistListener = function(updatePlaylistCallback) {
+        self.updatePlaylistCallback = updatePlaylistCallback;
+    };
+    mongo_driver.prototype.registerRemovePlaylistListener = function(removePlaylistCallback) {
+        self.removePlaylistCallback = removePlaylistCallback;
+    };
+
+    mongo_driver.prototype.validTimes = function() {
+        var now = moment(new Date());
+        var until = moment(new Date());
+        until.add(config.load_time * 60 * 1000);
+        return {
+            from: now,
+            to: until
+        }
+    };
+
+    mongo_driver.prototype.inTime = function(sched) {
+        var boundaries = self.validTimes();
+        return (sched.start <= boundaries.to.unix() &&
+                sched.end >= boundaries.from.unix());
+    };
+
+    mongo_driver.prototype.readPlaylists =  function() {
+        // read playlists from the database
+
+        /*
+         * This should get the database's 'scheds' and 'lists' collections
+         * and turn them into a mosto.api.Playlist
+         */
+        //console.log("mbc-mosto: [INFO] Start reading playlists from " + config.playlists.to_read);
+        var boundaries = self.validTimes();
+        var now = boundaries.from;
+        var until = boundaries.to;
+        self.scheds.findEach({
+            start: { $lte: until.unix()},
+            end: { $gte: now.unix() }}, function(err, sched) {
+                if( err ) {
+                    console.log(err);
+                } else if( sched ) {
+                    console.log("Processing sched:", sched);
+                    self.createPlaylist(sched, self.newPlaylistCallback);
+                } else {
+                    console.log('Done');
+                }
+            });
+    };
+
+    mongo_driver.prototype.createPlaylist = function(sched, callback) {
+        self.lists.findById(sched.list, function(err, list) {
+            console.log("Processing list:", list);
+            var startDate = new Date(sched.start * 1000);
+            var endDate   = new Date(sched.end * 1000);
+            var name = (sched._id.toHexString && sched._id.toHexString()) || sched._id;
+
+            var medias = [];
+            list.models.forEach(function(block) {
+                // TODO: don't know what goes in type
+                var type = "default";
+                var file = block.file;
+                var length = block.durationraw;
+                var fps = block.fps;
+                medias.push(new Media(type, file, length, parseFloat(fps)));
+            });
+            callback(new Playlist(name, startDate, medias, endDate));
+        });
+    };
+}
+
+exports = module.exports = function() {
+    var driver = new mongo_driver();
+    return driver;
+};

drivers/playlists/playlists-driver.js

@@ -1,6 +1,7 @@
-var json_driver = require("./json-driver");
+var json_driver = require("./json-driver"),
+    mongo_driver = require("./mongo-driver");
 
-function playlists_driver(type) {
+function playlists_driver(type, config) {
     var self = this;
 
     this.driver                = undefined;
@@ -11,7 +12,9 @@ function playlists_driver(type) {
     console.log("mbc-mosto: [INFO] Creating playlists driver for type [" + type + "]");
 
     if (type === 'json') {
-        this.driver = new json_driver();
+        this.driver = new json_driver(config);
+    } else if (type === 'mongo') {
+        this.driver = new mongo_driver(config);
     } else {
         var err = new Error("mbc-mosto: [ERROR] Unknown type of driver [" + type + "]");
         console.error(err);
@@ -47,7 +50,7 @@ function playlists_driver(type) {
 
 }
 
-exports = module.exports = function(type) {
-    var driver = new playlists_driver(type);
+exports = module.exports = function(type, config) {
+    var driver = new playlists_driver(type, config);
     return driver;
 };

mosto.js

@@ -142,15 +142,16 @@ function mosto(configFile) {
     this.configFile = configFile;
     this.config     = false;
     this.playlists  = [];
-    this.server     = new mvcp_server("melted");
-    this.driver     = new playlists_driver("json");
 
     if (!this.configFile)
         this.configFile = './config.json';
 
     console.log("mbc-mosto: [INFO] Reading configuration from " + this.configFile);
 
     this.config = require(this.configFile);
+
+    this.server     = new mvcp_server("melted");
+    this.driver     = new playlists_driver(this.config.playlist_server);
 
     console.log("mbc-mosto: [INFO] Starting mbc-mosto... ") ;
 

package.json

@@ -23,7 +23,10 @@
         "underscore"  : "1.2.x",
         "node-uuid"   : "1.3.x",
         "xmlbuilder"  : "0.3.x",
-        "watchr"      : ">=2.3"
+        "watchr"      : ">=2.3",
+        "mubsub"      : "git://github.com/inaes-tic/mubsub.git",
+        "moment"      : "2.0.0",
+        "mongoskin"   : "0.4.x"
     },
     "devDependencies": {
         "mocha"    :  "1.7.x"