|
@ -22,6 +22,12 @@ const SESSION_TYPES = require('../../include/commons').SESSION_TYPES;
|
|
|
class Topics extends RedisModel {
|
|
|
constructor() {
|
|
|
super();
|
|
|
}
|
|
|
|
|
|
getTopics(user){
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
/**
|
|
@ -162,8 +168,8 @@ class Topics extends RedisModel {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
saveTopicToMySQL(topicName, topicId, sessionId, messageId, date, description) {
|
|
|
TopicsRepo.saveTopic(topicName, topicId, sessionId, messageId, date, description);
|
|
|
saveTopicToMySQL(topicName, topicId, sessionId, messageId, date, description,status) {
|
|
|
TopicsRepo.saveTopic(topicName, topicId, sessionId, messageId, date, description,status);
|
|
|
}
|
|
|
|
|
|
/**
|
|
@ -230,7 +236,7 @@ class Topics extends RedisModel {
|
|
|
ModelUtil.emitOK(self.eventEmitter, err);
|
|
|
} else {
|
|
|
ModelUtil.emitOK(self.eventEmitter, {"id": msgId});
|
|
|
TopicsRepo.endTopic(topicId, endUser, msg.date, msgId);
|
|
|
TopicsRepo.endTopic(topicId, endUser, msg.date, msgId,TOPIC_STATUS.ENDED);
|
|
|
}
|
|
|
})
|
|
|
}
|