express - モデルが更新されたことをsocket.ioに認識させる方法

Question

私はMEAN/Mongoose/socket.ioに比較的慣れていないので、基本的なものと思われるものが欠けていますが、とにかく、前進するのを妨げています.

グループの会議を追跡しており、次のスキーマがあります。

'use strict';

var mongoose = require('mongoose'),
    Schema = mongoose.Schema;

var ScheduleSchema = new Schema({
  description: String,
  meetingPlace: String,
  office: String,
  start: { type: Date, default: Date.now },
  end: { type: Date, default: Date.now },
  participants: [{
    type: Schema.Types.ObjectId,
    ref: 'User'
  }],
  author: {
    type: Schema.Types.ObjectId,
    ref: 'User'
  },
  timestamp: { type: Date, default: Date.now },
  active: Boolean
});

ScheduleSchema.statics = {
  load: function(cb) {
    this.find({})
      .populate({path:'participants'})
      .exec(cb);
  }
};

module.exports = mongoose.model('Schedule', ScheduleSchema);

Schedule モデルで新しい項目を作成すると、次のコードで (クライアント側のコントローラーから) 動作が開始されます。

$http.post('/api/schedules', { description: info.description, participants: attendees, meetingPlace: info.meetingPlace, office: info.office, start: info.start, end: info.end, timestamp: new Date(), active: true });

そして、このコードのために：

'use strict';

var express = require('express');
var controller = require('./schedule.controller');

var router = express.Router();

router.get('/', controller.index);
router.get('/:id', controller.show);
router.post('/', controller.create);
router.put('/:id', controller.update);
router.patch('/:id', controller.update);
router.delete('/:id', controller.destroy);

module.exports = router;

リクエストは controller.create にルーティングされていると思います。これは次のとおりです。

'use strict';

var _ = require('lodash');
var Schedule = require('./schedule.model');

// Get list of schedules
exports.index = function(req, res) {
  Schedule.load(function (err, schedules) { /*.find*/
    if(err) { return handleError(res, err); }
    return res.json(200, schedules);
  });
};

// Get a single schedule
exports.show = function(req, res) {
  Schedule.findById(req.params.id, function (err, schedule) {
    if(err) { return handleError(res, err); }
    if(!schedule) { return res.send(404); }
    return res.json(schedule);
  });
};

// Creates a new schedule in the DB.
exports.create = function(req, res) {
  var promise = Schedule.create(req.body, function(err, schedule) {
    if(err) { return handleError(res, err); }
    return res.json(201, schedule);
  });
};

// Updates an existing schedule in the DB.
exports.update = function(req, res){
  var updatedMeeting = req.body;
  var id = updatedMeeting._id;
  delete updatedMeeting._id;
  Schedule.update({_id : id}, updatedMeeting, { }, function (err, numberAffected, raw) {
    if (err) return res.json(500, err);
    updatedMeeting._id = id;
    return res.json(201, updatedMeeting);
  });
};

// Deletes a schedule from the DB.
exports.destroy = function(req, res) {
  Schedule.findById(req.params.id, function (err, schedule) {
    if(err) { return handleError(res, err); }
    if(!schedule) { return res.send(404); }
    schedule.remove(function(err) {
      if(err) { return handleError(res, err); }
      return res.send(204);
    });
  });
};

function handleError(res, err) {
  return res.send(500, err);
}

exports.create が実行された後、方法はわかりませんが、何かがそれをここに送信します:

'use strict';

var Schedule = require('./schedule.model');

exports.register = function(socket) {
  Schedule.schema.post('save', function (doc) {
    onSave(socket, doc);
  });
  Schedule.schema.post('remove', function (doc) {
    onRemove(socket, doc);
  });
  Schedule.schema.post('update', function (doc) {
    onUpdate(socket, doc);
  });
}

function onSave(socket, doc, cb) {
  console.log('**********onSave**********');
  Schedule
    .findOne({ _id : doc._id })
    .populate('participants')
    .exec(function (err, event) {
      if (err) return handleError(err);
      socket.emit('schedule:save', event);
    });
}

function onRemove(socket, doc, cb) {
  socket.emit('schedule:remove', doc);
}

function onUpdate(socket, doc, cb) {
  console.log('**********onUpdate**********');
  socket.emit('schedule:update', doc);
}

および行 socket.emit('schedule:save', event); と呼ばれます。

これで問題ありませんが、Schedule モデルを更新すると、ソケットから「schedule:update」を発行できません。これは、このすぐ上のコード スニペットの「onUpdate」関数に到達しないためです。

クライアント側の呼び出しから始めます。

$http.patch('/api/schedules/' + info._id, { _id: info._id, description: info.description, participants: attendees, meetingPlace: info.meetingPlace, office: info.office, start: info.start, end: info.end, timestamp: new Date(), active: true });

ルーターはそれを exports.update に送信し、モデルは更新されますが、ソケットは何も発行しないため、接続されているすべてのクライアントは古いスケジュール情報を参照します。

モデルが更新されたことを socket.io に伝える方法と場所を教えてください。私が見逃しているのは、 Schedule.schema.post('some action... が exports.register 関数内でどのように呼び出されるかだと思いますが、私はこれをしばらく見ていて、手を使うことができました-ありがとう.