Do not forward $SYS topics for +/# subscriptions.

Fixes: #135

aedes.js

@@ -200,8 +200,12 @@ function DoEnqueues () {
   }
 }
 
+// + is 43
+// # is 35
 function removeSharp (sub) {
-  return sub.topic !== '#'
+  var code = sub.topic.charCodeAt(0)
+  console.log(sub.topic, code)
+  return code !== 43 && code !== 35
 }
 
 function doEnqueue (sub, done) {

lib/handlers/subscribe.js

@@ -100,7 +100,7 @@ function subTopic (sub, done) {
       break
   }
 
-  if (sub.topic === '#') {
+  if (isWildcardThatMatchesSys(sub.topic)) {
     func = blockSys(func)
   }
 
@@ -118,6 +118,13 @@ function subTopic (sub, done) {
   }
 }
 
+// + is 43
+// # is 35
+function isWildcardThatMatchesSys (topic) {
+  var code = topic.charCodeAt(0)
+  return code === 43 || code === 35
+}
+
 function completeSubscribe (err) {
   var packet = this.packet
   var client = this.client

test/events.js

@@ -40,6 +40,25 @@ test('does not forward $SYS topics to # subscription', function (t) {
   })
 })
 
+test('does not forward $SYS topics to +/# subscription', function (t) {
+  t.plan(4)
+  var s = connect(setup())
+
+  subscribe(t, s, '+/#', 0, function () {
+    s.outStream.once('data', function (packet) {
+      t.fail('no packet should be received')
+    })
+
+    s.broker.mq.emit({
+      cmd: 'publish',
+      topic: '$SYS/hello',
+      payload: 'world'
+    }, function () {
+      t.pass('nothing happened')
+    })
+  })
+})
+
 test('does not store $SYS topics to QoS 1 # subscription', function (t) {
   t.plan(3)