--with-facts / --facts-json write root=facts leafs; --with-chats picks up var/chats/md as info. WhatsApp sync stays out of v1 (Gitea #18).
98 lines
3.7 KiB
Python
98 lines
3.7 KiB
Python
"""Import adapters write files only. Index rebuild is brain/index (D14 / Gitea #7)."""
|
|
from __future__ import annotations
|
|
|
|
import json
|
|
import os
|
|
import subprocess
|
|
import sys
|
|
import tempfile
|
|
import unittest
|
|
from pathlib import Path
|
|
|
|
ROOT = Path(__file__).resolve().parents[2]
|
|
|
|
|
|
class IndexAdapterTest(unittest.TestCase):
|
|
def test_dry_run_fixture_corpus_does_not_write_lbug(self) -> None:
|
|
tmp = Path(tempfile.mkdtemp())
|
|
(tmp / "note.md").write_text("# Fixture\n\n## Leaf\n\nhello corpus\n", encoding="utf-8")
|
|
lbug = tmp / "kb.lbug"
|
|
try:
|
|
import ladybug # noqa: F401
|
|
except ImportError:
|
|
venv_py = ROOT / ".venv" / "bin" / "python"
|
|
if not venv_py.is_file():
|
|
self.skipTest("ladybug missing")
|
|
py = str(venv_py)
|
|
else:
|
|
py = sys.executable
|
|
proc = subprocess.run(
|
|
[py, str(ROOT / "bin" / "kb" / "index"), "--dry-run", "--json", "--corpus", str(tmp)],
|
|
cwd=ROOT,
|
|
capture_output=True,
|
|
text=True,
|
|
env=os.environ.copy(),
|
|
check=False,
|
|
)
|
|
self.assertEqual(proc.returncode, 0, proc.stderr)
|
|
msg = json.loads(proc.stdout)
|
|
self.assertTrue(msg.get("dry_run"))
|
|
self.assertGreaterEqual(msg.get("corpus_total", 0), 1)
|
|
self.assertFalse(lbug.exists(), "dry-run must not create a Ladybug file")
|
|
|
|
def test_facts_json_and_chats_land_on_rebuild(self) -> None:
|
|
"""Gitea #18: facts (2-source) + chats markdown become leafs on rebuild."""
|
|
tmp = Path(tempfile.mkdtemp())
|
|
dbpath = tmp / "kb.lbug"
|
|
chats = tmp / "chats"
|
|
chats.mkdir()
|
|
(chats / "alice.md").write_text(
|
|
"# Chat\n\n## Alice and Bob\n\nhello from chats fixture unique-chat-token\n",
|
|
encoding="utf-8",
|
|
)
|
|
facts_path = tmp / "facts.json"
|
|
facts_path.write_text(json.dumps([{
|
|
"text": "container 'brain' unique-fact-token is running and declared in compose.yaml",
|
|
"source": "docker ps x compose.yaml",
|
|
"loc": "compose.yaml:brain",
|
|
"how": "facts/extract",
|
|
}]), encoding="utf-8")
|
|
venv_py = ROOT / ".venv" / "bin" / "python"
|
|
py = str(venv_py) if venv_py.is_file() else sys.executable
|
|
proc = subprocess.run(
|
|
[
|
|
py, str(ROOT / "bin" / "kb" / "index"),
|
|
"--rebuild", "--db", str(dbpath), "--no-defaults",
|
|
"--with-chats", str(chats),
|
|
"--facts-json", str(facts_path),
|
|
"--json",
|
|
],
|
|
cwd=ROOT,
|
|
capture_output=True,
|
|
text=True,
|
|
env=os.environ.copy(),
|
|
check=False,
|
|
)
|
|
self.assertEqual(proc.returncode, 0, proc.stderr)
|
|
msg = json.loads(proc.stdout)
|
|
self.assertGreaterEqual(msg.get("facts_leafs", 0), 1)
|
|
self.assertGreaterEqual(msg.get("chat_leafs", 0), 1)
|
|
self.assertTrue(dbpath.exists())
|
|
sys.path.insert(0, str(ROOT / "bin" / "tools"))
|
|
import kblib
|
|
db, conn = kblib.connect(dbpath, read_only=True)
|
|
try:
|
|
stats = kblib.stats(conn)
|
|
self.assertGreaterEqual(stats["by_root"].get("facts", 0), 1)
|
|
fts = kblib.query_fts(conn, "unique-chat-token", 5)
|
|
self.assertTrue(fts, "chats markdown must be FTS-searchable")
|
|
fact_hits = kblib.query_fts(conn, "unique-fact-token", 5)
|
|
self.assertTrue(any(h.get("root") == "facts" for h in fact_hits))
|
|
src = conn.execute(
|
|
"MATCH (l:Leaf {root:'facts'}) RETURN l.source"
|
|
).get_all()
|
|
self.assertTrue(any(" x " in str(r[0]) for r in src))
|
|
finally:
|
|
conn.close()
|
|
db.close()
|