v0.3.12-pre.007-fix.002

This commit is contained in:
2026-09-09 17:14:47 +02:00
parent 8410b2f4ef
commit 90c266d68a
4 changed files with 147 additions and 5 deletions

View File

@@ -1,12 +1,12 @@
# file: Cargo.toml # file: Cargo.toml
# version: 530 # version: 531
[workspace] [workspace]
resolver = "3" resolver = "3"
members = ["crates/ksp-app-backfill-desk", "crates/ksp-app-config-desk", "crates/ksp-app-solprices-desk", "crates/ksp-app-store-desk", "crates/ksp-app-wallet-desk", "crates/ksp-config-lib", "crates/ksp-core-lib", "crates/ksp-interface-lib", "crates/ksp-job-api", "crates/ksp-job-backfill-lib", "crates/ksp-logging-lib", "crates/ksp-offchain-transport-lib", "crates/ksp-onchain-transport-lib", "crates/ksp-program-api", "crates/ksp-raw-transaction-lib", "crates/ksp-store-api", "crates/ksp-store-lib", "crates/ksp-store-postgres-lib", "crates/ksp-wallet-lib", "crates/ksp-worker-api", "crates/ksp-worker-raw-transaction-ingest-lib"] members = ["crates/ksp-app-backfill-desk", "crates/ksp-app-config-desk", "crates/ksp-app-solprices-desk", "crates/ksp-app-store-desk", "crates/ksp-app-wallet-desk", "crates/ksp-config-lib", "crates/ksp-core-lib", "crates/ksp-interface-lib", "crates/ksp-job-api", "crates/ksp-job-backfill-lib", "crates/ksp-logging-lib", "crates/ksp-offchain-transport-lib", "crates/ksp-onchain-transport-lib", "crates/ksp-program-api", "crates/ksp-raw-transaction-lib", "crates/ksp-store-api", "crates/ksp-store-lib", "crates/ksp-store-postgres-lib", "crates/ksp-wallet-lib", "crates/ksp-worker-api", "crates/ksp-worker-raw-transaction-ingest-lib"]
[workspace.package] [workspace.package]
version = "0.3.12-pre.7.fix.1" version = "0.3.12-pre.7.fix.2"
edition = "2024" edition = "2024"
license = "MIT" license = "MIT"
repository = "https://git.sasedev.com/Sasedev/khadhroony-solana-project" repository = "https://git.sasedev.com/Sasedev/khadhroony-solana-project"

View File

@@ -1,5 +1,5 @@
// file: crates/ksp-worker-raw-transaction-ingest-lib/tests/dependency_boundary.rs // file: crates/ksp-worker-raw-transaction-ingest-lib/tests/dependency_boundary.rs
// version: 14 // version: 15
//! Dependency firewall canaries for the RAW transaction ingest Worker foundation. //! Dependency firewall canaries for the RAW transaction ingest Worker foundation.
@@ -270,7 +270,17 @@ fn v0_3_12_pre_006_source_surface_hardens_shutdown_and_faults_without_backend_ed
"pre.009 crossed a forbidden runtime boundary: {forbidden}" "pre.009 crossed a forbidden runtime boundary: {forbidden}"
); );
} }
assert_eq!(runtime.matches("tokio::sync::watch::channel").count(), 2, "runtime retains only the external-control and private-source stop watches"); assert_eq!(
runtime.matches("tokio::sync::watch::channel(false)").count(),
2,
"runtime retains exactly the external-control and private-source stop watches"
);
assert_eq!(
runtime.matches("tokio::sync::watch::channel(crate::RawTransactionIngestProcessingFrontierProjection::empty())").count(),
1,
"runtime retains exactly one run-local processing-frontier latest-value watch",
);
assert_eq!(runtime.matches("tokio::sync::watch::channel").count(), 3, "runtime watch inventory is two stop watches plus one processing-frontier watch");
assert_eq!(snapshot.matches("tokio::sync::watch::channel").count(), 1, "exactly one shared concrete snapshot watch is allowed"); assert_eq!(snapshot.matches("tokio::sync::watch::channel").count(), 1, "exactly one shared concrete snapshot watch is allowed");
return; return;
} }

View File

