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

reduce dltconnectorclient from writing in database

Browse Source
This commit is contained in:
Claus-Peter Huebner 2023-07-21 19:50:47 +02:00
parent 69a33c7ba2
commit 80cd549359
1 changed files with 3 additions and 45 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
backend/src/apis/DltConnectorClient.ts
View File

@ -14,43 +14,6 @@ const mutation = gql`
}
`
/**
* write message id into db to transaction
* @param dltMessageId message id of dlt message
* @param transactionId typeorm transaction id
*/
const writeDltMessageId = async (
dltMessageIdHex: string,
transactionId: number,
): Promise<boolean> => {
try {
const transaction = await DbTransaction.findOne({ where: { id: transactionId } })
if (transaction) {
const dltMessageId = Buffer.from(dltMessageIdHex, 'hex')
if (dltMessageId.length !== 32) {
logger.error(
'Error dlt message id is invalid: %s, should by 32 Bytes long in binary after converting from hex',
dltMessageIdHex,
)
return false
}
transaction.dltTransactionId = dltMessageId
await transaction.save()
logger.info(
'transmit transaction over dlt connector, store message id: %s in db',
dltMessageIdHex,
)
return true
} else {
logger.error('transaction with id: %d not found', transactionId)
return false
}
} catch (e) {
logger.error('exception by finding transaction in db: %s', e)
return false
}
}
// from ChatGPT
function getTransactionTypeString(id: TransactionTypeId): string {
const key = Object.keys(TransactionTypeId).find(
@ -109,7 +72,7 @@ export class DltConnectorClient {
* transmit transaction via dlt-connector to iota
* and update dltTransactionId of transaction in db with iota message id
*/
public async transmitTransaction(transaction: DbTransaction): Promise<boolean> {
public async transmitTransaction(transaction: DbTransaction): Promise<string> {
const typeString = getTransactionTypeString(transaction.typeId)
const secondsSinceEpoch = Math.round(transaction.balanceDate.getTime() / 1000)
const amountString = transaction.amount.toString()
@ -122,14 +85,9 @@ export class DltConnectorClient {
createdAt: secondsSinceEpoch,
},
})
const writeResult = await writeDltMessageId(
result.transmitTransaction.dltTransactionIdHex,
transaction.id,
)
return writeResult
return result.transmitTransaction.dltTransactionIdHex
} catch (e) {
logger.error('Error send sending transaction to dlt-connector: %o', e)
return false
throw new LogError('Error send sending transaction to dlt-connector: %o', e)
}
}
}