Rename mep_miner to mep_provider for legal safety

node/{mep_miner.py → mep_provider.py}

@@ -17,7 +17,7 @@ sys.path.append(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
 HUB_URL = "http://localhost:8000"
 WS_URL = "ws://localhost:8000"
 
-class MEPMiner:
+class MEPProvider:
     def __init__(self, node_id: str):
         self.node_id = node_id
         self.balance = 0.0
@@ -154,18 +154,18 @@ Would you like me to elaborate on any specific aspect?"""
 
 async def main():
     # Create a miner with unique ID
-    miner_id = f"mep-miner-{uuid.uuid4().hex[:8]}"
-    miner = MEPMiner(miner_id)
+    provider_id = f"mep-provider-{uuid.uuid4().hex[:8]}"
+    miner = MEPProvider(provider_id)
     
     try:
         await miner.connect()
     except KeyboardInterrupt:
         miner.stop()
-        print("\n[MEP] Mining stopped by user")
+        print("\n[MEP] Contribution stopped by user")
 
 if __name__ == "__main__":
     print("=" * 60)
     print("Miao Exchange Protocol (MEP) Miner")
-    print("Earn SECONDS by processing tasks while you sleep")
+    print("Earn SECONDS by contributing idle compute")
     print("=" * 60)
     asyncio.run(main())

node/race_test.py

@@ -13,7 +13,7 @@ import time
 HUB_URL = "http://localhost:8000"
 WS_URL = "ws://localhost:8000"
 
-class RacingMiner:
+class RacingProvider:
     def __init__(self, name, location):
         self.name = name
         self.location = location
@@ -43,7 +43,7 @@ class RacingMiner:
                     self.response_time = time.time() - start_time
                     print(f"[{self.name}] 🏁 GOT THE TASK! Response: {self.response_time:.3f}s")
                     
-                    # Simulate processing (faster miners win)
+                    # Simulate processing (faster providers win)
                     process_time = 0.1 if "fast" in self.name.lower() else 0.5
                     await asyncio.sleep(process_time)
                     
@@ -76,12 +76,12 @@ async def run_race():
     consumer_id = "race-test-consumer"
     requests.post(f"{HUB_URL}/register", json={"pubkey": consumer_id})
     
-    # Create 4 miners in different "locations"
-    miners = [
-        RacingMiner("FastMiner-USA", "New York"),
-        RacingMiner("SlowMiner-EU", "Berlin"),
-        RacingMiner("QuickMiner-Asia", "Singapore"),
-        RacingMiner("SteadyMiner-AU", "Sydney")
+    # Create 4 providers in different "locations"
+    providers = [
+        RacingProvider("FastProvider-USA", "New York"),
+        RacingProvider("SlowProvider-EU", "Berlin"),
+        RacingProvider("QuickProvider-Asia", "Singapore"),
+        RacingProvider("SteadyProvider-AU", "Sydney")
     ]
     
     # Submit a task
@@ -101,9 +101,9 @@ async def run_race():
     task_id = task_data["task_id"]
     print(f"   Task ID: {task_id[:8]}...")
     
-    # Start all miners simultaneously
-    print("\n🏁 Starting miners...")
-    tasks = [miner.compete(task_id, task_payload, bounty) for miner in miners]
+    # Start all providers simultaneously
+    print("\n🏁 Starting providers...")
+    tasks = [provider.compete(task_id, task_payload, bounty) for provider in providers]
     await asyncio.gather(*tasks)
     
     # Results
@@ -112,13 +112,13 @@ async def run_race():
     print("=" * 60)
     
     winner = None
-    for miner in miners:
-        status = "🏆 WINNER" if miner.won_race else "❌ Lost"
-        time_str = f"{miner.response_time:.3f}s" if miner.response_time else "N/A"
-        print(f"{status} {miner.name:20} {miner.location:15} Response: {time_str:8} Balance: {miner.balance}")
+    for provider in providers:
+        status = "🏆 WINNER" if provider.won_race else "❌ Lost"
+        time_str = f"{provider.response_time:.3f}s" if provider.response_time else "N/A"
+        print(f"{status} {provider.name:20} {provider.location:15} Response: {time_str:8} Balance: {provider.balance}")
         
-        if miner.won_race:
-            winner = miner
+        if provider.won_race:
+            winner = provider
     
     if winner:
         print(f"\n🎯 The market chose: {winner.name} from {winner.location}")

node/race_test_fixed.py

@@ -1,6 +1,6 @@
 #!/usr/bin/env python3
 """
-MEP Race Test FIXED: Ensure task is broadcast AFTER all miners connect.
+MEP Race Test FIXED: Ensure task is broadcast AFTER all providers connect.
 """
 import asyncio
 import websockets
@@ -12,7 +12,7 @@ import time
 HUB_URL = "http://localhost:8000"
 WS_URL = "ws://localhost:8000"
 
-class RacingMiner:
+class RacingProvider:
     def __init__(self, name, location):
         self.name = name
         self.location = location
@@ -71,18 +71,18 @@ async def run_race():
     print("MEP GLOBAL RACE TEST: Real Competition")
     print("=" * 60)
     
-    # Create miners
-    miners = [
-        RacingMiner("FastMiner-USA", "New York"),
-        RacingMiner("SlowMiner-EU", "Berlin"),
-        RacingMiner("QuickMiner-Asia", "Singapore"),
-        RacingMiner("SteadyMiner-AU", "Sydney")
+    # Create providers
+    providers = [
+        RacingProvider("FastProvider-USA", "New York"),
+        RacingProvider("SlowProvider-EU", "Berlin"),
+        RacingProvider("QuickProvider-Asia", "Singapore"),
+        RacingProvider("SteadyProvider-AU", "Sydney")
     ]
     
-    # Connect ALL miners first
-    print("\n🔗 Connecting miners to hub...")
-    for miner in miners:
-        await miner.connect()
+    # Connect ALL providers first
+    print("\n🔗 Connecting providers to hub...")
+    for provider in providers:
+        await provider.connect()
     
     await asyncio.sleep(0.5)  # Ensure all connected
     
@@ -90,10 +90,10 @@ async def run_race():
     consumer_id = "race-consumer-v2"
     requests.post(f"{HUB_URL}/register", json={"pubkey": consumer_id})
     
-    task_payload = "Which miner is fastest in the MEP race?"
+    task_payload = "Which provider is fastest in the MEP race?"
     bounty = 7.5
     
-    print(f"\n📤 Broadcasting task to {len(miners)} connected miners...")
+    print(f"\n📤 Broadcasting task to {len(providers)} connected providers...")
     print(f"   Task: {task_payload}")
     print(f"   Bounty: {bounty} SECONDS")
     
@@ -106,20 +106,20 @@ async def run_race():
     task_id = resp.json()["task_id"]
     print(f"   Task ID: {task_id[:8]}...")
     
-    # All miners listen simultaneously
-    print("\n🏁 ALL MINERS LISTENING... RACE STARTS!")
-    results = await asyncio.gather(*[miner.listen_for_task(task_id, bounty) for miner in miners])
+    # All providers listen simultaneously
+    print("\n🏁 ALL PROVIDERS LISTENING... RACE STARTS!")
+    results = await asyncio.gather(*[provider.listen_for_task(task_id, bounty) for provider in providers])
     
     # Close connections
-    for miner in miners:
-        await miner.close()
+    for provider in providers:
+        await provider.close()
     
     # Results
     print("\n" + "=" * 60)
     print("RACE RESULTS:")
     print("=" * 60)
     
-    winners = [m for m in miners if m.won_race]
+    winners = [m for m in providers if m.won_race]
     
     if winners:
         winner = winners[0]  # First to finish
@@ -130,10 +130,10 @@ async def run_race():
         
         # Show all times
         print(f"\n📊 All response times:")
-        for miner in miners:
-            if miner.response_time:
-                status = "✅ WON" if miner.won_race else "❌ Lost"
-                print(f"   {status} {miner.name:20} {miner.response_time:.3f}s")
+        for provider in providers:
+            if provider.response_time:
+                status = "✅ WON" if provider.won_race else "❌ Lost"
+                print(f"   {status} {provider.name:20} {provider.response_time:.3f}s")
     else:
         print("❌ No winner - check hub logs")
     

node/test_auction.py

@@ -7,9 +7,9 @@ import uuid
 HUB_URL = "http://localhost:8000"
 
 async def test():
-    miner = f'mep-miner-{uuid.uuid4().hex[:6]}'
-    requests.post(f'{HUB_URL}/register', json={'pubkey': miner})
-    async with websockets.connect(f'ws://localhost:8000/ws/{miner}') as ws:
+    provider = f'mep-provider-{uuid.uuid4().hex[:6]}'
+    requests.post(f'{HUB_URL}/register', json={'pubkey': provider})
+    async with websockets.connect(f'ws://localhost:8000/ws/{provider}') as ws:
         consumer = 'test-consumer'
         requests.post(f'{HUB_URL}/register', json={'pubkey': consumer})
         requests.post(f'{HUB_URL}/tasks/submit', json={'consumer_id': consumer, 'payload': 'Test payload', 'bounty': 1.0})
@@ -20,12 +20,12 @@ async def test():
         
         if data['event'] == 'rfc':
             task_id = data['data']['id']
-            resp = requests.post(f'{HUB_URL}/tasks/bid', json={'task_id': task_id, 'provider_id': miner})
+            resp = requests.post(f'{HUB_URL}/tasks/bid', json={'task_id': task_id, 'provider_id': provider})
             print('Bid response:', resp.json())
             
             complete_resp = requests.post(f'{HUB_URL}/tasks/complete', json={
                 'task_id': task_id, 
-                'provider_id': miner, 
+                'provider_id': provider, 
                 'result_payload': 'Done!'
             })
             print('Complete response:', complete_resp.json())