0

我对 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);
}

在 export.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 没有发出任何东西，所以所有连接的客户端都会看到旧的调度信息。

我如何以及在哪里可以将模型已更新的信息传递给 socket.io？我认为我缺少的是如何在 export.register 函数中调用 Schedule.schema.post('some action... ，但我已经研究了一段时间并且可以使用手 - 谢谢。

4

0 回答 0