Revert "".git/.scripts/commands/fmt/fmt.sh""

This reverts commit c12d339.

bridges/modules/xcm-bridge-hub/src/lib.rs

@@ -1456,26 +1456,25 @@ mod tests {
 		let lane_id = TestLaneIdType::try_new(1, 2).unwrap();
 		let lane_id_mismatch = TestLaneIdType::try_new(3, 4).unwrap();
 
-		let test_bridge_state =
-			|id,
-			 bridge,
-			 (lane_id, bridge_id),
-			 (inbound_lane_id, outbound_lane_id),
-			 expected_error: Option<TryRuntimeError>| {
-				Bridges::<TestRuntime, ()>::insert(id, bridge);
-				LaneToBridge::<TestRuntime, ()>::insert(lane_id, bridge_id);
+		let test_bridge_state = |id,
+		                         bridge,
+		                         (lane_id, bridge_id),
+		                         (inbound_lane_id, outbound_lane_id),
+		                         expected_error: Option<TryRuntimeError>| {
+			Bridges::<TestRuntime, ()>::insert(id, bridge);
+			LaneToBridge::<TestRuntime, ()>::insert(lane_id, bridge_id);
 
-				let lanes_manager = LanesManagerOf::<TestRuntime, ()>::new();
-				lanes_manager.create_inbound_lane(inbound_lane_id).unwrap();
-				lanes_manager.create_outbound_lane(outbound_lane_id).unwrap();
-
-				let result = XcmOverBridge::do_try_state();
-				if let Some(e) = expected_error {
-					assert_err!(result, e);
-				} else {
-					assert_ok!(result);
-				}
-			};
+			let lanes_manager = LanesManagerOf::<TestRuntime, ()>::new();
+			lanes_manager.create_inbound_lane(inbound_lane_id).unwrap();
+			lanes_manager.create_outbound_lane(outbound_lane_id).unwrap();
+
+			let result = XcmOverBridge::do_try_state();
+			if let Some(e) = expected_error {
+				assert_err!(result, e);
+			} else {
+				assert_ok!(result);
+			}
+		};
 		let cleanup = |bridge_id, lane_ids| {
 			Bridges::<TestRuntime, ()>::remove(bridge_id);
 			for lane_id in lane_ids {

bridges/relays/lib-substrate-relay/src/cli/relay_headers_and_messages/mod.rs

@@ -325,9 +325,7 @@ where
 				_,
 				Self::Left,
 				MessagesLaneIdOf<Self::R2L>,
-			>(
-				common.right.client.clone(), &common.metrics_params, &common.right.accounts, &lanes
-			)
+			>(common.right.client.clone(), &common.metrics_params, &common.right.accounts, &lanes)
 			.await?;
 		}
 

bridges/relays/lib-substrate-relay/src/on_demand/parachains.rs

@@ -664,8 +664,7 @@ impl<'a, P: SubstrateParachainsPipeline, SourceRelayClnt, TargetClnt>
 	for (
 		&'a OnDemandParachainsRelay<P, SourceRelayClnt, TargetClnt>,
 		&'a ParachainsSource<P, SourceRelayClnt>,
-	)
-where
+	) where
 	SourceRelayClnt: Client<P::SourceRelayChain>,
 	TargetClnt: Client<P::TargetChain>,
 {

bridges/relays/messages/src/message_race_strategy.rs

@@ -67,8 +67,7 @@ impl<
 		TargetHeaderHash,
 		SourceNoncesRange,
 		Proof,
-	>
-where
+	> where
 	SourceHeaderHash: Clone,
 	SourceHeaderNumber: Clone + Ord,
 	SourceNoncesRange: NoncesRange,
@@ -190,8 +189,7 @@ impl<
 		TargetHeaderHash,
 		SourceNoncesRange,
 		Proof,
-	>
-where
+	> where
 	SourceHeaderHash: Clone + Debug + Send + Sync,
 	SourceHeaderNumber: Clone + Ord + Debug + Send + Sync,
 	SourceNoncesRange: NoncesRange + Debug + Send + Sync,

bridges/snowbridge/primitives/router/src/inbound/mod.rs

@@ -168,8 +168,7 @@ impl<
 		ConvertAssetId,
 		EthereumUniversalLocation,
 		GlobalAssetHubLocation,
-	>
-where
+	> where
 	CreateAssetCall: Get<CallIndex>,
 	CreateAssetDeposit: Get<u128>,
 	InboundQueuePalletInstance: Get<u8>,
@@ -227,8 +226,7 @@ impl<
 		ConvertAssetId,
 		EthereumUniversalLocation,
 		GlobalAssetHubLocation,
-	>
-where
+	> where
 	CreateAssetCall: Get<CallIndex>,
 	CreateAssetDeposit: Get<u128>,
 	InboundQueuePalletInstance: Get<u8>,

bridges/snowbridge/primitives/router/src/outbound/mod.rs

@@ -44,8 +44,7 @@ impl<UniversalLocation, EthereumNetwork, OutboundQueue, AgentHashedDescription,
 		OutboundQueue,
 		AgentHashedDescription,
 		ConvertAssetId,
-	>
-where
+	> where
 	UniversalLocation: Get<InteriorLocation>,
 	EthereumNetwork: Get<NetworkId>,
 	OutboundQueue: SendMessage<Balance = u128>,

bridges/snowbridge/runtime/runtime-common/src/lib.rs

@@ -50,8 +50,7 @@ impl<Balance, AccountId, FeeAssetLocation, EthereumNetwork, AssetTransactor, Fee
 		EthereumNetwork,
 		AssetTransactor,
 		FeeProvider,
-	>
-where
+	> where
 	Balance: BaseArithmetic + Unsigned + Copy + From<u128> + Into<u128> + Debug,
 	AccountId: Clone + FullCodec,
 	FeeAssetLocation: Get<Location>,

cumulus/pallets/parachain-system/src/lib.rs

@@ -366,8 +366,7 @@ pub mod pallet {
 
 			let maximum_channels = host_config
 				.hrmp_max_message_num_per_candidate
-				.min(<AnnouncedHrmpMessagesPerCandidate<T>>::take())
-				as usize;
+				.min(<AnnouncedHrmpMessagesPerCandidate<T>>::take()) as usize;
 
 			// Note: this internally calls the `GetChannelInfo` implementation for this
 			// pallet, which draws on the `RelevantMessagingState`. That in turn has

cumulus/pallets/parachain-system/src/validate_block/trie_cache.rs

@@ -85,10 +85,7 @@ impl<H: Hasher> CacheProvider<H> {
 }
 
 impl<H: Hasher> TrieCacheProvider<H> for CacheProvider<H> {
-	type Cache<'a>
-		= TrieCache<'a, H>
-	where
-		H: 'a;
+	type Cache<'a> = TrieCache<'a, H> where H: 'a;
 
 	fn as_trie_db_cache(&self, storage_root: <H as Hasher>::Out) -> Self::Cache<'_> {
 		TrieCache {

cumulus/pallets/parachain-system/src/validate_block/trie_recorder.rs

@@ -115,10 +115,7 @@ impl<H: Hasher> SizeOnlyRecorderProvider<H> {
 }
 
 impl<H: trie_db::Hasher> sp_trie::TrieRecorderProvider<H> for SizeOnlyRecorderProvider<H> {
-	type Recorder<'a>
-		= SizeOnlyRecorder<'a, H>
-	where
-		H: 'a;
+	type Recorder<'a> = SizeOnlyRecorder<'a, H> where H: 'a;
 
 	fn drain_storage_proof(self) -> Option<StorageProof> {
 		None

cumulus/parachains/integration-tests/emulated/tests/assets/asset-hub-rococo/src/tests/teleport.rs

@@ -265,9 +265,7 @@ fn limited_teleport_native_assets_from_system_para_to_relay_fails() {
 	let delivery_fees = AssetHubRococo::execute_with(|| {
 		xcm_helpers::teleport_assets_delivery_fees::<
 			<AssetHubRococoXcmConfig as xcm_executor::Config>::XcmSender,
-		>(
-			test.args.assets.clone(), 0, test.args.weight_limit, test.args.beneficiary, test.args.dest
-		)
+		>(test.args.assets.clone(), 0, test.args.weight_limit, test.args.beneficiary, test.args.dest)
 	});
 
 	// Sender's balance is reduced

cumulus/parachains/integration-tests/emulated/tests/assets/asset-hub-westend/src/tests/teleport.rs

@@ -265,9 +265,7 @@ fn limited_teleport_native_assets_from_system_para_to_relay_fails() {
 	let delivery_fees = AssetHubWestend::execute_with(|| {
 		xcm_helpers::teleport_assets_delivery_fees::<
 			<AssetHubWestendXcmConfig as xcm_executor::Config>::XcmSender,
-		>(
-			test.args.assets.clone(), 0, test.args.weight_limit, test.args.beneficiary, test.args.dest
-		)
+		>(test.args.assets.clone(), 0, test.args.weight_limit, test.args.beneficiary, test.args.dest)
 	});
 
 	// Sender's balance is reduced

cumulus/parachains/integration-tests/emulated/tests/people/people-rococo/src/tests/teleport.rs

@@ -107,9 +107,7 @@ fn limited_teleport_native_assets_from_system_para_to_relay_fails() {
 	let delivery_fees = PeopleRococo::execute_with(|| {
 		xcm_helpers::teleport_assets_delivery_fees::<
 			<PeopleRococoXcmConfig as xcm_executor::Config>::XcmSender,
-		>(
-			test.args.assets.clone(), 0, test.args.weight_limit, test.args.beneficiary, test.args.dest
-		)
+		>(test.args.assets.clone(), 0, test.args.weight_limit, test.args.beneficiary, test.args.dest)
 	});
 
 	// Sender's balance is reduced

cumulus/parachains/integration-tests/emulated/tests/people/people-westend/src/tests/teleport.rs

@@ -107,9 +107,7 @@ fn limited_teleport_native_assets_from_system_para_to_relay_fails() {
 	let delivery_fees = PeopleWestend::execute_with(|| {
 		xcm_helpers::teleport_assets_delivery_fees::<
 			<PeopleWestendXcmConfig as xcm_executor::Config>::XcmSender,
-		>(
-			test.args.assets.clone(), 0, test.args.weight_limit, test.args.beneficiary, test.args.dest
-		)
+		>(test.args.assets.clone(), 0, test.args.weight_limit, test.args.beneficiary, test.args.dest)
 	});
 
 	// Sender's balance is reduced

cumulus/parachains/runtimes/assets/asset-hub-rococo/src/lib.rs

@@ -546,8 +546,7 @@ impl InstanceFilter<RuntimeCall> for ProxyType {
 						RuntimeCall::Utility { .. } |
 						RuntimeCall::Multisig { .. } |
 						RuntimeCall::NftFractionalization { .. } |
-						RuntimeCall::Nfts { .. } |
-						RuntimeCall::Uniques { .. }
+						RuntimeCall::Nfts { .. } | RuntimeCall::Uniques { .. }
 				)
 			},
 			ProxyType::AssetOwner => matches!(

cumulus/parachains/runtimes/assets/asset-hub-rococo/tests/tests.rs

@@ -27,8 +27,7 @@ use asset_hub_rococo_runtime::{
 	AllPalletsWithoutSystem, AssetConversion, AssetDeposit, Assets, Balances, Block,
 	CollatorSelection, ExistentialDeposit, ForeignAssets, ForeignAssetsInstance,
 	MetadataDepositBase, MetadataDepositPerByte, ParachainSystem, Runtime, RuntimeCall,
-	RuntimeEvent, RuntimeOrigin, SessionKeys, ToWestendXcmRouterInstance,
-	TrustBackedAssetsInstance, XcmpQueue,
+	RuntimeEvent, RuntimeOrigin, SessionKeys, ToWestendXcmRouterInstance, TrustBackedAssetsInstance, XcmpQueue,
 };
 use asset_test_utils::{
 	test_cases_over_bridge::TestBridgingConfig, CollatorSessionKey, CollatorSessionKeys,

cumulus/parachains/runtimes/assets/asset-hub-westend/src/lib.rs

@@ -544,8 +544,7 @@ impl InstanceFilter<RuntimeCall> for ProxyType {
 						RuntimeCall::Utility { .. } |
 						RuntimeCall::Multisig { .. } |
 						RuntimeCall::NftFractionalization { .. } |
-						RuntimeCall::Nfts { .. } |
-						RuntimeCall::Uniques { .. }
+						RuntimeCall::Nfts { .. } | RuntimeCall::Uniques { .. }
 				)
 			},
 			ProxyType::AssetOwner => matches!(

cumulus/parachains/runtimes/assets/test-utils/src/test_cases.rs

@@ -1146,8 +1146,7 @@ pub fn create_and_manage_foreign_assets_for_local_consensus_parachain_assets_wor
 		.with_balances(vec![(
 			foreign_creator_as_account_id.clone(),
 			existential_deposit +
-				asset_deposit +
-				metadata_deposit_base +
+				asset_deposit + metadata_deposit_base +
 				metadata_deposit_per_byte_eta +
 				buy_execution_fee_amount.into() +
 				buy_execution_fee_amount.into(),
@@ -1696,10 +1695,8 @@ where
 			0,
 			test_account
 		));
-		let execution_fees = Runtime::query_weight_to_asset_fee(
-			xcm_weight.unwrap(),
-			VersionedAssetId::from(AssetId(asset_not_in_pool)),
-		);
+		let execution_fees =
+			Runtime::query_weight_to_asset_fee(xcm_weight.unwrap(), VersionedAssetId::from(AssetId(asset_not_in_pool)));
 		// Now it works!
 		assert_ok!(execution_fees);
 	});

cumulus/parachains/runtimes/bridge-hubs/bridge-hub-rococo/tests/tests.rs

@@ -18,9 +18,8 @@
 
 use bp_polkadot_core::Signature;
 use bridge_hub_rococo_runtime::{
-	bridge_common_config, bridge_to_bulletin_config,
 	bridge_to_ethereum_config::EthereumGatewayAddress,
-	bridge_to_westend_config,
+	bridge_common_config, bridge_to_bulletin_config, bridge_to_westend_config,
 	xcm_config::{LocationToAccountId, RelayNetwork, TokenLocation, XcmConfig},
 	AllPalletsWithoutSystem, Block, BridgeRejectObsoleteHeadersAndMessages, Executive,
 	ExistentialDeposit, ParachainSystem, PolkadotXcm, Runtime, RuntimeCall, RuntimeEvent,

cumulus/parachains/runtimes/bridge-hubs/test-utils/src/test_cases/mod.rs

@@ -506,12 +506,11 @@ pub fn message_dispatch_routing_works<
 
 		// 2. this message is sent from other global consensus with destination of this Runtime
 		//    sibling parachain (HRMP)
-		let bridging_message =
-			test_data::simulate_message_exporter_on_bridged_chain::<
-				BridgedNetwork,
-				NetworkWithParentCount<RuntimeNetwork, NetworkDistanceAsParentCount>,
-				AlwaysLatest,
-			>((RuntimeNetwork::get(), [Parachain(sibling_parachain_id)].into()));
+		let bridging_message = test_data::simulate_message_exporter_on_bridged_chain::<
+			BridgedNetwork,
+			NetworkWithParentCount<RuntimeNetwork, NetworkDistanceAsParentCount>,
+			AlwaysLatest,
+		>((RuntimeNetwork::get(), [Parachain(sibling_parachain_id)].into()));
 
 		// 2.1. WITHOUT opened hrmp channel -> RoutingError
 		let result =

cumulus/primitives/utility/src/lib.rs

@@ -385,8 +385,7 @@ impl<
 		FungiblesAssetMatcher,
 		OnUnbalanced,
 		AccountId,
-	>
-where
+	> where
 	Fungibles::Balance: Into<u128>,
 {
 	fn new() -> Self {
@@ -546,8 +545,7 @@ impl<
 		FungiblesAssetMatcher,
 		OnUnbalanced,
 		AccountId,
-	>
-where
+	> where
 	Fungibles::Balance: Into<u128>,
 {
 	fn drop(&mut self) {

polkadot/node/core/approval-voting/src/lib.rs

@@ -2422,12 +2422,7 @@ fn schedule_wakeup_action(
 				last_assignment_tick.map(|l| l + APPROVAL_DELAY).filter(|t| t > &tick_now),
 				next_no_show,
 			)
-			.map(|tick| Action::ScheduleWakeup {
-				block_hash,
-				block_number,
-				candidate_hash,
-				tick,
-			})
+			.map(|tick| Action::ScheduleWakeup { block_hash, block_number, candidate_hash, tick })
 		},
 		RequiredTranches::Pending { considered, next_no_show, clock_drift, .. } => {
 			// select the minimum of `next_no_show`, or the tick of the next non-empty tranche

polkadot/node/core/approval-voting/src/tests.rs

@@ -263,8 +263,7 @@ where
 		_relay_vrf_story: polkadot_node_primitives::approval::v1::RelayVRFStory,
 		_assignment: &polkadot_node_primitives::approval::v2::AssignmentCertV2,
 		_backing_groups: Vec<polkadot_primitives::GroupIndex>,
-	) -> Result<polkadot_node_primitives::approval::v1::DelayTranche, criteria::InvalidAssignment>
-	{
+	) -> Result<polkadot_node_primitives::approval::v1::DelayTranche, criteria::InvalidAssignment> {
 		self.1(validator_index)
 	}
 }

polkadot/node/core/pvf/common/src/worker/security/change_root.rs

@@ -124,8 +124,7 @@ fn try_restrict(worker_info: &WorkerInfo) -> Result<()> {
 				libc::MS_BIND |
 					libc::MS_REC | libc::MS_NOEXEC |
 					libc::MS_NODEV | libc::MS_NOSUID |
-					libc::MS_NOATIME |
-					additional_flags,
+					libc::MS_NOATIME | additional_flags,
 				ptr::null(), // ignored when MS_BIND is used
 			) < 0
 			{

polkadot/node/network/approval-distribution/src/tests.rs

@@ -535,8 +535,7 @@ impl AssignmentCriteria for MockAssignmentCriteria {
 		_relay_vrf_story: polkadot_node_primitives::approval::v1::RelayVRFStory,
 		_assignment: &polkadot_node_primitives::approval::v2::AssignmentCertV2,
 		_backing_groups: Vec<polkadot_primitives::GroupIndex>,
-	) -> Result<polkadot_node_primitives::approval::v1::DelayTranche, criteria::InvalidAssignment>
-	{
+	) -> Result<polkadot_node_primitives::approval::v1::DelayTranche, criteria::InvalidAssignment> {
 		self.tranche
 	}
 }

polkadot/node/network/availability-recovery/src/task/strategy/chunks.rs

@@ -107,10 +107,9 @@ impl FetchChunks {
 		state: &mut State,
 		common_params: &RecoveryParams,
 	) -> Result<AvailableData, RecoveryError> {
-		let recovery_duration =
-			common_params
-				.metrics
-				.time_erasure_recovery(RecoveryStrategy::<Sender>::strategy_type(self));
+		let recovery_duration = common_params
+			.metrics
+			.time_erasure_recovery(RecoveryStrategy::<Sender>::strategy_type(self));
 
 		// Send request to reconstruct available data from chunks.
 		let (avilable_data_tx, available_data_rx) = oneshot::channel();

polkadot/node/subsystem-bench/src/lib/statement/mod.rs

@@ -114,14 +114,14 @@ fn build_overseer(
 		state.pvd.clone(),
 		state.own_backing_group.clone(),
 	);
-	let (statement_req_receiver, statement_req_cfg) =
-		IncomingRequest::get_config_receiver::<Block, sc_network::NetworkWorker<Block, Hash>>(
-			&ReqProtocolNames::new(GENESIS_HASH, None),
-		);
-	let (candidate_req_receiver, candidate_req_cfg) =
-		IncomingRequest::get_config_receiver::<Block, sc_network::NetworkWorker<Block, Hash>>(
-			&ReqProtocolNames::new(GENESIS_HASH, None),
-		);
+	let (statement_req_receiver, statement_req_cfg) = IncomingRequest::get_config_receiver::<
+		Block,
+		sc_network::NetworkWorker<Block, Hash>,
+	>(&ReqProtocolNames::new(GENESIS_HASH, None));
+	let (candidate_req_receiver, candidate_req_cfg) = IncomingRequest::get_config_receiver::<
+		Block,
+		sc_network::NetworkWorker<Block, Hash>,
+	>(&ReqProtocolNames::new(GENESIS_HASH, None));
 	let keystore = make_keystore();
 	let subsystem = StatementDistributionSubsystem::new(
 		keystore.clone(),

polkadot/node/subsystem-types/src/runtime_client.rs

@@ -643,8 +643,7 @@ where
 	fn number(
 		&self,
 		hash: Block::Hash,
-	) -> sc_client_api::blockchain::Result<Option<<<Block as BlockT>::Header as HeaderT>::Number>>
-	{
+	) -> sc_client_api::blockchain::Result<Option<<<Block as BlockT>::Header as HeaderT>::Number>> {
 		self.client.number(hash)
 	}