feat: add plugin via api

api/restHandler/GlobalPluginRestHandler.go

@@ -1,11 +1,13 @@
 package restHandler
 
 import (
+	"encoding/json"
 	"fmt"
 	"github.com/devtron-labs/devtron/api/restHandler/common"
 	"github.com/devtron-labs/devtron/pkg/pipeline"
 	"github.com/devtron-labs/devtron/pkg/plugin"
 	"github.com/devtron-labs/devtron/pkg/plugin/repository"
+	"github.com/devtron-labs/devtron/pkg/user"
 	"github.com/devtron-labs/devtron/pkg/user/casbin"
 	"github.com/devtron-labs/devtron/util/rbac"
 	"github.com/gorilla/mux"
@@ -15,19 +17,25 @@ import (
 )
 
 type GlobalPluginRestHandler interface {
+	PatchPlugin(w http.ResponseWriter, r *http.Request)
+
 	GetAllGlobalVariables(w http.ResponseWriter, r *http.Request)
 	ListAllPlugins(w http.ResponseWriter, r *http.Request)
 	GetPluginDetailById(w http.ResponseWriter, r *http.Request)
+	GetDetailedPluginInfoByPluginId(w http.ResponseWriter, r *http.Request)
+	GetAllDetailedPluginInfo(w http.ResponseWriter, r *http.Request)
 }
 
 func NewGlobalPluginRestHandler(logger *zap.SugaredLogger, globalPluginService plugin.GlobalPluginService,
-	enforcerUtil rbac.EnforcerUtil, enforcer casbin.Enforcer, pipelineBuilder pipeline.PipelineBuilder) *GlobalPluginRestHandlerImpl {
+	enforcerUtil rbac.EnforcerUtil, enforcer casbin.Enforcer, pipelineBuilder pipeline.PipelineBuilder,
+	userService user.UserService) *GlobalPluginRestHandlerImpl {
 	return &GlobalPluginRestHandlerImpl{
 		logger:              logger,
 		globalPluginService: globalPluginService,
 		enforcerUtil:        enforcerUtil,
 		enforcer:            enforcer,
 		pipelineBuilder:     pipelineBuilder,
+		userService:         userService,
 	}
 }
 
@@ -37,6 +45,97 @@ type GlobalPluginRestHandlerImpl struct {
 	enforcerUtil        rbac.EnforcerUtil
 	enforcer            casbin.Enforcer
 	pipelineBuilder     pipeline.PipelineBuilder
+	userService         user.UserService
+}
+
+func (handler *GlobalPluginRestHandlerImpl) PatchPlugin(w http.ResponseWriter, r *http.Request) {
+	decoder := json.NewDecoder(r.Body)
+	userId, err := handler.userService.GetLoggedInUser(r)
+	if userId == 0 || err != nil {
+		common.WriteJsonResp(w, err, "Unauthorized User", http.StatusUnauthorized)
+		return
+	}
+	var pluginDataDto plugin.PluginMetadataDto
+	err = decoder.Decode(&pluginDataDto)
+	if err != nil {
+		handler.logger.Errorw("request err, PatchPlugin", "error", err, "payload", pluginDataDto)
+		common.WriteJsonResp(w, err, nil, http.StatusBadRequest)
+		return
+	}
+	handler.logger.Infow("request payload received for patching plugins", pluginDataDto, "userId", userId)
+	// RBAC enforcer applying
+	isSuperAdmin, err := handler.userService.IsSuperAdmin(int(userId))
+	if !isSuperAdmin || err != nil {
+		if err != nil {
+			handler.logger.Errorw("request err, CheckSuperAdmin", "err", err, "isSuperAdmin", isSuperAdmin)
+		}
+		common.WriteJsonResp(w, err, "Unauthorized User", http.StatusForbidden)
+		return
+	}
+	//RBAC enforcer Ends
+	pluginData, err := handler.globalPluginService.PatchPlugin(&pluginDataDto, userId)
+	if err != nil {
+		handler.logger.Errorw("error in patching plugin data", "action", pluginDataDto.Action, "pluginMetadataPayloadDto", pluginDataDto, "err", err)
+		common.WriteJsonResp(w, err, nil, http.StatusInternalServerError)
+		return
+	}
+	common.WriteJsonResp(w, nil, pluginData, http.StatusOK)
+
+}
+func (handler *GlobalPluginRestHandlerImpl) GetDetailedPluginInfoByPluginId(w http.ResponseWriter, r *http.Request) {
+	userId, err := handler.userService.GetLoggedInUser(r)
+	if userId == 0 || err != nil {
+		common.WriteJsonResp(w, err, "Unauthorized User", http.StatusUnauthorized)
+		return
+	}
+	vars := mux.Vars(r)
+	pluginId, err := strconv.Atoi(vars["pluginId"])
+	if err != nil {
+		handler.logger.Errorw("error in converting from string to integer", "userId", userId, "err", err)
+		common.WriteJsonResp(w, err, nil, http.StatusBadRequest)
+		return
+	}
+	// RBAC enforcer applying
+	isSuperAdmin, err := handler.userService.IsSuperAdmin(int(userId))
+	if !isSuperAdmin || err != nil {
+		if err != nil {
+			handler.logger.Errorw("request err, CheckSuperAdmin", "err", err, "isSuperAdmin", isSuperAdmin)
+		}
+		common.WriteJsonResp(w, err, "Unauthorized User", http.StatusForbidden)
+		return
+	}
+	//RBAC enforcer Ends
+	pluginMetaData, err := handler.globalPluginService.GetDetailedPluginInfoByPluginId(pluginId)
+	if err != nil {
+		handler.logger.Errorw("error in getting plugin metadata", "pluginId", pluginId, "err", err)
+		common.WriteJsonResp(w, err, nil, http.StatusInternalServerError)
+		return
+	}
+	common.WriteJsonResp(w, nil, pluginMetaData, http.StatusOK)
+}
+func (handler *GlobalPluginRestHandlerImpl) GetAllDetailedPluginInfo(w http.ResponseWriter, r *http.Request) {
+	userId, err := handler.userService.GetLoggedInUser(r)
+	if userId == 0 || err != nil {
+		common.WriteJsonResp(w, err, "Unauthorized User", http.StatusUnauthorized)
+		return
+	}
+	// RBAC enforcer applying
+	isSuperAdmin, err := handler.userService.IsSuperAdmin(int(userId))
+	if !isSuperAdmin || err != nil {
+		if err != nil {
+			handler.logger.Errorw("request err, CheckSuperAdmin", "err", err, "isSuperAdmin", isSuperAdmin)
+		}
+		common.WriteJsonResp(w, err, "Unauthorized User", http.StatusForbidden)
+		return
+	}
+	//RBAC enforcer Ends
+	pluginMetaData, err := handler.globalPluginService.GetAllDetailedPluginInfo()
+	if err != nil {
+		handler.logger.Errorw("error in getting all plugins metadata", "err", err)
+		common.WriteJsonResp(w, err, nil, http.StatusInternalServerError)
+		return
+	}
+	common.WriteJsonResp(w, nil, pluginMetaData, http.StatusOK)
 }
 
 func (handler *GlobalPluginRestHandlerImpl) GetAllGlobalVariables(w http.ResponseWriter, r *http.Request) {

api/router/GlobalPluginRouter.go

@@ -23,12 +23,19 @@ type GlobalPluginRouterImpl struct {
 }
 
 func (impl *GlobalPluginRouterImpl) initGlobalPluginRouter(globalPluginRouter *mux.Router) {
-	globalPluginRouter.Path("/global/list/global-variable").
+	globalPluginRouter.Path("").
+		HandlerFunc(impl.globalPluginRestHandler.PatchPlugin).Methods("POST")
+	globalPluginRouter.Path("/detail/all").
+		HandlerFunc(impl.globalPluginRestHandler.GetAllDetailedPluginInfo).Methods("GET")
+	globalPluginRouter.Path("/detail/{pluginId}").
+		HandlerFunc(impl.globalPluginRestHandler.GetDetailedPluginInfoByPluginId).Methods("GET")
+
+	globalPluginRouter.Path("/list/global-variable").
 		HandlerFunc(impl.globalPluginRestHandler.GetAllGlobalVariables).Methods("GET")
 
-	globalPluginRouter.Path("/global/list").
+	globalPluginRouter.Path("/list").
 		HandlerFunc(impl.globalPluginRestHandler.ListAllPlugins).Methods("GET")
 
-	globalPluginRouter.Path("/global/{pluginId}").
+	globalPluginRouter.Path("/{pluginId}").
 		HandlerFunc(impl.globalPluginRestHandler.GetPluginDetailById).Methods("GET")
 }

api/router/router.go

@@ -386,7 +386,7 @@ func (r MuxRouter) Init() {
 	pProfListenerRouter := r.Router.PathPrefix("/orchestrator/debug/pprof").Subrouter()
 	r.pProfRouter.initPProfRouter(pProfListenerRouter)
 
-	globalPluginRouter := r.Router.PathPrefix("/orchestrator/plugin").Subrouter()
+	globalPluginRouter := r.Router.PathPrefix("/orchestrator/plugin/global").Subrouter()
 	r.globalPluginRouter.initGlobalPluginRouter(globalPluginRouter)
 
 	//  deployment router starts

internal/sql/repository/CiArtifactRepository.go

@@ -254,7 +254,7 @@ func (impl CiArtifactRepositoryImpl) GetLatestArtifactTimeByCiPipelineIds(ciPipe
 	return artifacts, nil
 }
 
-//GetLatestArtifactTimeByCiPipelineId will fetch latest ci artifact time(created) against that ci pipeline
+// GetLatestArtifactTimeByCiPipelineId will fetch latest ci artifact time(created) against that ci pipeline
 func (impl CiArtifactRepositoryImpl) GetLatestArtifactTimeByCiPipelineId(ciPipelineId int) (*CiArtifact, error) {
 	artifacts := &CiArtifact{}
 	query := "select cws.pipeline_id, cws.created_on from " +

pkg/pipeline/WorkflowService.go

@@ -97,8 +97,8 @@ const (
 	CI_NODE_PVC_PIPELINE_PREFIX    = "devtron.ai/ci-pvc"
 	PRE                            = "PRE"
 	POST                           = "POST"
- preCdStage = "preCD"
- postCdStage = "postCD"
+	preCdStage                     = "preCD"
+	postCdStage                    = "postCD"
 )
 
 func (impl *WorkflowServiceImpl) SubmitWorkflow(workflowRequest *WorkflowRequest) (*unstructured.UnstructuredList, error) {

pkg/pipeline/repository/PipelineStageRepository.go

@@ -157,6 +157,7 @@ type PipelineStageRepository interface {
 	GetStepById(stepId int) (*PipelineStageStep, error)
 	MarkStepsDeletedByStageId(stageId int) error
 	MarkStepsDeletedExcludingActiveStepsInUpdateReq(activeStepIdsPresentInReq []int, stageId int) error
+	GetActiveStepsByRefPluginId(refPluginId int) ([]*PipelineStageStep, error)
 
 	CreatePipelineScript(pipelineScript *PluginPipelineScript, tx *pg.Tx) (*PluginPipelineScript, error)
 	UpdatePipelineScript(pipelineScript *PluginPipelineScript) (*PluginPipelineScript, error)
@@ -417,6 +418,18 @@ func (impl *PipelineStageRepositoryImpl) MarkStepsDeletedExcludingActiveStepsInU
 	return nil
 }
 
+func (impl *PipelineStageRepositoryImpl) GetActiveStepsByRefPluginId(refPluginId int) ([]*PipelineStageStep, error) {
+	var steps []*PipelineStageStep
+	err := impl.dbConnection.Model(&steps).
+		Where("ref_plugin_id = ?", refPluginId).
+		Where("deleted = ?", false).Select()
+	if err != nil {
+		impl.logger.Errorw("err in getting all steps by refPluginId", "err", err, "refPluginId", refPluginId)
+		return nil, err
+	}
+	return steps, nil
+}
+
 func (impl *PipelineStageRepositoryImpl) CreatePipelineScript(pipelineScript *PluginPipelineScript, tx *pg.Tx) (*PluginPipelineScript, error) {
 	var err error
 	if tx != nil {