Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 0 additions & 6 deletions crates/tracedecay-application/src/primitives/runtime.rs
Original file line number Diff line number Diff line change
Expand Up @@ -342,12 +342,6 @@ impl PrimitiveProjectRuntime {
pub fn database(&self) -> &Database {
&self.database
}

/// Releases the project database, dispatch, and all Arc-backed
/// primitive authorities as one teardown unit.
pub fn teardown(self) {
drop(self);
}
}

impl PrimitiveDispatch for OwnedPrimitiveRuntime {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -446,8 +446,8 @@ fn session_fact_category(category: &str) -> Option<FactCategoryV1> {

/// Accepts numeric trust in `[0, 1]` plus the `low`/`medium`/`high` bucket
/// labels models frequently emit despite the numeric prompt instruction.
/// Buckets map to the representative scores defined next to
/// [`tracedecay_session_memory::memory::trust::trust_bucket`], so they cannot drift out of their
/// Buckets map to the representative scores in
/// [`tracedecay_session_memory::memory::trust`], so they cannot drift out of their
/// documented ranges.
///
/// Deliberate decision: the prompt forbids string labels, but they are
Expand Down
7 changes: 0 additions & 7 deletions crates/tracedecay-code-index/src/chunks.rs
Original file line number Diff line number Diff line change
Expand Up @@ -585,13 +585,6 @@ impl DeterministicCodeChunker {
}
}

/// Pin the sensitivity level recorded on every chunk of this generation.
#[must_use]
pub fn with_sensitivity_level(mut self, level: SensitivityLevelV1) -> Self {
self.sensitivity_level = level;
self
}

/// The generation this chunker is bound to.
pub fn generation_id(&self) -> &CodeGenerationId {
&self.generation_id
Expand Down
8 changes: 0 additions & 8 deletions crates/tracedecay-contracts/src/external_source.rs
Original file line number Diff line number Diff line change
Expand Up @@ -274,14 +274,6 @@ impl SourceCanonicalRefetchAuthorityV1 {
self.binding == *refresh.binding()
&& self.original_refresh_digest == *refresh.receipt_digest()
}

/// Reports whether this opaque capability names the exact refresh.
///
/// The capability still exposes no binding fields or constructor, so a
/// provider or transport cannot mint or retarget it.
pub fn authorizes(&self, refresh: &SourceRefreshReceiptV1) -> bool {
self.matches(refresh)
}
}

#[derive(Clone, Debug)]
Expand Down
10 changes: 0 additions & 10 deletions crates/tracedecay-domain/src/configuration/topology.rs
Original file line number Diff line number Diff line change
Expand Up @@ -348,16 +348,6 @@ pub enum BranchNameSeparatorV1 {
Slash,
}

impl BranchNameSeparatorV1 {
pub const fn as_char(self) -> char {
match self {
Self::Hyphen => '-',
Self::Underscore => '_',
Self::Slash => '/',
}
}
}

#[derive(Clone, Debug, Serialize, Deserialize, JsonSchema, PartialEq, Eq)]
#[serde(rename_all = "snake_case", tag = "kind")]
pub enum BranchCollisionPolicyV1 {
Expand Down
14 changes: 0 additions & 14 deletions crates/tracedecay-domain/src/feedback/proximity.rs
Original file line number Diff line number Diff line change
Expand Up @@ -191,20 +191,6 @@ impl ProximityContributionV1 {
observed_at.0 >= self.expires_at.0
}

/// Records presentation suppression without discarding the evidence,
/// threshold provenance, or expiry that produced the duplicate warning.
pub fn suppressed_duplicate(mut self) -> Result<Self, DomainError> {
self.validate()?;
if self.inclusion != ProximityInclusionV1::Included {
return Err(DomainError::NonCanonical {
field: "proximity duplicate suppression input",
});
}
self.inclusion = ProximityInclusionV1::SuppressedDuplicate;
self.validate()?;
Ok(self)
}

pub fn validate(&self) -> Result<(), DomainError> {
self.contribution_id.validate()?;
self.warning_id.validate()?;
Expand Down
9 changes: 0 additions & 9 deletions crates/tracedecay-domain/src/git/read_model.rs
Original file line number Diff line number Diff line change
Expand Up @@ -65,15 +65,6 @@ pub enum GitObjectFormatV1 {
Sha256,
}

impl GitObjectFormatV1 {
pub const fn oid_hex_len(self) -> usize {
match self {
Self::Sha1 => 40,
Self::Sha256 => 64,
}
}
}

fn validate_git_oid(value: &str, field: &'static str) -> Result<(), DomainError> {
if value.is_empty() {
return Err(DomainError::Empty { field });
Expand Down
11 changes: 0 additions & 11 deletions crates/tracedecay-domain/src/research/watermark.rs
Original file line number Diff line number Diff line change
Expand Up @@ -29,17 +29,6 @@ impl VectorWatermark {
(false, false) => None,
}
}

pub fn merge_max(&self, other: &Self) -> Self {
let mut components = self.components.clone();
for (shard, sequence) in &other.components {
components
.entry(shard.clone())
.and_modify(|current| *current = (*current).max(*sequence))
.or_insert(*sequence);
}
Self { components }
}
}

#[derive(Clone, Debug, Serialize, Deserialize, PartialEq, Eq, PartialOrd, Ord, Hash)]
Expand Down
14 changes: 0 additions & 14 deletions crates/tracedecay-global-db/src/profile_registry_maintenance.rs
Original file line number Diff line number Diff line change
Expand Up @@ -10,8 +10,6 @@ use std::path::{Component, Path, PathBuf};
use crate::{
ProjectRegistryContext, RegisteredGlobalDb, RegisteredGlobalDbLeaseV1,
registry_maintenance::ForgetRegistryProjectRows, registry_maintenance::RegistryGcReport,
registry_maintenance::RegistryOrphanRelinkApplyReport,
registry_maintenance::RegistryOrphanRelinkReport,
registry_maintenance::forget_registry_project,
};

Expand Down Expand Up @@ -246,18 +244,6 @@ impl ProfileRegistryMaintenanceRuntime {
})
}

#[hotpath::measure(label = "daemon.profile_registry.apply_orphan_relink", future = true)]
pub async fn apply_orphan_relink(
&self,
report: &RegistryOrphanRelinkReport,
) -> std::result::Result<RegistryOrphanRelinkApplyReport, Vec<String>> {
crate::registry_maintenance::apply_registry_orphan_relink_report(
self.profile_database.as_ref(),
report,
)
.await
}

#[hotpath::measure(label = "daemon.profile_registry.gc", future = true)]
pub async fn registry_gc(
&self,
Expand Down
29 changes: 0 additions & 29 deletions crates/tracedecay-global-db/src/registered_lcm.rs
Original file line number Diff line number Diff line change
Expand Up @@ -497,35 +497,6 @@ impl RegisteredGlobalDb {
Ok((work, has_more))
}

#[hotpath::skip]
pub async fn lcm_payload_health_detail(
&self,
storage_root: &Path,
provider: &str,
session_id: Option<&str>,
deep: bool,
sample_limit: usize,
cfg: &LcmGcConfig,
) -> Result<tracedecay_lcm::query::PayloadHealthDetail, LcmError> {
SessionStoreAccess::new(self)
.lcm_payload_health_detail(storage_root, provider, session_id, deep, sample_limit, cfg)
.await
}

#[hotpath::skip]
pub async fn lcm_preview_payload_gc(
&self,
storage_root: &Path,
provider: &str,
session_id: Option<&str>,
cfg: &LcmGcConfig,
now: i64,
) -> Result<LcmGcReport, LcmError> {
SessionStoreAccess::new(self)
.lcm_preview_payload_gc(storage_root, provider, session_id, cfg, now)
.await
}

#[hotpath::skip]
pub async fn lcm_run_payload_gc_apply(
&self,
Expand Down
Loading
Loading