From e52e34397db9578740f81ff44803092f47351b18 Mon Sep 17 00:00:00 2001 From: Meta Vens Date: Mon, 9 Nov 2026 11:59:06 +0100 Subject: [PATCH] testkit: one committed_imported Co-Authored-By: Claude Opus 5.5 --- crates/mind-body/src/testkit.rs | 22 +--------------------- 1 file changed, 1 insertion(+), 21 deletions(-) diff --git a/crates/mind-body/src/testkit.rs b/crates/mind-body/src/testkit.rs index 1ad8af9..be5f7a4 100644 --- a/crates/mind-body/src/testkit.rs +++ b/crates/mind-body/src/testkit.rs @@ -18,7 +18,7 @@ use eureka_pipeline::{ PipelineTarget, QuestionOption, ResolutionOutcome, RulingAuthority, RunOperator, RunTurn, Sha, Slug, StructuralDelta, TargetInvariant, }; use huginn_mind::{ - Faculty, HuginnMindRequest, ImportSource, ImportSource, HuginnMindResponse, Mind, OwnedRedbMessagePackBackingStore, PipelineAdmissionBatch, PipelineAdmissionOutcome, + Faculty, HuginnMindRequest, ImportSource, HuginnMindResponse, Mind, OwnedRedbMessagePackBackingStore, PipelineAdmissionBatch, PipelineAdmissionOutcome, PipelineDocumentView, PipelineProvenance, PipelineSelectionPage, }; use tempfile::TempDir; @@ -175,26 +175,6 @@ impl TestMind { assert!(matches!(outcome, PipelineAdmissionOutcome::Committed { .. }), "{outcome:?}"); } - /// Admits as an import of a giver's receipt committed at `committed_at`, one second after the last admission here. - pub(crate) fn committed_imported(&self, committed_at: &str, documents: Vec) { - self.now.set(self.now.get() + Duration::seconds(1)); - let source = ImportSource { - instance: Slug("giver".into()), - receipt_id: format!("giver-{committed_at}").as_str().into(), - ordinal: 1, - committed_at: committed_at.into(), - faculty: Faculty::Hands, - agent: "test".into(), - session: "test".into(), - tool: "test".into(), - external: vec![], - }; - let provenance = PipelineProvenance { faculty: Faculty::Hands, agent: "test".into(), session: "test".into(), tool: "test".into(), imported_from: Some(source) }; - let batch = PipelineAdmissionBatch { instance: self.instance.clone(), provenance, documents }; - let outcome = self.mind.borrow_mut().admit(batch, self.now.get()); - assert!(matches!(outcome, PipelineAdmissionOutcome::Committed { .. }), "{outcome:?}"); - } - pub(crate) fn committed(&self, documents: Vec) { let outcome = self.put(documents); assert!(matches!(outcome, PipelineAdmissionOutcome::Committed { .. }), "{outcome:?}");