/app/status API that returns detailed app status

replicatedhq · Dec 19, 2024 · 9d92e9e · 9d92e9e
1 parent eeb5cac
commit 9d92e9e
Show file tree

Hide file tree

Showing 3 changed files with 45 additions and 1 deletion.
diff --git a/pkg/apiserver/server.go b/pkg/apiserver/server.go
@@ -68,6 +68,7 @@ func Start(params APIServerParams) {
 
 	// app
 	r.HandleFunc("/api/v1/app/info", handlers.GetCurrentAppInfo).Methods("GET")
+	r.HandleFunc("/api/v1/app/status", handlers.GetCurrentAppStatus).Methods("GET")
 	r.HandleFunc("/api/v1/app/updates", handlers.GetAppUpdates).Methods("GET")
 	r.HandleFunc("/api/v1/app/history", handlers.GetAppHistory).Methods("GET")
 	cachedRouter.HandleFunc("/api/v1/app/custom-metrics", handlers.SendCustomAppMetrics).Methods("POST", "PATCH")

diff --git a/pkg/handlers/app.go b/pkg/handlers/app.go
@@ -45,6 +45,10 @@ type GetCurrentAppInfoResponse struct {
 	ReleaseSequence int64               `json:"releaseSequence"`
 }
 
+type GetCurrentAppStatusResponse struct {
+	AppStatus appstatetypes.AppStatus `json:"appStatus"`
+}
+
 type GetAppHistoryResponse struct {
 	Releases []AppRelease `json:"releases"`
 }
@@ -149,6 +153,45 @@ func GetCurrentAppInfo(w http.ResponseWriter, r *http.Request) {
 	JSON(w, http.StatusOK, response)
 }
 
+func GetCurrentAppStatus(w http.ResponseWriter, r *http.Request) {
+	clientset, err := k8sutil.GetClientset()
+	if err != nil {
+		logger.Error(errors.Wrap(err, "failed to get clientset"))
+		w.WriteHeader(http.StatusInternalServerError)
+		return
+	}
+
+	isIntegrationModeEnabled, err := integration.IsEnabled(r.Context(), clientset, store.GetStore().GetNamespace(), store.GetStore().GetLicense())
+	if err != nil {
+		logger.Errorf("failed to check if integration mode is enabled: %v", err)
+		w.WriteHeader(http.StatusInternalServerError)
+		return
+	}
+
+	if isIntegrationModeEnabled {
+		response := GetCurrentAppStatusResponse{}
+
+		// TODO: mock app status
+		// mockData, err := integration.GetMockData(r.Context(), clientset, store.GetStore().GetNamespace())
+		// if err != nil {
+		// 	logger.Errorf("failed to get mock data: %v", err)
+		// 	w.WriteHeader(http.StatusInternalServerError)
+		// 	return
+		// }
+
+		// response.AppStatus = mockData.AppStatus
+
+		JSON(w, http.StatusOK, response)
+		return
+	}
+
+	response := GetCurrentAppStatusResponse{
+		AppStatus: store.GetStore().GetAppStatus(),
+	}
+
+	JSON(w, http.StatusOK, response)
+}
+
 func GetAppUpdates(w http.ResponseWriter, r *http.Request) {
 	if util.IsAirgap() {
 		JSON(w, http.StatusOK, []upstreamtypes.ChannelRelease{})

diff --git a/pkg/integration/types/types.go b/pkg/integration/types/types.go
@@ -5,7 +5,7 @@ import (
 )
 
 type MockData struct {
-	AppStatus         appstatetypes.State `json:"appStatus,omitempty" yaml:"appStatus,omitempty"`
+	AppStatus         appstatetypes.State `json:"appStatus,omitempty" yaml:"appStatus,omitempty"` // TODO: detailed status
 	HelmChartURL      string              `json:"helmChartURL,omitempty" yaml:"helmChartURL,omitempty"`
 	CurrentRelease    *MockRelease        `json:"currentRelease,omitempty" yaml:"currentRelease,omitempty"`
 	DeployedReleases  []MockRelease       `json:"deployedReleases,omitempty" yaml:"deployedReleases,omitempty"`