|
@ -253,7 +253,7 @@ class Sessions extends RedisModel {
|
|
|
return;
|
|
|
}
|
|
|
start_msg_id = res[0];
|
|
|
self.getMessagesByPage(sessionId, user, startMsgId, endMsgId, page, pagesize, function (err, res) {
|
|
|
self.getMessagesByPage(sessionId, user, start_msg_id, end_msg_id, page, pagesize, function (err, res) {
|
|
|
if (err) {
|
|
|
logger.error("getMessagesByPage error" + err);
|
|
|
ModelUtil.emitError(self.eventEmitter, err, err);
|
|
@ -473,6 +473,7 @@ class Sessions extends RedisModel {
|
|
|
if (err) {
|
|
|
ModelUtil.emitError(self.eventEmitter, {message: "Failed to save message to mysql: " + err});
|
|
|
} else {
|
|
|
message.timestamp = message.timestamp.getTime();
|
|
|
ModelUtil.emitOK(self.eventEmitter, {count: 1, messages: [message]});
|
|
|
}
|
|
|
});
|