1
0
mirror of https://github.com/laurent22/joplin.git synced 2024-12-18 09:35:20 +02:00
joplin/packages/lib/services/synchronizer/tools.ts

49 lines
1.3 KiB
TypeScript
Raw Normal View History

import { SqlQuery } from '../../database';
import JoplinDatabase from '../../JoplinDatabase';
import BaseItem from '../../models/BaseItem';
import Setting from '../../models/Setting';
const SyncTargetRegistry = require('../../SyncTargetRegistry');
async function clearSyncContext() {
const syncTargetIds = SyncTargetRegistry.allIds();
for (const syncTargetId of syncTargetIds) {
const key = `sync.${syncTargetId}.context`;
if (!Setting.keyExists(key)) break;
Setting.resetKey(key);
}
await Setting.saveAll();
}
export async function clearLocalSyncStateForReupload(db: JoplinDatabase) {
const queries: SqlQuery[] = [
{ sql: 'DELETE FROM deleted_items' },
{ sql: 'DELETE FROM sync_items' },
];
await db.transactionExecBatch(queries);
await clearSyncContext();
}
export async function clearLocalDataForRedownload(db: JoplinDatabase) {
const queries: SqlQuery[] = [
{ sql: 'DELETE FROM deleted_items' },
{ sql: 'DELETE FROM sync_items' },
{ sql: 'DELETE FROM item_changes' },
{ sql: 'DELETE FROM note_resources' },
];
const syncItemTypes = BaseItem.syncItemTypes();
for (const syncItemType of syncItemTypes) {
const SyncItemClass = BaseItem.getClassByItemType(syncItemType);
queries.push({ sql: `DELETE FROM ${db.escapeField(SyncItemClass.tableName())}` });
}
await db.transactionExecBatch(queries);
await clearSyncContext();
}