package environment import ( "errors" "fmt" "net/http" "github.com/porter-dev/porter/api/server/authz" "github.com/porter-dev/porter/api/server/handlers" "github.com/porter-dev/porter/api/server/shared" "github.com/porter-dev/porter/api/server/shared/apierrors" "github.com/porter-dev/porter/api/server/shared/config" "github.com/porter-dev/porter/api/server/shared/requestutils" "github.com/porter-dev/porter/api/types" "github.com/porter-dev/porter/internal/models" "gorm.io/gorm" ) type ToggleNewCommentHandler struct { handlers.PorterHandlerReadWriter authz.KubernetesAgentGetter } func NewToggleNewCommentHandler( config *config.Config, decoderValidator shared.RequestDecoderValidator, writer shared.ResultWriter, ) *ToggleNewCommentHandler { return &ToggleNewCommentHandler{ PorterHandlerReadWriter: handlers.NewDefaultPorterHandler(config, decoderValidator, writer), KubernetesAgentGetter: authz.NewOutOfClusterAgentGetter(config), } } func (c *ToggleNewCommentHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) { project, _ := r.Context().Value(types.ProjectScope).(*models.Project) cluster, _ := r.Context().Value(types.ClusterScope).(*models.Cluster) environmentID, reqErr := requestutils.GetURLParamUint(r, "environment_id") if reqErr != nil { c.HandleAPIError(w, r, reqErr) return } request := &types.ToggleNewCommentRequest{} if ok := c.DecodeAndValidate(w, r, request); !ok { return } env, err := c.Repo().Environment().ReadEnvironmentByID(project.ID, cluster.ID, environmentID) if err != nil { if errors.Is(err, gorm.ErrRecordNotFound) { c.HandleAPIError(w, r, apierrors.NewErrNotFound(fmt.Errorf("no such environment with ID: %d", environmentID))) return } c.HandleAPIError(w, r, apierrors.NewErrInternal(err)) return } if env.NewCommentsDisabled != request.Disable { env.NewCommentsDisabled = request.Disable _, err = c.Repo().Environment().UpdateEnvironment(env) if err != nil { c.HandleAPIError(w, r, apierrors.NewErrInternal(err)) return } } }