Introducing Analyzer (#32)

* Adding Analyzer class and main function

* Adding EchoAnalyzer

* Adding abstractmethod annotation to Analyzer methods

---------

Co-authored-by: Ben Rady <[email protected]>

src/alogamous/__main__.py

@@ -0,0 +1,5 @@
+import sys
+
+from alogamous import analyzer, echo_analyzer
+
+analyzer.analyze_log_stream([echo_analyzer.EchoAnalyzer()], sys.stdin, sys.stdout)

src/alogamous/analyzer.py

@@ -0,0 +1,19 @@
+from abc import ABC, abstractmethod
+
+
+class Analyzer(ABC):
+    @abstractmethod
+    def read_log_line(self, line):
+        pass
+
+    @abstractmethod
+    def report(self, out_stream):
+        pass
+
+
+def analyze_log_stream(analyzers, in_stream, out_stream):
+    for line in in_stream:
+        for analyzer in analyzers:
+            analyzer.read_log_line(line.rstrip())
+    for analyzer in analyzers:
+        analyzer.report(out_stream)

src/alogamous/echo_analyzer.py

@@ -0,0 +1,12 @@
+from alogamous import analyzer
+
+
+class EchoAnalyzer(analyzer.Analyzer):
+    def __init__(self):
+        self.lines = []
+
+    def read_log_line(self, line):
+        self.lines.append(line)
+
+    def report(self, out_stream):
+        out_stream.write("\n".join(self.lines))

tests/echo_analyzer_test.py

@@ -0,0 +1,17 @@
+import io
+
+from alogamous import analyzer, echo_analyzer
+
+
+def test_echo_lines():
+    in_stream = io.StringIO("""line1
+        line2
+        line3""")
+    out_stream = io.StringIO()
+    analyzer.analyze_log_stream([echo_analyzer.EchoAnalyzer()], in_stream, out_stream)
+    assert (
+        out_stream.getvalue()
+        == """line1
+        line2
+        line3"""
+    )