Coerce ids in other publish* methods (pubsub hook)

lib/hooks/pubsub/index.js

@@ -741,6 +741,15 @@ module.exports = function(sails) {
           this.beforePublishDestroy(id, req, options);
         }
 
+        // Coerce id to match the attribute type of the primary key of the model
+        try {
+          var pkAttrDef = this.attributes[this.primaryKey];
+          if (pkAttrDef.type === 'integer') {  id = +id; }
+          else if (pkAttrDef.type === 'string') { id = id+''; }
+        }
+        catch(e){
+          // well... worth a shot
+        }
 
         var data = {
           model: this.identity,
@@ -975,6 +984,16 @@ module.exports = function(sails) {
           this.beforePublishRemove(id, alias, idRemoved, req);
         }
 
+        // Coerce id to match the attribute type of the primary key of the model
+        try {
+          var pkAttrDef = this.attributes[this.primaryKey];
+          if (pkAttrDef.type === 'integer') {  id = +id; }
+          else if (pkAttrDef.type === 'string') { id = id+''; }
+        }
+        catch(e){
+          // well... worth a shot
+        }
+
         // If a request object was sent, get its socket, otherwise assume a socket was sent.
         var socketToOmit = (req && req.socket ? req.socket : req);
 
@@ -1054,6 +1073,16 @@ module.exports = function(sails) {
 
         var id = values[this.primaryKey];
 
+        // Coerce id to match the attribute type of the primary key of the model
+        try {
+          var pkAttrDef = this.attributes[this.primaryKey];
+          if (pkAttrDef.type === 'integer') {  id = +id; }
+          else if (pkAttrDef.type === 'string') { id = id+''; }
+        }
+        catch(e){
+          // well... worth a shot
+        }
+
         // If any of the added values were association attributes, publish add or remove messages.
         _.each(values, function(val, key) {