import subprocess
raw=subprocess.check_output(["docker","inspect","graphiti-neo4j","--format","{{range .Config.Env}}{{println .}}{{end}}"],text=True)
for line in raw.splitlines():
    if line.startswith("NEO4J_AUTH="):
        u,p=line.split("=",1)[1].split("/",1)
        break
queries=[
    "RETURN 1 AS x",
    "MATCH (n:Episodic) RETURN count(n) AS c",
    "MATCH (n:Episodic) WHERE coalesce(n.source_description,\"\") CONTAINS \"video_id:-BF7-d0WaAA\" RETURN count(n) AS c",
    "MATCH (n:Episodic) WHERE ANY(k IN keys(n) WHERE (CASE WHEN n[k] IS :: LIST<ANY> THEN reduce(s='', x IN n[k] | s + ' ' + toString(x)) ELSE toString(n[k]) END) CONTAINS '-BF7-d0WaAA') RETURN count(n) AS c",
]
for q in queries:
    r=subprocess.run(["docker","exec","graphiti-neo4j","cypher-shell","-u",u,"-p",p,"--format","plain","--non-interactive",q],text=True,capture_output=True)
    print("RETURN_CODE",r.returncode)
    print("STDOUT",repr(r.stdout[:1000]))
    print("STDERR",repr(r.stderr[:1000]))