fix: add gettoken on affine provider

This commit is contained in:
DiamondThree
2023-02-02 18:30:36 +08:00
parent 82c261767f
commit fca165c672
4 changed files with 12 additions and 5 deletions
+1 -2
View File
@@ -17,7 +17,6 @@ import { getLogger } from './logger';
import { createBlocksuiteWorkspace } from './utils/index.js'; import { createBlocksuiteWorkspace } from './utils/index.js';
import { MessageCenter } from './message'; import { MessageCenter } from './message';
import { WorkspaceUnit } from './workspace-unit'; import { WorkspaceUnit } from './workspace-unit';
import { token } from './provider/affine/apis/token';
/** /**
* @class DataCenter * @class DataCenter
* @classdesc Data center is made for managing different providers for business * @classdesc Data center is made for managing different providers for business
@@ -169,7 +168,7 @@ export class DataCenter {
const params: StoreOptions = {}; const params: StoreOptions = {};
if (provider.id === 'affine') { if (provider.id === 'affine') {
params.blobOptionsGetter = (k: string) => params.blobOptionsGetter = (k: string) =>
({ api: '/api/workspace', token: token.token }[k]); ({ api: '/api/workspace', token: provider.getToken() }[k]);
} else { } else {
params.blobOptionsGetter = (k: string) => undefined; params.blobOptionsGetter = (k: string) => undefined;
} }
@@ -360,6 +360,10 @@ export class AffineProvider extends BaseProvider {
await this._apis.updateWorkspace({ id, public: isPublish }); await this._apis.updateWorkspace({ id, public: isPublish });
} }
public override getToken(): string {
return this._apis.token.token;
}
public override async getUserByEmail( public override async getUserByEmail(
workspace_id: string, workspace_id: string,
email: string email: string
@@ -82,7 +82,7 @@ export const migrateBlobDB = async (
return [id, { id, blob }] as [string, PendingTask]; return [id, { id, blob }] as [string, PendingTask];
}); });
await newPendingDB.setMany(pendingEntries); await newPendingDB.setMany(pendingEntries);
// FIXME: delete old db
await oldDB.deleteDB(); // await oldDB.deleteDB();
await oldPendingDB.deleteDB(); // await oldPendingDB.deleteDB();
}; };
@@ -64,6 +64,10 @@ export class BaseProvider {
return; return;
} }
public getToken(): string {
return '';
}
/** /**
* warp workspace with provider functions * warp workspace with provider functions
* @param workspace * @param workspace