diff --git a/js/modules/migrations/17/index.js b/js/modules/migrations/17/index.js index 20631af15..feffbb058 100644 --- a/js/modules/migrations/17/index.js +++ b/js/modules/migrations/17/index.js @@ -17,29 +17,21 @@ const _initializeMessageSchemaVersion = messagesStore => const messagePutOperations = []; const cursorRequest = messagesStore.openCursor(); - cursorRequest.onsuccess = (event) => { + cursorRequest.onsuccess = async (event) => { const cursor = event.target.result; const hasMoreData = Boolean(cursor); if (!hasMoreData) { - // eslint-disable-next-line more/no-then - return Promise.all(messagePutOperations) - .then(() => resolve(messagePutOperations.length)); + await Promise.all(messagePutOperations); + return resolve(messagePutOperations.length); } const message = cursor.value; const messageWithSchemaVersion = Message.initializeSchemaVersion(message); - messagePutOperations.push(new Promise((resolvePut) => { - console.log( - 'Initialize schema version for message:', - messageWithSchemaVersion.id - ); - - resolvePut(putItem( - messagesStore, - messageWithSchemaVersion, - messageWithSchemaVersion.id - )); - })); + messagePutOperations.push(putItem( + messagesStore, + messageWithSchemaVersion, + messageWithSchemaVersion.id + )); return cursor.continue(); };