infra
/
cryptpad
2
1
Fork 0
Code Issues Pull Requests Projects Releases 1 Activity

Use offline state per team and not global state

Browse Source
pull/1/head
yflory 4 years ago
parent b1f29678ca
commit ebd007fdb9
3 changed files with 61 additions and 19 deletions
Show Stats Download Patch File Download Diff File

23
www/common/outer/team.js
Unescape Escape View File

@ -57,11 +57,11 @@ define([
}); });
proxy.on('disconnect', function () { proxy.on('disconnect', function () {
team.offline = true; team.offline = true;
team.sendEvent('NETWORK_DISCONNECT'); team.sendEvent('NETWORK_DISCONNECT', team.id);
}); });
proxy.on('reconnect', function () { proxy.on('reconnect', function () {
team.offline = false; team.offline = false;
team.sendEvent('NETWORK_RECONNECT'); team.sendEvent('NETWORK_RECONNECT', team.id);
}); });
} }
proxy.on('change', [], function (o, n, p) { proxy.on('change', [], function (o, n, p) {
@ -931,7 +931,9 @@ define([
if (!team) { return void cb ({error: 'ENOENT'}); } if (!team) { return void cb ({error: 'ENOENT'}); }
if (!team.roster) { return void cb({error: 'NO_ROSTER'}); } if (!team.roster) { return void cb({error: 'NO_ROSTER'}); }
var state = team.roster.getState() || {}; var state = team.roster.getState() || {};
cb(state.metadata || {}); var md = state.metadata || {};
md.offline = team.offline;
cb(md);
}; };
var setTeamMetadata = function (ctx, data, cId, cb) { var setTeamMetadata = function (ctx, data, cId, cb) {
@ -1879,15 +1881,15 @@ define([
var t = Util.clone(teams); var t = Util.clone(teams);
Object.keys(t).forEach(function (id) { Object.keys(t).forEach(function (id) {
// If failure to load the team, don't send it // If failure to load the team, don't send it
if (ctx.teams[id]) { return; } if (ctx.teams[id]) {
t[id].offline = ctx.teams[id].offline;
return;
}
t[id].error = true; t[id].error = true;
}); });
cb(t); cb(t);
}; };
team.execCommand = function (clientId, obj, cb) { team.execCommand = function (clientId, obj, cb) {
if (ctx.store.offline) {
return void cb({ error: 'OFFLINE' });
}
var cmd = obj.cmd; var cmd = obj.cmd;
var data = obj.data; var data = obj.data;
@ -1911,30 +1913,36 @@ define([
return void setTeamMetadata(ctx, data, clientId, cb); return void setTeamMetadata(ctx, data, clientId, cb);
} }
if (cmd === 'OFFER_OWNERSHIP') { if (cmd === 'OFFER_OWNERSHIP') {
if (ctx.store.offline) { return void cb({ error: 'OFFLINE' }); }
return void offerOwnership(ctx, data, clientId, cb); return void offerOwnership(ctx, data, clientId, cb);
} }
if (cmd === 'ANSWER_OWNERSHIP') { if (cmd === 'ANSWER_OWNERSHIP') {
if (ctx.store.offline) { return void cb({ error: 'OFFLINE' }); }
return void answerOwnership(ctx, data, clientId, cb); return void answerOwnership(ctx, data, clientId, cb);
} }
if (cmd === 'DESCRIBE_USER') { if (cmd === 'DESCRIBE_USER') {
return void describeUser(ctx, data, clientId, cb); return void describeUser(ctx, data, clientId, cb);
} }
if (cmd === 'INVITE_TO_TEAM') { if (cmd === 'INVITE_TO_TEAM') {
if (ctx.store.offline) { return void cb({ error: 'OFFLINE' }); }
return void inviteToTeam(ctx, data, clientId, cb); return void inviteToTeam(ctx, data, clientId, cb);
} }
if (cmd === 'LEAVE_TEAM') { if (cmd === 'LEAVE_TEAM') {
return void leaveTeam(ctx, data, clientId, cb); return void leaveTeam(ctx, data, clientId, cb);
} }
if (cmd === 'JOIN_TEAM') { if (cmd === 'JOIN_TEAM') {
if (ctx.store.offline) { return void cb({ error: 'OFFLINE' }); }
return void joinTeam(ctx, data, clientId, cb); return void joinTeam(ctx, data, clientId, cb);
} }
if (cmd === 'REMOVE_USER') { if (cmd === 'REMOVE_USER') {
return void removeUser(ctx, data, clientId, cb); return void removeUser(ctx, data, clientId, cb);
} }
if (cmd === 'DELETE_TEAM') { if (cmd === 'DELETE_TEAM') {
if (ctx.store.offline) { return void cb({ error: 'OFFLINE' }); }
return void deleteTeam(ctx, data, clientId, cb); return void deleteTeam(ctx, data, clientId, cb);
} }
if (cmd === 'CREATE_TEAM') { if (cmd === 'CREATE_TEAM') {
if (ctx.store.offline) { return void cb({ error: 'OFFLINE' }); }
return void createTeam(ctx, data, clientId, cb); return void createTeam(ctx, data, clientId, cb);
} }
if (cmd === 'GET_EDITABLE_FOLDERS') { if (cmd === 'GET_EDITABLE_FOLDERS') {
@ -1947,6 +1955,7 @@ define([
return void getPreviewContent(ctx, data, clientId, cb); return void getPreviewContent(ctx, data, clientId, cb);
} }
if (cmd === 'ACCEPT_LINK_INVITATION') { if (cmd === 'ACCEPT_LINK_INVITATION') {
if (ctx.store.offline) { return void cb({ error: 'OFFLINE' }); }
return void acceptLinkInvitation(ctx, data, clientId, cb); return void acceptLinkInvitation(ctx, data, clientId, cb);
} }
}; };

53
www/teams/inner.js
Unescape Escape View File

@ -46,7 +46,9 @@ define([
Backup, Backup,
Messages) Messages)
{ {
var APP = {}; var APP = {
teams: {}
};
var driveAPP = {}; var driveAPP = {};
var saveAs = window.saveAs; var saveAs = window.saveAs;
//var SHARED_FOLDER_NAME = Messages.fm_sharedFolderName; //var SHARED_FOLDER_NAME = Messages.fm_sharedFolderName;
@ -211,6 +213,11 @@ define([
if (obj && obj.error) { if (obj && obj.error) {
return void UI.warn(Messages.error); return void UI.warn(Messages.error);
} }
// Refresh offline state
APP.teams[APP.team] = APP.teams[APP.team] || {};
APP.teams[APP.team].offline = obj.offline;
common.displayAvatar($avatar, obj.avatar, obj.name); common.displayAvatar($avatar, obj.avatar, obj.name);
$category.append($avatar); $category.append($avatar);
$avatar.append(h('span.cp-sidebarlayout-category-name', obj.name)); $avatar.append(h('span.cp-sidebarlayout-category-name', obj.name));
@ -333,6 +340,11 @@ define([
}); });
APP.drive = drive; APP.drive = drive;
driveAPP.refresh = drive.refresh; driveAPP.refresh = drive.refresh;
if (APP.teams[id] && APP.teams[id].offline) {
setEditable(false);
drive.refresh();
}
}); });
}; };
@ -406,7 +418,18 @@ define([
content.push(h('h3', Messages.team_listTitle + ' ' + slots)); content.push(h('h3', Messages.team_listTitle + ' ' + slots));
var metadataMgr = common.getMetadataMgr();
var privateData = metadataMgr.getPrivateData();
var teams = privateData.teams || {};
APP.teams = {};
keys.forEach(function (id) { keys.forEach(function (id) {
if (!obj[id].empty) {
APP.teams[id] = {
offline: obj[id] && obj[id].offline
};
}
var team = obj[id]; var team = obj[id];
if (team.empty) { if (team.empty) {
list.push(h('div.cp-team-list-team.empty', [ list.push(h('div.cp-team-list-team.empty', [
@ -1433,27 +1456,37 @@ define([
} }
}); });
var onDisconnect = function (noAlert) { var teams = privateData.teams || {};
var onDisconnect = function (teamId) {
if (APP.team && teamId && APP.team !== teamId) { return; }
setEditable(false); setEditable(false);
if (APP.team && driveAPP.refresh) { driveAPP.refresh(); } if (APP.team && driveAPP.refresh) { driveAPP.refresh(); }
toolbar.failed(); toolbar.failed();
if (!noAlert) { UIElements.disconnectAlert(); } UIElements.disconnectAlert();
}; };
var onReconnect = function () { var onReconnect = function (teamId) {
if (APP.team && teamId && APP.team !== teamId) { return; }
setEditable(true); setEditable(true);
if (APP.team && driveAPP.refresh) { driveAPP.refresh(); } if (APP.team && driveAPP.refresh) { driveAPP.refresh(); }
toolbar.reconnecting(); toolbar.reconnecting();
UIElements.reconnectAlert(); UIElements.reconnectAlert();
}; };
sframeChan.on('EV_DRIVE_LOG', function (msg) { sframeChan.on('EV_DRIVE_LOG', function (data) {
UI.log(msg); UI.log(data.msg);
}); });
sframeChan.on('EV_NETWORK_DISCONNECT', function () { sframeChan.on('EV_NETWORK_DISCONNECT', function (teamId) {
onDisconnect(); onDisconnect(teamId);
if (teamId && APP.teams[teamId]) {
APP.teams[teamId].offline = true;
}
}); });
sframeChan.on('EV_NETWORK_RECONNECT', function () { sframeChan.on('EV_NETWORK_RECONNECT', function (teamId) {
onReconnect(); onReconnect(teamId);
if (teamId && APP.teams[teamId]) {
APP.teams[teamId].offline = false;
}
}); });
common.onLogout(function () { setEditable(false); }); common.onLogout(function () { setEditable(false); });
}); });

4
www/teams/main.js
Unescape Escape View File

@ -85,10 +85,10 @@ define([
sframeChan.event('EV_'+obj.data.ev, obj.data.data); sframeChan.event('EV_'+obj.data.ev, obj.data.data);
} }
if (obj.data.ev === 'NETWORK_RECONNECT') { if (obj.data.ev === 'NETWORK_RECONNECT') {
sframeChan.event('EV_NETWORK_RECONNECT'); sframeChan.event('EV_NETWORK_RECONNECT', obj.data.data);
} }
if (obj.data.ev === 'NETWORK_DISCONNECT') { if (obj.data.ev === 'NETWORK_DISCONNECT') {
sframeChan.event('EV_NETWORK_DISCONNECT'); sframeChan.event('EV_NETWORK_DISCONNECT', obj.data.data);
} }
}); });

Write Preview
Loading…
Cancel
Save