import sqlite3, json, subprocess, urllib.request
p='/opt/struktur/obsidian-graphiti-import/obsidian_graphiti_import.db'; c=sqlite3.connect('file:'+p+'?mode=ro',uri=True)
for t in ['fast_imports','files','runs','status_history']:
 print('TABLE',t); print(c.execute('pragma table_info('+t+')').fetchall()); print('SAMPLE',c.execute('select * from '+t+' limit 3').fetchall())
print('RETRY COUNTS')
for t in ['fast_imports','files']:
 try: print(t,c.execute('select status,count(*) from '+t+' group by status').fetchall())
 except: pass
print('REQUEST COUNT',sqlite3.connect('file:/opt/struktur/graphiti/request-data/requests.db?mode=ro',uri=True).execute('select count(*) from graphiti_requests').fetchone())
print('BLOCK',open('/opt/struktur/obsidian-graphiti-import/import_run_block.json').read())
print('PROCS',subprocess.run(['pgrep','-af','importer.py'],text=True,capture_output=True).stdout)
for u in ['http://127.0.0.1:8644/health','http://127.0.0.1:8655/v1/dashboard']:
 try: print(u,urllib.request.urlopen(u,timeout=20).read().decode()[:5000])
 except Exception as e: print(u,e)