services/postprocessing/registry.py

"""Registry for building the post-processing orchestrator."""
from config import settings
from .base import PostProcessingOrchestrator
from .processors.carbon_impact import CarbonImpactProcessor
from .processors.pricing import PricingProcessor
from .processors.equivalences import EquivalencesProcessor


ALL = {
    "carbon_impact": CarbonImpactProcessor(),
    "pricing": PricingProcessor(),
    "equivalences": EquivalencesProcessor(),
}


def build_orchestrator() -> PostProcessingOrchestrator:
    enabled = getattr(settings, "postprocessors_enabled", [
        "carbon_impact",
        "pricing",
        "equivalences",
    ])
    processors = [ALL[name] for name in enabled if name in ALL]
    return PostProcessingOrchestrator(processors)