import asyncio
import json
from mcp.client.sse import sse_client
from mcp.client.session import ClientSession

SPURIOUS_UUIDS = [
    "4b280ddb-2070-4ae5-8593-db58562d0e01",
    "8fe43655-9a94-421b-b9f8-3b7a16ef5974",
    "6fd67e29-7e62-4dac-ab38-793deabf6a58",
    "692b1c37-7d53-496e-8c5d-062596c6ff72",
    "497e8ddd-8d5e-4070-8960-84960b601745",
    "ea43eab6-48a2-4e72-930b-88d3aef8c3b9",
    "21ba54f5-f006-4bd9-81a0-2f5f6e22ffc9",
    "d8f86e6d-dfca-480a-8d52-332898539475",
    "943f1e95-08ea-46fc-b88f-d7201f89723f",
    "1088f69e-8a82-4ec1-96d7-10e476370f00",
    "f14cb724-210c-4b62-bf7f-1cdec547a6ab",
    "db037309-e210-4b83-96be-802ab8dca27a",
    "36dd51f9-2729-42cf-b82c-fb0fc27e85ca",
    "42219b0c-c1a4-403d-8679-bfdb61ee8668",
    "ab29fdbe-d6cd-40a0-b890-68660a2da236",
    "e1a0f9f7-0bbd-41f4-8f80-f794214b680f",
    "3c7351db-e0f8-4040-9ef9-28a473782682",
    "4abeb7ad-405f-4eb0-b6e6-7a1e41dd7a93",
    "9ad8dc5f-eb4a-488b-895f-767ec151823d"
]

async def main():
    async with sse_client("http://127.0.0.1:8765/sse") as (read, write):
        async with ClientSession(read, write) as session:
            await session.initialize()
            for uid in SPURIOUS_UUIDS:
                res = await session.call_tool("mem0_delete", {"memory_id": uid})
                print(f"Deleted {uid}: {res.content[0].text}")
            
            status = await session.call_tool("mem0_status", {})
            print("Status after cleanup:", status.content[0].text)

if __name__ == "__main__":
    asyncio.run(main())