blockworks-foundation
/
pyth-crosschain
mirror of https://github.com/blockworks-foundation/pyth-crosschain.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix(hermes): fix slot metadata bug

This commit is contained in:
Ali Behjati 2023-09-20 11:32:14 +02:00
parent 2008da7a45
commit 272dbef9b3
4 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hermes/Cargo.lock generated
View File

@ -1764,7 +1764,7 @@ checksum = "95505c38b4572b2d910cecb0281560f54b440a19336cbbcb27bf6ce6adc6f5a8"
[[package]] [[package]]
name = "hermes" name = "hermes"
version = "0.1.17" version = "0.1.18"
dependencies = [ dependencies = [
"anyhow", "anyhow",
"async-trait", "async-trait",

2
hermes/Cargo.toml
View File

@ -1,6 +1,6 @@
[package] [package]
name = "hermes" name = "hermes"
version = "0.1.17" version = "0.1.18"
edition = "2021" edition = "2021"
[dependencies] [dependencies]

4
hermes/shell.nix
View File

@ -8,14 +8,16 @@ with pkgs; mkShell {
llvmPackages.libclang llvmPackages.libclang
nettle nettle
openssl_1_1 openssl_1_1
pkgconfig pkg-config
iconv iconv
protobuf protobuf
go go
rustup rustup
curl
]; ];
shellHook = '' shellHook = ''
export LIBCLANG_PATH="${llvmPackages.libclang.lib}/lib"; export LIBCLANG_PATH="${llvmPackages.libclang.lib}/lib";
export CPATH="${darwin.Libsystem}/include";
''; '';
} }

6
hermes/src/aggregate.rs
View File

@ -211,7 +211,8 @@ pub async fn store_update(state: &State, update: Update) -> Result<()> {
let mut aggregate_state = state.aggregate_state.write().await; let mut aggregate_state = state.aggregate_state.write().await;
aggregate_state.latest_observed_slot = aggregate_state aggregate_state.latest_observed_slot = aggregate_state
.latest_observed_slot .latest_observed_slot
.map(|latest| latest.max(slot)); .map(|latest| latest.max(slot))
.or(Some(slot));
} }
let accumulator_messages = state.fetch_accumulator_messages(slot).await?; let accumulator_messages = state.fetch_accumulator_messages(slot).await?;
@ -260,7 +261,8 @@ pub async fn store_update(state: &State, update: Update) -> Result<()> {
aggregate_state.latest_completed_slot = aggregate_state aggregate_state.latest_completed_slot = aggregate_state
.latest_completed_slot .latest_completed_slot
.map(|latest| latest.max(slot)); .map(|latest| latest.max(slot))
.or(Some(slot));
aggregate_state aggregate_state
.latest_completed_update_at .latest_completed_update_at