Mailspring/packages/nylas-sync/sync-worker.js

203 lines
5.9 KiB
JavaScript

const {
Provider,
SchedulerUtils,
IMAPConnection,
PubsubConnector,
DatabaseConnector,
} = require('nylas-core');
const FetchCategoryList = require('./imap/fetch-category-list')
const FetchMessagesInCategory = require('./imap/fetch-messages-in-category')
const SyncbackTaskFactory = require('./syncback-task-factory')
class SyncWorker {
constructor(account, db) {
this._db = db;
this._conn = null;
this._account = account;
this._lastSyncTime = null;
this._syncTimer = null;
this._expirationTimer = null;
this._destroyed = false;
this.syncNow();
this._listener = PubsubConnector.observableForAccountChanges(account.id)
.subscribe(() => this.onAccountChanged())
}
cleanup() {
this._destroyed = true;
this._listener.dispose();
this.closeConnection()
}
closeConnection() {
this._conn.end();
this._conn = null
}
onAccountChanged() {
console.log("SyncWorker: Detected change to account. Reloading and syncing now.")
DatabaseConnector.forShared().then(({Account}) => {
Account.find({where: {id: this._account.id}}).then((account) => {
this._account = account;
this.syncNow();
})
});
}
onSyncDidComplete() {
const {afterSync} = this._account.syncPolicy;
if (afterSync === 'idle') {
return this.getInboxCategory()
.then((inboxCategory) => this._conn.openBox(inboxCategory.name))
.then(() => console.log('SyncWorker: - Idling on inbox category'))
.catch((error) => {
this.closeConnection()
console.error('SyncWorker: - Unhandled error while attempting to idle on Inbox after sync: ', error)
})
} else if (afterSync === 'close') {
console.log('SyncWorker: - Closing connection');
} else {
console.warn(`SyncWorker: - Unknown afterSync behavior: ${afterSync}. Closing connection`)
}
this.closeConnection()
return Promise.resolve()
}
onConnectionIdleUpdate() {
this.syncNow();
}
getInboxCategory() {
return this._db.Category.find({where: {role: 'inbox'}})
}
ensureConnection() {
if (this._conn) {
return this._conn.connect();
}
const settings = this._account.connectionSettings;
const credentials = this._account.decryptedCredentials();
if (!settings || !settings.imap_host) {
return Promise.reject(new NylasError("ensureConnection: There are no IMAP connection settings for this account."))
}
if (!credentials) {
return Promise.reject(new NylasError("ensureConnection: There are no IMAP connection credentials for this account."))
}
const conn = new IMAPConnection(this._db, Object.assign({}, settings, credentials));
conn.on('mail', () => {
this.onConnectionIdleUpdate();
})
conn.on('update', () => {
this.onConnectionIdleUpdate();
})
conn.on('queue-empty', () => {
});
this._conn = conn;
return this._conn.connect();
}
fetchCategoryList() {
return this._conn.runOperation(new FetchCategoryList())
}
syncbackMessageActions() {
return Promise.resolve();
// TODO
const {SyncbackRequest, accountId, Account} = this._db;
return Account.find({where: {id: accountId}}).then((account) => {
return Promise.each(SyncbackRequest.findAll().then((reqs = []) =>
reqs.map((request) => {
const task = SyncbackTaskFactory.create(account, request);
return this._conn.runOperation(task)
})
));
});
}
syncAllCategories() {
const {Category} = this._db;
const {folderSyncOptions} = this._account.syncPolicy;
return Category.findAll().then((categories) => {
const priority = ['inbox', 'all', 'drafts', 'sent', 'spam', 'trash'].reverse();
let categoriesToSync = categories.sort((a, b) =>
(priority.indexOf(a.role) - priority.indexOf(b.role)) * -1
)
if (this._account.provider === Provider.Gmail) {
categoriesToSync = categoriesToSync.filter(cat =>
['[Gmail]/All Mail', '[Gmail]/Trash', '[Gmail]/Spam'].includes(cat.name)
)
if (categoriesToSync.length !== 3) {
throw new Error(`Account is missing a core Gmail folder: ${categoriesToSync.join(',')}`)
}
}
return Promise.all(categoriesToSync.map((cat) =>
this._conn.runOperation(new FetchMessagesInCategory(cat, folderSyncOptions))
))
});
}
performSync() {
return this.fetchCategoryList()
.then(() => this.syncbackMessageActions())
.then(() => this.syncAllCategories())
}
syncNow() {
clearTimeout(this._syncTimer);
if (this._account.errored()) {
console.log(`SyncWorker: Account ${this._account.emailAddress} is in error state - Skipping sync`)
return
}
this.ensureConnection()
.then(() => this.performSync())
.then(() => this.onSyncDidComplete())
.catch((error) => this.onSyncError(error))
.finally(() => {
this._lastSyncTime = Date.now()
this.scheduleNextSync()
})
}
onSyncError(error) {
console.error(`SyncWorker: Error while syncing account ${this._account.emailAddress} `, error)
this.closeConnection()
if (error.source === 'socket') {
// Continue to retry if it was a network error
return Promise.resolve()
}
this._account.syncError = error
return this._account.save()
}
scheduleNextSync() {
if (this._account.errored()) { return }
SchedulerUtils.checkIfAccountIsActive(this._account.id).then((active) => {
const {intervals} = this._account.syncPolicy;
const interval = active ? intervals.active : intervals.inactive;
if (interval) {
const target = this._lastSyncTime + interval;
console.log(`SyncWorker: Account ${active ? 'active' : 'inactive'}. Next sync scheduled for ${new Date(target).toLocaleString()}`);
this._syncTimer = setTimeout(() => {
this.syncNow();
}, target - Date.now());
}
});
}
}
module.exports = SyncWorker;