4. Extract player data (name, XP, skills)

#!/usr/bin/env python3
"""Print username + top skills for a name search via relay-cache HTTP."""
import json
import sys
import urllib.parse
import urllib.request

BASE = "https://relay.bitcraftsync.app"
NEEDLE = sys.argv[1] if len(sys.argv) > 1 else "maple"


def get(path: str):
    with urllib.request.urlopen(BASE + path, timeout=60) as r:
        return json.load(r)


players = get("/player?name=" + urllib.parse.quote(NEEDLE))
if not players:
    sys.exit(f"no players matching {NEEDLE!r}")

# Prefer an exact (case-insensitive) username match when present.
pick = next(
    (p for p in players if p["username"].lower() == NEEDLE.lower()),
    players[0],
)
entity_id = pick["entity_id"]  # str — keep as str for the URL
print(f"{pick['username']}  entity_id={entity_id}  region={pick['region']}")
print(f"  signed_in={pick.get('signed_in')}  last_login={pick.get('last_login_timestamp')}")

detail = get(f"/player/{entity_id}/skills")
skills = sorted(detail["skills"], key=lambda s: s["xp"], reverse=True)
print(f"  {len(skills)} skills — top 5 by XP:")
for s in skills[:5]:
    print(f"    {s['name']:<20} level={s['level']:<3} xp={s['xp']}")

# Every column on the skills payload:
#   skill_id: int   name: str   level: int   xp: int

#!/usr/bin/env python3
"""Same runnable join as Subscribe → “Many tables” (v1.json).
   pip install websockets
"""
import asyncio
import json
import websockets

URL = (
    "wss://relay.bitcraftsync.app:3014"
    "/v1/database/relay-mirror-bc14/subscribe?compression=None"
)
ENTITY = 1297036692699996362  # Maplesugar on region 14

QUERIES = [
    "SELECT * FROM skill_desc",
    "SELECT * FROM player_username_state WHERE username = 'Maplesugar'",
    f"SELECT * FROM player_state WHERE entity_id = {ENTITY}",
    f"SELECT * FROM experience_state WHERE entity_id = {ENTITY}",
]

async def recv_json(ws, timeout=180):
    while True:
        msg = await asyncio.wait_for(ws.recv(), timeout=timeout)
        if isinstance(msg, str):
            return json.loads(msg)

async def main():
    async with websockets.connect(
        URL, subprotocols=["v1.json.spacetimedb"], max_size=None
    ) as ws:
        assert "IdentityToken" in await recv_json(ws)  # v1 greeting

        await ws.send(json.dumps({
            "Subscribe": {"request_id": 1, "query_strings": QUERIES}
        }))
        applied = await recv_json(ws)
        isub = applied["InitialSubscription"]

        skill_names = {}
        stacks = []
        for table in isub["database_update"]["tables"]:
            name = table["table_name"]
            for upd in table["updates"]:
                for raw in upd.get("inserts", []):
                    row = json.loads(raw) if isinstance(raw, str) else raw
                    if name == "skill_desc":
                        skill_names[row["id"]] = row["name"]
                    elif name == "player_username_state":
                        print(f"username={row['username']}  entity_id={row['entity_id']}")
                    elif name == "player_state":
                        print(
                            f"  signed_in={row.get('signed_in')}  "
                            f"sign_in_timestamp={row.get('sign_in_timestamp')}"
                        )
                    elif name == "experience_state":
                        stacks = row.get("experience_stacks") or []

        for skill_id, xp in sorted(stacks, key=lambda p: -p[1])[:5]:
            label = skill_names.get(skill_id, "?")
            print(f"  {label:<20} skill_id={skill_id}  xp={xp}")

        # Snapshot done — close the socket (OneOffQuery substitute).
        # For a live cache, keep the connection and apply TransactionUpdates.

asyncio.run(main())