Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
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
46 changes: 23 additions & 23 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

46 changes: 23 additions & 23 deletions Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -45,32 +45,32 @@ homepage = "https://fuel.network/"
keywords = ["blockchain", "cryptocurrencies", "fuel-vm", "vm"]
license = "BUSL-1.1"
repository = "https://github.com/FuelLabs/fuel-core"
version = "0.19.1"
version = "0.19.2"

[workspace.dependencies]
# Workspace members
fuel-core = { version = "0.19.1", path = "./crates/fuel-core", default-features = false }
fuel-core-client-bin = { version = "0.19.1", path = "./bin/client" }
fuel-core-bin = { version = "0.19.1", path = "./bin/fuel-core" }
fuel-core-keygen = { version = "0.19.1", path = "./bin/keygen" }
fuel-core-chain-config = { version = "0.19.1", path = "./crates/chain-config" }
fuel-core-client = { version = "0.19.1", path = "./crates/client" }
fuel-core-database = { version = "0.19.1", path = "./crates/database" }
fuel-core-metrics = { version = "0.19.1", path = "./crates/metrics" }
fuel-core-services = { version = "0.19.1", path = "./crates/services" }
fuel-core-consensus-module = { version = "0.19.1", path = "./crates/services/consensus_module" }
fuel-core-bft = { version = "0.19.1", path = "./crates/services/consensus_module/bft" }
fuel-core-poa = { version = "0.19.1", path = "./crates/services/consensus_module/poa" }
fuel-core-executor = { version = "0.19.1", path = "./crates/services/executor" }
fuel-core-importer = { version = "0.19.1", path = "./crates/services/importer" }
fuel-core-p2p = { version = "0.19.1", path = "./crates/services/p2p" }
fuel-core-producer = { version = "0.19.1", path = "./crates/services/producer" }
fuel-core-relayer = { version = "0.19.1", path = "./crates/services/relayer" }
fuel-core-sync = { version = "0.19.1", path = "./crates/services/sync" }
fuel-core-txpool = { version = "0.19.1", path = "./crates/services/txpool" }
fuel-core-storage = { version = "0.19.1", path = "./crates/storage" }
fuel-core-trace = { version = "0.19.1", path = "./crates/trace" }
fuel-core-types = { version = "0.19.1", path = "./crates/types", default-features = false }
fuel-core = { version = "0.19.2", path = "./crates/fuel-core", default-features = false }
fuel-core-client-bin = { version = "0.19.2", path = "./bin/client" }
fuel-core-bin = { version = "0.19.2", path = "./bin/fuel-core" }
fuel-core-keygen = { version = "0.19.2", path = "./bin/keygen" }
fuel-core-chain-config = { version = "0.19.2", path = "./crates/chain-config" }
fuel-core-client = { version = "0.19.2", path = "./crates/client" }
fuel-core-database = { version = "0.19.2", path = "./crates/database" }
fuel-core-metrics = { version = "0.19.2", path = "./crates/metrics" }
fuel-core-services = { version = "0.19.2", path = "./crates/services" }
fuel-core-consensus-module = { version = "0.19.2", path = "./crates/services/consensus_module" }
fuel-core-bft = { version = "0.19.2", path = "./crates/services/consensus_module/bft" }
fuel-core-poa = { version = "0.19.2", path = "./crates/services/consensus_module/poa" }
fuel-core-executor = { version = "0.19.2", path = "./crates/services/executor" }
fuel-core-importer = { version = "0.19.2", path = "./crates/services/importer" }
fuel-core-p2p = { version = "0.19.2", path = "./crates/services/p2p" }
fuel-core-producer = { version = "0.19.2", path = "./crates/services/producer" }
fuel-core-relayer = { version = "0.19.2", path = "./crates/services/relayer" }
fuel-core-sync = { version = "0.19.2", path = "./crates/services/sync" }
fuel-core-txpool = { version = "0.19.2", path = "./crates/services/txpool" }
fuel-core-storage = { version = "0.19.2", path = "./crates/storage" }
fuel-core-trace = { version = "0.19.2", path = "./crates/trace" }
fuel-core-types = { version = "0.19.2", path = "./crates/types", default-features = false }
fuel-core-tests = { version = "0.0.0", path = "./tests" }
fuel-core-xtask = { version = "0.0.0", path = "./xtask" }

