added a prev_bundle field in knowledge objects to allow access to the previous version of the bundle after an update happens

Author: lukvmil

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "koi-net"
-version = "2.0.4"
+version = "2.1.0-beta.1"
 description = "Implementation of KOI-net framework in Python"
 maintainers = [
     { name = "Luke Miller", email = "luke@block.science" }

src/koi_net/components/pipeline.py

@@ -175,10 +175,15 @@ def process(self, kobj: KnowledgeObject):
         kobj = self.call_handler_chain(HandlerType.Bundle, kobj)
         if kobj is STOP_CHAIN: return
 
-        if kobj.normalized_event_type in (EventType.UPDATE, EventType.NEW):
+        if kobj.normalized_event_type == EventType.NEW:
             self.log.info(f"Writing to cache: {kobj!r}")
             self.cache.write(kobj.bundle)
 
+        elif kobj.normalized_event_type == EventType.UPDATE:
+            self.log.info(f"Writing to cache: {kobj!r}")
+            kobj.prev_bundle = self.cache.read(kobj.rid)
+            self.cache.write(kobj.bundle)
+            
         elif kobj.normalized_event_type == EventType.FORGET:
             self.log.info(f"Deleting from cache: {kobj!r}")
             self.cache.delete(kobj.rid)

src/koi_net/protocol/knowledge_object.py

@@ -33,6 +33,7 @@ class KnowledgeObject(BaseModel):
     normalized_event_type: EventType | None = None
     source: KoiNetNode | None = None
     network_targets: set[KoiNetNode] = set()
+    prev_bundle: Bundle | None = None
 
     def __repr__(self):
         return f"<KObj '{self.rid}' event type: '{self.event_type}' -> '{self.normalized_event_type}', source: '{self.source}'>"