From 4a534352ad046ca804f1f58ef5afb6e366e202b8 Mon Sep 17 00:00:00 2001 From: Chocobozzz Date: Wed, 26 Sep 2018 10:15:50 +0200 Subject: Fix avatar transaction retry --- server/lib/avatar.ts | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) (limited to 'server/lib') diff --git a/server/lib/avatar.ts b/server/lib/avatar.ts index 14f0a05f5..4b6bc3185 100644 --- a/server/lib/avatar.ts +++ b/server/lib/avatar.ts @@ -6,6 +6,7 @@ import { processImage } from '../helpers/image-utils' import { AccountModel } from '../models/account/account' import { VideoChannelModel } from '../models/video/video-channel' import { extname, join } from 'path' +import { retryTransactionWrapper } from '../helpers/database-utils' async function updateActorAvatarFile (avatarPhysicalFile: Express.Multer.File, accountOrChannel: AccountModel | VideoChannelModel) { const extension = extname(avatarPhysicalFile.filename) @@ -13,13 +14,15 @@ async function updateActorAvatarFile (avatarPhysicalFile: Express.Multer.File, a const destination = join(CONFIG.STORAGE.AVATARS_DIR, avatarName) await processImage(avatarPhysicalFile, destination, AVATARS_SIZE) - return sequelizeTypescript.transaction(async t => { - const updatedActor = await updateActorAvatarInstance(accountOrChannel.Actor, avatarName, t) - await updatedActor.save({ transaction: t }) + return retryTransactionWrapper(() => { + return sequelizeTypescript.transaction(async t => { + const updatedActor = await updateActorAvatarInstance(accountOrChannel.Actor, avatarName, t) + await updatedActor.save({ transaction: t }) - await sendUpdateActor(accountOrChannel, t) + await sendUpdateActor(accountOrChannel, t) - return updatedActor.Avatar + return updatedActor.Avatar + }) }) } -- cgit v1.2.3