IT4Change/gradido
3
0
Fork 0
mirror of https://github.com/IT4Change/gradido.git synced 2026-02-06 01:46:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

shift dltTx-creation in send-function

Browse Source
This commit is contained in:
Claus-Peter Huebner 2023-07-27 02:17:55 +02:00
parent a6dea37b69
commit fc90df9765
3 changed files with 3 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -536,16 +536,10 @@ export class ContributionResolver {
contribution.contributionStatus = ContributionStatus.CONFIRMED
await queryRunner.manager.update(DbContribution, { id: contribution.id }, contribution)
const dltTx = DltTransaction.create()
dltTx.transactionId = transaction.id
await DltTransaction.save(dltTx)
await queryRunner.commitTransaction()
// trigger to send transaction via dlt-connector
sendTransactionsToDltConnector().catch((e) => {
logger.error('error on sending transactions to DltConnector:', e)
})
void sendTransactionsToDltConnector()
logger.info('creation commited successfuly.')
void sendContributionConfirmedEmail({

8
backend/src/graphql/resolver/TransactionLinkResolver.ts
View File

@ -291,10 +291,6 @@ export class TransactionLinkResolver {
contribution.transactionId = transaction.id
await queryRunner.manager.update(DbContribution, { id: contribution.id }, contribution)
const dltTx = DltTransaction.create()
dltTx.transactionId = transaction.id
await DltTransaction.save(dltTx)
await queryRunner.commitTransaction()
await EVENT_CONTRIBUTION_LINK_REDEEM(
@ -314,9 +310,7 @@ export class TransactionLinkResolver {
releaseLock()
}
// trigger to send transaction via dlt-connector
sendTransactionsToDltConnector().catch((e) => {
logger.error('error on sending transactions to DltConnector:', e)
})
void sendTransactionsToDltConnector()
return true
} else {
const now = new Date()

12
backend/src/graphql/resolver/TransactionResolver.ts
View File

@ -141,14 +141,6 @@ export const executeTransaction = async (
)
}
const dltTxSend = DltTransaction.create()
dltTxSend.transactionId = transactionSend.id
await DltTransaction.save(dltTxSend)
const dltTxRec = DltTransaction.create()
dltTxRec.transactionId = transactionReceive.id
await DltTransaction.save(dltTxRec)
await queryRunner.commitTransaction()
logger.info(`commit Transaction successful...`)
@ -162,9 +154,7 @@ export const executeTransaction = async (
)
// trigger to send transaction via dlt-connector
sendTransactionsToDltConnector().catch((e) => {
logger.error('error on sending transactions to DltConnector:', e)
})
void sendTransactionsToDltConnector()
} catch (e) {
await queryRunner.rollbackTransaction()
throw new LogError('Transaction was not successful', e)