2016-02-26 88 views
1

我是新来的猫鼬作为更新Mongo的方法。我正在使用nmap来映射我的网络,并提供一些关于服务器和端口的可见性(作为较大策略的一部分)。这一部分策略alos从CHEF和vSphere中提取信息,这些信息都在GUI中链接在一起。这些部分只是简单的单级对象,并且工作正常,但是NMAP部分具有父/子对象模型。该对象模型有一个Server对象和一个Port对象 - 两者都添加了onOn和updatedOn日期。Mongoose Pre保存挂钩父对象不执行

不幸的是,预存储的mongoose钩子只会触发子对象(每个对象)而不是父对象 - 尽管父对象正在保存。 我真的希望父对象也有addedOn和updatedOn日期。我似乎无法弄清楚。在此先感谢

一个免责声明,下面的代码被剪掉了一个用民间故事,ramda和点自由形式写的大型应用程序。

5.1的NodeJS,猫鼬4.4.1

的port.js文件

const mongoose = require('mongoose'); 

const Schema = mongoose.Schema, 
    ObjectId = Schema.ObjectId; 

const PortSchema = new Schema({ 
    id    : ObjectId, 
    port    : String, 
    protocol   : String, 
    application  : String, 
    addedOn   : { type: Date, default: Date.now, setDefaultsOnInsert: true }, 
    updatedOn  : { type: Date, default: Date.now } 
}); 

PortSchema.pre('save', function(next){ 
    this.update({},{ 
     $set: { 
      updatedOn: new Date() 
     } 
    }) 
    next(); 
}); 

module.exports.model = mongoose.model('Port', PortSchema) 
module.exports.schema = PortSchema 

的server.js文件

const mongoose = require('mongoose'); 
const PortSchema = require('./port').schema 

const Schema = mongoose.Schema, 
    ObjectId = Schema.ObjectId; 

const ServerSchema = new Schema({ 
    id    : ObjectId, 
    address   : String, 
    addressType  : String, 
    ports   : [PortSchema], 
    addedOn   : { type: Date, default: Date.now, setDefaultsOnInsert: true }, 
    updatedOn  : { type: Date, default: Date.now } 
}); 

ServerSchema.pre('save', function(next){ 
    this.update({},{ 
     $set: { 
      updatedOn: new Date() 
     } 
    }) 
    next(); 
}); 


module.exports.model = mongoose.model('Server', ServerSchema) 
module.exports.schema = ServerSchema 

的Upsert代码在我的应用

// nmapUpsert :: (criteria, {}) => Task {ok :: int, ...} 
const nmapUpsert = adapt.findOneAndUpdate(Server) 


// persist :: [{address :: string, ...}] => [Task {ok :: int, ...}] 
const persistNmap = R.map((data) => { 
    return nmapUpsert({ "address": data.address }, data) 
}) 

这是我的模型 - >任务UPSERT适配器(adapt.findOneAndUpdate)

module.exports.findOneAndUpdate = (originalModel) => { 
    return (criteria, record) => { 

     return new Task((reject, resolve) => { 
      const callback = (error, updatedModel) => { 
       if (error) { 
        reject(error) 
       } 
       else { 
        if(!updatedModel) { 
         resolve(null) 
        }else { 
         // this looks to be required to apply defaults from the Schema 
         updatedModel.save((error) => { 
          if (error) { 
           reject(error) 
          } 
          resolve(updatedModel) 
         }) 
        } 

       } 
      } 

      originalModel.findOneAndUpdate(criteria, record, {upsert: true}, callback) 
     }) 

    } 
} 

不可否认的是最后一个函数是有点cludgy - 但我只是想弄清楚这之前,我清理。

+0

'预save'钩不上'update'运行。你应该可以添加一个'更新前'钩子。让我知道这是否有效。 – Mike

+0

@Mike更新挂钩无法正常工作,但我将Server.js上的挂钩更改为“findOneAndUpdate”挂钩,而且似乎可以在该层上工作。现在底层端口不更新。我需要调查一下。 – akaphenom

回答

0

如果我改变钩子findOneAndUpdate我会得到更好的行为。服务器将insertOn(和updatedOn)上的addedOn对象化,然后只更新updatedOn。 Unforutnately整个Ports对象集合被取代 - 即使在更新时 - 并且addedOn和updatedOn都会在此时更新。

的port.js文件

const mongoose = require('mongoose'); 

const Schema = mongoose.Schema, 
    ObjectId = Schema.ObjectId; 

const PortSchema = new Schema({ 
    id    : ObjectId, 
    port    : String, 
    protocol   : String, 
    application  : String, 
    addedOn   : { type: Date, default: Date.now, setDefaultsOnInsert: true }, 
    updatedOn  : { type: Date, default: Date.now } 
}); 

PortSchema.pre('findOneAndUpdate', function(next){ 
    this.update({},{ 
     $set: { 
      updatedOn: new Date() 
     } 
    }) 
    next(); 
}); 

module.exports.model = mongoose.model('Port', PortSchema) 
module.exports.schema = PortSchema 

的server.js文件

const mongoose = require('mongoose'); 
const PortSchema = require('./port').schema 

const Schema = mongoose.Schema, 
    ObjectId = Schema.ObjectId; 

const ServerSchema = new Schema({ 
    id    : ObjectId, 
    address   : String, 
    addressType  : String, 
    ports   : [PortSchema], 
    addedOn   : { type: Date, default: Date.now, setDefaultsOnInsert: true }, 
    updatedOn  : { type: Date, default: Date.now } 
}); 

ServerSchema.pre('findOneAndUpdate', function(next){ 
    this.update({},{ 
     $set: { 
      updatedOn: new Date() 
     } 
    }) 
    next(); 
}); 


module.exports.model = mongoose.model('Server', ServerSchema) 
module.exports.schema = ServerSchema