Skip to content

Commit

Permalink
f
Browse files Browse the repository at this point in the history
  • Loading branch information
jbesraa committed Jan 9, 2025
1 parent e4c2510 commit 6b9cfaa
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion roles/tests-integration/lib/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ pub async fn start_sniffer(
}

pub async fn start_pool(template_provider_address: Option<SocketAddr>) -> (PoolSv2, SocketAddr) {
use pool_sv2::mining_pool::{CoinbaseOutput, Configuration};
use pool_sv2::mining_pool::{CoinbaseOutput, Configuration};
let listening_address = get_available_address();
let authority_public_key = Secp256k1PublicKey::try_from(
"9auqWEzQDVyd2oe1JVGFLMLHZtCo2FFqZwtKA5gd9xbuEu7PH72".to_string(),
Expand Down
6 changes: 3 additions & 3 deletions roles/tests-integration/tests/pool_integration.rs
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
use integration_tests_sv2::*;

use const_sv2::{MESSAGE_TYPE_NEW_EXTENDED_MINING_JOB, MESSAGE_TYPE_NEW_TEMPLATE};
use crate::sniffer::MessageDirection;
use const_sv2::{MESSAGE_TYPE_NEW_EXTENDED_MINING_JOB, MESSAGE_TYPE_NEW_TEMPLATE};
use roles_logic_sv2::{
common_messages_sv2::{Protocol, SetupConnection},
parsers::{AnyMessage, CommonMessages, Mining, PoolMessages, TemplateDistribution},
Expand Down Expand Up @@ -112,14 +112,14 @@ async fn header_timestamp_value_assertion_in_new_extended_mining_job() {
SetNewPrevHash
);
// Wait for a second NewExtendedMiningJob message
dbg!("waiting for second NewExtendedMiningJob message");
dbg!("waiting for second NewExtendedMiningJob message");
pool_translator_sniffer
.wait_for_message_type(
MessageDirection::ToDownstream,
MESSAGE_TYPE_NEW_EXTENDED_MINING_JOB,
)
.await;
dbg!("after waiting for second NewExtendedMiningJob message");
dbg!("after waiting for second NewExtendedMiningJob message");
// Extract min_ntime from the second NewExtendedMiningJob message
let second_job_ntime = match pool_translator_sniffer.next_message_from_upstream() {
Some((_, AnyMessage::Mining(Mining::NewExtendedMiningJob(job)))) => {
Expand Down

0 comments on commit 6b9cfaa

Please sign in to comment.