list_namespaces.go 1.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950
  1. package cluster
  2. import (
  3. "net/http"
  4. "github.com/porter-dev/porter/api/server/handlers"
  5. "github.com/porter-dev/porter/api/server/shared"
  6. "github.com/porter-dev/porter/api/server/shared/apierrors"
  7. "github.com/porter-dev/porter/api/types"
  8. "github.com/porter-dev/porter/internal/models"
  9. )
  10. type ClusterListNamespacesHandler struct {
  11. handlers.PorterHandlerWriter
  12. KubernetesAgentGetter
  13. }
  14. func NewClusterListNamespacesHandler(
  15. config *shared.Config,
  16. writer shared.ResultWriter,
  17. ) *ClusterListNamespacesHandler {
  18. return &ClusterListNamespacesHandler{
  19. PorterHandlerWriter: handlers.NewDefaultPorterHandler(config, nil, writer),
  20. KubernetesAgentGetter: NewDefaultKubernetesAgentGetter(config),
  21. }
  22. }
  23. func (c *ClusterListNamespacesHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
  24. cluster, _ := r.Context().Value(types.ClusterScope).(*models.Cluster)
  25. agent, err := c.GetAgent(cluster)
  26. if err != nil {
  27. c.HandleAPIError(w, apierrors.NewErrInternal(err))
  28. return
  29. }
  30. namespaceList, err := agent.ListNamespaces()
  31. if err != nil {
  32. c.HandleAPIError(w, apierrors.NewErrInternal(err))
  33. return
  34. }
  35. res := types.ClusterListNamespacesResponse{
  36. NamespaceList: namespaceList,
  37. }
  38. c.WriteResult(w, res)
  39. }