0.7.41

kb_lib/src/dex_detect.rs

@@ -88,6 +88,9 @@ impl DexDetectService {
                 crate::dex_detection_route::DexDetectionRoute::RaydiumAmmV4Initialize2Pool => {
                     self.detect_raydium_initialize2_pool(&transaction, decoded_event).await
                 },
+                crate::dex_detection_route::DexDetectionRoute::RaydiumAmmV4Trade => {
+                    self.detect_raydium_amm_v4_trade(&transaction, decoded_event).await
+                },
                 crate::dex_detection_route::DexDetectionRoute::RaydiumCpmmTrade => {
                     self.detect_raydium_cpmm_trade(&transaction, decoded_event).await
                 },
@@ -522,6 +525,60 @@ impl DexDetectService {
             .await;
     }
 
+    async fn detect_raydium_amm_v4_trade(
+        &self,
+        transaction: &crate::ChainTransactionDto,
+        decoded_event: &crate::DexDecodedEventDto,
+    ) -> Result<crate::DexPoolDetectionResult, crate::Error> {
+        let dex_id_result =
+            crate::dex_catalog::ensure_known_dex(self.database.as_ref(), "raydium_amm_v4").await;
+        let dex_id = match dex_id_result {
+            Ok(dex_id) => dex_id,
+            Err(error) => return Err(error),
+        };
+        let payload_value_result = parse_payload_json(decoded_event.payload_json.as_str());
+        let payload_value = match payload_value_result {
+            Ok(payload_value) => payload_value,
+            Err(error) => return Err(error),
+        };
+        let base_vault_address = extract_payload_string_field(&payload_value, "baseVault");
+        let quote_vault_address = extract_payload_string_field(&payload_value, "quoteVault");
+        let input_result =
+            crate::dex_pool_materialization::DexPoolMaterializationInput::from_decoded_event(
+                decoded_event,
+                dex_id,
+                crate::PoolKind::Amm,
+                crate::PoolStatus::Active,
+                crate::dex_pool_materialization::DexPoolTokenOrder::AlreadyBaseQuote,
+                base_vault_address,
+                quote_vault_address,
+                transaction.source_endpoint_name.clone(),
+            );
+        let input = match input_result {
+            Ok(input) => input,
+            Err(error) => return Err(error),
+        };
+        let detection_result =
+            crate::dex_pool_materialization::materialize_dex_pool(self.database.as_ref(), &input)
+                .await;
+        let detection_result = match detection_result {
+            Ok(detection_result) => detection_result,
+            Err(error) => return Err(error),
+        };
+        let signal_result = self
+            .record_pool_detection_signals(
+                transaction,
+                "signal.dex.raydium_amm_v4",
+                &detection_result,
+                payload_value,
+            )
+            .await;
+        if let Err(error) = signal_result {
+            return Err(error);
+        }
+        return Ok(detection_result);
+    }
+
     async fn detect_raydium_clmm_trade(
         &self,
         transaction: &crate::ChainTransactionDto,