Skip to content

feat: fix rewards calculations with stake address map in bootstrap #480

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
lowhung merged 20 commits into from
Dec 16, 2025
Merged

feat: fix rewards calculations with stake address map in bootstrap #480

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
20 commits
Select commit Hold shift + click to select a range
83b4226
Reorder subscription parameters in AccountsState run method
lowhung Dec 11, 2025
38f9383
Add UTXO stake credential extraction and reporting
lowhung Dec 12, 2025
a2ce0ad
Refactor UTXO handling with new types and CBOR decoding
lowhung Dec 12, 2025
f718dac
Add diagnostic logging to epoch snapshots and improve SPDD validation
lowhung Dec 12, 2025
dc09f7a
Add Reward Snapshot CBOR Decoding Types
lowhung Dec 12, 2025
21872ff
Refactor epoch snapshot processing and improve logging for unregister…
lowhung Dec 13, 2025
10fa17d
Remove SPDD generation from accounts state, clean up publisher
lowhung Dec 13, 2025
8c47593
Unstage SPDD integration test changes
lowhung Dec 13, 2025
81272b1
Add back logging we had originally
lowhung Dec 14, 2025
8e166e0
Preserve precision in likelihood values using SignedRationalNumber
lowhung Dec 15, 2025
4aa7e9e
Simplify CBOR map length parsing logic
lowhung Dec 15, 2025
2ffc8a0
Merge branch 'main' into lowhung/generate-spdd-from-bootstrap
lowhung Dec 15, 2025
03fe949
Merge in Alex's UTxO work from 386
lowhung Dec 15, 2025
197afda
Update UTXO sample display with new method calls
lowhung Dec 15, 2025
9de58aa
Merge branch 'ajw/386-bootstrap-utxo-module' into lowhung/generate-sp…
lowhung Dec 15, 2025
d8a7a4a
Refactor Shelley address stake credential extraction
lowhung Dec 16, 2025
c56899d
Add tests for encoding/decoding utxos
lowhung Dec 16, 2025
318f98e
Merge branch 'main' into lowhung/generate-spdd-from-bootstrap
lowhung Dec 16, 2025
3a7dfb0
Remove SignedRationalNumber and migrate to RationalNumber
lowhung Dec 16, 2025
1f2a955
Simplify rational number decoding for float types
lowhung Dec 16, 2025
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
19 changes: 16 additions & 3 deletions common/examples/test_streaming_parser.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -51,9 +51,14 @@ impl UtxoCallback for CountingCallbacks {
// Keep first 10 for display
if self.sample_utxos.len() < 10 {
if self.sample_utxos.len() < 10 {
let addr_bytes = utxo.address_bytes();
eprintln!(
" UTXO #{}: {} → {:?}",
self.utxo_count, utxo.id, utxo.value
" UTXO #{}: {}:{} → {} ({} lovelace)",
self.utxo_count,
&utxo.tx_hash_hex()[..16],
utxo.output_index(),
hex::encode(&addr_bytes[..addr_bytes.len().min(16)]),
utxo.coin()
);
}
self.sample_utxos.push(utxo);
Expand Down Expand Up @@ -502,7 +507,15 @@ fn main() {
if !callbacks.sample_utxos.is_empty() {
println!("Sample UTXOs (first 10):");
for (i, utxo) in callbacks.sample_utxos.iter().enumerate() {
println!(" {}: {} → {:?}", i + 1, utxo.id, utxo.value);
let addr_bytes = utxo.address_bytes();
println!(
" {}: {}:{} → {} ({} lovelace)",
i + 1,
&utxo.tx_hash_hex()[..16],
utxo.output_index(),
hex::encode(&addr_bytes[..addr_bytes.len().min(16)]),
utxo.coin()
);
}
println!();
}
Expand Down
4 changes: 4 additions & 0 deletions common/src/snapshot/mod.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,7 @@ mod error;
pub mod mark_set_go;
mod parser;
pub mod protocol_parameters;
pub mod reward_snapshot;
pub mod streaming_snapshot;
pub mod utxo;
pub use error::SnapshotError;
Expand All @@ -28,3 +29,6 @@ pub use streaming_snapshot::{
};

pub use mark_set_go::{RawSnapshot, RawSnapshotsContainer, SnapshotsCallback, VMap};
pub use reward_snapshot::{
Likelihood, NonMyopic, PulsingRewardUpdate, Reward, RewardSnapshot, RewardType, RewardUpdate,
};
Loading