Determine app health status for plugin architecture

pkg/app/pipedv1/livestatereporter/livestatereporter.go

@@ -142,8 +142,7 @@ func (pr *pluginReporter) flushSnapshots(ctx context.Context) {
 			Kind:                 app.Kind,
 			ApplicationLiveState: res.GetApplicationLiveState(),
 		}
-		// TODO: Implement DetermineAppHealthStatus for the case of plugin architecture.
-		snapshot.DetermineAppHealthStatus()
+		snapshot.DetermineApplicationHealthStatus()
 
 		if _, err := pr.apiClient.ReportApplicationLiveState(ctx, &pipedservice.ReportApplicationLiveStateRequest{
 			Snapshot: snapshot,

pkg/model/application_live_state.go

@@ -144,3 +144,38 @@ func (s *ApplicationLiveStateSnapshot) determineLambdaAppHealthStatus() {
 	}
 	s.HealthStatus = ApplicationLiveStateSnapshot_HEALTHY
 }
+
+// DetermineApplicationHealthStatus updates the health status of the application based on the health status of its resources.
+func (s *ApplicationLiveStateSnapshot) DetermineApplicationHealthStatus() {
+	app := s.ApplicationLiveState
+	if app == nil {
+		s.HealthStatus = ApplicationLiveStateSnapshot_UNKNOWN
+		return
+	}
+
+	unhealthy := false
+	unknown := false
+
+	for _, r := range app.Resources {
+		if r.HealthStatus == ResourceState_UNHEALTHY {
+			unhealthy = true
+		}
+
+		if r.HealthStatus == ResourceState_UNKNOWN {
+			unknown = true
+		}
+	}
+
+	s.HealthStatus = ApplicationLiveStateSnapshot_HEALTHY
+
+	// prioritize unhealthy over unknown when these two statuses are both set.
+	if unhealthy {
+		s.HealthStatus = ApplicationLiveStateSnapshot_UNHEALTHY
+		return
+	}
+
+	if unknown {
+		s.HealthStatus = ApplicationLiveStateSnapshot_UNKNOWN
+		return
+	}
+}

pkg/model/application_live_state.proto

@@ -29,6 +29,7 @@ message ApplicationLiveStateSnapshot {
         UNKNOWN = 0;
         HEALTHY = 1;
         OTHER = 2;
+        UNHEALTHY = 3;
     }
     string application_id = 1 [(validate.rules).string.min_len = 1];
     string piped_id = 3 [(validate.rules).string.min_len = 1];

pkg/model/application_live_state_test.go

@@ -168,3 +168,78 @@ func TestApplicationLiveStateSnapshot_DetermineAppHealthStatus(t *testing.T) {
 		})
 	}
 }
+
+func TestApplicationLiveStateSnapshot_DetermineApplicationHealthStatus(t *testing.T) {
+	testcases := []struct {
+		name     string
+		snapshot *ApplicationLiveStateSnapshot
+		want     ApplicationLiveStateSnapshot_Status
+	}{
+		{
+			name: "healthy: all resources are healthy",
+			snapshot: &ApplicationLiveStateSnapshot{
+				ApplicationLiveState: &ApplicationLiveState{
+					Resources: []*ResourceState{
+						{HealthStatus: ResourceState_HEALTHY},
+						{HealthStatus: ResourceState_HEALTHY},
+					},
+				},
+			},
+			want: ApplicationLiveStateSnapshot_HEALTHY,
+		},
+		{
+			name: "healthy: no resources",
+			snapshot: &ApplicationLiveStateSnapshot{
+				ApplicationLiveState: &ApplicationLiveState{},
+			},
+			want: ApplicationLiveStateSnapshot_HEALTHY,
+		},
+		{
+			name: "unhealthy: one of the resources is unhealthy",
+			snapshot: &ApplicationLiveStateSnapshot{
+				ApplicationLiveState: &ApplicationLiveState{
+					Resources: []*ResourceState{
+						{HealthStatus: ResourceState_HEALTHY},
+						{HealthStatus: ResourceState_UNHEALTHY},
+					},
+				},
+			},
+			want: ApplicationLiveStateSnapshot_UNHEALTHY,
+		},
+		{
+			name: "unhealthy: prioritize unhealthy over unknown",
+			snapshot: &ApplicationLiveStateSnapshot{
+				ApplicationLiveState: &ApplicationLiveState{
+					Resources: []*ResourceState{
+						{HealthStatus: ResourceState_UNKNOWN},
+						{HealthStatus: ResourceState_UNHEALTHY},
+					},
+				},
+			},
+			want: ApplicationLiveStateSnapshot_UNHEALTHY,
+		},
+		{
+			name: "unknown: one of the resources is unknown",
+			snapshot: &ApplicationLiveStateSnapshot{
+				ApplicationLiveState: &ApplicationLiveState{
+					Resources: []*ResourceState{
+						{HealthStatus: ResourceState_HEALTHY},
+						{HealthStatus: ResourceState_UNKNOWN},
+					},
+				},
+			},
+			want: ApplicationLiveStateSnapshot_UNKNOWN,
+		},
+		{
+			name:     "unknown: nil application live state",
+			snapshot: &ApplicationLiveStateSnapshot{},
+			want:     ApplicationLiveStateSnapshot_UNKNOWN,
+		},
+	}
+	for _, tc := range testcases {
+		t.Run(tc.name, func(t *testing.T) {
+			tc.snapshot.DetermineApplicationHealthStatus()
+			assert.Equal(t, tc.want, tc.snapshot.HealthStatus)
+		})
+	}
+}

web/model/application_live_state_pb.d.ts

@@ -83,6 +83,7 @@ export namespace ApplicationLiveStateSnapshot {
     UNKNOWN = 0,
     HEALTHY = 1,
     OTHER = 2,
+    UNHEALTHY = 3,
   }
 }
 

web/src/components/application-detail-page/application-detail/health-status-icon/index.tsx

@@ -15,6 +15,9 @@ const useStyles = makeStyles((theme) => ({
   other: {
     color: theme.palette.info.main,
   },
+  unhealthy: {
+    color: theme.palette.info.main,
+  },
 }));
 
 export interface ApplicationHealthStatusIconProps {
@@ -31,6 +34,8 @@ export const ApplicationHealthStatusIcon: FC<ApplicationHealthStatusIconProps> =
         return <FavoriteIcon className={classes.healthy} />;
       case ApplicationLiveStateSnapshot.Status.OTHER:
         return <OtherIcon className={classes.other} />;
+      case ApplicationLiveStateSnapshot.Status.UNHEALTHY:
+        return <OtherIcon className={classes.unhealthy} />;
     }
   }
 );

web/src/constants/health-status-text.ts

@@ -7,4 +7,5 @@ export const APPLICATION_HEALTH_STATUS_TEXT: Record<
   [ApplicationLiveStateSnapshot.Status.UNKNOWN]: "Unknown",
   [ApplicationLiveStateSnapshot.Status.HEALTHY]: "Healthy",
   [ApplicationLiveStateSnapshot.Status.OTHER]: "Other",
+  [ApplicationLiveStateSnapshot.Status.UNHEALTHY]: "Unhealthy",
 };