Foundry376/Mailspring
1
1
Fork 0
mirror of https://github.com/Foundry376/Mailspring.git synced 2024-11-11 01:54:40 +08:00
Code Issues Projects Releases Packages Wiki Activity

[local-sync] Add global dbs and cleanup orphan messages

Browse source
This commit is contained in:
Evan Morikawa 2016-12-07 16:36:52 -08:00
parent 878735f52e
commit d161a30a34
2 changed files with 19 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
packages/local-sync/src/local-sync-worker/sync-process-manager.js
View file

@ -1,3 +1,4 @@
const _ = require('underscore')
const SyncWorker = require('./sync-worker');
const LocalDatabaseConnector = require('../shared/local-database-connector')
@ -28,9 +29,13 @@ class SyncProcessManager {
this._workers = {};
this._listenForSyncsClient = null;
this._exiting = false;
this._accounts = []
this._logger = global.Logger.child();
}
/**
* Useful for debugging.
*/
async start() {
this._logger.info(`ProcessManager: Starting with ID`)
@ -41,6 +46,10 @@ class SyncProcessManager {
}
}
accounts() { return this._accounts }
workers() { return _.values(this._workers) }
dbs() { return this.workers().map(w => w._db) }
wakeWorkerForAccount(account) {
this._workers[account.id].syncNow();
}
@ -53,6 +62,7 @@ class SyncProcessManager {
if (this._workers[account.id]) {
throw new Error("Local worker already exists");
}
this._accounts.push(account)
this._workers[account.id] = new SyncWorker(account, db, this);
this._logger.info({account_id: account.id}, `ProcessManager: Claiming Account Succeeded`)
} catch (err) {
@ -68,4 +78,6 @@ class SyncProcessManager {
}
}
module.exports = new SyncProcessManager()
window.syncProcessManager = new SyncProcessManager();
window.dbs = window.syncProcessManager.dbs.bind(window.syncProcessManager)
module.exports = window.syncProcessManager

6
packages/local-sync/src/local-sync-worker/sync-worker.js
View file

@ -236,6 +236,7 @@ class SyncWorker {
await this.runNewSyncbackRequests();
await this._conn.runOperation(new FetchFolderList(this._account.provider, this._logger));
await this.syncMessagesInAllFolders();
await this.cleanupOrpahnMessages();
await this.onSyncDidComplete();
} catch (error) {
this.onSyncError(error);
@ -245,6 +246,11 @@ class SyncWorker {
}
}
async cleanupOrpahnMessages() {
const orphans = await this._db.Message.findAll({where: {folderId: null}})
return Promise.map(orphans, (msg) => msg.destroy());
}
onSyncError(error) {
this.closeConnection()