feat(watcher): Include failed containers in message

Author: AdrianoKF

watcher/main.go

@@ -142,19 +142,27 @@ func handleUpdate(obj interface{}, newObj interface{}) {
 			buf := new(strings.Builder)
 			buf.WriteString("\n")
 
-			buf.WriteString("*Failed Pods*\n\n")
-
 			for _, pod := range pods {
+				// Ignore non-failed pods
 				if pod.Status.Phase != corev1.PodFailed {
 					continue
 				}
+
 				logs, _ := getPodLogs(pod)
 				fmt.Fprintf(buf, "Pod `%s`\n```\n%s\n```\n\n", pod.Name, logs)
 
+				// Log all terminated containers
+				for _, cstate := range pod.Status.ContainerStatuses {
+					containerId := cstate.Name
+					exitCode := cstate.State.Terminated.ExitCode
+					reason := cstate.State.Terminated.Reason
+					time := cstate.State.Terminated.FinishedAt
+					fmt.Fprintf(buf, "Container `%s` exited at %s with code `%d` (reason `%s`)\n", containerId, time, exitCode, reason)
+				}
 			}
 			body = buf.String()
 		} else {
-			subject = "Job completed"
+			subject = "Job failed"
 			body = formatJob(job, false)
 		}
 
@@ -202,7 +210,7 @@ func getPodLogs(pod corev1.Pod) (string, error) {
 	if err != nil {
 		return "", nil
 	}
-	return buf.String(), nil
+	return strings.TrimSpace(buf.String()), nil
 }
 
 func collectJobOutputs(job *batchv1.Job) (map[string]string, error) {