delete docsusers database

git-svn-id: svn://192.168.3.15/activex/AVS/Sources/TeamlabOffice/trunk/nodeJSProjects@56369 954022d7-b5bf-4e40-9824-e11837661b57
This commit is contained in:
Alexander.Trofimov
2014-05-28 15:16:36 +00:00
parent fd96875138
commit c728527ef1
3 changed files with 7 additions and 25 deletions

View File

@ -218,11 +218,11 @@ function removeSaveChanges(id, deleteMessages) {
}
function getOriginalParticipantsId(docId) {
var result = [], tmpObject = {}, element;
var result = [], tmpObject = {}, elConnection;
for (var i = 0, length = connections.length; i < length; ++i) {
element = connections[i];
if (element.connection.docId === docId)
tmpObject[element.connection.userIdOriginal] = 1;
elConnection = connections[i].connection;
if (elConnection.docId === docId && false === elConnection.isViewer)
tmpObject[elConnection.userIdOriginal] = 1;
}
for(var name in tmpObject) if (tmpObject.hasOwnProperty(name))
result.push(name);
@ -342,10 +342,6 @@ exports.install = function (server, callbackFunction) {
arrsavelock[conn.docId] = undefined;
}
// Удаляем данного пользователя из базы данных
if (mysqlBase)
mysqlBase.deleteUser(conn.docId, conn.userId);
// Если у нас нет пользователей, то удаляем все сообщения
if (0 >= participants.length) {
// Очищаем предыдущий таймер
@ -620,10 +616,7 @@ exports.install = function (server, callbackFunction) {
//Kill previous connections
connections = _.reject(connections, function (el) {
var res = el.connection.sessionId === data.sessionId;//Delete this connection
if (res && mysqlBase)
mysqlBase.deleteUser(el.connection.docId, el.connection.userId);
return res;
return el.connection.sessionId === data.sessionId;//Delete this connection
});
conn.sessionId = data.sessionId;//restore old
@ -636,10 +629,6 @@ exports.install = function (server, callbackFunction) {
return {id: conn.connection.userId,
username: conn.connection.userName, color: conn.connection.userColor};});
// Добавляем данного пользователя в базу данных
if (mysqlBase)
mysqlBase.insertUser(conn.docId, conn.userIdOriginal, conn.userId);
sendStatusDocument(conn.docId, false);
sendData(conn,
@ -1007,12 +996,6 @@ exports.install = function (server, callbackFunction) {
callbackFunction ();
};
var callbackClearAllUsersMySql = function () {
if (mysqlBase)
mysqlBase.loadChanges(callbackLoadChangesMySql);
else
callbackLoadMessages(null);
};
var callbackLoadChangesMySql = function (arrayElements){
var createTimer = function (id, objProp) {
return setTimeout(function () {
@ -1051,7 +1034,7 @@ exports.install = function (server, callbackFunction) {
if (dataBase)
dataBase.load("messages", callbackLoadMessages);
else if (mysqlBase)
mysqlBase.clearAllUsers(callbackClearAllUsersMySql);
mysqlBase.loadChanges(callbackLoadChangesMySql);
else
callbackLoadMessages(null);
};

View File

@ -15,7 +15,6 @@
"pass" : "canvas_usr",
"charset" : "utf8",
"tableChangesName" : "docschanges",
"tableUsersName" : "docsusers",
"tableCallbacks" : "doccallbacks"
}
}

View File

@ -1 +1 @@
var config = require('./config.json');
var config = require('./config.json');