beenull/ente
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

add entity sync logs

Browse source
This commit is contained in:
Abhinav 2023-07-25 11:41:07 +05:30
parent cfc89be734
commit b6b6aa84c6
1 changed files with 10 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
apps/photos/src/services/entityService.ts
View file

@ -14,6 +14,7 @@ import {
EncryptedEntity,
} from 'types/entity';
import { getLatestVersionEntities } from 'utils/entity';
import { addLogLine } from 'utils/logging';
const ENDPOINT = getEndpoint();
@ -105,10 +106,14 @@ export const syncEntities = async () => {
}
};
const syncEntity = async <T>(type: EntityType): Promise<Entity<T>> => {
const syncEntity = async <T>(type: EntityType): Promise<void> => {
try {
let entities = await getLocalEntity(type);
let entities = await getLocalEntity<T>(type);
addLogLine(
`Syncing ${type} entities localEntitiesCount: ${entities.length}`
);
let syncTime = await getEntityLastSyncTime(type);
addLogLine(`Syncing ${type} entities syncTime: ${syncTime}`);
let response: EntitySyncDiffResponse;
do {
response = await getEntityDiff(type, syncTime);
@ -152,6 +157,9 @@ const syncEntity = async <T>(type: EntityType): Promise<Entity<T>> => {
}
await localForage.setItem(ENTITY_TABLES[type], nonDeletedEntities);
await localForage.setItem(ENTITY_SYNC_TIME_TABLES[type], syncTime);
addLogLine(
`Syncing ${type} entities nonDeletedEntitiesCount: ${nonDeletedEntities.length}`
);
} while (response.hasMore);
} catch (e) {
logError(e, 'Sync entity failed');