IT4Change/gradido
3
0
Fork 0
mirror of https://github.com/IT4Change/gradido.git synced 2025-12-13 07:45:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

lock also on contributions

Browse Source
This commit is contained in:
Ulf Gebhardt 2022-12-15 13:06:55 +01:00
parent a98d569fb3
commit 9537910413
Signed by: ulfgebhardt
GPG Key ID: DA6B843E748679C9
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
backend/src/graphql/resolver/ContributionResolver.ts
View File

@ -50,6 +50,7 @@ import {
sendContributionConfirmedEmail, sendContributionConfirmedEmail,
sendContributionRejectedEmail, sendContributionRejectedEmail,
} from '@/emails/sendEmailVariants' } from '@/emails/sendEmailVariants'
import { TRANSACTIONS_LOCK } from '@/util/TRANSACTIONS_LOCK'
@Resolver() @Resolver()
export class ContributionResolver { export class ContributionResolver {
@ -581,6 +582,8 @@ export class ContributionResolver {
const receivedCallDate = new Date() const receivedCallDate = new Date()
// acquire lock
const releaseLock = await TRANSACTIONS_LOCK.acquire()
const queryRunner = getConnection().createQueryRunner() const queryRunner = getConnection().createQueryRunner()
await queryRunner.connect() await queryRunner.connect()
await queryRunner.startTransaction('REPEATABLE READ') // 'READ COMMITTED') await queryRunner.startTransaction('REPEATABLE READ') // 'READ COMMITTED')
@ -643,6 +646,7 @@ export class ContributionResolver {
throw new Error(`Creation was not successful.`) throw new Error(`Creation was not successful.`)
} finally { } finally {
await queryRunner.release() await queryRunner.release()
releaseLock()
} }
const event = new Event() const event = new Event()