fixup! refactor(rabbitmq): now the package respects all the repository standards

Author: iccicci

packages/rabbitmq/src/TxSubmitWorker.ts

@@ -1,7 +1,7 @@
 /* eslint-disable @typescript-eslint/no-shadow */
+import { Cardano, ProviderError, ProviderFailure, TxSubmitProvider } from '@cardano-sdk/core';
 import { Channel, Connection, Message, connect } from 'amqplib';
 import { Logger, dummyLogger } from 'ts-log';
-import { ProviderError, ProviderFailure, TxSubmitProvider } from '@cardano-sdk/core';
 import { TX_SUBMISSION_QUEUE, serializeError, txBodyToId, waitForPending } from './utils';
 
 const moduleName = 'TxSubmitWorker';
@@ -270,7 +270,7 @@ export class TxSubmitWorker {
       const txBody = new Uint8Array(content);
 
       // Register the handling of current transaction
-      txId = txBodyToId(txBody, this.#config.dummyTxId);
+      txId = this.#config.dummyTxId ? txBodyToId(txBody, true) : Cardano.util.deserializeTx(txBody).id.toString();
 
       this.#dependencies.logger!.info(`${moduleName}: submitting tx #${counter} id: ${txId}`);
       this.#dependencies.logger!.debug(`${moduleName}: tx #${counter} dump:`, content.toString('hex'));

packages/rabbitmq/src/rabbitmqTxSubmitProvider.ts

@@ -168,7 +168,10 @@ export class RabbitMqTxSubmitProvider implements TxSubmitProvider {
       };
 
       try {
-        txId = txBodyToId(signedTransaction, this.#config.dummyTxId);
+        txId = this.#config.dummyTxId
+          ? txBodyToId(signedTransaction, true)
+          : Cardano.util.deserializeTx(signedTransaction).id.toString();
+
         this.#dependencies.logger!.info(`${moduleName}: queuing tx id: ${txId}`);
 
         // Actually send the message