changelog

src/main/kotlin/com/dsoftware/ghmanager/api/GetJobLogRequest.kt

@@ -9,6 +9,7 @@ import java.io.BufferedReader
 import java.io.IOException
 import java.io.InputStream
 import java.io.InputStreamReader
+import java.text.ParseException
 import java.text.SimpleDateFormat
 import java.util.Date
 import java.util.TimeZone
@@ -44,17 +45,20 @@ class GetJobLogRequest(private val job: Job) : GithubApiRequest.Get<String>(job.
         var currStep = 1
         try {
             val reader = BufferedReader(InputStreamReader(inputStream))
-            val lines = reader.readLines()
+            val lines = reader.lines()
             for (line in lines) {
                 ++lineNum
                 if (line.length < 29) {
                     contentBuilders.getOrDefault(currStep, StringBuilder()).append(line + "\n")
                     continue
                 }
                 val datetimeStr = line.substring(0, 23)
-                val time = formatter.parse(datetimeStr)
-                currStep = findStep(currStep, time)
-
+                try {
+                    val time = formatter.parse(datetimeStr)
+                    currStep = findStep(currStep, time)
+                } catch (e: ParseException) {
+                    LOG.warn("Failed to parse date from log line $lineNum: $line, $e")
+                }
                 contentBuilders.getOrPut(currStep) { StringBuilder(400_000) }.append(line + "\n")
             }
         } catch (e: IOException) {

src/main/kotlin/com/dsoftware/ghmanager/api/model/RunModel.kt

@@ -1,23 +1,9 @@
 package com.dsoftware.ghmanager.api.model
 
 import com.fasterxml.jackson.annotation.JsonFormat
-import kotlinx.serialization.Serializable
 import java.util.Date
 
 
-data class WorkflowTypes(
-    val totalCount: Int,
-    val workflows: List<WorkflowType> = emptyList()
-)
-
-@Serializable
-data class WorkflowType(
-    val id: Long,
-    val name: String,
-    val path: String,
-    val state: String,
-)
-
 data class PullRequest(
     val id: Int,
     val number: Int,

src/main/kotlin/com/dsoftware/ghmanager/api/model/WorkflowTypes.kt

@@ -0,0 +1,16 @@
+package com.dsoftware.ghmanager.api.model
+
+import kotlinx.serialization.Serializable
+
+data class WorkflowTypes(
+    val totalCount: Int,
+    val workflows: List<WorkflowType> = emptyList()
+)
+
+@Serializable
+data class WorkflowType(
+    val id: Long,
+    val name: String,
+    val path: String,
+    val state: String,
+)

src/test/kotlin/com/dsoftware/ghmanager/TestGetJobLogRequest.kt

@@ -53,4 +53,18 @@ class TestGetJobLogRequest : TestCase() {
         assertTrue(log.contains("[31m---- Step   3: step 3 (failed) ----"))
     }
 
+    fun testBadLogStructure() {
+        // arrange
+        val wfJobsJson = TestGetJobLogRequest::class.java.getResource("/wf-run-jobs.json")!!.readText()
+        val wfJobs: WorkflowRunJobs = mapper.readValue(wfJobsJson)
+        val job = wfJobs.jobs.first()
+        val line="2024-02-11T18:09:51.DDDDDDDZ LTS\n"
+        //act
+        val log = GetJobLogRequest(job).extractJobLogFromStream(line.byteInputStream())
+
+        //assert
+        assertTrue(log.contains(line))
+
+    }
+
 }