test: add a new hoizon and estardig no improve V2.receipts

Author: neithanmo

integration-tests/Cargo.toml

@@ -28,3 +28,17 @@ clap = { version = "4.0", features = ["derive"] }
 base64 = { workspace = true }
 prost = { workspace = true }
 tap_aggregator = { workspace = true }
+bigdecimal = { workspace = true }
+sqlx = { workspace = true, features = [
+    "macros",
+    "postgres",
+    "runtime-tokio",
+    "migrate",
+    "chrono",
+    "json",
+    "bigdecimal",
+    "rust_decimal",
+    "uuid",
+] }
+# rdkafka = { workspace = true }
+rdkafka = { version = "0.38.0", features = ["gssapi", "tracing"] }

integration-tests/src/constants.rs

@@ -18,6 +18,9 @@ pub const TAP_AGENT_METRICS_URL: &str = "http://localhost:7300/metrics";
 // they must match otherwise receipts would be rejected
 pub const TAP_VERIFIER_CONTRACT: &str = "0xC9a43158891282A2B1475592D5719c001986Aaec";
 
+pub const V1_DOMAIN_NAME: &str = "TAP";
+pub const V2_DOMAIN_NAME: &str = "GraphTally";
+
 // V2 GraphTallyCollector contract address (for Horizon receipts)
 pub const GRAPH_TALLY_COLLECTOR_CONTRACT: &str = "0xB0D4afd8879eD9F52b28595d31B441D079B2Ca07";
 pub const ACCOUNT0_SECRET: &str =
@@ -36,3 +39,17 @@ pub const MAX_RECEIPT_VALUE: u128 = GRT_BASE / 10_000;
 // Data service address for V2 testing
 // For testing, we'll use the indexer address as the data service
 pub const TEST_DATA_SERVICE: &str = "0xf4ef6650e48d099a4972ea5b414dab86e1998bd3"; // indexer address
+
+// Gateway mnemonic for direct service testing (from local-network-semiotic/.env)
+pub const GATEWAY_MNEMONIC: &str = "test test test test test test test test test test test junk";
+
+// Gateway uses ACCOUNT0_SECRET as raw private key (not mnemonic)
+pub const GATEWAY_PRIVATE_KEY: &str =
+    "0xac0974bec39a17e36ba4a6b4d238ff944bacb478cbed5efcae784d7bf4f2ff80";
+
+// Kafka configuration (from local-network-semiotic/.env)
+pub const KAFKA_SERVERS: &str = "localhost:9092";
+
+// Taken from indexer-service configuration
+pub const POSTGRES_PORT: &str = "5432";
+pub const POSTGRES_URL: &str = "postgresql://postgres@localhost:5432/indexer_components_1";

integration-tests/src/main.rs

@@ -2,6 +2,7 @@
 // SPDX-License-Identifier: Apache-2.0
 
 mod constants;
+mod database_checker;
 mod load_test;
 mod metrics;
 mod rav_tests;
@@ -12,7 +13,9 @@ use anyhow::Result;
 use clap::Parser;
 use load_test::{receipt_handler_load_test, receipt_handler_load_test_v2};
 use metrics::MetricsChecker;
-pub(crate) use rav_tests::{test_invalid_chain_id, test_tap_rav_v1, test_tap_rav_v2};
+pub(crate) use rav_tests::{
+    test_direct_service_rav_v2, test_invalid_chain_id, test_tap_rav_v1, test_tap_rav_v2,
+};
 
 /// Main CLI parser structure
 #[derive(Parser, Debug)]
@@ -27,6 +30,9 @@ enum Commands {
     Rav1,
     Rav2,
 
+    #[clap(name = "direct-service")]
+    DirectService,
+
     #[clap(name = "load")]
     LoadService {
         // for example: --num-receipts 10000 or -n 10000
@@ -59,6 +65,13 @@ async fn main() -> Result<()> {
         Commands::Rav2 => {
             test_tap_rav_v2().await?;
         }
+        Commands::DirectService => {
+            use crate::rav_tests::test_direct_service_rav_v2_simplified;
+
+            // test_direct_service_rav_v2().await?;
+            test_direct_service_rav_v2_simplified().await?;
+            // test_direct_service_rav_v2_config_aligned().await?;
+        }
         // cargo run -- load --num-receipts 1000
         Commands::LoadService { num_receipts } => {
             let concurrency = num_cpus::get();