stub in ver 1 txn for chain id check

aptos-indexer-processors-sdk/testing-framework/src/mock_grpc.rs

@@ -29,8 +29,9 @@ impl RawData for MockGrpcServer {
     ) -> Result<Response<Self::GetTransactionsStream>, Status> {
         let request = req.into_inner();
         let starting_version = request.starting_version.unwrap_or(0); // Default to 0 if starting_version is not provided
+        println!( "Starting version: {}", starting_version);
         let transactions_count = request.transactions_count.unwrap_or(1); // Default to 1 if transactions_count is not provided
-
+        println!( "Transactions count: {}", transactions_count);
         let mut collected_transactions = Vec::new();
 
         let mut transaction_map = HashMap::new();
@@ -48,7 +49,9 @@ impl RawData for MockGrpcServer {
         sorted_transactions.sort_by_key(|tx| tx.version);
 
         collected_transactions.extend(sorted_transactions.into_iter().take(transactions_count as usize));
-
+        for tx in &collected_transactions {
+            println!( "Collected transaction: {:?}", tx);
+        }
         let result = if !collected_transactions.is_empty() {
             TransactionsResponse {
                 transactions: collected_transactions,

aptos-indexer-processors-sdk/testing-framework/src/sdk_test_context.rs

@@ -28,7 +28,12 @@ const SLEEP_DURATION: Duration = Duration::from_millis(250);
 
 impl SdkTestContext {
     pub async fn new(txn_bytes: &[&[u8]]) -> anyhow::Result<Self> {
-        let transaction_batches = txn_bytes
+        // Create a dummy transaction server.
+        let transaction = Transaction {
+            version: 1,
+            ..Transaction::default()
+        };
+        let mut transaction_batches = txn_bytes
             .iter()
             .enumerate()
             .map(|(idx, txn)| {
@@ -49,6 +54,7 @@ impl SdkTestContext {
                 Ok::<Transaction, anyhow::Error>(transaction) // Explicit type annotation
             })
             .collect::<Result<Vec<Transaction>, _>>()?;
+        transaction_batches.append(&mut vec![transaction]);
 
         let mut context = SdkTestContext {
             transaction_batches,