fix last stuffs

Author: eclipsevortex

subvortex/core/metagraph/metagraph.py

@@ -109,6 +109,9 @@ async def start(self):
                         axons
                     )
 
+                    # Get the last udpate
+                    last_update = await self.database.get_neuron_last_updated()
+
                     # Determine whether a resync is needed
                     time_to_resync = block - last_synced_block >= sync_interval
                     must_resync = (
@@ -117,15 +120,20 @@ async def start(self):
                         or has_axons_changed
                         or has_missing_country
                         or time_to_resync
+                        or last_update is None
                     )
 
                     if not must_resync:
                         btul.logging.debug(
                             "No changes detected; skipping sync.",
                             prefix=self.settings.logging_name,
                         )
-                        continue
+                        
+                        # Notify listener the metagraph is ready
+                        ready = await self._notify_if_needed(ready)
 
+                        continue
+                  
                     if has_axons_changed:
                         reason = "hotkey/IP changes detected"
                     elif has_missing_country:
@@ -143,7 +151,9 @@ async def start(self):
                     )
 
                     # Sync from chain and update Redis
-                    axons, has_missing_country = await self._resync()
+                    axons, has_missing_country = await self._resync(
+                        last_update=last_update
+                    )
 
                     # Store the sync block
                     last_synced_block = block
@@ -202,7 +212,7 @@ async def stop(self):
             f"✅ MetagraphObserver service stopped", prefix=self.settings.logging_name
         )
 
-    async def _resync(self) -> dict[str, str]:
+    async def _resync(self, last_update: bool) -> dict[str, str]:
         await self.metagraph.sync(subtensor=self.subtensor, lite=False)
         btul.logging.debug(
             "📡 Full metagraph sync complete", prefix=self.settings.logging_name
@@ -247,7 +257,7 @@ async def _resync(self) -> dict[str, str]:
                         else None
                     )
                 )
-                
+
             except sccc.CountryApiException as e:
                 btul.logging.error(f"🚨 Country API failure: {e}")
                 btul.logging.warning(
@@ -257,7 +267,9 @@ async def _resync(self) -> dict[str, str]:
                 # Wait for the longest rate limit to expire (ensures all APIs are available)
                 if e.rate_limited:
                     max_wait = max(e.rate_limited.values())
-                    btul.logging.info(f"⏰ Waiting {max_wait:.0f}s for all APIs to recover...")
+                    btul.logging.info(
+                        f"⏰ Waiting {max_wait:.0f}s for all APIs to recover..."
+                    )
                     await asyncio.sleep(max_wait)
                 else:
                     await asyncio.sleep(60)  # Default wait if no rate limit info
@@ -399,7 +411,7 @@ async def _resync(self) -> dict[str, str]:
                 updated_neurons
             )
 
-        if updated_neurons or neurons_to_delete:
+        if last_update is None or updated_neurons or neurons_to_delete:
             block = await self.subtensor.get_current_block()
             not self.settings.dry_run and await self.database.set_last_updated(block)
             btul.logging.debug(

subvortex/core/shared/substrate.py

@@ -66,7 +66,7 @@ async def get_owner_hotkey(substrate: AsyncSubstrateInterface, netuid: int):
         module="SubtensorModule", storage_function="SubnetOwnerHotkey", params=[netuid]
     )
 
-    return result.value
+    return result.value if hasattr(result, "value") else result
 
 
 def get_weights_min_stake(substrate: SubstrateInterface):

subvortex/miner/neuron/src/main.py

@@ -415,7 +415,7 @@ async def _blacklist(self, synapse: Synapse) -> typing.Tuple[bool, str]:
         synapse_type = type(synapse).__name__
 
         # Whitelist the subnet owner hotkey
-        owner_hotkey = get_owner_hotkey(self.subtensor.substrate, self.config.netuid)
+        owner_hotkey = await get_owner_hotkey(self.subtensor.substrate, self.config.netuid)
         if caller == owner_hotkey:
             return False, "Hotkey recognized!"
 

subvortex/validator/neuron/src/main.py

@@ -385,7 +385,7 @@ async def run(self):
         # Signal the neuron has finished
         self.run_complete.set()
 
-    async def _shutdown(self):
+    async def shutdown(self):
         btul.logging.info("Waiting validator to complete its work...")
 
         # Wait the neuron to stop