Expand Down
2 changes: 1 addition & 1 deletion crates/services/relayer/src/config.rs
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@ pub struct Config {

#[allow(missing_docs)]
impl Config {
pub const DEFAULT_LOG_PAGE_SIZE: u64 = 5;
pub const DEFAULT_LOG_PAGE_SIZE: u64 = 10_000;
pub const DEFAULT_DA_FINALIZATION: u64 = 100;
pub const DEFAULT_DA_DEPLOY_HEIGHT: u64 = 0;
pub const DEFAULT_SYNC_MINIMUM_DURATION: Duration = Duration::from_secs(5);
Expand Down
4 changes: 3 additions & 1 deletion crates/services/relayer/src/service.rs
Original file line number Diff line number Diff line change
Expand Up @@ -226,7 +226,9 @@ where

let result = run::run(self).await;

if self.shutdown.borrow_and_update().started() && self.synced.borrow().is_some() {
if self.shutdown.borrow_and_update().started()
&& (result.is_err() | self.synced.borrow().is_some())
{
// Sleep the loop so the da node is not spammed.
tokio::time::sleep(
self.config
Expand Down
4 changes: 3 additions & 1 deletion crates/services/relayer/src/service/get_logs/test.rs
Original file line number Diff line number Diff line change
Expand Up @@ -79,6 +79,8 @@ struct Expected {
m: Vec<Log>,
}

const DEFAULT_LOG_PAGE_SIZE: u64 = 5;

#[test_case(
Input {
eth_gap: 0..=1,
Expand Down Expand Up @@ -132,7 +134,7 @@ async fn can_paginate_logs(input: Input) -> Expected {
&EthSyncGap::new(*eth_gap.start(), *eth_gap.end()),
contracts,
&eth_node,
Config::DEFAULT_LOG_PAGE_SIZE,
DEFAULT_LOG_PAGE_SIZE,
)
.map_ok(|(_, l)| l)
.try_concat()
Expand Down
4 changes: 3 additions & 1 deletion crates/services/relayer/src/service/test.rs
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,8 @@ use futures::TryStreamExt;

use super::*;

const DEFAULT_LOG_PAGE_SIZE: u64 = 5;

#[tokio::test]
async fn can_download_logs() {
let eth_node = MockMiddleware::default();
Expand Down Expand Up @@ -32,7 +34,7 @@ async fn can_download_logs() {
&eth_state.needs_to_sync_eth().unwrap(),
contracts,
&eth_node,
Config::DEFAULT_LOG_PAGE_SIZE,
DEFAULT_LOG_PAGE_SIZE,
)
.map_ok(|(_, l)| l)
.try_concat()
Expand Down
6 changes: 5 additions & 1 deletion crates/services/relayer/tests/integration.rs
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,11 @@ async fn stop_service_at_the_middle() {
let mock_db = MockDb::default();
let eth_node = MockMiddleware::default();
eth_node.update_data(|data| data.best_block.number = Some(200.into()));
let relayer = new_service_test(eth_node, mock_db.clone(), Default::default());
let config = Config {
log_page_size: 5,
..Default::default()
};
let relayer = new_service_test(eth_node, mock_db.clone(), config);
relayer.start_and_await().await.unwrap();

// Skip the initial requests to start the synchronization.
Expand Down
2 changes: 1 addition & 1 deletion deployment/charts/Chart.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -2,5 +2,5 @@ apiVersion: v2
name: ${fuel_core_service_name}
description: ${fuel_core_service_name} Helm Chart
type: application
appVersion: "0.19.1"
appVersion: "0.19.2"
version: 0.1.0