Skip to content
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

updated with latest zingolabs/dev #37

Open
wants to merge 35 commits into
base: darkside_reloaded_2
Choose a base branch
from
Open

updated with latest zingolabs/dev #37

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
35 commits
Select commit Hold shift + click to select a range
dd00f96
what todo?!
zancas Nov 29, 2024
f8f2679
fix typo
zancas Nov 30, 2024
312e2bf
implement index on valuetransfers
zancas Nov 30, 2024
f312170
impl Deref for ValueTransfers
zancas Nov 30, 2024
647eecd
set incremental on in dev builds to support language analyzer
zancas Nov 30, 2024
0849fe9
deprecate, probably useless, ValueTransfers::new
zancas Nov 30, 2024
314a0b5
this is now a particular case of deref logic
zancas Nov 30, 2024
c5f0e7c
to reduce overhead: https://rust-lang.github.io/rust-clippy/master/in…
zancas Nov 30, 2024
c4d7b06
remove clippy-irritating dbg
zancas Nov 30, 2024
5afd9e5
comment out dbg, and rationalize commenting
zancas Nov 30, 2024
3f610d8
clean up last clippy warnings
zancas Nov 30, 2024
810af94
impl DerefMut and use it
zancas Nov 30, 2024
fdc6286
update consumer to use ergonomic interface
zancas Nov 30, 2024
cc5f349
improve no_messages call
zancas Nov 30, 2024
1aa961e
use impl<'a> std::iter::IntoIterator for &'a ValueTransfers
zancas Nov 30, 2024
ec04445
use Derefgit add -p! Ha. :)
zancas Nov 30, 2024
cc1af3b
update comments and unify behavior, explicitly note inauthenticity!
zancas Nov 30, 2024
6fa99f1
tighten test
zancas Nov 30, 2024
a96fcfe
rm dbg
zancas Nov 30, 2024
2af8833
simplify interface in fast::value_transfers
zancas Nov 30, 2024
b5629f7
finish simplifying with same semantics
zancas Nov 30, 2024
b7a7d97
fix incorrect test assertion, and rm dbg
zancas Nov 30, 2024
496a444
these implementations make ValueTransfer ergonomic, important for cla…
zancas Nov 30, 2024
ab4ce7d
start applying ergonomic calls to ValueTransfer
zancas Nov 30, 2024
513c8f2
complete migration to idiomatic ValueTransfers interface
zancas Nov 30, 2024
2ed49cb
propose short staling interval
zancas Nov 30, 2024
d31c9d0
name block window before clearing pending the pending_window, verify …
zancas Nov 30, 2024
1f8f41e
the pending_window is about 140 - 210 seconds, usually.
zancas Nov 30, 2024
be6c159
Merge pull request #1566 from zancas/reduce_broadcast_fail_watch_time
zancas Nov 30, 2024
aaa545d
Merge branch 'dev' into make_value_transfers_more_idiomatic
dorianvp Nov 30, 2024
6c0e7d2
Merge pull request #1564 from zancas/make_value_transfers_more_idiomatic
zancas Nov 30, 2024
1a0c1a8
update dependency versions
zancas Dec 1, 2024
644ab86
Merge pull request #1570 from zancas/cargo_update
zancas Dec 1, 2024
5f32804
Merge remote-tracking branch 'zingolabs/dev' into darkside_reloaded_2
zancas Dec 1, 2024
ba32723
undeprecate, cargo update, fix typo, remove incorrect comment
zancas Dec 1, 2024
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
619 changes: 446 additions & 173 deletions Cargo.lock
View file
Open in desktop

Large diffs are not rendered by default.

8 changes: 6 additions & 2 deletions Cargo.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -91,10 +91,10 @@ tokio = "1"
tokio-rustls = "0.26"
tonic = {version = "0.12", features = ["tls", "tls-roots", "tls-webpki-roots"]}
tonic-build = "0.12"
tower = { version = "0.4" }
tower = { version = "0.5" }
tracing = "0.1"
tracing-subscriber = "0.3"
webpki-roots = "0.25"
webpki-roots = "0.26"

# Parallel processing
crossbeam-channel = "0.5"
Expand All @@ -104,7 +104,11 @@ bs58 = "0.5"

[profile.release]
debug = false
incremental = false

[profile.test]
opt-level = 3
debug = false

[profile.dev]
incremental = true
2 changes: 1 addition & 1 deletion darkside-tests/src/darkside_connector.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@ impl DarksideConnector {
let uri = Uri::builder()
.scheme(uri.scheme().unwrap().clone())
.authority(uri.authority().unwrap().clone())
//here. The Request's uri contains the path to the GRPC sever and
//here. The Request's uri contains the path to the GRPC server and
//the method being called
.path_and_query(req.uri().path_and_query().unwrap().clone())
.build()
Expand Down
22 changes: 11 additions & 11 deletions darkside-tests/tests/advanced_reorg_tests.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,7 @@ async fn reorg_changes_incoming_tx_height() {
}
);

