back to kaspa and testing new changes rpc connection

coinchimp · Aug 9, 2024 · 1af6b76 · 1af6b76
1 parent 679c0fd
commit 1af6b76
Showing 1 changed file with 11 additions and 7 deletions.
diff --git a/src/index.ts b/src/index.ts
@@ -75,6 +75,12 @@ const rpc = new RpcClient({
 let transactionManager: trxManager | null = null;
 let rpcConnected = false;
 
+// Transaction Manager setup
+const setupTransactionManager = () => {
+  if (DEBUG) monitoring.debug(`Main: Starting transaction manager`);
+  transactionManager = new trxManager(config.network, treasuryPrivateKey, databaseUrl, rpc!);
+};
+
 const startRpcConnection = async () => {
   if (DEBUG) monitoring.debug(`Main: Starting RPC connection`);
   try {
@@ -87,16 +93,18 @@ const startRpcConnection = async () => {
     throw Error('Provided node is either not synchronized or lacks the UTXO index.');
   }
   rpcConnected = true;
-  if (DEBUG) monitoring.debug(`Main: RPC connection established`);
-  setupTransactionManager();
+
 };
 
 if (!rpcConnected) {
   await startRpcConnection();
   if (DEBUG) monitoring.debug('Main: RPC connection started');
+  if (DEBUG) monitoring.debug(`Main: RPC connection established`);
+  setupTransactionManager();
 }
 
 
+
 // const stopRpcConnection = async () => {
 //   if (rpc) {
 //     await transactionManager!.stopProcessor();
@@ -106,11 +114,7 @@ if (!rpcConnected) {
 //   }
 // };
 
-// Transaction Manager setup
-const setupTransactionManager = () => {
-  if (DEBUG) monitoring.debug(`Main: Starting transaction manager`);
-  transactionManager = new trxManager(config.network, treasuryPrivateKey, databaseUrl, rpc!);
-};
+
 
 // Unified cron schedule
 cron.schedule(`*/10 * * * *`, async () => {