history first last property; optimise imports

Author: r3w0p

bobocep/cep/engine/decider/decider.py

@@ -8,16 +8,14 @@
 """
 
 from collections import deque
-from queue import Queue
 from threading import RLock
 from typing import Tuple, Dict, List, Optional, Deque, Any
 
 from bobocep.cep.engine.decider.pubsub import BoboDeciderPublisher, \
     BoboDeciderSubscriber
 from bobocep.cep.engine.decider.run import BoboRun
 from bobocep.cep.engine.decider.runserial import BoboRunSerial
-from bobocep.cep.engine.receiver.pubsub import BoboReceiverSubscriber
-from bobocep.cep.engine.task import BoboEngineTaskError, BoboEngineTask
+from bobocep.cep.engine.task import BoboEngineTaskError
 from bobocep.cep.event import BoboHistory, BoboEvent, BoboEventSimple
 from bobocep.cep.gen import BoboGenTimestamp
 from bobocep.cep.gen.event_id import BoboGenEventID

bobocep/cep/engine/engine.py

@@ -6,26 +6,22 @@
 CEP engine.
 """
 
+from queue import Queue
 from threading import RLock
 from typing import Any, List, Optional, Tuple
-from queue import Queue
+
 from bobocep import BoboError
 from bobocep.cep.action import BoboActionHandler
 from bobocep.cep.action.handler import BoboHandlerResponse
 from bobocep.cep.engine.decider.decider import BoboDecider
 from bobocep.cep.engine.decider.pubsub import BoboDeciderSubscriber
 from bobocep.cep.engine.decider.runserial import BoboRunSerial
-from bobocep.cep.engine.forwarder.forwarder import BoboForwarder
-from bobocep.cep.engine.producer.producer import BoboProducer
 from bobocep.cep.engine.pubsub import BoboEngineSubscriber
-from bobocep.cep.engine.receiver.receiver import BoboReceiver
 from bobocep.cep.engine.receiver.validator import BoboValidator
-from bobocep.cep.event import BoboEvent, BoboEventSimple, BoboEventComplex, \
+from bobocep.cep.event import BoboEventComplex, \
     BoboEventAction
-from bobocep.cep.gen import BoboGenEventID, BoboGenTimestamp, BoboGenEvent
 from bobocep.cep.gen.data import BoboGenData
 from bobocep.cep.phenom import BoboPhenomenon
-from tests.postman.non_dist.flask_123.run import data_int
 
 _EXC_QUEUE_FULL_IN = "incoming queue is full (max size: {})"
 _EXC_QUEUE_FULL_OUT = "outgoing queue is full (max size: {})"

bobocep/cep/engine/pubsub.py

@@ -7,9 +7,6 @@
 """
 
 from abc import ABC, abstractmethod
-from typing import Any
-
-from bobocep.cep.event import BoboEvent
 
 
 class BoboEngineSubscriber(ABC):

bobocep/cep/engine/receiver/pubsub.py

@@ -9,8 +9,6 @@
 from abc import ABC, abstractmethod
 from typing import Any
 
-from bobocep.cep.event import BoboEvent
-
 
 class BoboReceiverSubscriber(ABC):
     """

bobocep/cep/event/history.py

@@ -61,6 +61,22 @@ def events(self) -> Dict[str, List[BoboEvent]]:
 
         return eventscopy
 
+    @property
+    def first(self) -> Optional[BoboEvent]:
+        """
+        :return: The BoboEvent with the oldest timestamp,
+            if there is at least one BoboEvent in the history.
+        """
+        return self._first
+
+    @property
+    def last(self) -> Optional[BoboEvent]:
+        """
+        :return: The BoboEvent with the most recent timestamp,
+            if there is at least one BoboEvent in the history.
+        """
+        return self._last
+
     def size(self) -> int:
         """
         :return: The total number of history events across all groups.
@@ -97,20 +113,6 @@ def group(self, group: str) -> Tuple[BoboEvent, ...]:
         else:
             return tuple()
 
-    def first(self) -> Optional[BoboEvent]:
-        """
-        :return: The BoboEvent with the oldest timestamp,
-            if there is at least one BoboEvent in the history.
-        """
-        return self._first
-
-    def last(self) -> Optional[BoboEvent]:
-        """
-        :return: The BoboEvent with the most recent timestamp,
-            if there is at least one BoboEvent in the history.
-        """
-        return self._last
-
     def to_json_dict(self) -> dict:
         """
         :return: A JSON `dict` representation of the history.

bobocep/cep/gen/data.py

@@ -10,6 +10,7 @@
 from threading import RLock
 from types import MethodType
 from typing import Optional, Callable, Any
+
 from bobocep.cep.gen.timestamp import BoboGenTimestampEpoch
 
 

bobocep/cep/phenom/pattern/predicate.py

@@ -13,7 +13,7 @@
 from typing import Callable, Any
 
 from bobocep import BoboError
-from bobocep.cep.event import BoboEvent, BoboHistory
+from bobocep.cep.event import BoboHistory
 
 EXC_INVALID_PARAM = "call must have {} parameters, found {}"
 LEN_PARAM_CALL = 3

bobocep/setup/simple.py

@@ -11,7 +11,8 @@
 from bobocep.cep.action.handler import BoboActionHandler
 from bobocep.cep.engine.decider.decider import BoboDecider
 from bobocep.cep.engine.engine import BoboEngine
-from bobocep.cep.engine.receiver.validator import BoboValidator, BoboValidatorJSONable
+from bobocep.cep.engine.receiver.validator import BoboValidator, \
+    BoboValidatorJSONable
 from bobocep.cep.gen.data import BoboGenData
 from bobocep.cep.gen.event_id import BoboGenEventIDUnique
 from bobocep.cep.gen.timestamp import BoboGenTimestampEpoch