Skip to content
This repository has been archived by the owner on Sep 25, 2023. It is now read-only.

Commit

Permalink
fix: fix dependency imports
Browse files Browse the repository at this point in the history
Signed-off-by: Joseph Livesey <[email protected]>
  • Loading branch information
suchapalaver committed Feb 1, 2023
1 parent 84959ef commit 30efbba
Show file tree
Hide file tree
Showing 3 changed files with 29 additions and 26 deletions.
1 change: 1 addition & 0 deletions Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@ name = "sawtooth-devmode-engine-rust"
version = "1.2.5"
authors = ["Intel Corporation"]
description = "Hyperledger Sawtooth DevMode Rust consensus engine"
edition = "2021"

[[bin]]
name = "devmode-engine-rust"
Expand Down
27 changes: 15 additions & 12 deletions src/engine.rs
Original file line number Diff line number Diff line change
Expand Up @@ -15,16 +15,19 @@
* ------------------------------------------------------------------------------
*/

use std::fmt::{self, Write};
use std::str::FromStr;
use std::sync::mpsc::{Receiver, RecvTimeoutError};
use std::thread::sleep;
use std::time;

use rand;
use rand::Rng;

use sawtooth_sdk::consensus::{engine::*, service::Service};
use std::{
fmt::{self, Write},
str::FromStr,
sync::mpsc::{Receiver, RecvTimeoutError},
thread::sleep,
time,
};

use rand::{thread_rng, Rng};
use sawtooth_sdk::consensus::{
engine::{Block, BlockId, Engine, Error, PeerId, StartupState, Update},
service::Service,
};

const DEFAULT_WAIT_TIME: u64 = 0;
const NULL_BLOCK_IDENTIFIER: [u8; 8] = [0, 0, 0, 0, 0, 0, 0, 0];
Expand Down Expand Up @@ -141,7 +144,7 @@ impl DevmodeService {
Ok(_) => {}
Err(Error::InvalidState(_)) => {}
Err(err) => {
panic!("Failed to cancel block: {:?}", err);
panic!("Failed to cancel block: {err:?}");
}
};
}
Expand Down Expand Up @@ -200,7 +203,7 @@ impl DevmodeService {
if min_wait_time >= max_wait_time {
DEFAULT_WAIT_TIME
} else {
rand::thread_rng().gen_range(min_wait_time, max_wait_time)
thread_rng().gen_range(min_wait_time, max_wait_time)
}
} else {
DEFAULT_WAIT_TIME
Expand Down
27 changes: 13 additions & 14 deletions src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -15,24 +15,23 @@
* ------------------------------------------------------------------------------
*/

#[macro_use]
extern crate clap;
#[macro_use]
extern crate log;
extern crate log4rs;
extern crate rand;
extern crate sawtooth_sdk;

mod engine;

use std::process;

use log::LevelFilter;
use log4rs::append::console::ConsoleAppender;
use log4rs::config::{Appender, Config, Root};
use log4rs::encode::pattern::PatternEncoder;
#[macro_use]
extern crate clap;
#[macro_use]
extern crate log;

use engine::DevmodeEngine;
use log::LevelFilter;
use log4rs::{
append::console::ConsoleAppender,
config::{Appender, Root},
encode::pattern::PatternEncoder,
init_config, Config,
};
use sawtooth_sdk::consensus::zmq_driver::ZmqDriver;

fn main() {
Expand Down Expand Up @@ -67,10 +66,10 @@ fn main() {
.build(Root::builder().appender("stdout").build(console_log_level))
.unwrap_or_else(|err| {
error!("{}", err);
process::exit(1);
process::exit(1)
});

log4rs::init_config(config).unwrap_or_else(|err| {
init_config(config).unwrap_or_else(|err| {
error!("{}", err);
process::exit(1);
});
Expand Down

0 comments on commit 30efbba

Please sign in to comment.