Source code for ascetic_ddd.seedwork.domain.aggregate.persistent_domain_event_exporter

from ascetic_ddd.seedwork.domain.aggregate.event_meta import EventMeta
from ascetic_ddd.seedwork.domain.aggregate.event_meta_exporter import EventMetaExporter
from ascetic_ddd.seedwork.domain.aggregate.persistent_domain_event import IPersistentDomainEventExporter

__all__ = ("PersistentDomainEventExporter",)



[docs]
class PersistentDomainEventExporter(IPersistentDomainEventExporter):
    def __init__(self) -> None:
        self.data = {}


[docs]
    def set_event_type(self, value: str) -> None:
        self.data["event_type"] = value



[docs]
    def set_event_version(self, value: int) -> None:
        self.data["event_version"] = value



[docs]
    def set_event_meta(self, meta: EventMeta) -> None:
        exporter = EventMetaExporter()
        meta.export(exporter)
        self.data["event_meta"] = exporter.data



[docs]
    def set_aggregate_version(self, value: int) -> None:
        self.data["aggregate_version"] = value