File size: 2,127 Bytes
6f5405c | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 | import uuid
from typing import Dict
class ChronosLedger:
"""
L1 Ledger: Tracks Identity and SECONDS balance.
No economics, no inflation control, just pure time accounting.
"""
def __init__(self):
self.accounts: Dict[str, float] = {} # Node ID -> Balance in SECONDS
self.tasks: Dict[str, dict] = {} # Task ID -> Task details
def register_node(self, node_id: str) -> None:
if node_id not in self.accounts:
self.accounts[node_id] = 0.0
print(f"[Ledger] Node registered: {node_id}")
def create_task(self, consumer_id: str, payload: str, bounty_seconds: float) -> str:
"""
Consumer creates a task, locking in SECONDS.
"""
if self.accounts.get(consumer_id, 0) < bounty_seconds:
raise ValueError("Insufficient SECONDS balance.")
task_id = str(uuid.uuid4())
self.accounts[consumer_id] -= bounty_seconds
self.tasks[task_id] = {
"consumer": consumer_id,
"payload": payload,
"bounty": bounty_seconds,
"status": "pending",
"provider": None
}
print(f"[Ledger] Task {task_id} created by {consumer_id} for {bounty_seconds}s.")
return task_id
def submit_result(self, task_id: str, provider_id: str, result: str) -> bool:
"""
Provider submits result and claims the bounty.
"""
task = self.tasks.get(task_id)
if not task or task["status"] != "pending":
return False
task["status"] = "completed"
task["provider"] = provider_id
task["result"] = result
self.register_node(provider_id)
self.accounts[provider_id] += task["bounty"]
print(f"[Ledger] Task {task_id} completed by {provider_id}. Earned {task['bounty']}s.")
return True
def get_balance(self, node_id: str) -> float:
return self.accounts.get(node_id, 0.0)
# Global singleton for simulation
_global_ledger = ChronosLedger()
def get_ledger() -> ChronosLedger:
return _global_ledger
|