bug/Timers being lost on shutdown due to a race condition in nats

lib/timer.js

@@ -201,26 +201,33 @@ timers.create(id, options, (err) => {
       debug('setting timer', id);
       //TODO(esatterwhite):
       // what should happen if leveldb fails.
-      if (err) console.error(err);
+      if (err) {
+        console.error(err);
+        cb(err, null);
+      }
       this.nats.publish('skyring:events', JSON.stringify({
         type: EVENT_STATUS.CREATED
       , timer: id
       , node: this[kNode]
       , created: data.created
       , payload: payload
-      }), noop);
-
-      data.timer = setTimeout(
-        transport
-      , payload.timeout - elapsed
-      , payload.callback.method
-      , payload.callback.uri
-      , payload.data
-      , id
-      , this
-      ).unref();
-      this.set( id, data );
-      cb(null, id);
+      }), (err) => {
+        if (err) {
+          console.error(err);
+          cb(err, null);
+        }
+        data.timer = setTimeout(
+          transport
+          , payload.timeout - elapsed
+          , payload.callback.method
+          , payload.callback.uri
+          , payload.data
+          , id
+          , this
+        ).unref();
+        this.set(id, data);
+        cb(null, id);
+      });
     });
   }
 
@@ -418,13 +425,17 @@ timers.success('2e2f6dad-9678-4caf-bc41-8e62ca07d551', error)
   }
 
   disconnect(cb = noop) {
-    this[storage].close(noop)
+    this[storage].close(noop);
     this.transports[shutdown](() => {
+      const client = this.nats;
       this.nats.publish('skyring:node', JSON.stringify({
         node: this[kNode]
       , type: EVENT_STATUS.SHUTDOWN
-      }), noop)
-      setImmediate(this.nats.quit, cb)
+      }), function() {
+        client.flush(function() {
+          setImmediate(client.quit, cb);
+        });
+      });
     });
   }