Determine app health status for plugin architecture

pkg/app/pipedv1/livestatereporter/livestatereporter.go

@@ -142,8 +142,7 @@
 			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,24 @@ 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 {
+		return
+	}
+
+	for _, r := range app.Resources {
+		if r.HealthStatus == ResourceState_UNHEALTHY {
+			s.HealthStatus = ApplicationLiveStateSnapshot_UNHEALTHY
+			return
+		}
+
+		if r.HealthStatus == ResourceState_UNKNOWN {
+			s.HealthStatus = ApplicationLiveStateSnapshot_UNKNOWN
+			return
+		}
+	}
+	s.HealthStatus = ApplicationLiveStateSnapshot_HEALTHY
+}

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,65 @@ 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: "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,
   }
 }