marcopanandClaude Opus 4.8
c4d130828f
Implementazione del piano di remediation progressiva sui difetti emersi dall'analisi dell'harness. Tutto verificato: 214 test Python (incl. L0 su Postgres reale), 14 test JS del gate, ruff pulito. Blocco 1 (CRITICA, integrazione gate↔CLI): - phase advance: gate usa --auto + exit 6; reviewer_confirm kind:phase fa advance esplicito che applica i prerequisiti (prima non avanzava per le fasi a conferma umana). - cte plan riceve i --name dal gate (param names); set-question con id posizionale; skill `tht search find`; nuovo comando `tht memory save-one` con dedup hash client-side in save_one_memory. Blocco 2 (D15, stato post-rollback): - campo `phase` su DecisionRecord + effective_decisions phase-aware per i subject "a nome" (cte_approved ecc.); _compute_promotions e finalize sulla vista effective; finalize confronta col piano CTE effettivo, non glob; `decision add --retracts` + comando `decision retract`. Blocco 3 (D7 read-only + D6 manifest): - assert_read_only su tutti e quattro i codepath (direct + REST); - manifest author/summary/updated_at/updated_by/schema_version popolati + helper touch_manifest sulle mutazioni. Blocco 4-5 (D14a/D14b): - decision_min_phase data-driven via `emits:` in workflow.yaml; - formula evidence: status auto, search_formulas, gruppo CLI `tht formula`, `search find --kind formula`, load_evidence_dir salta i .sql.md. Blocco 6 (robustezza): - taskdoc slice promoted_tables + bound enforced; report escaping/bound + rsplit note; filtro kind reader REST/direct; conteggio upserted robusto; guard REST run_query non-list; LSH disallineato -> LshIndexError. Blocco 7 (pulizia): - dead code gate e KIND_TO_TABLE morto rimossi; doc Postgres-only (README + connection.py). Blocco 0 (parziale): test di compatibilità firma gate↔CLI (tests/integration). Rinviati: fake-Pi runtime completo, artifact-gate da disco (#23), parità eligibility REST/direct (#28), unificazione reserved-labels (#30), memory_rejected da deselezione (#33). Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
43 lines
1.6 KiB
Python
43 lines
1.6 KiB
Python
from sqlalchemy import Engine, create_engine, text
|
|
|
|
from tht.config import DatabaseConfig
|
|
|
|
|
|
def make_engine(cfg: DatabaseConfig) -> Engine:
|
|
# MVP: il transport `direct` supporta SOLO PostgreSQL (driver psycopg2; introspezione
|
|
# su cataloghi pg_*; sqlcheck/EXPLAIN dialetto postgres). Il DWH centrale di
|
|
# produzione usa il transport `rest`. Il supporto multi-dialetto (sqlserver/mariadb/
|
|
# informix, cfr. Thoth/thoth_sqldb2) e' lavoro futuro separato: aggiungere un campo
|
|
# dialect/driver a DatabaseConfig e astrarre introspect/sqlcheck/connection.
|
|
url = (
|
|
f"postgresql+psycopg2://{cfg.user}:{cfg.password}"
|
|
f"@{cfg.host}:{cfg.port}/{cfg.database}"
|
|
)
|
|
return create_engine(url, echo=False)
|
|
|
|
|
|
def ping(engine: Engine) -> None:
|
|
with engine.connect() as conn:
|
|
conn.execute(text("SELECT 1"))
|
|
|
|
|
|
def writable_tables(engine: Engine, schema: str) -> list[str]:
|
|
"""Tabelle dello schema su cui l'utente corrente ha privilegi di scrittura."""
|
|
q = text("""
|
|
SELECT c.relname
|
|
FROM pg_class c
|
|
JOIN pg_namespace n ON n.oid = c.relnamespace
|
|
WHERE n.nspname = :schema
|
|
AND c.relkind IN ('r', 'p')
|
|
AND has_table_privilege(current_user, c.oid, 'INSERT, UPDATE, DELETE')
|
|
ORDER BY c.relname
|
|
""")
|
|
with engine.connect() as conn:
|
|
return [row[0] for row in conn.execute(q, {"schema": schema})]
|
|
|
|
|
|
def can_create_in_schema(engine: Engine, schema: str) -> bool:
|
|
q = text("SELECT has_schema_privilege(current_user, :schema, 'CREATE')")
|
|
with engine.connect() as conn:
|
|
return bool(conn.execute(q, {"schema": schema}).scalar())
|