From d0faf79f6c036391567cc362d052685ed4c359e8 Mon Sep 17 00:00:00 2001
From: benbierens <thatbenbierens@gmail.com>
Date: Mon, 20 Mar 2023 15:42:42 +0100
Subject: [PATCH] Writes pod logs to separate files.

---
 TestCore/K8sManager.cs |  4 ++--
 TestCore/TestLog.cs    | 25 ++++++++++++-------------
 2 files changed, 14 insertions(+), 15 deletions(-)

diff --git a/TestCore/K8sManager.cs b/TestCore/K8sManager.cs
index 2dc8d6f..391ec4c 100644
--- a/TestCore/K8sManager.cs
+++ b/TestCore/K8sManager.cs
@@ -72,7 +72,7 @@ namespace CodexDistTests.TestCore
             WaitUntilNamespaceDeleted(client);
         }
 
-        public void FetchAllPodsLogs(Action<string, Stream> onLog)
+        public void FetchAllPodsLogs(Action<string, string, Stream> onLog)
         {
             var client = CreateClient();
             foreach (var node in activeNodes.Values)
@@ -81,7 +81,7 @@ namespace CodexDistTests.TestCore
                 foreach (var podName in node.ActivePodNames)
                 {
                     var stream = client.ReadNamespacedPodLog(podName, k8sNamespace);
-                    onLog($"{nodeDescription}:{podName}", stream);
+                    onLog(node.SelectorName, $"{nodeDescription}:{podName}", stream);
                 }
             }
         }
diff --git a/TestCore/TestLog.cs b/TestCore/TestLog.cs
index f21a619..9dea292 100644
--- a/TestCore/TestLog.cs
+++ b/TestCore/TestLog.cs
@@ -41,7 +41,6 @@ namespace CodexDistTests.TestCore
                 IncludeFullPodLogging(k8sManager);
             }
 
-            LogRaw("");
             file = null;
         }
 
@@ -52,26 +51,26 @@ namespace CodexDistTests.TestCore
             return $"{className}.{test.MethodName}";
         }
 
-        private static void LogRaw(string message)
+        private static void LogRaw(string message, string filename)
         {
-            file!.WriteRaw(message);
+            file!.WriteRaw(message, filename);
         }
 
         private static void IncludeFullPodLogging(K8sManager k8sManager)
         {
-            LogRaw("Full pod logging:");
+            Log("Full pod logging:");
             k8sManager.FetchAllPodsLogs(WritePodLog);
         }
 
-        private static void WritePodLog(string nodeDescription, Stream stream)
+        private static void WritePodLog(string id, string nodeDescription, Stream stream)
         {
-            LogRaw("---");
-            LogRaw(nodeDescription);
+            Log($"{nodeDescription} -->> {id}");
+            LogRaw(nodeDescription, id);
             var reader = new StreamReader(stream);
             var line = reader.ReadLine();
             while (line != null)
             {
-                LogRaw(line);
+                LogRaw(line, id);
                 line = reader.ReadLine();
             }
         }
@@ -79,21 +78,21 @@ namespace CodexDistTests.TestCore
 
     public class LogFile
     {
+        private readonly string filepath;
         private readonly string filename;
 
         public LogFile(string name)
         {
             var now = DateTime.UtcNow;
 
-            var filepath = Path.Join(
+            filepath = Path.Join(
                 TestLog.LogRoot,
                 $"{now.Year}-{Pad(now.Month)}",
                 Pad(now.Day));
 
             Directory.CreateDirectory(filepath);
 
-            filename = Path.Combine(filepath,
-                $"{Pad(now.Hour)}-{Pad(now.Minute)}-{Pad(now.Second)}Z_{name.Replace('.', '-')}.log");
+            filename = Path.Combine(filepath, $"{Pad(now.Hour)}-{Pad(now.Minute)}-{Pad(now.Second)}Z_{name.Replace('.', '-')}");
         }
 
         public void Write(string message)
@@ -101,11 +100,11 @@ namespace CodexDistTests.TestCore
             WriteRaw($"{GetTimestamp()} {message}");
         }
 
-        public void WriteRaw(string message)
+        public void WriteRaw(string message, string subfile = "")
         {
             try
             {
-                File.AppendAllLines(filename, new[] {  message });
+                File.AppendAllLines(filename + subfile + ".log", new[] {  message });
             }
             catch (Exception ex)
             {