feat: Resource status for integration

api/helm-app/HelmAppService.go

@@ -37,6 +37,7 @@ const DEFAULT_CLUSTER_ID = 1
 type HelmAppService interface {
 	ListHelmApplications(clusterIds []int, w http.ResponseWriter, token string, helmAuth func(token string, object string) bool)
 	GetApplicationDetail(ctx context.Context, app *AppIdentifier) (*AppDetail, error)
+	GetApplicationDetailWithFilter(ctx context.Context, app *AppIdentifier, resourceTreeFilter *ResourceTreeFilter) (*AppDetail, error)
 	HibernateApplication(ctx context.Context, app *AppIdentifier, hibernateRequest *openapi.HibernateRequest) ([]*openapi.HibernateStatus, error)
 	UnHibernateApplication(ctx context.Context, app *AppIdentifier, hibernateRequest *openapi.HibernateRequest) ([]*openapi.HibernateStatus, error)
 	DecodeAppId(appId string) (*AppIdentifier, error)
@@ -233,15 +234,24 @@ func (impl *HelmAppServiceImpl) GetClusterConf(clusterId int) (*ClusterConfig, e
 }
 
 func (impl *HelmAppServiceImpl) GetApplicationDetail(ctx context.Context, app *AppIdentifier) (*AppDetail, error) {
+	return impl.getApplicationDetail(ctx, app, nil)
+}
+
+func (impl *HelmAppServiceImpl) GetApplicationDetailWithFilter(ctx context.Context, app *AppIdentifier, resourceTreeFilter *ResourceTreeFilter) (*AppDetail, error) {
+	return impl.getApplicationDetail(ctx, app, resourceTreeFilter)
+}
+
+func (impl *HelmAppServiceImpl) getApplicationDetail(ctx context.Context, app *AppIdentifier, resourceTreeFilter *ResourceTreeFilter) (*AppDetail, error) {
 	config, err := impl.GetClusterConf(app.ClusterId)
 	if err != nil {
 		impl.logger.Errorw("error in fetching cluster detail", "err", err)
 		return nil, err
 	}
 	req := &AppDetailRequest{
-		ClusterConfig: config,
-		Namespace:     app.Namespace,
-		ReleaseName:   app.ReleaseName,
+		ClusterConfig:      config,
+		Namespace:          app.Namespace,
+		ReleaseName:        app.ReleaseName,
+		ResourceTreeFilter: resourceTreeFilter,
 	}
 	appdetail, err := impl.helmAppClient.GetAppDetail(ctx, req)
 	if err != nil {
@@ -265,7 +275,6 @@ func (impl *HelmAppServiceImpl) GetApplicationDetail(ctx context.Context, app *A
 		}
 	}
 	return appdetail, err
-
 }
 
 func (impl *HelmAppServiceImpl) GetDeploymentHistory(ctx context.Context, app *AppIdentifier) (*HelmAppDeploymentHistory, error) {

api/helm-app/applist.proto

@@ -62,6 +62,8 @@ message AppDetailRequest {
   ClusterConfig clusterConfig = 1;
   string namespace = 2;
   string ReleaseName = 3;
+  // Map key cannot be float, double, bytes, message, or enum types (map<Gvk, Labels> could be a better option)
+  ResourceTreeFilter resourceTreeFilter = 4;
 }
 
 message AppDetail{
@@ -271,4 +273,24 @@ message HelmInstallCustomResponse {
 
 message ChartContent {
   bytes Content = 1;
+}
+
+message Gvk {
+  string Group = 1;
+  string Version = 2;
+  string Kind = 3;
+}
+
+message ResourceFilter {
+  Gvk gvk = 1;
+  ResourceIdentifier resourceIdentifier = 2;
+}
+
+message ResourceIdentifier {
+  map<string, string> labels = 1;
+}
+
+message ResourceTreeFilter {
+  ResourceIdentifier globalFilter = 1;
+  repeated ResourceFilter resourceFilters = 2;
 }

api/module/wire_module.go

@@ -3,6 +3,7 @@ package module
 import (
 	"github.com/devtron-labs/devtron/pkg/module"
 	moduleRepo "github.com/devtron-labs/devtron/pkg/module/repo"
+	moduleDataStore "github.com/devtron-labs/devtron/pkg/module/store"
 	"github.com/google/wire"
 )
 
@@ -11,7 +12,12 @@ var ModuleWireSet = wire.NewSet(
 	wire.Bind(new(module.ModuleActionAuditLogRepository), new(*module.ModuleActionAuditLogRepositoryImpl)),
 	moduleRepo.NewModuleRepositoryImpl,
 	wire.Bind(new(moduleRepo.ModuleRepository), new(*moduleRepo.ModuleRepositoryImpl)),
+	moduleRepo.NewModuleResourceStatusRepositoryImpl,
+	wire.Bind(new(moduleRepo.ModuleResourceStatusRepository), new(*moduleRepo.ModuleResourceStatusRepositoryImpl)),
 	module.ParseModuleEnvConfig,
+	moduleDataStore.InitModuleDataStore,
+	module.NewModuleServiceHelperImpl,
+	wire.Bind(new(module.ModuleServiceHelper), new(*module.ModuleServiceHelperImpl)),
 	module.NewModuleServiceImpl,
 	wire.Bind(new(module.ModuleService), new(*module.ModuleServiceImpl)),
 	module.NewModuleCronServiceImpl,

pkg/module/Bean.go

@@ -20,11 +20,13 @@ package module
 import (
 	"fmt"
 	"github.com/caarlos0/env"
+	"k8s.io/apimachinery/pkg/runtime/schema"
 )
 
 type ModuleInfoDto struct {
-	Name   string `json:"name,notnull"`
-	Status string `json:"status,notnull" validate:"oneof=notInstalled installed installing installFailed timeout"`
+	Name                  string                     `json:"name,notnull"`
+	Status                string                     `json:"status,notnull" validate:"oneof=notInstalled installed installing installFailed timeout"`
+	ModuleResourcesStatus []*ModuleResourceStatusDto `json:"moduleResourcesStatus"`
 }
 
 type ModuleConfigDto struct {
@@ -45,7 +47,16 @@ type ActionResponse struct {
 }
 
 type ModuleEnvConfig struct {
-	ModuleStatusHandlingCronDurationInMin int `env:"MODULE_STATUS_HANDLING_CRON_DURATION_MIN" envDefault:"3"` // default 3 mins
+	ModuleStatusHandlingCronDurationInMin int `env:"MODULE_STATUS_HANDLING_CRON_DURATION_MIN" envDefault:"3"` // default 3 minutes
+}
+
+type ModuleResourceStatusDto struct {
+	Group         string `json:"group"`
+	Version       string `json:"version"`
+	Kind          string `json:"kind"`
+	Name          string `json:"name"`
+	HealthStatus  string `json:"healthStatus"`
+	HealthMessage string `json:"healthMessage"`
 }
 
 func ParseModuleEnvConfig() (*ModuleEnvConfig, error) {
@@ -82,3 +93,17 @@ const (
 )
 
 var SupportedModuleNamesListFirstReleaseExcludingCicd = []string{ModuleNameArgoCd, ModuleNameSecurityClair, ModuleNameNotification, ModuleNameMonitoringGrafana}
+
+type ResourceFilter struct {
+	GlobalFilter    *ResourceIdentifier `json:"globalFilter,omitempty"`
+	GvkLevelFilters []*GvkLevelFilter   `json:"gvkLevelFilters,omitempty"`
+}
+
+type GvkLevelFilter struct {
+	Gvk                *schema.GroupVersionKind `json:"gvk"`
+	ResourceIdentifier *ResourceIdentifier      `json:"filter"`
+}
+
+type ResourceIdentifier struct {
+	Labels map[string]string `json:"labels"`
+}