package namespace import ( "fmt" "net/http" "strings" "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/websocket" "github.com/porter-dev/porter/api/types" "github.com/porter-dev/porter/internal/models" ) type StreamJobRunsHandler struct { handlers.PorterHandlerReadWriter authz.KubernetesAgentGetter } func NewStreamJobRunsHandler( config *config.Config, decoderValidator shared.RequestDecoderValidator, writer shared.ResultWriter, ) *StreamJobRunsHandler { return &StreamJobRunsHandler{ PorterHandlerReadWriter: handlers.NewDefaultPorterHandler(config, decoderValidator, writer), KubernetesAgentGetter: authz.NewOutOfClusterAgentGetter(config), } } func (c *StreamJobRunsHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) { safeRW := r.Context().Value(types.RequestCtxWebsocketKey).(*websocket.WebsocketSafeReadWriter) namespace := r.Context().Value(types.NamespaceScope).(string) cluster, _ := r.Context().Value(types.ClusterScope).(*models.Cluster) req := &types.StreamJobRunsRequest{} if ok := c.DecodeAndValidate(w, r, req); !ok { return } agent, err := c.GetAgent(r, cluster, "") if err != nil { c.HandleAPIError(w, r, apierrors.NewErrInternal(err)) return } if strings.ToLower(namespace) == "all" { namespace = "" } selectors := "" if req.Name != "" { selectors = fmt.Sprintf("meta.helm.sh/release-name=%s", req.Name) } err = agent.StreamJobs(namespace, selectors, safeRW) if err != nil { c.HandleAPIError(w, r, apierrors.NewErrInternal(err)) return } }