from pathlib import Path
import sqlite3
for p in Path('/opt/struktur/youtube-research').glob('*.py'):
 s=p.read_text(errors='ignore'); hits=[(i,l[:220]) for i,l in enumerate(s.splitlines(),1) if any(k in l for k in ['write_obsidian','sync_ce','register_graphiti','e2e_jobs','INSERT INTO graphiti_import_queue'])]
 if hits:
  print('FILE',p)
  for i,l in hits: print(i,l)
for p in ['/opt/struktur/content-extraction/data/content_extraction.db','/opt/struktur/content-extraction/content_extraction.db']:
 if Path(p).exists():
  c=sqlite3.connect('file:'+p+'?mode=ro',uri=True)
  print('CE',p)
  for t in c.execute("SELECT name FROM sqlite_master WHERE type='table'"):
   print(t[0],c.execute('PRAGMA table_info('+t[0]+')').fetchall())
  c.close()