sails mongo topology was destroyed exception - sails-mongo/lib/collection.js

gistfile1.js

Collection.prototype.insert = function insert(values, cb) {                                                                                                                                                                                                                                
                                                                                                                                                                                                                                                                                           
  var self = this;                                                                                                                                                                                                                                                                         
                                                                                                                                                                                                                                                                                           
  // Normalize values to an array                                                                                                                                                                                                                                                          
  if(!Array.isArray(values)) values = [values];                                                                                                                                                                                                                                            
                                                                                                                                                                                                                                                                                           
  // Build a Document and add the values to a new array                                                                                                                                                                                                                                    
  var docs = values.map(function(value) {                                                                                                                                                                                                                                                  
    return new Document(value, self.schema).values;                                                                                                                                                                                                                                        
  });                                                                                                                                                                                                                                                                                      
                                                                                                                                                                                                                                                                                           
  this.connection.db.collection(this.identity).insert(docs, function(err, results) {                                                                                                                                                                                                       
    if(err) return cb(err);                                                                                                                                                                                                                                                                
    setTimeout(function() {                                                                                                                                                                                                                                                                
      cb(null, utils.rewriteIds(results.ops, self.schema));                                                                                                                                                                                                                                
    }, 10);                                                                                                                                                                                                                                                                                
  });                                                                                                                                                                                                                                                                                      
};