feat: Added dry run feature for default tx executor and logs file

bot.ts

@@ -151,6 +151,7 @@ export class Bot {
             `Send buy transaction attempt: ${i + 1}/${this.config.maxBuyRetries}`,
           );
           const tokenOut = new Token(TOKEN_PROGRAM_ID, poolKeys.baseMint, poolKeys.baseDecimals);
+          console.log("detected at ", new Date().toISOString());
           const result = await this.swap(
             poolKeys,
             this.config.quoteAta,

package.json

@@ -20,6 +20,7 @@
     "bs58": "^5.0.0",
     "dotenv": "^16.4.1",
     "ed25519-hd-key": "^1.3.0",
+    "ffi-rs": "^1.0.69",
     "i": "^0.3.7",
     "npm": "^10.5.2",
     "pino": "^8.18.0",

transactions/tpu-transaction-executor.ts

@@ -0,0 +1,56 @@
+import {
+    BlockhashWithExpiryBlockHeight,
+    Keypair,
+    VersionedTransaction
+} from '@solana/web3.js';
+import { AxiosError } from 'axios';
+
+import { TransactionExecutor } from './transaction-executor.interface';
+import { load, DataType, open, close } from 'ffi-rs';
+import bs58 from 'bs58';
+import { logger } from '../helpers';
+
+export class TpuTransactionExecutor implements TransactionExecutor {
+
+    constructor() { }
+
+    public async executeAndConfirm(
+        transaction: VersionedTransaction,
+        payer: Keypair,
+        latestBlockhash: BlockhashWithExpiryBlockHeight,
+        simulate: boolean
+    ): Promise<{ confirmed: boolean; signature?: string }> {
+        const serializedTransaction = transaction.serialize();
+        const signatureBase58 = bs58.encode(transaction.signatures[0]);
+        let result = false
+        try {
+            open({
+                library: 'tpu_client', // key
+                path: "/Users/kasiopea/dev/rust/tpu-sol-test/target/aarch64-apple-darwin/release/libtpu_client.dylib" // path
+            })
+            const RPC_ENDPOINT="http://127.0.0.1:8899"
+            const RPC_WEBSOCKET_ENDPOINT="ws://127.0.0.1:8900"
+
+
+            result = load({
+                library: "tpu_client", // path to the dynamic library file
+                funcName: 'send_tpu_tx', // the name of the function to call
+                retType: DataType.Boolean, // the return value type
+                paramsType: [DataType.String, DataType.String, DataType.U8Array, DataType.I32], // the parameter types
+                paramsValue: [RPC_ENDPOINT, RPC_WEBSOCKET_ENDPOINT, serializedTransaction, serializedTransaction.length] // the actual parameter values
+            })
+            console.log({
+                result
+            })
+        } catch (error) {
+            logger.error(error, "executeAndConfirm");
+            if (error instanceof AxiosError) {
+                logger.trace({ error: error.response?.data }, 'Failed to execute warp transaction');
+            }
+        } finally {
+            close('tpu_client')
+        }
+
+        return { confirmed: result, signature: signatureBase58 };
+    }
+}