event.py 1.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960
  1. from dataclasses import dataclass
  2. from datetime import datetime
  3. from enum import Enum
  4. class EventSource(str, Enum):
  5. AGENT = 'agent'
  6. USER = 'user'
  7. @dataclass
  8. class Event:
  9. @property
  10. def message(self) -> str | None:
  11. if hasattr(self, '_message'):
  12. return self._message # type: ignore[attr-defined]
  13. return ''
  14. @property
  15. def id(self) -> int:
  16. if hasattr(self, '_id'):
  17. return self._id # type: ignore[attr-defined]
  18. return -1
  19. @property
  20. def timestamp(self):
  21. if hasattr(self, '_timestamp') and isinstance(self._timestamp, str):
  22. return self._timestamp
  23. @timestamp.setter
  24. def timestamp(self, value: datetime) -> None:
  25. if isinstance(value, datetime):
  26. self._timestamp = value.isoformat()
  27. @property
  28. def source(self) -> EventSource | None:
  29. if hasattr(self, '_source'):
  30. return self._source # type: ignore[attr-defined]
  31. return None
  32. @property
  33. def cause(self) -> int | None:
  34. if hasattr(self, '_cause'):
  35. return self._cause # type: ignore[attr-defined]
  36. return None
  37. @property
  38. def timeout(self) -> int | None:
  39. if hasattr(self, '_timeout'):
  40. return self._timeout # type: ignore[attr-defined]
  41. return None
  42. @timeout.setter
  43. def timeout(self, value: int | None) -> None:
  44. self._timeout = value
  45. # Check if .blocking is an attribute of the event
  46. if hasattr(self, 'blocking'):
  47. # .blocking needs to be set to True if .timeout is set
  48. self.blocking = True