Преглед изворни кода

Removed get latest job enpdoint

jnfrati пре 4 година
родитељ
комит
f22c6c909c
2 измењених фајлова са 0 додато и 93 уклоњено
  1. 0 62
      api/server/handlers/release/get_latest_job_run.go
  2. 0 31
      api/server/router/release.go

+ 0 - 62
api/server/handlers/release/get_latest_job_run.go

@@ -1,62 +0,0 @@
-package release
-
-import (
-	"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/types"
-	"github.com/porter-dev/porter/internal/models"
-	"helm.sh/helm/v3/pkg/release"
-)
-
-type GetLatestJobRunHandler struct {
-	handlers.PorterHandlerReadWriter
-	authz.KubernetesAgentGetter
-}
-
-func NewGetLatestJobRunHandler(
-	config *config.Config,
-	writer shared.ResultWriter,
-) *GetLatestJobRunHandler {
-	return &GetLatestJobRunHandler{
-		PorterHandlerReadWriter: handlers.NewDefaultPorterHandler(config, nil, writer),
-		KubernetesAgentGetter:   authz.NewOutOfClusterAgentGetter(config),
-	}
-}
-
-func (c *GetLatestJobRunHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
-	helmRelease, _ := r.Context().Value(types.ReleaseScope).(*release.Release)
-	cluster, _ := r.Context().Value(types.ClusterScope).(*models.Cluster)
-	agent, err := c.GetAgent(r, cluster, "")
-
-	if err != nil {
-		c.HandleAPIError(w, r, apierrors.NewErrInternal(err))
-		return
-	}
-
-	jobs, err := agent.ListJobsByLabel(helmRelease.Namespace, getJobLabels(helmRelease)...)
-
-	if err != nil {
-		c.HandleAPIError(w, r, apierrors.NewErrInternal(err))
-		return
-	}
-
-	// get the most recent job
-	if len(jobs) > 0 {
-		mostRecentJob := jobs[0]
-
-		for _, job := range jobs {
-			createdAt := job.ObjectMeta.CreationTimestamp
-
-			if mostRecentJob.CreationTimestamp.Before(&createdAt) {
-				mostRecentJob = job
-			}
-		}
-
-		c.WriteResult(w, r, mostRecentJob)
-	}
-}

+ 0 - 31
api/server/router/release.go

@@ -691,37 +691,6 @@ func getReleaseRoutes(
 		Router:   r,
 	})
 
-	// GET /api/projects/{project_id}/clusters/{cluster_id}/namespaces/{namespace}/releases/{name}/{version}/latest_job_run ->
-	// release.NewGetLatestJobRunHandler
-	getLatestJobRunEndpoint := factory.NewAPIEndpoint(
-		&types.APIRequestMetadata{
-			Verb:   types.APIVerbGet,
-			Method: types.HTTPVerbGet,
-			Path: &types.Path{
-				Parent:       basePath,
-				RelativePath: relPath + "/latest_job_run",
-			},
-			Scopes: []types.PermissionScope{
-				types.UserScope,
-				types.ProjectScope,
-				types.ClusterScope,
-				types.NamespaceScope,
-				types.ReleaseScope,
-			},
-		},
-	)
-
-	getLatestJobRunHandler := release.NewGetLatestJobRunHandler(
-		config,
-		factory.GetResultWriter(),
-	)
-
-	routes = append(routes, &Route{
-		Endpoint: getLatestJobRunEndpoint,
-		Handler:  getLatestJobRunHandler,
-		Router:   r,
-	})
-
 	// GET /api/projects/{project_id}/clusters/{cluster_id}/namespaces/{namespace}/releases/{name}/{version}/jobs/status ->
 	// release.NewGetJobsHandler
 	getJobsStatusEndpoint := factory.NewAPIEndpoint(