Source code for cadrumo.application.aggregation._modelo_bindings_support

"""Shared internal support for modelo-binding source resolvers.

Core types:
:class:`~cadrumo.domain.calculations.registry.schema.ModeloRevision`.
"""

from __future__ import annotations

from typing import Final

from ...core.aggregation import BindingSourceKind
from ...domain.calculations.registry.schema import ModeloRevision
from ...domain.invoices.errors import InvoicePersistenceError
from ...domain.transactions.errors import TransactionPersistenceError
from ...domain.usage_ratios.errors import UsageRatioPersistenceError
from ..persistence_errors import PersistenceDegradationError
from .source_mesh import CalculationSourceResolution

STORAGE_DEGRADATION_ERRORS: Final[tuple[type[Exception], ...]] = (
    PersistenceDegradationError,
    InvoicePersistenceError,
    TransactionPersistenceError,
    UsageRatioPersistenceError,
)




def revision_has_binding_source(revision: ModeloRevision, source: str) -> bool:
    return any(binding.source == source for binding in revision.bindings)





def empty_source_resolution(
    resolver_id: str,
    owned_sources: tuple[BindingSourceKind, ...],
) -> CalculationSourceResolution:
    return CalculationSourceResolution(resolver_id=resolver_id, owned_sources=owned_sources)