Feat/new coinbase

pallets/subtensor/src/coinbase/block_step.rs

@@ -18,13 +18,18 @@ impl<T: Config + pallet_drand::Config> Pallet<T> {
                 .to_u64(),
         );
         log::debug!("Block emission: {block_emission:?}");
-        // --- 3. Run emission through network.
+
+        // --- 3. Reveal matured weights.
+        Self::reveal_crv3_commits();
+        // --- 4. Run emission through network.
         Self::run_coinbase(block_emission);
-        // --- 4. Set pending children on the epoch; but only after the coinbase has been run.
+        // --- 5. Update moving prices AFTER using them for emissions.
+        Self::update_moving_prices();
+        // --- 6. Set pending children on the epoch; but only after the coinbase has been run.
         Self::try_set_pending_children(block_number);
-        // --- 5. Run auto-claim root divs.
+        // --- 7. Run auto-claim root divs.
         Self::run_auto_claim_root_divs(last_block_hash);
-        // --- 6. Populate root coldkey maps.
+        // --- 8. Populate root coldkey maps.
         Self::populate_root_coldkey_staking_maps();
 
         // Return ok.
@@ -261,4 +266,24 @@ impl<T: Config + pallet_drand::Config> Pallet<T> {
             return next_value.saturating_to_num::<u64>().into();
         }
     }
+
+    pub fn update_moving_prices() {
+        let subnets_to_emit_to: Vec<NetUid> =
+            Self::get_subnets_to_emit_to(&Self::get_all_subnet_netuids());
+        // Only update price EMA for subnets that we emit to.
+        for netuid_i in subnets_to_emit_to.iter() {
+            // Update moving prices after using them above.
+            Self::update_moving_price(*netuid_i);
+        }
+    }
+
+    pub fn reveal_crv3_commits() {
+        let netuids: Vec<NetUid> = Self::get_all_subnet_netuids();
+        for netuid in netuids.into_iter().filter(|netuid| *netuid != NetUid::ROOT) {
+            // Reveal matured weights.
+            if let Err(e) = Self::reveal_crv3_commits_for_subnet(netuid) {
+                log::warn!("Failed to reveal commits for subnet {netuid} due to error: {e:?}");
+            };
+        }
+    }
 }

pallets/subtensor/src/coinbase/reveal_commits.rs

@@ -36,7 +36,7 @@ pub struct LegacyWeightsTlockPayload {
 
 impl<T: Config> Pallet<T> {
     /// The `reveal_crv3_commits` function is run at the very beginning of epoch `n`,
-    pub fn reveal_crv3_commits(netuid: NetUid) -> dispatch::DispatchResult {
+    pub fn reveal_crv3_commits_for_subnet(netuid: NetUid) -> dispatch::DispatchResult {
         let reveal_period = Self::get_reveal_period(netuid);
         let cur_block = Self::get_current_block_as_u64();
         let cur_epoch = Self::get_epoch_index(netuid, cur_block);

pallets/subtensor/src/coinbase/subnet_emissions.rs

@@ -7,10 +7,18 @@ use subtensor_swap_interface::SwapHandler;
 
 impl<T: Config> Pallet<T> {
     pub fn get_subnets_to_emit_to(subnets: &[NetUid]) -> Vec<NetUid> {
+        // Filter out root subnet.
         // Filter out subnets with no first emission block number.
         subnets
             .iter()
+            .filter(|netuid| !netuid.is_root())
             .filter(|netuid| FirstEmissionBlockNumber::<T>::get(*netuid).is_some())
+            .filter(|netuid| SubtokenEnabled::<T>::get(*netuid))
+            .filter(|&netuid| {
+                // Only emit TAO if the subnetwork allows registration.
+                Self::get_network_registration_allowed(*netuid)
+                    || Self::get_network_pow_registration_allowed(*netuid)
+            })
             .copied()
             .collect()
     }