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

"""Governed-persistence repository for parsed justificante metadata.

Justificante metadata captures AEAT verification identifiers, operator
identity, timestamps, and verification URLs. The structured metadata is
stored as encrypted byte objects in the primary SQL backend at
:class:`~core.classification.policies.SensitivityClass` ``AUDIT``
sensitivity; no plaintext metadata JSON or envelope file lands on disk.

This concrete repository is the persistence adapter for the
:class:`~domain.justificante.schema.Justificante` audit-sink record. It lives in
the persistence adapter (not in :mod:`~domain.justificante`) because its
base :class:`~adapters.persistence.storage.envelope.secure_bound_repository.SecureBoundRepository` is
SQL/crypto-coupled; the domain package owns the pure record and the
:class:`~domain.justificante.protocols.JustificanteRepositoryProtocol` port.

See Also:
    :class:`~domain.justificante.schema.Justificante`
        Payload model encrypted by this repository.
    :class:`~adapters.persistence.storage.sql.secure_objects.SecureObjectRepository`
        SQL object store underlying the bound repository.
"""

from __future__ import annotations

from collections.abc import Iterator
from typing import ClassVar, override

from ....core.classification.policies import SensitivityClass
from ....domain.justificante.schema import Justificante
from ..storage.envelope.secure_bound_repository import SecureBoundRepository
from ..storage.secure_object_namespaces import JUSTIFICANTE_METADATA_NAMESPACE




class JustificanteRepository(SecureBoundRepository[Justificante]):
    """Encrypted AUDIT repository for :class:`Justificante` metadata.

    The :class:`~adapters.persistence.storage.envelope.secure_bound_repository.SecureBoundRepository` base
    stores each :class:`Justificante` in a
    :class:`~adapters.persistence.storage.envelope.contract.Envelope` row under the AUDIT
    justificante-metadata namespace. The AEAT CSV is the natural key, so list
    and iteration APIs expose persisted receipt metadata without reading
    plaintext metadata from disk.
    """

    namespace: ClassVar[str] = JUSTIFICANTE_METADATA_NAMESPACE.namespace
    sensitivity: ClassVar[SensitivityClass] = JUSTIFICANTE_METADATA_NAMESPACE.sensitivity
    schema_version: ClassVar[int] = JUSTIFICANTE_METADATA_NAMESPACE.schema_version



    @override
    @classmethod
    def payload_model(cls) -> type[Justificante]:
        return Justificante




    @override
    def extract_identifier(self, payload: Justificante) -> str:
        return payload.csv




    def iter_justificantes(self) -> Iterator[Justificante]:
        """Yield every persisted justificante, in lexicographic CSV order.

        Returns:
            Iterator over :class:`Justificante` records.
        """
        yield from sorted(self.iter_records(), key=self.extract_identifier)




__all__ = [
    "JustificanteRepository",
]