chore: add performance logger

This commit is contained in:
李华桥
2023-11-10 00:25:15 +08:00
committed by LongYinan
parent 927a6489f9
commit 09c3a8828f
10 changed files with 79 additions and 3 deletions

View File

@@ -1,3 +1,4 @@
import { DebugLogger } from '@affine/debug';
import { createIndexeddbStorage } from '@blocksuite/store';
import {
createIndexedDBDatasource,
@@ -12,6 +13,7 @@ import { createCloudBlobStorage } from '../blob/cloud-blob-storage';
import { createAffineDataSource } from '.';
import { CRUD } from './crud';
const performanceLogger = new DebugLogger('performance:sync');
let abortController: AbortController | undefined;
const downloadRootFromIndexedDB = async (
@@ -29,9 +31,13 @@ const downloadRootFromIndexedDB = async (
};
export async function startSync() {
performanceLogger.info('start');
abortController = new AbortController();
const signal = abortController.signal;
const workspaces = await CRUD.list();
performanceLogger.info('CRUD list');
const syncDocPromises = workspaces.map(workspace =>
downloadRootFromIndexedDB(
workspace.id,
@@ -40,6 +46,8 @@ export async function startSync() {
)
);
await Promise.all(syncDocPromises);
performanceLogger.info('all sync promise');
const syncPromises = workspaces.map(workspace => {
const remoteDataSource = createAffineDataSource(
workspace.id,
@@ -104,6 +112,7 @@ export async function startSync() {
});
});
await Promise.all([...syncPromises, ...syncBlobPromises]);
performanceLogger.info('sync done');
}
export async function stopSync() {

View File

@@ -1,3 +1,4 @@
import { DebugLogger } from '@affine/debug';
import type { WorkspaceAdapter } from '@affine/env/workspace';
import { WorkspaceFlavour } from '@affine/env/workspace';
import type { BlockHub } from '@blocksuite/blocks';
@@ -12,6 +13,8 @@ import { z } from 'zod';
import { getOrCreateWorkspace } from './manager';
const performanceJotaiLogger = new DebugLogger('performance:jotai');
const rootWorkspaceMetadataV1Schema = z.object({
id: z.string(),
flavour: z.nativeEnum(WorkspaceFlavour),
@@ -80,6 +83,8 @@ type FetchMetadata = (
* @internal
*/
const fetchMetadata: FetchMetadata = async (get, { signal }) => {
performanceJotaiLogger.info('fetch metadata start');
const WorkspaceAdapters = get(workspaceAdaptersAtom);
assertExists(WorkspaceAdapters, 'workspace adapter should be defined');
const metadata: RootWorkspaceMetadata[] = [];
@@ -120,6 +125,7 @@ const fetchMetadata: FetchMetadata = async (get, { signal }) => {
once: true,
});
});
performanceJotaiLogger.info('migration done');
}
metadata.push(...loadFromLocalStorage());
@@ -131,11 +137,15 @@ const fetchMetadata: FetchMetadata = async (get, { signal }) => {
);
for (const Adapter of Adapters) {
performanceJotaiLogger.info('%s adapter', Adapter.flavour);
const { CRUD, flavour: currentFlavour } = Adapter;
if (
Adapter.Events['app:access'] &&
!(await Adapter.Events['app:access']())
) {
performanceJotaiLogger.info('%s app:access', Adapter.flavour);
// skip the adapter if the user doesn't have access to it
const removed = metadata.filter(
meta => meta.flavour === currentFlavour
@@ -148,6 +158,7 @@ const fetchMetadata: FetchMetadata = async (get, { signal }) => {
}
try {
const item = await CRUD.list();
performanceJotaiLogger.info('%s CRUD list', Adapter.flavour);
// remove the metadata that is not in the list
// because we treat the workspace adapter as the source of truth
{
@@ -179,6 +190,7 @@ const fetchMetadata: FetchMetadata = async (get, { signal }) => {
} catch (e) {
console.error('list data error:', e);
}
performanceJotaiLogger.info('%s service:start', Adapter.flavour);
Adapter.Events['service:start']?.();
}
}
@@ -195,7 +207,7 @@ const fetchMetadata: FetchMetadata = async (get, { signal }) => {
}
});
const result = Array.from(metadataMap.values());
console.info('metadata', result);
performanceJotaiLogger.info('fetch metadata done', result);
return result;
};