Source code for cadrumo.adapters.persistence.profile.iva_remote_state

"""Encrypted persistence adapter for live IVA acquisition manifests.

Core types:
:class:`~cadrumo.adapters.persistence.storage.sql.secure_objects.SecureObjectRepository`.
"""

from __future__ import annotations

from typing import TYPE_CHECKING, ClassVar, override

from pydantic import BaseModel

from ....application.live.remote_state_models import IvaRemoteStateAcquisitionManifest
from ..storage.envelope.secure_bound_repository import SecureBoundRepository
from ..storage.runtime_repository import secure_object_repository_for_active_bucket
from ..storage.secure_object_namespaces import LIVE_IVA_REMOTE_STATE_ACQUISITIONS_NAMESPACE

if TYPE_CHECKING:
    from ..storage.sql.secure_objects import SecureObjectRepository



[docs]
class IvaRemoteStateAcquisitionManifestRepository(SecureBoundRepository[IvaRemoteStateAcquisitionManifest]):
    """Persist redacted live IVA acquisition manifests in the active bucket."""

    namespace: ClassVar[str] = LIVE_IVA_REMOTE_STATE_ACQUISITIONS_NAMESPACE.namespace
    sensitivity: ClassVar = LIVE_IVA_REMOTE_STATE_ACQUISITIONS_NAMESPACE.sensitivity
    schema_version: ClassVar[int] = LIVE_IVA_REMOTE_STATE_ACQUISITIONS_NAMESPACE.schema_version
    payload_type: ClassVar[type[BaseModel]] = IvaRemoteStateAcquisitionManifest

    def __init__(self, *, objects: SecureObjectRepository | None = None) -> None:
        """Bind the active-bucket secure-object repository."""
        super().__init__(objects=objects or secure_object_repository_for_active_bucket())


[docs]
    @override
    def extract_identifier(self, payload: IvaRemoteStateAcquisitionManifest) -> str:
        return payload.acquisition_id




__all__ = ["IvaRemoteStateAcquisitionManifestRepository"]