Merge pull request #112 from drift-labs/master

configurable tx sender

package.json

@@ -5,8 +5,8 @@
 	"main": "lib/index.js",
 	"license": "Apache-2.0",
 	"dependencies": {
-		"@drift-labs/jit-proxy": "0.10.154",
-		"@drift-labs/sdk": "2.53.0-beta.1",
+		"@drift-labs/jit-proxy": "0.10.155",
+		"@drift-labs/sdk": "2.53.0-beta.2",
 		"@opentelemetry/api": "^1.1.0",
 		"@opentelemetry/auto-instrumentations-node": "^0.31.1",
 		"@opentelemetry/exporter-prometheus": "^0.31.0",

src/config.ts

@@ -85,6 +85,7 @@ export interface GlobalConfig {
 	jitoBlockEngineUrl?: string;
 	jitoAuthPrivateKey?: string;
 	txRetryTimeoutMs?: number;
+	txSenderType?: 'fast' | 'retry';
 }
 
 export interface Config {

src/index.ts

@@ -149,6 +149,10 @@ program
 		'--event-susbcriber',
 		'Explicitly intialize an eventSubscriber (RPC heavy'
 	)
+	.option(
+		'--tx-sender-type <string>',
+		'Choose tx sender type, options are: fast, retry'
+	)
 	.parse();
 
 const opts = program.opts();
@@ -263,18 +267,24 @@ const runBot = async () => {
 		commitment: stateCommitment,
 		disableRetryOnRateLimit: true,
 	});
-	// const txSender = new FastSingleTxSender({
-	// 	connection: sendTxConnection,
-	// 	blockhashRefreshInterval: 10_000,
-	// 	wallet,
-	// 	opts,
-	// });
-	const txSender = new RetryTxSender({
-		connection: sendTxConnection,
-		wallet,
-		opts,
-		timeout: 3000,
-	});
+
+	const txSenderType = config.global.txSenderType || 'retry';
+	let txSender;
+	if (txSenderType === 'retry') {
+		txSender = new RetryTxSender({
+			connection: sendTxConnection,
+			wallet,
+			opts,
+			timeout: 3000,
+		});
+	} else {
+		txSender = new FastSingleTxSender({
+			connection: sendTxConnection,
+			blockhashRefreshInterval: 1000,
+			wallet,
+			opts,
+		});
+	}
 
 	/**
 	 * Creating and subscribing to the drift client