15 lines
899 B
Python
15 lines
899 B
Python
from __future__ import annotations
|
|
from datetime import datetime, timedelta, timezone
|
|
|
|
class GovernedPublisher:
|
|
def __init__(self, store, audit, retention_days=30): self.store, self.audit, self.retention_days = store, audit, retention_days
|
|
def publish(self, batch):
|
|
if any(d.tenant_id != batch.tenant_id for d in batch.documents): raise PermissionError('tenant mismatch')
|
|
self.store.upsert(batch.documents)
|
|
self.audit.append({'tenant_id': batch.tenant_id, 'run_id': batch.run_id, 'action': 'publish', 'count': len(batch.documents), 'at': datetime.now(timezone.utc).isoformat()})
|
|
def purge_expired_tombstones(self, docs):
|
|
cutoff = datetime.now(timezone.utc) - timedelta(days=self.retention_days)
|
|
ids = [d.document_id for d in docs if d.deleted and d.updated_at < cutoff]
|
|
if ids: self.store.delete(ids, docs[0].tenant_id)
|
|
return ids
|