|
@ -144,7 +144,7 @@ class Topics extends RedisModel {
|
|
|
})
|
|
|
}
|
|
|
}
|
|
|
ModelUtil.emitOK(self.eventEmitter, startMsgId);
|
|
|
ModelUtil.emitOK(self.eventEmitter, {"id":startMsgId});
|
|
|
}
|
|
|
}
|
|
|
|
|
@ -182,7 +182,7 @@ class Topics extends RedisModel {
|
|
|
if (err) {
|
|
|
ModelUtil.emitOK(self.eventEmitter, err);
|
|
|
} else {
|
|
|
ModelUtil.emitOK(self.eventEmitter, msgId);
|
|
|
ModelUtil.emitOK(self.eventEmitter, {"id":msgId});
|
|
|
TopicsRepo.endTopic(topicId, endUser, msg.date, msgId);
|
|
|
}
|
|
|
})
|