Officially remove firehose

balderdashy · Nov 1, 2016 · 86b8884 · 86b8884
1 parent 7a31a51
commit 86b8884
Show file tree

Hide file tree

Showing 4 changed files with 0 additions and 70 deletions.
diff --git a/lib/hooks/pubsub/drink.js b/lib/hooks/pubsub/drink.js
diff --git a/lib/hooks/pubsub/index.js b/lib/hooks/pubsub/index.js
@@ -724,9 +724,6 @@ module.exports = function(sails) {
         // If a request object was sent, get its socket, otherwise assume a socket was sent.
         var socketToOmit = (req && req.socket ? req.socket : req);
 
-        // In development environment, blast out a message to everyone
-        sails.sockets.publishToFirehose(data);
-
         data.verb = 'updated';
         data.previous = options.previous;
         delete data.model;
@@ -782,9 +779,6 @@ module.exports = function(sails) {
         // If a request object was sent, get its socket, otherwise assume a socket was sent.
         var socketToOmit = (req && req.socket ? req.socket : req);
 
-        // In development environment, blast out a message to everyone
-        sails.sockets.publishToFirehose(data);
-
         data.verb = 'destroyed';
         delete data.model;
 
@@ -917,16 +911,6 @@ module.exports = function(sails) {
         // If a request object was sent, get its socket, otherwise assume a socket was sent.
         var socketToOmit = (req && req.socket ? req.socket : req);
 
-
-        // In development environment, blast out a message to everyone
-        sails.sockets.publishToFirehose({
-          id: id,
-          model: this.identity,
-          verb: 'addedTo',
-          attribute: alias,
-          addedId: idAdded
-        });
-
         this.publish(id, this.identity, 'add:'+alias, (function (){
           var event = {
             id: id,
@@ -1013,15 +997,6 @@ module.exports = function(sails) {
         // If a request object was sent, get its socket, otherwise assume a socket was sent.
         var socketToOmit = (req && req.socket ? req.socket : req);
 
-        // In development environment, blast out a message to everyone
-        sails.sockets.publishToFirehose({
-          id: id,
-          model: this.identity,
-          verb: 'removedFrom',
-          attribute: alias,
-          removedId: idRemoved
-        });
-
         this.publish(id, this.identity, 'remove:' + alias, {
           id: id,
           verb: 'removedFrom',
@@ -1215,16 +1190,6 @@ module.exports = function(sails) {
         // If a request object was sent, get its socket, otherwise assume a socket was sent.
         var socketToOmit = (req && req.socket ? req.socket : req);
 
-        // Blast success message
-        sails.sockets.publishToFirehose({
-
-          model: this.identity,
-          verb: 'create',
-          data: values,
-          id: values[this.primaryKey]
-
-        });
-
         // Publish to classroom
         var payload = {
           verb: 'created',

diff --git a/lib/hooks/pubsub/spit.js b/lib/hooks/pubsub/spit.js
diff --git a/lib/hooks/pubsub/squirt.js b/lib/hooks/pubsub/squirt.js