diff --git a/ts/sql/Server.node.ts b/ts/sql/Server.node.ts index 8376823064..1faa22a134 100644 --- a/ts/sql/Server.node.ts +++ b/ts/sql/Server.node.ts @@ -3178,6 +3178,15 @@ function saveMessagesIndividually( arrayOfMessages: ReadonlyArray>, options: { forceSave?: boolean; ourAci: AciString } ): { failedIndices: Array } { + try { + saveMessages(db, arrayOfMessages, options); + return { failedIndices: [] }; + } catch (e) { + logger.error( + 'saveMessagesIndividually: Failed to save messages in one transaction, falling over to individual saves' + ); + } + return db.transaction(() => { const failedIndices: Array = []; arrayOfMessages.forEach((message, index) => {