Skip to content

Commit

Permalink
Add emojis (paritytech#5420)
Browse files Browse the repository at this point in the history
  • Loading branch information
gavofyork authored Mar 27, 2020
1 parent f7bd10a commit beff538
Show file tree
Hide file tree
Showing 19 changed files with 42 additions and 42 deletions.
6 changes: 3 additions & 3 deletions bin/node/cli/src/browser.rs
Original file line number Diff line number Diff line change
Expand Up @@ -43,9 +43,9 @@ async fn start_inner(chain_spec: String, log_level: String) -> Result<Client, Bo
info!("Substrate browser node");
info!(" version {}", config.full_version());
info!(" by Parity Technologies, 2017-2020");
info!("Chain specification: {}", config.expect_chain_spec().name());
info!("Node name: {}", config.name);
info!("Roles: {:?}", config.roles);
info!("📋 Chain specification: {}", config.expect_chain_spec().name());
info!("🏷 Node name: {}", config.name);
info!("👤 Roles: {:?}", config.roles);

// Create the service. This is the most heavy initialization step.
let service = crate::service::new_light(config)
Expand Down
4 changes: 2 additions & 2 deletions client/basic-authorship/src/basic_authorship.rs
Original file line number Diff line number Diff line change
Expand Up @@ -76,7 +76,7 @@ impl<B, Block, C, A> ProposerFactory<A, B, C>

let id = BlockId::hash(parent_hash);

info!("Starting consensus session on top of parent {:?}", parent_hash);
info!("🙌 Starting consensus session on top of parent {:?}", parent_hash);

let proposer = Proposer {
inner: Arc::new(ProposerInner {
Expand Down Expand Up @@ -277,7 +277,7 @@ impl<A, B, Block, C> ProposerInner<B, Block, C, A>

let (block, storage_changes, proof) = block_builder.build()?.into_inner();

info!("Prepared block for proposing at {} [hash: {:?}; parent_hash: {}; extrinsics ({}): [{}]]",
info!("🎁 Prepared block for proposing at {} [hash: {:?}; parent_hash: {}; extrinsics ({}): [{}]]",
block.header().number(),
<Block as BlockT>::Hash::from(block.header().hash()),
block.header().parent_hash(),
Expand Down
8 changes: 4 additions & 4 deletions client/cli/src/commands/runcmd.rs
Original file line number Diff line number Diff line change
Expand Up @@ -140,7 +140,7 @@ pub struct RunCmd {
///
/// A comma-separated list of origins (protocol://domain or special `null`
/// value). Value of `all` will disable origin validation. Default is to
/// allow localhost and https://polkadot.js.org origins. When running in
/// allow localhost and https://polkadot.js.org origins. When running in
/// --dev mode the default is to allow all origins.
#[structopt(long = "rpc-cors", value_name = "ORIGINS", parse(try_from_str = parse_cors))]
pub rpc_cors: Option<Cors>,
Expand Down Expand Up @@ -461,9 +461,9 @@ impl RunCmd {
info!("{}", version.name);
info!(" version {}", config.full_version());
info!(" by {}, {}-{}", version.author, version.copyright_start_year, Local::today().year());
info!("Chain specification: {}", config.expect_chain_spec().name());
info!("Node name: {}", config.name);
info!("Roles: {}", config.display_role());
info!("📋 Chain specification: {}", config.expect_chain_spec().name());
info!("🏷 Node name: {}", config.name);
info!("👤 Roles: {}", config.display_role());

match config.roles {
Roles::LIGHT => run_service_until_exit(
Expand Down
2 changes: 1 addition & 1 deletion client/cli/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -211,7 +211,7 @@ pub fn init_logger(pattern: &str) {
});

if builder.try_init().is_err() {
info!("Not registering Substrate logger, as there is already a global logger registered!");
info!("💬 Not registering Substrate logger, as there is already a global logger registered!");
}
}

Expand Down
6 changes: 3 additions & 3 deletions client/consensus/babe/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -368,7 +368,7 @@ pub fn start_babe<B, C, SC, E, I, SO, CAW, Error>(BabeParams {
&inherent_data_providers,
)?;

babe_info!("Starting BABE Authorship worker");
babe_info!("👶 Starting BABE Authorship worker");
Ok(sc_consensus_slots::start_slot_worker(
config.0,
select_chain,
Expand Down Expand Up @@ -1010,15 +1010,15 @@ impl<Block, Client, Inner> BlockImport<Block> for BabeBlockImport<Block, Client,
ConsensusError::ClientImport(Error::<Block>::FetchEpoch(parent_hash).into())
})?;

babe_info!("New epoch {} launching at block {} (block slot {} >= start slot {}).",
babe_info!("👶 New epoch {} launching at block {} (block slot {} >= start slot {}).",
viable_epoch.as_ref().epoch_index,
hash,
slot_number,
viable_epoch.as_ref().start_slot);

let next_epoch = viable_epoch.increment(next_epoch_descriptor);

babe_info!("Next epoch starts at slot {}", next_epoch.as_ref().start_slot);
babe_info!("👶 Next epoch starts at slot {}", next_epoch.as_ref().start_slot);

// prune the tree of epochs not part of the finalized chain or
// that are not live anymore, and then track the given epoch change
Expand Down
4 changes: 2 additions & 2 deletions client/consensus/manual-seal/src/finalize_block.rs
Original file line number Diff line number Diff line change
Expand Up @@ -57,8 +57,8 @@ pub async fn finalize_block<B, CB>(params: FinalizeBlockParams<B, CB>)
rpc::send_result(&mut sender, Err(e.into()))
}
Ok(()) => {
log::info!("Successfully finalized block: {}", hash);
log::info!("Successfully finalized block: {}", hash);
rpc::send_result(&mut sender, Ok(()))
}
}
}
}
6 changes: 3 additions & 3 deletions client/consensus/slots/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -258,10 +258,10 @@ pub trait SimpleSlotWorker<B: BlockT> {
Box::new(futures::future::select(proposing, delay).map(move |v| match v {
futures::future::Either::Left((b, _)) => b.map(|b| (b, claim)),
futures::future::Either::Right(_) => {
info!("Discarding proposal for slot {}; block production took too long", slot_number);
info!("⌛️ Discarding proposal for slot {}; block production took too long", slot_number);
// If the node was compiled with debug, tell the user to use release optimizations.
#[cfg(build_type="debug")]
info!("Recompile your node in `--release` mode to mitigate this problem.");
info!("👉 Recompile your node in `--release` mode to mitigate this problem.");
telemetry!(CONSENSUS_INFO; "slots.discarding_proposal_took_too_long";
"slot" => slot_number,
);
Expand Down Expand Up @@ -289,7 +289,7 @@ pub trait SimpleSlotWorker<B: BlockT> {
);

info!(
"Pre-sealed block for proposal at {}. Hash now {:?}, previously {:?}.",
"🔖 Pre-sealed block for proposal at {}. Hash now {:?}, previously {:?}.",
header_num,
block_import_params.post_hash(),
header_hash,
Expand Down
4 changes: 2 additions & 2 deletions client/finality-grandpa/src/environment.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1090,9 +1090,9 @@ pub(crate) fn finalize_block<BE, Block, Client>(
let (new_id, set_ref) = authority_set.current();

if set_ref.len() > 16 {
info!("Applying GRANDPA set change to new set with {} authorities", set_ref.len());
info!("👴 Applying GRANDPA set change to new set with {} authorities", set_ref.len());
} else {
info!("Applying GRANDPA set change to new set {:?}", set_ref);
info!("👴 Applying GRANDPA set change to new set {:?}", set_ref);
}

telemetry!(CONSENSUS_INFO; "afg.generating_new_authority_set";
Expand Down
2 changes: 1 addition & 1 deletion client/finality-grandpa/src/import.rs
Original file line number Diff line number Diff line change
Expand Up @@ -629,7 +629,7 @@ where

match result {
Err(CommandOrError::VoterCommand(command)) => {
info!(target: "afg", "Imported justification for block #{} that triggers \
info!(target: "afg", "👴 Imported justification for block #{} that triggers \
command {}, signaling voter.", number, command);

// send the command to the voter
Expand Down
6 changes: 3 additions & 3 deletions client/informant/src/display.rs
Original file line number Diff line number Diff line change
Expand Up @@ -68,9 +68,9 @@ impl<B: BlockT> InformantDisplay<B> {
self.last_number = Some(best_number);

let (status, target) = match (net_status.sync_state, net_status.best_seen_block) {
(SyncState::Idle, _) => ("Idle".into(), "".into()),
(SyncState::Downloading, None) => (format!("Syncing{}", speed), "".into()),
(SyncState::Downloading, Some(n)) => (format!("Syncing{}", speed), format!(", target=#{}", n)),
(SyncState::Idle, _) => ("💤 Idle".into(), "".into()),
(SyncState::Downloading, None) => (format!("⚙️ Syncing{}", speed), "".into()),
(SyncState::Downloading, Some(n)) => (format!("⚙️ Syncing{}", speed), format!(", target=#{}", n)),
};

if self.format == OutputFormat::Coloured {
Expand Down
4 changes: 2 additions & 2 deletions client/informant/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -79,7 +79,7 @@ pub fn build(service: &impl AbstractService, format: OutputFormat) -> impl futur

match maybe_ancestor {
Ok(ref ancestor) if ancestor.hash != *last_hash => info!(
"Reorg from #{},{} to #{},{}, common ancestor #{},{}",
"♻️ Reorg from #{},{} to #{},{}, common ancestor #{},{}",
last_num, last_hash,
n.header.number(), n.hash,
ancestor.number, ancestor.hash,
Expand All @@ -94,7 +94,7 @@ pub fn build(service: &impl AbstractService, format: OutputFormat) -> impl futur
last_best = Some((n.header.number().clone(), n.hash.clone()));
}

info!(target: "substrate", "Imported #{} ({})", n.header.number(), n.hash);
info!(target: "substrate", "Imported #{} ({})", n.header.number(), n.hash);
future::ready(())
});

Expand Down
2 changes: 1 addition & 1 deletion client/network/src/discovery.rs
Original file line number Diff line number Diff line change
Expand Up @@ -293,7 +293,7 @@ impl NetworkBehaviour for DiscoveryBehaviour {
fn inject_new_external_addr(&mut self, addr: &Multiaddr) {
let new_addr = addr.clone()
.with(Protocol::P2p(self.local_peer_id.clone().into()));
info!(target: "sub-libp2p", "Discovered new external address for our node: {}", new_addr);
info!(target: "sub-libp2p", "🔍 Discovered new external address for our node: {}", new_addr);
NetworkBehaviour::inject_new_external_addr(&mut self.kademlia, addr)
}

Expand Down
6 changes: 3 additions & 3 deletions client/network/src/protocol/light_dispatch.rs
Original file line number Diff line number Diff line change
Expand Up @@ -270,7 +270,7 @@ impl<B: BlockT> LightDispatch<B> where
let request = match self.remove(peer.clone(), request_id) {
Some(request) => request,
None => {
info!("Invalid remote {} response from peer {}", rtype, peer);
info!("💔 Invalid remote {} response from peer {}", rtype, peer);
network.report_peer(&peer, ReputationChange::new_fatal("Invalid remote response"));
network.disconnect_peer(&peer);
self.remove_peer(&peer);
Expand All @@ -282,7 +282,7 @@ impl<B: BlockT> LightDispatch<B> where
let (retry_count, retry_request_data) = match try_accept(request, &self.checker) {
Accept::Ok => (retry_count, None),
Accept::CheckFailed(error, retry_request_data) => {
info!("Failed to check remote {} response from peer {}: {}", rtype, peer, error);
info!("💔 Failed to check remote {} response from peer {}: {}", rtype, peer, error);
network.report_peer(&peer, ReputationChange::new_fatal("Failed remote response check"));
network.disconnect_peer(&peer);
self.remove_peer(&peer);
Expand All @@ -296,7 +296,7 @@ impl<B: BlockT> LightDispatch<B> where
}
},
Accept::Unexpected(retry_request_data) => {
info!("Unexpected response to remote {} from peer", rtype);
info!("💔 Unexpected response to remote {} from peer", rtype);
network.report_peer(&peer, ReputationChange::new_fatal("Unexpected remote response"));
network.disconnect_peer(&peer);
self.remove_peer(&peer);
Expand Down
10 changes: 5 additions & 5 deletions client/network/src/protocol/sync.rs
Original file line number Diff line number Diff line change
Expand Up @@ -378,12 +378,12 @@ impl<B: BlockT> ChainSync<B> {
Err(BadPeer(who, rep::BLOCKCHAIN_READ_ERROR))
}
Ok(BlockStatus::KnownBad) => {
info!("New peer with known bad best block {} ({}).", best_hash, best_number);
info!("💔 New peer with known bad best block {} ({}).", best_hash, best_number);
Err(BadPeer(who, rep::BAD_BLOCK))
}
Ok(BlockStatus::Unknown) => {
if best_number.is_zero() {
info!("New peer with unknown genesis hash {} ({}).", best_hash, best_number);
info!("💔 New peer with unknown genesis hash {} ({}).", best_hash, best_number);
return Err(BadPeer(who, rep::GENESIS_MISMATCH));
}
// If there are more than `MAJOR_SYNC_BLOCKS` in the import queue then we have
Expand Down Expand Up @@ -711,7 +711,7 @@ impl<B: BlockT> ChainSync<B> {
return Err(BadPeer(who, rep::UNKNOWN_ANCESTOR))
},
(_, Err(e)) => {
info!("Error answering legitimate blockchain query: {:?}", e);
info!("Error answering legitimate blockchain query: {:?}", e);
return Err(BadPeer(who, rep::BLOCKCHAIN_READ_ERROR))
}
};
Expand Down Expand Up @@ -943,7 +943,7 @@ impl<B: BlockT> ChainSync<B> {

if aux.bad_justification {
if let Some(peer) = who {
info!("Sent block with bad justification to import");
info!("💔 Sent block with bad justification to import");
output.push(Err(BadPeer(peer, rep::BAD_JUSTIFICATION)));
}
}
Expand Down Expand Up @@ -973,7 +973,7 @@ impl<B: BlockT> ChainSync<B> {
},
Err(BlockImportError::BadBlock(who)) => {
if let Some(peer) = who {
info!("Block {:?} received from peer {} has been blacklisted", hash, peer);
info!("💔 Block {:?} received from peer {} has been blacklisted", hash, peer);
output.push(Err(BadPeer(peer, rep::BAD_BLOCK)));
}
},
Expand Down
2 changes: 1 addition & 1 deletion client/network/src/protocol/sync/extra_requests.rs
Original file line number Diff line number Diff line change
Expand Up @@ -221,7 +221,7 @@ impl<B: BlockT> ExtraRequests<B> {
};

if self.tree.finalize_root(&finalized_hash).is_none() {
warn!(target: "sync", "Imported {:?} {:?} which isn't a root in the tree: {:?}",
warn!(target: "sync", "‼️ Imported {:?} {:?} which isn't a root in the tree: {:?}",
finalized_hash,
finalized_number,
self.tree.roots().collect::<Vec<_>>()
Expand Down
4 changes: 2 additions & 2 deletions client/network/src/service.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1090,7 +1090,7 @@ impl<'a, B: BlockT, H: ExHashT> Link<B> for NetworkLink<'a, B, H> {
fn justification_imported(&mut self, who: PeerId, hash: &B::Hash, number: NumberFor<B>, success: bool) {
self.protocol.user_protocol_mut().justification_import_result(hash.clone(), number, success);
if !success {
info!("Invalid justification provided by {} for #{}", who, hash);
info!("💔 Invalid justification provided by {} for #{}", who, hash);
self.protocol.user_protocol_mut().disconnect_peer(&who);
self.protocol.user_protocol_mut().report_peer(who, ReputationChange::new_fatal("Invalid justification"));
}
Expand All @@ -1110,7 +1110,7 @@ impl<'a, B: BlockT, H: ExHashT> Link<B> for NetworkLink<'a, B, H> {
let success = finalization_result.is_ok();
self.protocol.user_protocol_mut().finality_proof_import_result(request_block, finalization_result);
if !success {
info!("Invalid finality proof provided by {} for #{}", who, request_block.0);
info!("💔 Invalid finality proof provided by {} for #{}", who, request_block.0);
self.protocol.user_protocol_mut().disconnect_peer(&who);
self.protocol.user_protocol_mut().report_peer(who, ReputationChange::new_fatal("Invalid finality proof"));
}
Expand Down
2 changes: 1 addition & 1 deletion client/service/src/builder.rs
Original file line number Diff line number Diff line change
Expand Up @@ -827,7 +827,7 @@ ServiceBuilder<
let chain_spec = config.expect_chain_spec();

let version = config.full_version();
info!("Highest known block at #{}", chain_info.best_number);
info!("📦 Highest known block at #{}", chain_info.best_number);
telemetry!(
SUBSTRATE_INFO;
"node.start";
Expand Down
4 changes: 2 additions & 2 deletions client/service/src/chain_ops.rs
Original file line number Diff line number Diff line change
Expand Up @@ -125,7 +125,7 @@ impl<
return std::task::Poll::Ready(Err(From::from(err)));
},
};
info!("Importing {} blocks", c);
info!("📦 Importing {} blocks", c);
count = Some(c);
c
}
Expand Down Expand Up @@ -185,7 +185,7 @@ impl<
}

if link.imported_blocks >= count {
info!("Imported {} blocks. Best: #{}", read_block_count, client.chain_info().best_number);
info!("🎉 Imported {} blocks. Best: #{}", read_block_count, client.chain_info().best_number);
return std::task::Poll::Ready(Ok(()));

} else {
Expand Down
2 changes: 1 addition & 1 deletion client/src/client.rs
Original file line number Diff line number Diff line change
Expand Up @@ -260,7 +260,7 @@ impl<B, E, Block, RA> Client<B, E, Block, RA> where
backend.begin_state_operation(&mut op, BlockId::Hash(Default::default()))?;
let state_root = op.reset_storage(genesis_storage)?;
let genesis_block = genesis::construct_genesis_block::<Block>(state_root.into());
info!("Initializing Genesis block/state (state: {}, header-hash: {})",
info!("🔨 Initializing Genesis block/state (state: {}, header-hash: {})",
genesis_block.header().state_root(),
genesis_block.header().hash()
);
Expand Down

0 comments on commit beff538

Please sign in to comment.