Mirror/brk
1
0
Fork 0
mirror of https://github.com/bitcoinresearchkit/brk.git synced 2026-04-25 15:19:58 -07:00
Code Issues Packages Projects Releases Wiki Activity

global: add sent volume

Browse Source
This commit is contained in:
nym21
2025-09-12 12:00:03 +02:00
parent 504d6eaa9f
commit a5951c58f3
4 changed files with 49 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
crates/brk_computer/src/chain.rs
View File

@@ -10,7 +10,7 @@ use brk_structs::{
YearIndex,
};
use vecdb::{
AnyCloneableIterableVec, AnyCollectableVec, AnyIterableVec, Database, EagerVec, Exit,
AnyCloneableIterableVec, AnyCollectableVec, AnyIterableVec, AnyVec, Database, EagerVec, Exit,
LazyVecFrom1, LazyVecFrom2, LazyVecFrom3, PAGE_SIZE, StoredIndex, VecIterator,
};
@@ -74,6 +74,7 @@ pub struct Vecs {
/// Value == 0 when Coinbase
pub txindex_to_input_value:
LazyVecFrom3<TxIndex, Sats, TxIndex, InputIndex, TxIndex, StoredU64, InputIndex, Sats>,
pub indexes_to_sent: ComputedValueVecsFromHeight,
// pub indexes_to_input_value: ComputedVecsFromTxindex<Sats>,
pub indexes_to_opreturn_count: ComputedVecsFromHeight<StoredU64>,
pub txindex_to_output_value:
@@ -605,6 +606,15 @@ impl Vecs {
indexes,
VecBuilderOptions::default().add_sum().add_cumulative(),
)?,
indexes_to_sent: ComputedValueVecsFromHeight::forced_import(
&db,
"sent",
Source::Compute,
version + VERSION + Version::ZERO,
VecBuilderOptions::default().add_sum(),
compute_dollars,
indexes,
)?,
indexes_to_fee: ComputedValueVecsFromTxindex::forced_import(
&db,
"fee",
@@ -1398,6 +1408,20 @@ impl Vecs {
exit,
)?;
self.indexes_to_sent
.compute_all(indexes, price, starting_indexes, exit, |v| {
dbg!(v.len());
v.compute_sum_from_indexes(
starting_indexes.height,
&indexer.vecs.height_to_first_txindex,
&indexes.height_to_txindex_count,
&self.txindex_to_input_value,
exit,
)?;
dbg!(v.len());
Ok(())
})?;
self.indexes_to_fee.compute_rest(
indexer,
indexes,
@@ -2147,6 +2171,7 @@ impl Vecs {
.iter_any_collectable(),
),
);
iter = Box::new(iter.chain(self.indexes_to_sent.iter_any_collectable()));
iter = Box::new(iter.chain(self.indexes_to_hash_price_ths.iter_any_collectable()));
iter = Box::new(iter.chain(self.indexes_to_hash_price_phs.iter_any_collectable()));
iter = Box::new(iter.chain(self.indexes_to_hash_value_ths.iter_any_collectable()));