the tx_interval should be between the first tx of from_cp up to the f…

…irst tx of to_cp

crates/sui-indexer-alt-framework/src/handlers/cp_mapping.rs

@@ -9,7 +9,7 @@ use anyhow::Result;
 use diesel::prelude::*;
 use diesel_async::RunQueryDsl;
 use sui_field_count::FieldCount;
-use sui_pg_db::{self as db};
+use sui_pg_db::{self as db, Connection};
 use sui_types::full_checkpoint_content::CheckpointData;
 
 #[derive(Insertable, Selectable, Queryable, Debug, Clone, FieldCount)]
@@ -63,7 +63,7 @@ impl PrunableRange {
 
     /// Inclusive start and exclusive end range of prunable txs.
     pub fn tx_interval(&self) -> (u64, u64) {
-        (self.from.tx_lo as u64, self.to.tx_hi as u64)
+        (self.from.tx_lo as u64, self.to.tx_lo as u64)
     }
 
     /// Returns the epochs that contain the checkpoints in this range.

crates/sui-indexer-alt-framework/src/lib.rs

@@ -14,7 +14,7 @@ use metrics::{IndexerMetrics, MetricsService};
 use pipeline::{
     concurrent::{self, ConcurrentConfig},
     sequential::{self, SequentialConfig},
-    CommitterConfig, Processor,
+    Processor,
 };
 use sui_pg_db::{Db, DbArgs};
 use task::graceful_shutdown;
@@ -376,7 +376,7 @@ impl Indexer {
         );
 
         if let Some(enabled_pipelines) = &mut self.enabled_pipelines {
-            if P::NAME != CpMapping::NAME && !enabled_pipelines.remove(P::NAME) {
+            if !enabled_pipelines.remove(P::NAME) {
                 info!(pipeline = P::NAME, "Skipping");
                 return Ok(None);
             }