update apis implementation for cli handling

kube-tarian · Jun 4, 2024 · f023d59 · f023d59
1 parent ae8aaeb
commit f023d59
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 15 deletions.
diff --git a/capten/agent/internal/api/cluster_plugin_apis.go b/capten/agent/internal/api/cluster_plugin_apis.go
@@ -17,16 +17,16 @@ func (a *Agent) GetClusterPlugins(ctx context.Context, request *clusterpluginspb
 	}
 
 	clusterPlugins := []*clusterpluginspb.ClusterPlugin{}
-	for idx, pluginConfig := range pluginConfigList {
-		clusterPlugins[idx] = &clusterpluginspb.ClusterPlugin{
+	for _, pluginConfig := range pluginConfigList {
+		clusterPlugins = append(clusterPlugins, &clusterpluginspb.ClusterPlugin{
 			StoreType:     pluginConfig.StoreType,
 			PluginName:    pluginConfig.PluginName,
 			Description:   pluginConfig.Description,
 			Category:      pluginConfig.Category,
 			Icon:          pluginConfig.Icon,
 			Version:       pluginConfig.Version,
 			InstallStatus: pluginConfig.InstallStatus,
-		}
+		})
 	}
 	return &clusterpluginspb.GetClusterPluginsResponse{
 		Status:  clusterpluginspb.StatusCode_OK,

diff --git a/capten/agent/internal/api/plugin_crossplane_project_apis.go b/capten/agent/internal/api/plugin_crossplane_project_apis.go
@@ -15,29 +15,25 @@ const (
 
 func (a *Agent) RegisterCrossplaneProject(ctx context.Context, request *captenpluginspb.RegisterCrossplaneProjectRequest) (
 	*captenpluginspb.RegisterCrossplaneProjectResponse, error) {
+	a.log.Infof("Register Crossplane Git project request recieved")
 
-	if err := validateArgs(request.Id); err != nil {
-		a.log.Infof("request validation failed", err)
+	crossplaneProject, err := a.as.GetCrossplaneProject()
+	if err != nil {
+		a.log.Infof("failed to get git project, %v", err)
 		return &captenpluginspb.RegisterCrossplaneProjectResponse{
 			Status:        captenpluginspb.StatusCode_INVALID_ARGUMENT,
 			StatusMessage: "request validation failed",
 		}, nil
 	}
-	a.log.Infof("Register Crossplane Git project %s request recieved", request.Id)
 
-	crossplaneProject, err := a.as.GetCrossplaneProjectForID(request.Id)
-	if err != nil {
-		a.log.Infof("failed to get git project %s, %v", request.Id, err)
-		return &captenpluginspb.RegisterCrossplaneProjectResponse{
-			Status:        captenpluginspb.StatusCode_INVALID_ARGUMENT,
-			StatusMessage: "request validation failed",
-		}, nil
+	if len(crossplaneProject.Status) == 0 {
+		crossplaneProject.Status = string(model.CrossplaneProjectAvailable)
 	}
 
 	if crossplaneProject.Status != string(model.CrossplaneProjectConfigurationFailed) &&
 		crossplaneProject.Status != string(model.CrossplaneProjectAvailable) &&
 		crossplaneProject.Status != string(model.CrossplaneProjectConfigured) {
-		a.log.Infof("currently the Crossplane project configuration on-going %s, %v", request.Id, crossplaneProject.Status)
+		a.log.Infof("currently the Crossplane project configuration on-going %s, %v", crossplaneProject.Id, crossplaneProject.Status)
 		return &captenpluginspb.RegisterCrossplaneProjectResponse{
 			Status:        captenpluginspb.StatusCode_OK,
 			StatusMessage: "Crossplane configuration on-going",

diff --git a/capten/common-pkg/capten-store/cluster_plugin_config_store.go b/capten/common-pkg/capten-store/cluster_plugin_config_store.go
@@ -102,7 +102,7 @@ func (a *Store) GetAllClusterPluginConfigs() ([]*clusterpluginspb.Plugin, error)
 		return nil, fmt.Errorf("failed to fetch plugins: %v", err.Error())
 	}
 
-	var pluginConfigs []*clusterpluginspb.Plugin
+	pluginConfigs := []*clusterpluginspb.Plugin{}
 	for _, p := range plugins {
 		values, _ := base64.StdEncoding.DecodeString(p.Values)
 		overrideValues, _ := base64.StdEncoding.DecodeString(p.OverrideValues)