Jayden/AFFiNE-Mirror
0
0
Fork 0
mirror of https://github.com/toeverything/AFFiNE.git synced 2026-09-07 01:09:54 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: remove current workspaces

Browse Source
This commit is contained in:
MingLiang Wang
2023-01-09 10:37:40 +08:00
parent c8101dfa4c
commit 1124d14055
1 changed files with 9 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/data-center/src/datacenter.ts
+9 -27
View File
@@ -16,7 +16,6 @@ import { applyUpdate, encodeStateAsUpdate } from 'yjs';
*/ */
export class DataCenter { export class DataCenter {
private readonly _workspaces = new Workspaces(); private readonly _workspaces = new Workspaces();
private currentWorkspace: Workspace | null = null;
private readonly _logger = getLogger('dc'); private readonly _logger = getLogger('dc');
/** /**
* A mainProvider must exist as the only data trustworthy source. * A mainProvider must exist as the only data trustworthy source.
@@ -150,9 +149,8 @@ export class DataCenter {
const provider = this.providerMap.get(workspaceInfo.provider); const provider = this.providerMap.get(workspaceInfo.provider);
assert(provider, `provide '${workspaceInfo.provider}' is not registered`); assert(provider, `provide '${workspaceInfo.provider}' is not registered`);
this._logger(`Loading ${workspaceInfo.provider} workspace: `, workspaceId); this._logger(`Loading ${workspaceInfo.provider} workspace: `, workspaceId);
const workspace = this._getWorkspace(workspaceId);
this.currentWorkspace = await provider.warpWorkspace(workspace); return await provider.warpWorkspace(this._getWorkspace(workspaceId));
return this.currentWorkspace;
} }
/** /**
@@ -184,24 +182,23 @@ export class DataCenter {
*/ */
public async resetWorkspaceMeta( public async resetWorkspaceMeta(
{ name, avatar }: WorkspaceMeta, { name, avatar }: WorkspaceMeta,
workspace?: Workspace workspace: Workspace
) { ) {
const w = workspace ?? this.currentWorkspace; assert(workspace?.room, 'No workspace to set meta');
assert(w?.room, 'No workspace to set meta');
const update: Partial<WorkspaceMeta> = {}; const update: Partial<WorkspaceMeta> = {};
if (name) { if (name) {
w.meta.setName(name); workspace.doc.meta.setName(name);
update.name = name; update.name = name;
} }
if (avatar) { if (avatar) {
w.meta.setAvatar(avatar); workspace.doc.meta.setAvatar(avatar);
update.avatar = avatar; update.avatar = avatar;
} }
// may run for change workspace meta // may run for change workspace meta
const workspaceInfo = this._workspaces.find(w.room); const workspaceInfo = this._workspaces.find(workspace.room);
assert(workspaceInfo, 'Workspace not found'); assert(workspaceInfo, 'Workspace not found');
const provider = this.providerMap.get(workspaceInfo.provider); const provider = this.providerMap.get(workspaceInfo.provider);
provider?.updateWorkspaceMeta(w.room, update); provider?.updateWorkspaceMeta(workspace.room, update);
} }
/** /**
@@ -250,19 +247,6 @@ export class DataCenter {
} }
} }
/**
*
* do close current workspace
*/
public async closeCurrentWorkspace() {
assert(this.currentWorkspace?.room, 'No workspace to close');
const currentWorkspace = this._workspaces.find(this.currentWorkspace.room);
assert(currentWorkspace, 'Workspace not found');
const provider = this.providerMap.get(currentWorkspace.provider);
assert(provider, 'Provider not found');
await provider.closeWorkspace(currentWorkspace.id);
}
private async _transWorkspaceProvider( private async _transWorkspaceProvider(
workspace: Workspace, workspace: Workspace,
providerId: string providerId: string
@@ -296,9 +280,7 @@ export class DataCenter {
* Enable workspace cloud * Enable workspace cloud
* @param {string} id ID of workspace. * @param {string} id ID of workspace.
*/ */
public async enableWorkspaceCloud( public async enableWorkspaceCloud(workspace: Workspace) {
workspace: Workspace | null = this.currentWorkspace
) {
assert(workspace?.room, 'No workspace to enable cloud'); assert(workspace?.room, 'No workspace to enable cloud');
return await this._transWorkspaceProvider(workspace, 'affine'); return await this._transWorkspaceProvider(workspace, 'affine');
} }