@@ -0,0 +1,108 @@
<!-- file: deltas/0.3.12/pre.007-fix.002.md -->
<!-- version: 1 -->
# Delta `0.3.12-pre.007-fix.002` — correction du canari d'inventaire des watches
## Base requise
```text
0.3.12-pre.007-fix.001
workspace.package.version = 0.3.12-pre.7.fix.1
```
Le gate opérateur de `pre.007-fix.001` a validé les audits Rust/Markdown, `cargo check`, Clippy strict et les 61 tests unitaires Worker. L'unique échec restant provient du test d'intégration `dependency_boundary`, qui comptait encore exactement deux `tokio::sync::watch::channel` dans `runtime.rs`.
Depuis `pre.007`, une troisième watch run-local transporte légitimement la projection latest-value de processing frontier.
## Objectif
Corriger uniquement ce canari structurel obsolète, sans modifier le runtime ni le contrat fonctionnel de la processing frontier.
## Version
```text
workspace.package.version = 0.3.12-pre.7.fix.2
```
## Modifications
### Canari `dependency_boundary`
Le test distingue désormais explicitement les usages de watch dans `runtime.rs` :
```text
2 x watch::channel(false) : stop external-control + stop private-source
1 x watch::channel(RawTransactionIngestProcessingFrontierProjection::empty()) : frontier run-local latest-value
3 x watch::channel au total dans runtime.rs
```
Le canari conserve aussi l'invariant d'une seule watch de snapshot concret dans `snapshot.rs`.
Aucun test n'est affaibli : le contrôle devient plus précis qu'un simple comptage global.
## Fichiers modifiés
```text
Cargo.toml
crates/ksp-worker-raw-transaction-ingest-lib/tests/dependency_boundary.rs
docs/validation/029-V0_3_12_YELLOWSTONE_HYDRATION_CONTINUITY.md
```
## Fichier ajouté
```text
deltas/0.3.12/pre.007-fix.002.md
```
## Fichiers supprimés
```text
aucun
```
## Invariants préservés
Le correctif ne modifie pas :
```text
runtime.rs
pending / settled
compaction des slots
processing_frontier_slot
oldest_pending_slot
hydration_pending
source Yellowstone productive
coalescence / hydration HTTP
admission / persistence
API publique
reconnect / from_slot / ReplayInfo / repair
```
## Validations exécutées dans l'environnement d'assemblage
```text
python3 scripts/audit_rust_workspace_rules.py
python3 scripts/audit_markdown_tables.py README.md RULES.md ROADMAP.md CHANGELOG.md docs prompts crates deltas
contrôle statique de l'inventaire des watches runtime/snapshot
reconstruction du delta sur base pre.007-fix.001
unzip -t de l'archive finale
```
## Validations non exécutées localement
L'environnement d'assemblage ne fournit pas Cargo/rustc/rustfmt. Les gates Cargo doivent être rejoués par l'opérateur :
```text
cargo fmt --all
cargo check --workspace
cargo clippy --workspace --all-targets --all-features -- -D warnings
cargo test -p ksp-worker-raw-transaction-ingest-lib
```
## Décisions
Aucune nouvelle décision fonctionnelle.
## Questions ouvertes
Aucune nouvelle question ouverte introduite par ce fix.

View File

@@ -1,5 +1,5 @@
<!-- file: docs/validation/029-V0_3_12_YELLOWSTONE_HYDRATION_CONTINUITY.md --> <!-- file: docs/validation/029-V0_3_12_YELLOWSTONE_HYDRATION_CONTINUITY.md -->
<!-- version: 14 --> <!-- version: 15 -->
# Validation v0.3.12 — Yellowstone + hydration HTTP + continuité de run du Worker RawTransaction # Validation v0.3.12 — Yellowstone + hydration HTTP + continuité de run du Worker RawTransaction
@@ -1468,3 +1468,27 @@ construit un reporter frontier test-only pour les deux appels queue_signal du ca
Aucune définition pending/settled, compaction, projection snapshot, API publique, source Yellowstone, hydration, admission, persistence, reconnect ou replay n'est modifiée. Aucune définition pending/settled, compaction, projection snapshot, API publique, source Yellowstone, hydration, admission, persistence, reconnect ou replay n'est modifiée.
Les validations Cargo de ce correctif restent à rejouer par l'opérateur. Les validations Cargo de ce correctif restent à rejouer par l'opérateur.
## 64. Gate opérateur `pre.007-fix.001` et correctif `pre.007-fix.002`
Le gate opérateur de `pre.007-fix.001` est vert pour les audits Rust/Markdown, `cargo check`, Clippy strict et les 61 tests unitaires Worker. L'unique échec restant est un canari source de `dependency_boundary` :
```text
assertion attendue : 2 tokio::sync::watch::channel dans runtime.rs
valeur observée : 3
```
Cette troisième watch est légitime et appartient à `pre.007` : elle transporte la projection latest-value run-local de processing frontier. Les deux autres watches restent exclusivement les stops external-control et private-source.
Le correctif `pre.007-fix.002` ne modifie donc pas le runtime. Il rend le canari structurel exact en vérifiant séparément :
```text
2 x tokio::sync::watch::channel(false) pour les stops
1 x watch de RawTransactionIngestProcessingFrontierProjection::empty()
3 x watch au total dans runtime.rs
1 x watch snapshot concret dans snapshot.rs
```
Aucune définition pending/settled, compaction, projection snapshot, source Yellowstone, hydration, admission, persistence, API publique, reconnect ou replay n'est modifiée.
Les validations Cargo de ce correctif restent à rejouer par l'opérateur.