Added sockets plugin, which bridges eve -> socket.io

assets/client/bridge-deckjs.js

@@ -1,3 +1,17 @@
 $(function() {
     $.deck('.slide');
+
+    function relayEvents(evt, from, to) {
+        eve('deck.goto', DECKEM, to);
+    } // relayEvents
+
+    eve.on('deck.goto', function(index, remote) {
+        if (remote) {
+            $(document).unbind('deck.change');
+            $.deck('go', index);
+            $(document).bind('deck.change', relayEvents);
+        } // if
+    });
+
+    $(document).bind('deck.change', relayEvents);
 });

assets/plugins/sockets.js

@@ -0,0 +1,34 @@
+DECKEM.Sockets = (function() {
+
+    var reSock = /^sock\:.*$/i;
+
+    /* exports */
+
+    function connect(server) {
+        if (typeof io != 'undefined') {
+            console.log('attempting connection to: ' + server);
+
+            var socket = io.connect(server);
+            socket.on('connect', function() {
+                eve.on('deck.*', function() {
+                    // get the last argument
+                    var lastArg = arguments.length ? arguments[arguments.length - 1] : null;
+
+                    // if the last arg is a socket connection, then don't send it to the serve
+                    // because we got it from the server...
+                    if ((! lastArg) || (! reSock.test(lastArg))) {
+                        socket.emit.apply(socket, ['event', eve.nt()].concat(Array.prototype.slice.call(arguments, 0)));
+                    } // if
+                });
+
+                socket.on('event', function(evtName) {
+                    eve.apply(eve, [evtName, DECKEM].concat(Array.prototype.slice.call(arguments, 1)));
+                });
+            });
+        }
+    } // connext
+
+    return {
+        connect: connect
+    };
+})();

assets/templates/default/layout.jade

@@ -28,8 +28,8 @@ html
 
         script(src='#{clientpath}deckem.js')
 
