refac(permission0): rename emission to streams (#135)

Final piece of the current delivery. We are renaming emission
permissions to stream permissions for two main reasons. It represents
better the concept of what the permission actually does (distribute
tokens through the streams), and is more accurate with what we want to
make possible in the future.

Closes CHAIN-123.

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);

pallets/permission0/src/ext.rs

@@ -7,7 +7,7 @@ use pallet_permission0_api::Permission0NamespacesApi;
 use pallet_torus0_api::{NamespacePath, NamespacePathInner, Torus0Api};
 use polkadot_sdk::{
     frame_support::{dispatch::DispatchResult, ensure},
-    frame_system::ensure_signed,
+    frame_system::{self, ensure_signed},
     polkadot_sdk_frame::prelude::OriginFor,
     sp_core::Get,
     sp_runtime::{BoundedBTreeMap, BoundedBTreeSet, DispatchError},
@@ -309,6 +309,7 @@ pub(crate) fn update_namespace_permission<T: Config>(
     }
 
     permission.max_instances = max_instances;
+    permission.last_update = frame_system::Pallet::<T>::block_number();
     Permissions::<T>::set(permission_id, Some(permission));
 
     Ok(())