fix(code-index): fence stale progress boundaries

crates/tracedecay-application/src/code_index.rs

@@ -9,7 +9,8 @@ use tracedecay_contracts::code_index_freshness::CodeIndexConvergenceParkedV1;
 use tracedecay_domain::CodeGenerationId;
 
 use tracedecay_code_index::{
-    chunks::CodeIndexImportEvidenceV1, production::CodeIndexExecutionControlV1,
+    chunks::CodeIndexImportEvidenceV1,
+    production::{CodeIndexExecutionControlV1, CodeIndexPresealWorkV1},
 };
 use tracedecay_runtime_core::resident_memory::{
     ResidentMemoryPressureStateV1, ResidentMemoryPressureV1,
@@ -99,6 +100,8 @@ pub struct DaemonCodeIndexControlV1 {
     pressure: Option<Arc<ResidentMemoryPressureV1>>,
     tripped: Arc<AtomicBool>,
     ignores_source_epoch: bool,
+    preseal_observer: Option<Arc<dyn Fn(CodeIndexPresealWorkV1) + Send + Sync>>,
+    preseal_finisher: Option<Arc<dyn Fn() + Send + Sync>>,
 }
 
 impl Default for DaemonCodeIndexControlV1 {
@@ -120,6 +123,8 @@ impl DaemonCodeIndexControlV1 {
             pressure: None,
             tripped: Arc::new(AtomicBool::new(false)),
             ignores_source_epoch: false,
+            preseal_observer: None,
+            preseal_finisher: None,
         }
     }
 
@@ -154,6 +159,25 @@ impl DaemonCodeIndexControlV1 {
         self
     }
 
+    /// The producer reports only to the separately scoped capture/parse
+    /// attempt, never to the sealed-generation text-progress authority.
+    #[must_use]
+    pub fn with_preseal_observer(
+        mut self,
+        observer: Arc<dyn Fn(CodeIndexPresealWorkV1) + Send + Sync>,
+    ) -> Self {
+        self.preseal_observer = Some(observer);
+        self
+    }
+
+    /// End the matching pre-seal attempt when the durable publisher takes over.
+    /// Ending activity must not advance its last observed work time.
+    #[must_use]
+    pub fn with_preseal_finisher(mut self, finisher: Arc<dyn Fn() + Send + Sync>) -> Self {
+        self.preseal_finisher = Some(finisher);
+        self
+    }
+
     pub fn advance(epoch: &AtomicU64) {
         epoch.fetch_add(1, Ordering::AcqRel);
     }
@@ -196,6 +220,18 @@ impl CodeIndexExecutionControlV1 for DaemonCodeIndexControlV1 {
     fn is_deadline_exceeded(&self) -> bool {
         false
     }
+
+    fn observed_preseal_work(&self, work: CodeIndexPresealWorkV1) {
+        if let Some(observer) = &self.preseal_observer {
+            observer(work);
+        }
+    }
+
+    fn finish_preseal_observation(&self) {
+        if let Some(finisher) = &self.preseal_finisher {
+            finisher();
+        }
+    }
 }
 
 #[cfg(test)]