Example 16.7 - LoggingRearrangedPipeline1

Three-actor logging pipeline without sanitization

amm TestLoggingPipeline.sc

Upstream Example: 16.6 - LoggingLongPipeline:

Diff:

diff --git a/16.6 - LoggingLongPipeline/LoggingPipeline.sc b/16.7 - LoggingRearrangedPipeline1/LoggingPipeline.sc
index 8b8abf9..dafa0c8 100644
--- a/16.6 - LoggingLongPipeline/LoggingPipeline.sc	
+++ b/16.7 - LoggingRearrangedPipeline1/LoggingPipeline.sc	
@@ -5,6 +5,5 @@ implicit val cc = new castor.Context.Test()
 val diskActor = new DiskActor(os.pwd / "log.txt")
 val uploadActor = new UploadActor("https://httpbin.org/post")
 val base64Actor = new Base64Actor(new castor.SplitActor(diskActor, uploadActor))
-val sanitizeActor = new SanitizeActor(base64Actor)
 
-val logger = sanitizeActor
+val logger = base64Actor
diff --git a/16.6 - LoggingLongPipeline/TestLoggingPipeline.sc b/16.7 - LoggingRearrangedPipeline1/TestLoggingPipeline.sc
index 15c06b8..d66276d 100644
--- a/16.6 - LoggingLongPipeline/TestLoggingPipeline.sc	
+++ b/16.7 - LoggingRearrangedPipeline1/TestLoggingPipeline.sc	
@@ -15,5 +15,6 @@ def decodeFile(p: os.Path) = {
   os.read.lines(p).map(s => new String(java.util.Base64.getDecoder.decode(s)))
 }
 
-assert(decodeFile(os.pwd / "log.txt-old") == Seq("Comes from liquids from my udder"))
-assert(decodeFile(os.pwd / "log.txt") == Seq("I am cow<redacted>", "Hear me moo, moooo"))
+println(decodeFile(os.pwd / "log.txt-old"))
+assert(decodeFile(os.pwd / "log.txt-old") == Seq("I am cow1234567887654321"))
+assert(decodeFile(os.pwd / "log.txt") == Seq("Hear me moo, moooo"))