GameCult/Epiphany
Archived
Watch
9
0
Fork
You've already forked Epiphany
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Delete unused Hands chain reader

Browse source
This commit is contained in:
Meta Vens 2026-08-23 20:41:28 +02:00
commit 1fea7bdeec
2 changed files with 1 additions and 77 deletions
Download patch file Download diff file Expand all files Collapse all files

2
epiphany-core/src/lib.rs
View file

@ -279,7 +279,6 @@ pub use runtime_spine::RepoFrontierResearchContinuationAction;
pub use runtime_spine::RepoFrontierResearchLifecycle;
pub use runtime_spine::RepoFrontierResearchLifecycleStage;
pub use runtime_spine::RepoFrontierVerdictModelingLaunchAuthority;
pub use runtime_spine::RuntimeHandsReceiptChainSummary;
pub use runtime_spine::RuntimeSpineHeartbeatJobOptions;
pub use runtime_spine::RuntimeSpineInitOptions;
pub use runtime_spine::RuntimeSpineJobOptions;
@ -340,7 +339,6 @@ pub use runtime_spine::runtime_hands_patch_receipt;
pub use runtime_spine::runtime_has_actionable_hands_frontier;
pub use runtime_spine::runtime_has_actionable_imagination_frontier;
pub use runtime_spine::runtime_job_snapshot;
pub use runtime_spine::runtime_latest_hands_receipt_chain_after;
pub use runtime_spine::runtime_registered_document_types;
pub use runtime_spine::runtime_reorient_worker_result;
pub use runtime_spine::runtime_repo_frontier_planning_eligibility;

76
epiphany-core/src/runtime_spine.rs
View file

@ -9347,7 +9347,7 @@ pub fn runtime_hands_commit_receipt(
#[derive(Debug, Clone, PartialEq, Eq)]
pub struct RuntimeHandsReceiptChainSummary {
struct RuntimeHandsReceiptChainSummary {
pub patch_schema_version: String,
pub patch_receipt_id: String,
pub command_schema_version: String,
@ -9369,76 +9369,6 @@ pub struct RuntimeHandsReceiptChainSummary {
pub emitted_at: String,
}
pub fn runtime_latest_hands_receipt_chain_after(
store_path: impl AsRef<Path>,
after_timestamp: &str,
) -> Result<Option<RuntimeHandsReceiptChainSummary>> {
validate_non_empty(after_timestamp, "Hands receipt lower-bound timestamp")?;
let mut cache = runtime_spine_cache(store_path)?;
cache.pull_all_backing_stores()?;
let patches = cache.get_all::<HandsPatchReceipt>()?;
let commands = cache.get_all::<HandsCommandReceipt>()?;
let commits = cache.get_all::<HandsCommitReceipt>()?;
let mut summaries = Vec::new();
for commit in commits
.iter()
.filter(|commit| timestamp_after(&commit.emitted_at, after_timestamp))
{
let Some(patch) = patches
.iter()
.filter(|patch| {
patch.intent_id == commit.intent_id
&& patch.review_id == commit.review_id
&& patch.runtime_job_id == commit.runtime_job_id
&& timestamp_after(&patch.emitted_at, after_timestamp)
&& patch.emitted_at <= commit.emitted_at
})
.max_by(|left, right| left.emitted_at.cmp(&right.emitted_at))
else {
continue;
};
let Some(command) = commands
.iter()
.filter(|command| {
command.intent_id == commit.intent_id
&& command.review_id == commit.review_id
&& command.runtime_job_id == commit.runtime_job_id
&& command.exit_code == "0"
&& timestamp_after(&command.emitted_at, after_timestamp)
&& command.emitted_at <= commit.emitted_at
})
.max_by(|left, right| left.emitted_at.cmp(&right.emitted_at))
else {
continue;
};
summaries.push(RuntimeHandsReceiptChainSummary {
patch_schema_version: patch.schema_version.clone(),
patch_receipt_id: patch.receipt_id.clone(),
command_schema_version: command.schema_version.clone(),
command_receipt_id: command.receipt_id.clone(),
commit_schema_version: commit.schema_version.clone(),
commit_receipt_id: commit.receipt_id.clone(),
intent_id: commit.intent_id.clone(),
review_id: commit.review_id.clone(),
runtime_job_id: commit.runtime_job_id.clone(),
substrate_gate_grant_receipt_id: command.substrate_gate_grant_receipt_id.clone(),
changed_paths: commit.changed_paths.clone(),
command: command.command.clone(),
exit_code: command.exit_code.clone(),
stdout_artifact: command.stdout_artifact.clone(),
stderr_artifact: command.stderr_artifact.clone(),
commit_sha: commit.commit_sha.clone(),
branch: commit.branch.clone(),
summary: commit.summary.clone(),
emitted_at: commit.emitted_at.clone(),
});
}
summaries.sort_by(|left, right| left.emitted_at.cmp(&right.emitted_at));
Ok(summaries.pop())
}
fn validate_coordinator_run_receipt(receipt: &EpiphanyCoordinatorRunReceipt) -> Result<()> {
validate_non_empty(&receipt.receipt_id, "coordinator run receipt id")?;
validate_non_empty(&receipt.session_id, "coordinator run receipt session id")?;
@ -10810,10 +10740,6 @@ fn validate_non_empty(value: &str, field: &str) -> Result<()> {
Ok(())
}
fn timestamp_after(value: &str, lower_bound: &str) -> bool {
!value.trim().is_empty() && value > lower_bound
}
fn worker_launch_document_kind(document: &EpiphanyWorkerLaunchDocument) -> &'static str {
document.document_kind()
}