openai4s/storage/shares.py

• SharesRepository · class · L17-L189 — class SharesRepository
• init · method · L20-L29 — def init( self, connection: sqlite3.Connection, lock: Any, *, clock_ms: Callable[[], int], ) -> None
• get · method · L32-L37 — def get(self, share_id: str) -> dict | None
• active_for_frame · method · L39-L47 — def active_for_frame(self, root_frame_id: str) -> dict | None
• list_for_frame · method · L49-L56 — def list_for_frame(self, root_frame_id: str) -> list[dict]
• list_all · method · L58-L64 — def list_all(self, *, include_revoked: bool = False) -> list[dict]
• list_active · method · L66-L71 — def list_active(self) -> list[dict]
• begin_publish · method · L74-L120 — def begin_publish( self, *, share_id: str, root_frame_id: str, title: str | None, pending_snapshot_id: str, expires_at: int | None = None, ) -> dict
• list_expired · method · L122-L129 — def list_expired(self, now_ms: int) -> list[dict]
• mark_ready · method · L131-L156 — def mark_ready( self, share_id: str, *, snapshot_id: str, bundle_sha256: str, bundle_size: int, projection_id: str, counts: dict | None, ) -> dict | None
• mark_failed · method · L158-L163 — def mark_failed(self, share_id: str) -> None
• mark_revoked · method · L165-L171 — def mark_revoked(self, share_id: str) -> None
• delete · method · L173-L174 — def delete(self, share_id: str) -> None
• _execute · method · L176-L179 — def _execute(self, sql: str, params: tuple = ()) -> None
• _row · method · L182-L189 — def _row(row: sqlite3.Row) -> dict