-        - plugins.forEach(function(plugin) {
-          script(src='#{clientpath}deckem-#{plugin}.js')
+        - scripts.forEach(function(pluginScript) {
+          script= pluginScript
         - })
 
         script(src='#{clientpath}bridge-#{bridge}.js')

build.js

@@ -17,6 +17,12 @@ interleave('src', {
     config: config
 });
 
+interleave('src/plugins', {
+    multi: 'pass', 
+    path: 'assets/plugins',
+    config: config
+});
+
 // build each of the themse
 interleave('src/themes', {
     multi: 'pass',

lib/actions/build.js

@@ -11,20 +11,22 @@ function compile(builder, deckPath, template, opts, callback) {
 
     fs.readFile(targetFile, 'utf8', function(err, data) {
         if (! err) {
-            var deck = jade.compile(data, {
-                    filename: targetFile
-                }),
-                deckContent = deck(opts),
-                templateOutput = template(_.extend({
-                    bridge: 'deckjs',
-                    deck: deckContent,
-                    title: 'Untitled Deck',
-                    theme: 'default',
-                    includes: [],
-                    plugins: []
-                }, opts));
-
-            fs.writeFile(outputFile, templateOutput);
+            loadPlugins(builder, opts.plugins || {}, function(scripts, includes) {
+                var deck = jade.compile(data, {
+                        filename: targetFile
+                    }),
+                    deckContent = deck(opts),
+                    templateOutput = template(_.extend({
+                        bridge: 'deckjs',
+                        deck: deckContent,
+                        title: 'Untitled Deck',
+                        theme: 'default',
+                        scripts: scripts || [],
+                        includes: includes || []
+                    }, opts));
+
+                fs.writeFile(outputFile, templateOutput);
+            });
         } // if
 
         callback();
@@ -72,6 +74,8 @@ function findDecks(builder, targetPath, config, callback) {
                 builder.out('!{red}Error parsing deck config @ {0}', configFile);
             } // try..catch
         } // if
+
+        // load the required plugins
 
         // read the contents of the directory
         fs.readdir(targetPath, function(err, files) {
@@ -105,6 +109,47 @@ function getClientPath(targetPath, basePath) {
     return clientPath;
 } // getClientPath
 
+function loadPlugins(builder, plugins, callback) {
+
+    var scripts = [], includes = [];
+
+    function loadPlugin(plugin, loadCallback) {
+        var pluginLoader;
+
+        try {
+            pluginLoader = require(path.resolve(__dirname, '../plugins/' + plugin));
+        }
+        catch (e) {
+            builder.out('!{red}Could not load plugin: {0}', plugin);
+        } // try..catch
+
+        if (pluginLoader) {
+            pluginLoader.call(pluginLoader, builder, plugins[plugin], function(newScripts, newIncludes) {
+                if (newScripts) {
+                    scripts = scripts.concat(newScripts);
+                } // if
+
+                if (newIncludes) {
+                    includes = includes.concat(newIncludes);
+                } // if
+
+                loadCallback();
+            });
+        }
+        else {
+            loadCallback();
+        } // if..else
+    } // loadPlugin
+
+    console.log('loading plugins: ' + _(plugins).keys());
+
+    async.forEach(_(plugins).keys(), loadPlugin, function() {
+        if (callback) {
+            callback(scripts, includes);
+        } // if
+    });
+} // loadPlugins
+
 function loadTemplate(templatePath, callback) {
     var layoutFile = path.join(templatePath, 'layout.jade');
 

lib/plugins/sockets.js

@@ -0,0 +1,20 @@
+var fs = require('fs'),
+    reTrailingSlash = /\/$/;
+
+module.exports = function(builder, opts, callback) {
+    // initialise options
+    opts = opts || {};
+
+    // initialise the server to the default shared deckem server (which doesn't exist, btw)
+    opts.server = (opts.server || 'http://deckem.com').replace(reTrailingSlash, '');
+
+    // load the sockets plugin text
+    fs.readFile(builder.getAssetPath('plugins/sockets.js'), 'utf8', function(err, data) {
+        if (! err) {
+            callback([data, 'DECKEM.Sockets.connect(\'' + opts.server + '\')'], opts.server + '/socket.io/socket.io.js');
+        }
+        else {
+            callback();
+        } // if..else
+    });
+};

src/bridge-deckjs.js

@@ -1,3 +1,17 @@
 $(function() {
     $.deck('.slide');
+
+    function relayEvents(evt, from, to) {
+        eve('deck.goto', DECKEM, to);
+    } // relayEvents
+
+    eve.on('deck.goto', function(index, remote) {
+        if (remote) {
+            $(document).unbind('deck.change');
+            $.deck('go', index);
+            $(document).bind('deck.change', relayEvents);
+        } // if
+    });
+
+    $(document).bind('deck.change', relayEvents);
 });

src/plugins/sockets.js

@@ -0,0 +1,34 @@
+DECKEM.Sockets = (function() {
+
+    var reSock = /^sock\:.*$/i;
+
+    /* exports */
+
+    function connect(server) {
+        if (typeof io != 'undefined') {
+            console.log('attempting connection to: ' + server);
+
+            var socket = io.connect(server);
+            socket.on('connect', function() {
+                eve.on('deck.*', function() {
+                    // get the last argument
+                    var lastArg = arguments.length ? arguments[arguments.length - 1] : null;
+
+                    // if the last arg is a socket connection, then don't send it to the serve
+                    // because we got it from the server...
+                    if ((! lastArg) || (! reSock.test(lastArg))) {
+                        socket.emit.apply(socket, ['event', eve.nt()].concat(Array.prototype.slice.call(arguments, 0)));
+                    } // if
+                });
+
+                socket.on('event', function(evtName) {
+                    eve.apply(eve, [evtName, DECKEM].concat(Array.prototype.slice.call(arguments, 1)));
+                });
+            });
+        }
+    } // connext
+
+    return {
+        connect: connect
+    };
+})();