diff --git a/packages/local-sync/src/local-api/routes/auth.js b/packages/local-sync/src/local-api/routes/auth.js index 31661a31a..3d176e672 100644 --- a/packages/local-sync/src/local-api/routes/auth.js +++ b/packages/local-sync/src/local-api/routes/auth.js @@ -3,17 +3,13 @@ const DefaultSyncPolicy = require('../default-sync-policy') const LocalDatabaseConnector = require('../../shared/local-database-connector') const SyncProcessManager = require('../../local-sync-worker/sync-process-manager') -const upsertAccount = (accountParams, credentials) => { - return LocalDatabaseConnector.forShared().then(({Account}) => { - accountParams.syncPolicy = DefaultSyncPolicy - accountParams.lastSyncCompletions = [] - - return Account.upsertWithCredentials(accountParams, credentials) - .then(({account, token}) => { - SyncProcessManager.addWorkerForAccount(account) - return {account, token} - }) - }); +async function upsertAccount(accountParams, credentials) { + accountParams.syncPolicy = DefaultSyncPolicy + accountParams.lastSyncCompletions = [] + const db = await LocalDatabaseConnector.forShared() + const {account, token} = await db.Account.upsertWithCredentials(accountParams, credentials) + SyncProcessManager.addWorkerForAccount(account) + return {account, token} } module.exports = (server) => {