MissingSchemaError при использовании библиотеки mongoose-наблюдателя

Question

У меня есть типичное приложение Node.js, экспресс, mongoDB и mongoose.

Я пытаюсь реализовать библиотеку-обозреватель mongoose, чтобы прослушивать изменения на моем mongodb. Смотрите сайт: https://www.npmjs.com/package/mongoose-observer

При добавлении этого кода (почти так же, как приведенный пример):

mongooseObserver.register('MessageModel', 'create', function(newMessage) {
    console.log("New Message!");
    console.log(newMessage);
});

Я получаю следующую ошибку:

    node_1     | /home/app/chat/node_modules/mongoose/lib/index.js:362
    node_1     |       throw new mongoose.Error.MissingSchemaError(name);
    node_1     |       ^
    nodered_1  | 28 Mar 07:32:11 - [info] Starting flows
    mongo_1    | 2017-03-28T07:32:04.562+0000 I NETWORK  [thread1] waiting for connections on port 27017
    node_1     | MissingSchemaError: Schema hasn't been registered for model "MessageModel".
    node_1     | Use mongoose.model(name, schema)
    node_1     |     at Mongoose.model (/home/app/chat/node_modules/mongoose/lib/index.js:362:13)
    node_1     |     at registerPre (/home/app/chat/node_modules/mongoose-observer/index.js:9:27)
    node_1     |     at Object.register (/home/app/chat/node_modules/mongoose-observer/index.js:38:9)
    node_1     |     at module.exports (/home/app/chat/app/routes.js:35:22)
    node_1     |     at Object.<anonymous> (/home/app/chat/server.js:83:24)
    node_1     |     at Module._compile (module.js:409:26)
    node_1     |     at Object.Module._extensions..js (module.js:416:10)
    node_1     |     at Module.load (module.js:343:32)
    node_1     |     at Function.Module._load (module.js:300:12)
    node_1     |     at Function.Module.runMain (module.js:441:10)
    node_1     |     at startup (node.js:134:18)
    node_1     |     at node.js:962:3
    mongo_1    | 2017-03-28T07:32:11.604+0000 I NETWORK  [thread1] connection accepted from 172.25.0.1:51800 #1 (1 connection now open)

Эта ошибка возникает только при добавлении кода Mongoose-Observer, без этого работает просто отлично.

Другой код, который может иметь отношение

var mongooseObserver = require('mongoose-observer');
var mongoose         = require('mongoose');
var bcrypt           = require('bcrypt'),
    SALT_WORK_FACTOR = 10;

mongoose.connect('mongodb://mongo:27017/LoRaMessages'); //database name

var messageSchema = mongoose.Schema({
    DevEUI: String,
    LoRaPayload: String,
    Header: String,
    Longitude: Number,
    Latitude: Number,
    PDOP: Number,
    TMG: Number,
    SOG: Number,
    Temparature: Number,
    Time: String,
    ServerTime: Number,
    type: String,
    deviceType: String,
    batteryLevel: String,
    JoinedAndBeeperStatus: String,
    EnabledFlags: Number,
    AlarmFlags: Number,
    T_Temp: Number,
    H_Humi: Number,
    One_Temp: Number, 
    Two_Temp: Number,
    _msgid: String        
});

var MessageModel = mongoose.model('loramessages', messageSchema);  //collection name

mongooseObserver.register('MessageModel', 'create', function(newMessage) { //it fails on this line
    console.log("New Message!");
    console.log(newMessage);
});

Я знаю, что эта библиотека не используется многими людьми, но, возможно, я упускаю что-то очевидное.

Я видел другой пост, содержащий эту ошибку, но, похоже, есть другая проблема, поскольку это происходит только при реализации конкретного кода библиотеки.

Любая помощь приветствуется.

РЕДАКТИРОВАТЬ: В то время как ответ @Love-Kesh был правильным. Я обнаружил, что эта библиотека предназначена только для прослушивания изменений из Node.js, внешние данные не обнаружены.

Answer 1

Передайте 'loramessages' вместо 'MessageModel' в Observer.register

Если вы используете save для создания нового элемента, он не сработает, используйте Model.create({}) для создания новой записи.

// Попробуем сохранить там прослушиватель событий Save

Observer.register('loramessages', 'save', function(createdUser){
    // this callback will be executed when a new user is created
    // Do something here, for example, send a email to the created user
  });