Merge pull request #15 from mr-raccoon-97/main

Add message class

pybondi/publisher.py

@@ -1,8 +1,24 @@
 from typing import Any
 from typing import Callable
+from datetime import datetime, timezone
 from collections import deque
+from dataclasses import dataclass
 from abc import ABC, abstractmethod
 
+@dataclass
+class Message:
+    '''
+    A message to be published by the publisher.
+
+    Attributes:
+        sender: The identifier of the entitiy that sends the message.
+        payload: The payload of the message.
+    '''
+    sender: str
+    payload: Any
+    timestamp: datetime = datetime.now(timezone.utc)
+
+
 class Base(ABC):
     """
     An abstract base class for a publisher.
@@ -22,7 +38,7 @@ class Base(ABC):
     """
 
     @abstractmethod
-    def publish(self, topic: str, message: Any) -> None:
+    def publish(self, topic: str, message: Message) -> None:
         """
         Publishes a message to a topic.
 
@@ -74,7 +90,7 @@ def subscribe(self, topic: str, subscriber: Callable):
         '''
         self.subscribers.setdefault(topic, []).append(subscriber)
 
-    def publish(self, topic: str, message: Any):
+    def publish(self, topic: str, message: Message):
         '''
         Receives a message from the publisher. 
         '''

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "pybondi"
-version = "0.3.1"
+version = "0.3.2"
 description = "A lightweight library for creating event driven systems using domain driven design."
 authors = ["Eric Cardozo <[email protected]>"]
 license = "MIT"