refac(permission0): rename emission to streams

Author: saiintbrisson

pallets/emission0/src/distribute.rs

@@ -1,5 +1,5 @@
 use pallet_governance_api::GovernanceApi;
-use pallet_permission0_api::Permission0EmissionApi;
+use pallet_permission0_api::Permission0StreamApi;
 use pallet_torus0_api::Torus0Api;
 use polkadot_sdk::{
     frame_support::{
@@ -336,7 +336,7 @@ fn linear_rewards<T: Config>(mut emission: NegativeImbalanceOf<T>) -> NegativeIm
         } else {
             // This is an impossible case, but if something changes in the future,
             // the code is here.
-            <T::Permission0>::accumulate_emissions(
+            <T::Permission0>::accumulate_streams(
                 delegating_to,
                 &pallet_permission0_api::generate_root_stream_id(delegating_to),
                 &mut stake,
@@ -368,7 +368,7 @@ fn linear_rewards<T: Config>(mut emission: NegativeImbalanceOf<T>) -> NegativeIm
         .zip(upscaled_dividends)
     {
         let add_stake = |staker, mut amount: NegativeImbalanceOf<T>| {
-            <T::Permission0>::accumulate_emissions(
+            <T::Permission0>::accumulate_streams(
                 &staker,
                 &pallet_permission0_api::generate_root_stream_id(&staker),
                 &mut amount,

pallets/emission0/src/lib.rs

@@ -31,7 +31,7 @@ pub mod pallet {
     use frame::prelude::BlockNumberFor;
     use frame_system::ensure_signed;
     use pallet_governance_api::GovernanceApi;
-    use pallet_permission0_api::{Permission0Api, Permission0EmissionApi};
+    use pallet_permission0_api::{Permission0Api, Permission0StreamApi};
     use pallet_torus0_api::Torus0Api;
     use polkadot_sdk::sp_std;
     use weights::WeightInfo;
@@ -99,7 +99,7 @@ pub mod pallet {
         type Governance: GovernanceApi<Self::AccountId>;
 
         type Permission0: Permission0Api<OriginFor<Self>>
-            + Permission0EmissionApi<
+            + Permission0StreamApi<
                 Self::AccountId,
                 OriginFor<Self>,
                 BlockNumberFor<Self>,

pallets/emission0/src/weights.rs

@@ -2,7 +2,7 @@
 //! Autogenerated weights for `pallet_emission0`
 //!
 //! THIS FILE WAS AUTO-GENERATED USING THE SUBSTRATE BENCHMARK CLI VERSION 43.0.0
-//! DATE: 2025-08-12, STEPS: `50`, REPEAT: `20`, LOW RANGE: `[]`, HIGH RANGE: `[]`
+//! DATE: 2025-08-22, STEPS: `50`, REPEAT: `20`, LOW RANGE: `[]`, HIGH RANGE: `[]`
 //! WORST CASE MAP SIZE: `1000000`
 //! HOSTNAME: `Luizs-MacBook-Pro.local`, CPU: `<UNKNOWN>`
 //! WASM-EXECUTION: `Compiled`, CHAIN: `Some("dev")`, DB CACHE: `1024`
@@ -65,7 +65,7 @@ impl<T: frame_system::Config> WeightInfo for SubstrateWeight<T> {
 		//  Measured:  `677`
 		//  Estimated: `7654`
 		// Minimum execution time: 26_000_000 picoseconds.
-		Weight::from_parts(26_000_000, 7654)
+		Weight::from_parts(27_000_000, 7654)
 			.saturating_add(T::DbWeight::get().reads(10_u64))
 			.saturating_add(T::DbWeight::get().writes(1_u64))
 	}
@@ -94,7 +94,7 @@ impl<T: frame_system::Config> WeightInfo for SubstrateWeight<T> {
 		// Proof Size summary in bytes:
 		//  Measured:  `333`
 		//  Estimated: `3529`
-		// Minimum execution time: 9_000_000 picoseconds.
+		// Minimum execution time: 10_000_000 picoseconds.
 		Weight::from_parts(10_000_000, 3529)
 			.saturating_add(T::DbWeight::get().reads(2_u64))
 			.saturating_add(T::DbWeight::get().writes(1_u64))
@@ -122,7 +122,7 @@ impl WeightInfo for () {
 		//  Measured:  `677`
 		//  Estimated: `7654`
 		// Minimum execution time: 26_000_000 picoseconds.
-		Weight::from_parts(26_000_000, 7654)
+		Weight::from_parts(27_000_000, 7654)
 			.saturating_add(RocksDbWeight::get().reads(10_u64))
 			.saturating_add(RocksDbWeight::get().writes(1_u64))
 	}
@@ -151,7 +151,7 @@ impl WeightInfo for () {
 		// Proof Size summary in bytes:
 		//  Measured:  `333`
 		//  Estimated: `3529`
-		// Minimum execution time: 9_000_000 picoseconds.
+		// Minimum execution time: 10_000_000 picoseconds.
 		Weight::from_parts(10_000_000, 3529)
 			.saturating_add(RocksDbWeight::get().reads(2_u64))
 			.saturating_add(RocksDbWeight::get().writes(1_u64))

pallets/governance/src/weights.rs

@@ -26,9 +26,9 @@ pub fn generate_root_stream_id<AccountId: Encode>(agent_id: &AccountId) -> Strea
     blake2_256(&data).into()
 }
 
-/// Defines what portion of emissions the permission applies to
+/// Defines what portion of streams the permission applies to
 #[derive(Encode, Decode, TypeInfo, Clone, PartialEq, Eq, Debug)]
-pub enum EmissionAllocation<Balance> {
+pub enum StreamAllocation<Balance> {
     /// Permission applies to a percentage of all emissions (0-100)
     Streams(BTreeMap<StreamId, Percent>),
     /// Permission applies to a specific fixed amount
@@ -100,13 +100,13 @@ pub trait Permission0Api<Origin> {
     fn execute_permission(who: Origin, permission_id: &PermissionId) -> DispatchResult;
 }
 
-pub trait Permission0EmissionApi<AccountId, Origin, BlockNumber, Balance, NegativeImbalance> {
-    /// Delegate a permission for emission delegation
+pub trait Permission0StreamApi<AccountId, Origin, BlockNumber, Balance, NegativeImbalance> {
+    /// Delegate a permission for streams delegation
     #[allow(clippy::too_many_arguments)]
-    fn delegate_emission_permission(
+    fn delegate_stream_permission(
         delegator: AccountId,
         recipients: Vec<(AccountId, u16)>,
-        allocation: EmissionAllocation<Balance>,
+        allocation: StreamAllocation<Balance>,
         distribution: DistributionControl<Balance, BlockNumber>,
         duration: PermissionDuration<BlockNumber>,
         revocation: RevocationTerms<AccountId, BlockNumber>,
@@ -115,8 +115,8 @@ pub trait Permission0EmissionApi<AccountId, Origin, BlockNumber, Balance, Negati
         weight_setter: Option<AccountId>,
     ) -> Result<PermissionId, DispatchError>;
 
-    /// Accumulate emissions for an agent with permissions
-    fn accumulate_emissions(agent: &AccountId, stream: &StreamId, amount: &mut NegativeImbalance);
+    /// Accumulate streams for an agent with permissions
+    fn accumulate_streams(agent: &AccountId, stream: &StreamId, amount: &mut NegativeImbalance);
 
     /// Check and process automatic distributions
     fn process_auto_distributions(current_block: BlockNumber);

pallets/permission0/api/src/lib.rs

@@ -28,7 +28,7 @@ mod benchmarks {
     }
 
     #[benchmark]
-    fn delegate_emission_permission() {
+    fn delegate_stream_permission() {
         let delegator: T::AccountId = account("delegator", 0, 0);
         let recipient: T::AccountId = account("recipient", 1, 0);
 
@@ -42,15 +42,15 @@ mod benchmarks {
 
         let stream_id: StreamId = [0; 32].into();
         let streams = BTreeMap::from([(stream_id, Percent::from_percent(30))]);
-        let allocation = EmissionAllocation::Streams(streams.try_into().unwrap());
+        let allocation = StreamAllocation::Streams(streams.try_into().unwrap());
         let recipients = bounded_btree_map![recipient => 100];
         let distribution = DistributionControl::Manual;
         let duration = PermissionDuration::Indefinite;
         let revocation = RevocationTerms::RevocableByDelegator;
         let enforcement = EnforcementAuthority::None;
 
         #[extrinsic_call]
-        delegate_emission_permission(
+        delegate_stream_permission(
             RawOrigin::Signed(delegator),
             recipients,
             allocation,
@@ -78,9 +78,9 @@ mod benchmarks {
 
         let stream_id: StreamId = [0; 32].into();
         let streams = BTreeMap::from([(stream_id, Percent::from_percent(30))]);
-        let allocation = EmissionAllocation::Streams(streams.try_into().unwrap());
+        let allocation = StreamAllocation::Streams(streams.try_into().unwrap());
         let recipients = bounded_btree_map![recipient => 100];
-        let permission_id = ext::emission_impl::delegate_emission_permission_impl::<T>(
+        let permission_id = ext::stream_impl::delegate_stream_permission_impl::<T>(
             delegator.clone(),
             recipients,
             allocation,
@@ -114,10 +114,10 @@ mod benchmarks {
         // Create permission with fixed amount allocation
         let stream_id: StreamId = [0; 32].into();
         let streams = BTreeMap::from([(stream_id, Percent::from_percent(30))]);
-        let allocation = EmissionAllocation::Streams(streams.try_into().unwrap());
+        let allocation = StreamAllocation::Streams(streams.try_into().unwrap());
         let recipients = bounded_btree_map![recipient => 100];
 
-        let permission_id = ext::emission_impl::delegate_emission_permission_impl::<T>(
+        let permission_id = ext::stream_impl::delegate_stream_permission_impl::<T>(
             delegator.clone(),
             recipients,
             allocation,
@@ -153,10 +153,10 @@ mod benchmarks {
         // Create permission with stream allocation
         let stream_id: StreamId = [0; 32].into();
         let streams = BTreeMap::from([(stream_id, Percent::from_percent(30))]);
-        let allocation = EmissionAllocation::Streams(streams.try_into().unwrap());
+        let allocation = StreamAllocation::Streams(streams.try_into().unwrap());
         let recipients = bounded_btree_map![recipient => 100];
 
-        let permission_id = ext::emission_impl::delegate_emission_permission_impl::<T>(
+        let permission_id = ext::stream_impl::delegate_stream_permission_impl::<T>(
             delegator.clone(),
             recipients,
             allocation,
@@ -192,7 +192,7 @@ mod benchmarks {
         // Create permission with fixed amount allocation and enforcement authority
         let stream_id: StreamId = [0; 32].into();
         let streams = BTreeMap::from([(stream_id, Percent::from_percent(30))]);
-        let allocation = EmissionAllocation::Streams(streams.try_into().unwrap());
+        let allocation = StreamAllocation::Streams(streams.try_into().unwrap());
         let recipients = bounded_btree_map![recipient => 100];
         let controllers = vec![controller.clone()].try_into().unwrap();
 
@@ -201,7 +201,7 @@ mod benchmarks {
             required_votes: 1,
         };
 
-        let permission_id = ext::emission_impl::delegate_emission_permission_impl::<T>(
+        let permission_id = ext::stream_impl::delegate_stream_permission_impl::<T>(
             delegator.clone(),
             recipients,
             allocation,
@@ -237,10 +237,10 @@ mod benchmarks {
 
         let stream_id: StreamId = [0; 32].into();
         let streams = BTreeMap::from([(stream_id, Percent::from_percent(30))]);
-        let allocation = EmissionAllocation::Streams(streams.try_into().unwrap());
+        let allocation = StreamAllocation::Streams(streams.try_into().unwrap());
         let recipients = bounded_btree_map![recipient => 100];
 
-        let permission_id = ext::emission_impl::delegate_emission_permission_impl::<T>(
+        let permission_id = ext::stream_impl::delegate_stream_permission_impl::<T>(
             delegator.clone(),
             recipients,
             allocation,

pallets/permission0/src/benchmarking.rs

@@ -15,8 +15,8 @@ use polkadot_sdk::{
 };
 
 pub mod curator_impl;
-pub mod emission_impl;
 pub mod namespace_impl;
+pub mod stream_impl;
 
 /// Implementation of the Permission0Api trait to be used externally
 impl<T: Config> Permission0Api<OriginFor<T>> for pallet::Pallet<T> {
@@ -141,8 +141,8 @@ pub(crate) fn execute_permission_impl<T: Config>(
     );
 
     match &contract.scope {
-        PermissionScope::Emission(emission_scope) => {
-            emission_impl::execute_permission_impl(permission_id, &contract, emission_scope)
+        PermissionScope::Stream(stream_scope) => {
+            stream_impl::execute_permission_impl(permission_id, &contract, stream_scope)
         }
         PermissionScope::Curator(_) => curator_impl::execute_permission_impl::<T>(permission_id),
         PermissionScope::Namespace(_) => Ok(()),
@@ -201,8 +201,8 @@ pub fn enforcement_execute_permission_impl<T: Config>(
     }
 
     match &contract.scope {
-        PermissionScope::Emission(emission_scope) => {
-            emission_impl::execute_permission_impl(&permission_id, &contract, emission_scope)?
+        PermissionScope::Stream(stream_scope) => {
+            stream_impl::execute_permission_impl(&permission_id, &contract, stream_scope)?
         }
         PermissionScope::Curator(_) => {
             return curator_impl::execute_permission_impl::<T>(&permission_id);