# { "Depends": "py-genlayer:1jb45aa8ynh2a9c9xn3b7qqh8sm5q93hwfp7jqmwsfhh8jpz09h6" } from genlayer import * from datetime import datetime,timezone import json def enc(v):return json.dumps(v,sort_keys=True,separators=(',',':')) def ident(v): v=v.strip().upper() if not 3<=len(v)<=48 or not all(c in 'ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789-_' for c in v):raise gl.vm.UserError('invalid id') return v def now():return int(datetime.now(timezone.utc).timestamp()) class ConsensusQueue(gl.Contract): tasks:TreeMap[str,str] def __init__(self):pass @gl.public.write def enqueue(self,task_id:str,payload:str,priority:u256,ttl:u256)->None: tid=ident(task_id);p=payload.strip();pr=int(priority);t=int(ttl) if self.tasks.get(tid,'') or not 10<=len(p)<=1200 or not 1<=pr<=100 or not 300<=t<=604800:raise gl.vm.UserError('invalid task') self.tasks[tid]=enc({'id':tid,'payload':p,'priority':pr,'created':now(),'expiry':now()+t,'status':'QUEUED','worker':'','nonce':0,'result':''}) @gl.public.write def claim(self,task_id:str,nonce:u256)->None: tid=ident(task_id);m=json.loads(self.tasks.get(tid,'{}'));worker=str(gl.message.sender_address).lower() if not m or m['status']!='QUEUED' or now()>m['expiry'] or int(nonce)!=0:raise gl.vm.UserError('not claimable') m.update({'status':'CLAIMED','worker':worker,'nonce':1});self.tasks[tid]=enc(m) @gl.public.write def complete(self,task_id:str,result:str)->None: tid=ident(task_id);m=json.loads(self.tasks.get(tid,'{}'));worker=str(gl.message.sender_address).lower();r=result.strip() if not m or m['status']!='CLAIMED' or m['worker']!=worker or not 2<=len(r)<=1200:raise gl.vm.UserError('not completable') m.update({'status':'COMPLETED','result':r});self.tasks[tid]=enc(m) @gl.public.write def cancel_expired(self,task_id:str)->None: tid=ident(task_id);m=json.loads(self.tasks.get(tid,'{}')) if not m or m['status'] not in ('QUEUED','CLAIMED') or now()<=m['expiry']:raise gl.vm.UserError('not expired') m['status']='EXPIRED';self.tasks[tid]=enc(m) @gl.public.view def get_task(self,task_id:str,maybe_task_id:str='')->str: return self.tasks.get(ident(maybe_task_id or task_id),'{}')