let before_reorg_transactions = light_client.sorted_value_transfers(true).await.0;
let before_reorg_transactions = light_client.sorted_value_transfers(true).await;

assert_eq!(before_reorg_transactions.len(), 1);
assert_eq!(
Expand Down Expand Up @@ -94,7 +94,7 @@ async fn reorg_changes_incoming_tx_height() {
}
);

let after_reorg_transactions = light_client.sorted_value_transfers(true).await.0;
let after_reorg_transactions = light_client.sorted_value_transfers(true).await;

assert_eq!(after_reorg_transactions.len(), 1);
assert_eq!(
Expand Down Expand Up @@ -215,7 +215,7 @@ async fn reorg_changes_incoming_tx_index() {
}
);

let before_reorg_transactions = light_client.sorted_value_transfers(true).await.0;
let before_reorg_transactions = light_client.sorted_value_transfers(true).await;

assert_eq!(before_reorg_transactions.len(), 1);
assert_eq!(
Expand Down Expand Up @@ -250,7 +250,7 @@ async fn reorg_changes_incoming_tx_index() {
}
);

let after_reorg_transactions = light_client.sorted_value_transfers(true).await.0;
let after_reorg_transactions = light_client.sorted_value_transfers(true).await;

assert_eq!(after_reorg_transactions.len(), 1);
assert_eq!(
Expand Down Expand Up @@ -370,7 +370,7 @@ async fn reorg_expires_incoming_tx() {
}
);

let before_reorg_transactions = light_client.sorted_value_transfers(true).await.0;
let before_reorg_transactions = light_client.sorted_value_transfers(true).await;

assert_eq!(before_reorg_transactions.len(), 1);
assert_eq!(
Expand Down Expand Up @@ -405,7 +405,7 @@ async fn reorg_expires_incoming_tx() {
}
);

let after_reorg_transactions = light_client.sorted_value_transfers(true).await.0;
let after_reorg_transactions = light_client.sorted_value_transfers(true).await;

assert_eq!(after_reorg_transactions.len(), 0);
}
Expand Down Expand Up @@ -548,7 +548,7 @@ async fn reorg_changes_outgoing_tx_height() {
}
);

let before_reorg_transactions = light_client.sorted_value_transfers(true).await.0;
let before_reorg_transactions = light_client.sorted_value_transfers(true).await;

assert_eq!(before_reorg_transactions.len(), 1);
assert_eq!(
Expand Down Expand Up @@ -662,7 +662,7 @@ async fn reorg_changes_outgoing_tx_height() {
expected_after_reorg_balance
);

let after_reorg_transactions = light_client.sorted_value_transfers(true).await.0;
let after_reorg_transactions = light_client.sorted_value_transfers(true).await;

assert_eq!(after_reorg_transactions.len(), 3);

Expand Down Expand Up @@ -787,7 +787,7 @@ async fn reorg_expires_outgoing_tx_height() {
light_client.do_sync(true).await.unwrap();
assert_eq!(light_client.do_balance().await, expected_initial_balance);

let before_reorg_transactions = light_client.sorted_value_transfers(true).await.0;
let before_reorg_transactions = light_client.sorted_value_transfers(true).await;

assert_eq!(before_reorg_transactions.len(), 1);
assert_eq!(
Expand Down Expand Up @@ -873,7 +873,7 @@ async fn reorg_expires_outgoing_tx_height() {
// sent transaction was never mined and has expired.
assert_eq!(light_client.do_balance().await, expected_initial_balance);

let after_reorg_transactions = light_client.sorted_value_transfers(true).await.0;
let after_reorg_transactions = light_client.sorted_value_transfers(true).await;

assert_eq!(after_reorg_transactions.len(), 1);

Expand Down Expand Up @@ -965,7 +965,7 @@ async fn reorg_changes_outgoing_tx_index() {
}
);

let before_reorg_transactions = light_client.sorted_value_transfers(true).await.0;
let before_reorg_transactions = light_client.sorted_value_transfers(true).await;

assert_eq!(before_reorg_transactions.len(), 1);
assert_eq!(
Expand Down
4 changes: 4 additions & 0 deletions libtonode-tests/tests/chain_generics.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -379,6 +379,10 @@ mod chain_generics {
target
);
}

fn lightserver_uri(&self) -> Option<http::Uri> {
todo!()
}
}
}
}
Loading
Loading