How to emit event in mongoose middleware?

在 Mongoose 中，我们可以通过定义中间件（middleware），也称为 pre 和 post 钩子（hooks），来在数据库操作执行前后触动事件。Mongoose 支持 document 中间件和 query 中间件，这些中间件可以在执行如 save, remove, find, update 等操作时触发。

定义 Document 中间件

Document 中间件适用于单个文档的操作。比如，在保存文档之前或之后执行某些动作。以下是一个示例，展示如何在保存文档前后打印消息：

javascript
const mongoose = require('mongoose');
const { Schema } = mongoose;

const userSchema = new Schema({
  name: String,
  email: String
});

// Pre-save 中间件
userSchema.pre('save', function(next) {
  console.log('A user document is about to be saved.');
  next();
});

// Post-save 中间件
userSchema.post('save', function(doc) {
  console.log(`User ${doc.name} was saved.`);
});

const User = mongoose.model('User', userSchema);

const newUser = new User({ name: 'Alice', email: 'alice@example.com' });
newUser.save(); // 这将触发上面定义的 pre 和 post save 钩子

定义 Query 中间件

Query 中间件适用于查询操作。比如在执行查询操作前后添加逻辑。下面是一个示例，展示如何在查询后添加一个日志：

javascript
userSchema.post('find', function(docs) {
  console.log(`Found ${docs.length} documents.`);
});

// 当调用 User.find() 时，将触发上述 post-find 钩子
User.find({ name: 'Alice' }, (err, docs) => {
  if (err) throw err;
  // 查询完成后，也会打印文档数量
});

触发自定义事件

如果需要触发自定义事件，可以使用 Node.js 的 events 模块来创建和触发事件。以下是一个扩展上述示例的方式：

javascript
const events = require('events');
const eventEmitter = new events.EventEmitter();

// 定义一个事件处理器
const myEventHandler = () => {
  console.log('Custom event triggered!');
};

// 绑定事件和事件处理器
eventEmitter.on('saved', myEventHandler);

// 触发事件
userSchema.post('save', function() {
  eventEmitter.emit('saved');
});

const anotherUser = new User({ name: 'Bob', email: 'bob@example.com' });
anotherUser.save(); // 除了触发 save 钩子，还会触发自定义事件

通过这种方式，我们可以在 Mongoose 中间件中添加复杂的逻辑，甚至是跨应用程序的事件通信。这使得代码更加模块化和可重用。