store methods wip

checks.js

@@ -34,6 +34,12 @@ function hasZeroSubscribersBug() {
 }
 module.exports.hasZeroSubscribersBug = hasZeroSubscribersBug;
 
+function hasChannelStoreMethods() {
+  return hasFullSupport()
+    || (MAJOR === 19 && MINOR >= 9);
+}
+module.exports.hasChannelStoreMethods = hasChannelStoreMethods;
+
 // if Channel#unsubscribe() returns a boolean
 function hasChUnsubscribeReturn() {
   return (MAJOR >= 18) // 18.0, 19.0, etc.

dc-polyfill.js

@@ -27,6 +27,10 @@ if (!checks.hasChUnsubscribeReturn()) {
   require('./patch-channel-unsubscribe-return.js')(dc);
 }
 
+if (!checks.hasChannelStoreMethods()) {
+  require('./patch-channel-store-methods.js')(dc);
+}
+
 if (!checks.hasTracingChannel()) {
   require('./patch-tracing-channel.js')(dc);
 }

patch-channel-store-methods.js

@@ -0,0 +1,25 @@
+module.exports = function (dc) {
+  const channels = new WeakSet();
+
+  const dc_channel = dc.channel;
+
+  dc.channel = function() {
+    const ch = dc_channel.apply(this, arguments);
+
+    if (channels.has(ch)) return ch;
+
+    ch.bindStore = function() {
+      // TODO
+    };
+
+    ch.unbindStore = function() {
+      // TODO
+    };
+
+    ch.runStores = function() {
+      // TODO
+    };
+
+    return ch;
+  };
+};

patch-channel-unsubscribe-return.js

@@ -30,5 +30,5 @@ module.exports = function (dc) {
     channels.add(ch);
 
     return ch;
-  }
+  };
 };

patch-zero-subscriber-bug.js

@@ -40,7 +40,7 @@ module.exports = function (dc) {
     }
 
     channels.add(ch);
-  }
 
-  return ch;
+    return ch;
+  }
 };

test/basic.spec.js

@@ -23,6 +23,9 @@ test('channel tests', t => {
   t.ok(ch instanceof dc.Channel, 'dc.channel() return value instance of dc.Channel');
   t.strictEqual(dc.channel('foo'), dc.channel('foo'), 'multiple calls to dc.channel() return same channel instance');
   t.notEqual(dc.channel('foo'), dc.channel('bar'), 'calls to dc.channel() with different names return separate channel instances');
+  t.equal(typeof dc.channel('foo1').bindStore, 'function', 'provides Channel#bindStore()');
+  t.equal(typeof dc.channel('foo2').unbindStore, 'function', 'provides Channel#unbindStore()');
+  t.equal(typeof dc.channel('foo3').runStores, 'function', 'provides Channel#runStores()');
   t.end();
 });