v0.1.0-pre.031

CHANGELOG.md

@@ -1,3 +1,10 @@
+## 0.1.0-pre.031
+
+- Migration complète de l’orchestration HTTP `backfill` dans `kb-pipeline`.
+- Conservation des sources explicites et historiques par adresse, des directions `before`/`after`, de la pagination bornée, des retries et de la reprise déterministe.
+- Adaptation aux façades `kb-onchain-transport`, `kb-store` et `kb-lib`.
+- Conservation des 15 tests bot2, dont les deux tests async d’annulation coopérative.
+
 
 ## 0.1.0-pre.030
 

README.md

@@ -98,3 +98,8 @@ La tranche `0.1.0-pre.029` migre la planification et l’extraction core de `kb-
 ### Pipeline migré
 
 `kb-pipeline` contient désormais l’extraction core et le replay contextuel de décodage avec matérialisation optionnelle.
+
+
+### Backfill HTTP
+
+La tranche `0.1.0-pre.031` ajoute l’orchestration HTTP de backfill : signatures explicites ou historiques par adresse, pagination bornée, hydration via `getTransaction`, retries, annulation, reprise déterministe et persistance des observations.

ROADMAP.md

@@ -282,7 +282,18 @@
 
 - [x] Planification et scopes de replay.
 - [x] Extraction canonique vers les tables core.
-- [ ] Backfill et replay de décodage.
+- [x] Backfill et replay de décodage.
 - [ ] Orchestrations Solana stateful et exécution.
 
 - [x] Migrer `decode_replay` dans `kb-pipeline`.
+
+
+### 0.1.0-pre.031 — Backfill HTTP
+
+- [x] Porter les campagnes par signatures explicites et historique d’adresse.
+- [x] Conserver les directions `before` et `after`, les ancres et la pagination RPC bornée.
+- [x] Conserver la reprise au dernier candidat contigu, les retries, le pacing et l’annulation coopérative.
+- [x] Adapter la persistance à `kb-store` et l’acquisition à `kb-onchain-transport`.
+- [x] Conserver les 15 tests bot2.
+- [ ] Valider avec Cargo sur la machine de développement.
+- [ ] Porter ensuite les orchestrations Solana stateful et d’exécution.

kb-pipeline/Cargo.toml

@@ -1,5 +1,5 @@
 # file: kb-pipeline/Cargo.toml
-# version: 5
+# version: 7
 
 [package]
 name = "kb-pipeline"
@@ -24,5 +24,8 @@ tokio.workspace = true
 tracing.workspace = true
 uuid.workspace = true
 
+[dev-dependencies]
+bs58.workspace = true
+
 [lints]
 workspace = true

kb-pipeline/src/lib.rs

@@ -1,5 +1,5 @@
 // file: kb-pipeline/src/lib.rs
-// version: 4
+// version: 5
 
 #![forbid(unsafe_code)]
 #![deny(unreachable_pub)]
@@ -7,11 +7,30 @@
 
 //! Pipeline orchestration boundary.
 
+mod backfill;
 mod constants;
 mod core_extraction;
 mod decode_replay;
 mod plan;
 
+/// Address category used by one targeted backfill campaign.
+pub use self::backfill::BackfillAddressKind;
+/// Chronological direction relative to one anchor signature.
+pub use self::backfill::BackfillDirection;
+/// Observer notified during HTTP backfill campaigns.
+pub use self::backfill::BackfillObserver;
+/// Progress event emitted by HTTP backfill campaigns.
+pub use self::backfill::BackfillProgressEvent;
+/// Severity of one HTTP backfill progress event.
+pub use self::backfill::BackfillProgressLevel;
+/// Complete bounded HTTP backfill request.
+pub use self::backfill::BackfillRequest;
+/// Candidate source used by one HTTP backfill campaign.
+pub use self::backfill::BackfillSource;
+/// Summary returned by one HTTP backfill campaign.
+pub use self::backfill::BackfillSummary;
+/// Executes one bounded HTTP transaction backfill campaign.
+pub use self::backfill::execute_http_backfill;
 /// Canonical tracing target for pipeline orchestration.
 pub(crate) use self::constants::TRACING_TARGET;
 /// Stable core extraction processor name.