/qjG*dZddlmZddlZddlZddlZddlZddlmZmZm Z ddl m Z ddl m Z e dZejj!dd dd Zdd Zdd Z d dd ZgdZdddZdddZdddZdddZy) aAria Audit-Log + DLQ (KAR-230 + KAR-233). Append-only Audit-Log + Dead-Letter-Queue in SQLite. Spaeter Migration nach Supabase EU geplant (separat). aria.audit_log: pro datenfluss-event ein record (ts, actor, action, target_kind, target_id, payload_hash, status, error). aria.dlq: fail-events mit retry-schedule (exp-backoff). Usage: from aria_audit import audit, dlq_push, dlq_pop_ready audit("aria-akp-deep", "promote", "video", "abc123", payload={...}, status="ok") dlq_push("aria-akp-deep", payload, error_msg) ) annotationsN)datetimetimezone timedelta)Path)Anyz/root/aria/state/audit.sqliteT)parentsexist_okcbtjt}tj|_|S)N)sqlite3connectDB_PATHRow row_factorycons /root/aria/lib/aria_audit.py_connrs //' "CkkCO Jcdt5}|jddddy#1swYyxYw)zIdempotent schema init.a CREATE TABLE IF NOT EXISTS audit_log ( id INTEGER PRIMARY KEY AUTOINCREMENT, ts TEXT NOT NULL, actor TEXT NOT NULL, action TEXT NOT NULL, target_kind TEXT, target_id TEXT, payload_hash TEXT, status TEXT NOT NULL, error TEXT, metadata_json TEXT ); CREATE INDEX IF NOT EXISTS ix_audit_ts ON audit_log(ts); CREATE INDEX IF NOT EXISTS ix_audit_actor ON audit_log(actor, ts); CREATE INDEX IF NOT EXISTS ix_audit_action ON audit_log(action); CREATE TABLE IF NOT EXISTS dlq ( id INTEGER PRIMARY KEY AUTOINCREMENT, ts_created TEXT NOT NULL, ts_next_retry TEXT NOT NULL, actor TEXT NOT NULL, action TEXT NOT NULL, payload_json TEXT, error TEXT, retry_count INTEGER NOT NULL DEFAULT 0, max_retries INTEGER NOT NULL DEFAULT 5, status TEXT NOT NULL DEFAULT 'pending' ); CREATE INDEX IF NOT EXISTS ix_dlq_next ON dlq(status, ts_next_retry); N)r executescriptrs r init_schemar$s1  C      s&/c|sytj|dtj}t j |j ddS)NT) sort_keysdefault)jsondumpsstrencodehashlibsha256 hexdigest)payloadraws r _payload_hashr'HsB  **Wc : A A CC >>#  ( ( *3B //rcNtt5}|jdtjt j j||||t||||rtj|tndf } | jcdddS#1swYyxYw)z)Append-only audit record. Returns row id.zINSERT INTO audit_log (ts, actor, action, target_kind, target_id, payload_hash, status, error, metadata_json) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)rN) rrexecuternowrutc isoformatr'rrr lastrowid) actoraction target_kind target_idr%statuserrormetadatarcurs rauditr7OsM Ckk 1 X\\*446g&5= 8S14  }}!s As rdlq_mark_retryrNsM  CkkQTZS\]ffh   -(1,  KKPS^`fRg h    #m, , KK[^ikprx]y z   "#k33G!3K"LMll8<<09W3MMXXZ  O *eV 4    s%DD+DA7DDc ttjtjt |z j }t5}d}|g}|r|dz }|j||jd|d|j}dddDcic]}|dd|d d|d |d c}S#1swY.xYwcc}w) u>Quick stats — wieviele audit-events last N hours pro action.)hourszts >= ?z AND actor = ?zASELECT actor, action, status, COUNT(*) as n FROM audit_log WHERE z/ GROUP BY actor, action, status ORDER BY n DESCNr/:r0r3n) rrr+rr,rr-rappendr*fetchall)r/rPsincerwhereparamsrowsrs r audit_summaryrZsM \\(,, ')%*@ @ K K ME  Cw  % %E MM% {{OPUwW= >   (* JN NAqzl!AhK=!H+ 73 ? NN   OsAC!CC )returnzsqlite3.Connection)r[None)r%rr[r )NNNokrN)r/r r0r r1 str | Noner2r^r%rr3r r4r r5z dict | Noner[int)r) r/r r0r r%rr4r r=r_r[r_)N )r/r^rBr_r[zlist[sqlite3.Row])r)rJr_rKboolr4r r[r\)N)r/r^rPr_r[dict)__doc__ __future__rr"rr timerrrpathlibrtypingrrparentmkdirrrr'r7r<r?rCrNrZrrrms #  22 . /TD1 ! H0#           @/, " .Or