Source code for eventscore.core.serializers

import json

from eventscore.core.abstract import IEventSerializer
from eventscore.core.types import Event



[docs]
class EventSerializer(IEventSerializer[bytes, bytes]):

[docs]
    def encode(self, event: Event) -> bytes:
        return json.dumps(event.asdict()).encode()



[docs]
    def decode(self, event: bytes) -> Event:
        return Event.fromdict(json.loads(event.decode()))