feature: enable OP Horizon campaign via feature flag (#146)

* feature: add isFeatureEnableOpHorizon

* Use env to switch OpHorizon campaign on

* fix: use stable @debridge-finance/legacy-dln-profitability

* chore: version bump

---------

Co-authored-by: Alexey Churkin <[email protected]>

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@debridge-finance/dln-taker",
-  "version": "2.15.10",
+  "version": "2.16.0",
   "description": "DLN executor is the rule-based daemon service developed to automatically execute orders placed on the deSwap Liquidity Network (DLN) across supported blockchains",
   "license": "GPL-3.0-only",
   "author": "deBridge",
@@ -32,8 +32,8 @@
   },
   "types": "./dist/index.d.ts",
   "dependencies": {
-    "@debridge-finance/dln-client": "8.0.0",
-    "@debridge-finance/legacy-dln-profitability": "2.0.0",
+    "@debridge-finance/dln-client": "8.1.0",
+    "@debridge-finance/legacy-dln-profitability": "2.1.0",
     "@debridge-finance/solana-utils": "4.2.1",
     "@protobuf-ts/plugin": "2.8.1",
     "@solana/web3.js": "1.66.2",

src/processors/universal.ts

@@ -644,7 +644,7 @@ class UniversalProcessor extends BaseOrderProcessor {
 
     let evmFulfillGasLimit: number | undefined;
     let evmFulfillCappedGasPrice: BigNumber | undefined;
-    let preswapTx: SwapConnectorRequest['preferEstimation'] | undefined;
+    let preswapTx: SwapConnectorRequest['routeHint'] | undefined;
     if (getEngineByChainId(this.takeChain.chain) === ChainEngine.EVM) {
       // we need to perform fulfill estimation (to obtain planned gasLimit),
       // but we don't know yet how much reserveAmount should we pass. So, we simply pick
@@ -737,6 +737,7 @@ class UniversalProcessor extends BaseOrderProcessor {
           ? BigInt(evmFulfillCappedGasPrice.integerValue().toString())
           : undefined,
         swapEstimationPreference: preswapTx,
+        isFeatureEnableOpHorizon: process.env.FEATURE_OP_HORIZON_CAMPAIGN === 'true',
       },
     );
 
@@ -935,11 +936,11 @@ class UniversalProcessor extends BaseOrderProcessor {
     reserveDstToken: Uint8Array,
     reservedAmount: string,
     evaluatedTakeAmount: bigint,
-    preferEstimation: SwapConnectorRequest['preferEstimation'] | undefined,
+    routeHint: SwapConnectorRequest['routeHint'] | undefined,
     context: OrderProcessorContext,
     logger: Logger,
   ): Promise<{
-    swapResult?: SwapConnectorRequest['preferEstimation'];
+    swapResult?: SwapConnectorRequest['routeHint'];
     transaction: Awaited<ReturnType<DlnClient['preswapAndFulfillOrder']>>;
   }> {
     if (buffersAreEqual(reserveDstToken, order.take.tokenAddress)) {
@@ -970,7 +971,7 @@ class UniversalProcessor extends BaseOrderProcessor {
         slippageBps: buffersAreEqual(reserveDstToken, order.take.tokenAddress)
           ? 0
           : this.getPreFulfillSlippage(evaluatedTakeAmount, order.take.amount),
-        preferEstimation,
+        routeHint,
         fromAddress: this.takeChain.fulfillProvider.bytesAddress,
         destReceiver: context.config.client.getForwarderAddress(order.take.chainId),
       },