Merge pull request WebOfTrust#760 from SmithSamuelM/main

added streaming.py and test_streaming.py preliminary setup for annota…

src/keri/core/coring.py

@@ -4797,73 +4797,6 @@ def _satisfy_weighted(self, indices):
 
 
 
-class Streamer:
-    """
-    Streamer is CESR sniffable stream class
-
-
-    Has the following public properties:
-
-    Properties:
-
-
-    Methods:
-
-
-    Hidden:
-
-
-
-    """
-
-    def __init__(self, stream):
-        """Initialize instance
-
-
-        Parameters:
-            stream (bytes | bytearray): sniffable CESR stream
-
-
-        """
-        self._stream = bytes(stream)
-
-
-    @property
-    def stream(self):
-        """stream property getter
-        """
-        return self._stream
-
-    @property
-    def text(self):
-        """expanded stream as qb64 text
-        Returns:
-           stream (bytes): expanded text qb64 version of stream
-
-        """
-        return self._stream
-
-    @property
-    def binary(self):
-        """compacted stream as qb2 binary
-        Returns:
-           stream (bytes): compacted binary qb2 version of stream
-
-        """
-        return self._stream
-
-    @property
-    def texter(self):
-        """expanded stream as Texter instance
-        Returns:
-           texter (Texter): Texter primitive of stream suitable wrapping
-
-        """
-        return self._stream
-
-
-
-
 class Sadder:
     """
     Sadder is self addressed data (SAD) serializer-deserializer class

src/keri/core/streaming.py

@@ -0,0 +1,97 @@
+# -*- coding: utf-8 -*-
+"""
+keri.core.streaming module
+
+Provides support for Streamer and Annotater
+"""
+
+
+from typing import NamedTuple
+from collections import namedtuple
+
+from .. import kering
+
+from .. import help
+
+
+from . import coring
+
+
+def annot():
+    """Annotate CESR stream"""
+
+
+
+def denot():
+    """De-annotate CESR stream"""
+
+
+
+class Streamer:
+    """
+    Streamer is CESR sniffable stream class
+
+
+    Has the following public properties:
+
+    Properties:
+
+
+    Methods:
+
+
+    Hidden:
+
+
+
+    """
+
+    def __init__(self, stream):
+        """Initialize instance
+
+
+        Parameters:
+            stream (bytes | bytearray): sniffable CESR stream
+
+
+        """
+        self._stream = bytes(stream)
+
+
+    @property
+    def stream(self):
+        """stream property getter
+        """
+        return self._stream
+
+    @property
+    def text(self):
+        """expanded stream as qb64 text
+        Returns:
+           stream (bytes): expanded text qb64 version of stream
+
+        """
+        return self._stream
+
+    @property
+    def binary(self):
+        """compacted stream as qb2 binary
+        Returns:
+           stream (bytes): compacted binary qb2 version of stream
+
+        """
+        return self._stream
+
+    @property
+    def texter(self):
+        """expanded stream as Texter instance
+        Returns:
+           texter (Texter): Texter primitive of stream suitable wrapping
+
+        """
+        return self._stream
+
+
+
+
+

tests/core/test_serdering.py

@@ -3323,6 +3323,8 @@ def test_cesr_native_dumps():
 
     """End Test"""
 
+
+
 def test_cesr_native_dumps_hby():
     """Test Serder._dumps with habery"""
 

tests/core/test_streaming.py

@@ -0,0 +1,37 @@
+# -*- coding: utf-8 -*-
+"""
+tests.core.test_streaming module
+
+"""
+
+
+import pytest
+
+
+from keri import kering
+
+from keri.help import helping
+
+from keri.core import (Matter, )
+
+
+from keri.core import streaming
+from keri.core.streaming import (annot, denot, Streamer)
+
+
+def test_annot():
+    """Test annot function  Annotate"""
+
+    """End Test"""
+
+def test_streamer():
+    """Test streamer instance"""
+
+    """End Test"""
+
+if __name__ == "__main__":
+    test_annot()
+    test_streamer()
+
+
+