import sys
import os
import json

# Add genesis-system to path
sys.path.append(r"E:\genesis-system")
from blackboard import Blackboard, TaskStatus, EntryType

def rescue_tasks():
    bb = Blackboard()
    print(f"[*] Rescuing CLAIMED tasks...")
    
    # Query claimed tasks
    tasks = bb.query(status=TaskStatus.CLAIMED)
    print(f"[*] Found {len(tasks)} claimed tasks.")
    
    for task in tasks:
        print(f"[*] Re-opening {task.id}: {task.content.get('description')[:50]}...")
        task.status = TaskStatus.OPEN
        task.claimed_by = None
        
        if bb.use_redis:
            bb.redis_client.set(f"{bb.namespace}:{task.id}", json.dumps(task.to_dict()))
        else:
            bb.entries[task.id] = task
            bb._persist()
            
    print("[DONE] Alld tasks re-opened.")

if __name__ == "__main__":
    rescue_tasks()