Working server-to-client refreshes.

client/helpers.js

@@ -1,3 +1,4 @@
+Meteor._debug("Loading client/helpers", CHANNEL_NAME, EVENT_NAME);
 Meteor.startup(function () {
   // Helper names have to be well-formed JS identifiers, so they cannot use a
   // "namespace.symbol" format... but a "namespace$symbol" is usable.

client/sso.js

@@ -1,4 +1,5 @@
 // Write your package code here!
+Meteor._debug("Loading client/sso", CHANNEL_NAME, EVENT_NAME);
 
 Meteor.startup(function () {
   var sso = new DrupalSSO();

lib/constants.js

@@ -0,0 +1,4 @@
+Meteor._debug("Loading lib/constants");
+
+CHANNEL_NAME = 'drupal-sso:refresh';
+EVENT_NAME = 'drupal-sso:userRefresh';

lib/drupalsso.js

@@ -1,3 +1,10 @@
+
+Meteor._debug("Loading lib/drupalsso");
+
+if (Meteor.isClient) {
+  var stream = new Meteor.Stream(CHANNEL_NAME);
+}
+
 /**
  * The SSO constructor.
  *
@@ -21,6 +28,7 @@ DrupalSSO = function () {
   // Work around "this" interpretation in local scope methods.
   var that = this;
 
+
   this.settings = {
     client: {}
   };
@@ -61,6 +69,13 @@ DrupalSSO = function () {
    * @param {string} cookies
    */
   this.updateUser = function (cookies) {
+    if (Meteor.isClient) {
+      Meteor._debug('Setting up once on ' + CHANNEL_NAME);
+      // Just listen once, since we rearm immediately.
+      stream.once(EVENT_NAME, function (e) {
+        that.updateUser(document.cookie);
+      });
+    }
     Meteor.call('drupal-sso.whoami', cookies, function (err, res) {
       if (err) {
         throw new Meteor.Error('whoami', err);

package.js

@@ -8,11 +8,15 @@ Package.describe({
 
 Package.onUse(function(api) {
   api.versionsFrom('1.1.0.3');
+  api.use('arunoda:streams');
+  api.use('webapp');
 
+  api.addFiles('lib/constants.js');
   api.addFiles('lib/drupalsso.js');
   api.addFiles('client/helpers.js', 'client');
   api.addFiles('client/sso.js', 'client');
   api.addFiles('server/sso.js', 'server');
+  api.addFiles('server/web.js', 'server');
 
   api.export('DrupalSSO');
 });

server/sso.js

@@ -1,5 +1,9 @@
+Meteor._debug("Loading server/sso");
+
 // Cause an error on startup if the Drupal server is unreachable.
 Meteor.startup(function () {
+  Meteor._debug("Startup server/sso", CHANNEL_NAME, EVENT_NAME);
+
   sso = new DrupalSSO();
   sso.initServerState(Meteor.settings);
 

server/web.js

@@ -0,0 +1,22 @@
+Meteor._debug("Loading server/web");
+
+Meteor.startup(function () {
+  Meteor._debug("Startup server/sso", CHANNEL_NAME, EVENT_NAME);
+  var stream = new Meteor.Stream(CHANNEL_NAME);
+
+  WebApp.connectHandlers.use('/updateUser', function (req, res, next) {
+    res.writeHead(200);
+    res.end('Send refresh request');
+    Meteor._debug('Emitting refresh request.');
+    stream.emit(EVENT_NAME);
+  });
+
+  WebApp.connectHandlers.use('/updateUserDeferred', function (req, res, next) {
+    res.writeHead(200);
+    res.end('Send refresh request');
+    Meteor.setTimeout(function () {
+      Meteor._debug('Emitting refresh request.');
+      stream.emit(EVENT_NAME);
+    }, 1000);
+  });
+});