Tested correlated job log view. Seems to work but the log chopping is still worse

Author: michelvocks

Diff for: frontend/client/views/pipeline/detail.vue

@@ -350,7 +350,13 @@ export default {
     },
 
     jobLog () {
-      this.$router.push({path: '/pipeline/log', query: { pipelineid: this.pipelineID, runid: this.runID, jobid: this.job.internalID }})
+      var jobid = null
+      if (this.job) {
+        jobid = this.job.intervalID
+      }
+
+      // Route
+      this.$router.push({path: '/pipeline/log', query: { pipelineid: this.pipelineID, runid: this.runID, jobid: jobid }})
     },
 
     startPipeline (pipelineid) {

Diff for: frontend/client/views/pipeline/log.vue

@@ -67,14 +67,29 @@ export default {
         })
         .then(response => {
           if (response.data) {
-            // We add the received log
-            this.logText += response.data.log
-
-            // LF does not work for HTML. Replace with <br />
-            this.logText = this.logText.replace(/\n/g, '<br />')
-
-            // Set the new start position defined by return value
-            this.startPos = response.data.start
+            // Check if we got multiple objects
+            var finished = true
+            for (let i = 0, l = response.data.length; i < l; i++) {
+              // We add the received log
+              this.logText += response.data[i].log
+
+              // LF does not work for HTML. Replace with <br />
+              this.logText = this.logText.replace(/\n/g, '<br />')
+
+              // Set the new start position defined by return value
+              this.startPos = response.data[i].start
+
+              // Job not finished?
+              if (!response.data[i].finished) {
+                finished = false
+              }
+            }
+
+            // All jobs finished. Stop interval.
+            if (finished) {
+              this.jobRunning = false
+              clearInterval(this.intervalID)
+            }
           }
         })
         .catch((error) => {

Diff for: handlers/pipeline_run.go

@@ -126,6 +126,11 @@ func GetJobLogs(c echo.Context) error {
 					return c.String(http.StatusBadRequest, err.Error())
 				}
 
+				// Check if job is finished
+				if job.Status == gaia.JobSuccess || job.Status == gaia.JobFailed {
+					jL.Finished = true
+				}
+
 				return c.JSON(http.StatusOK, *jL)
 			}
 		}
@@ -148,6 +153,11 @@ func GetJobLogs(c echo.Context) error {
 			return c.String(http.StatusBadRequest, err.Error())
 		}
 
+		// Check if job is finished
+		if job.Status == gaia.JobSuccess || job.Status == gaia.JobFailed {
+			jL.Finished = true
+		}
+
 		jobs = append(jobs, *jL)
 	}