|
|
@@ -3,8 +3,6 @@ package porter_app
|
|
|
import (
|
|
|
"net/http"
|
|
|
|
|
|
- "connectrpc.com/connect"
|
|
|
- porterv1 "github.com/porter-dev/api-contracts/generated/go/porter/v1"
|
|
|
"github.com/porter-dev/porter/api/server/authz"
|
|
|
"github.com/porter-dev/porter/api/server/handlers"
|
|
|
"github.com/porter-dev/porter/api/server/shared"
|
|
|
@@ -12,6 +10,7 @@ import (
|
|
|
"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/deployment_target"
|
|
|
"github.com/porter-dev/porter/internal/kubernetes"
|
|
|
"github.com/porter-dev/porter/internal/models"
|
|
|
"github.com/porter-dev/porter/internal/telemetry"
|
|
|
@@ -71,31 +70,19 @@ func (c *JobStatusHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
|
|
}
|
|
|
telemetry.WithAttributes(span, telemetry.AttributeKV{Key: "deployment-target-id", Value: request.DeploymentTargetID})
|
|
|
|
|
|
- deploymentTargetDetailsReq := connect.NewRequest(&porterv1.DeploymentTargetDetailsRequest{
|
|
|
- ProjectId: int64(project.ID),
|
|
|
- DeploymentTargetId: request.DeploymentTargetID,
|
|
|
+ deploymentTarget, err := deployment_target.DeploymentTargetDetails(ctx, deployment_target.DeploymentTargetDetailsInput{
|
|
|
+ ProjectID: int64(project.ID),
|
|
|
+ ClusterID: int64(cluster.ID),
|
|
|
+ DeploymentTargetID: request.DeploymentTargetID,
|
|
|
+ CCPClient: c.Config().ClusterControlPlaneClient,
|
|
|
})
|
|
|
-
|
|
|
- deploymentTargetDetailsResp, err := c.Config().ClusterControlPlaneClient.DeploymentTargetDetails(ctx, deploymentTargetDetailsReq)
|
|
|
if err != nil {
|
|
|
- err := telemetry.Error(ctx, span, err, "error getting deployment target details from cluster control plane client")
|
|
|
- c.HandleAPIError(w, r, apierrors.NewErrPassThroughToClient(err, http.StatusBadRequest))
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- if deploymentTargetDetailsResp == nil || deploymentTargetDetailsResp.Msg == nil {
|
|
|
- err := telemetry.Error(ctx, span, err, "deployment target details resp is nil")
|
|
|
- c.HandleAPIError(w, r, apierrors.NewErrPassThroughToClient(err, http.StatusInternalServerError))
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- if deploymentTargetDetailsResp.Msg.ClusterId != int64(cluster.ID) {
|
|
|
- err := telemetry.Error(ctx, span, err, "deployment target details resp cluster id does not match cluster id")
|
|
|
+ err := telemetry.Error(ctx, span, err, "error getting deployment target details")
|
|
|
c.HandleAPIError(w, r, apierrors.NewErrPassThroughToClient(err, http.StatusInternalServerError))
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- namespace := deploymentTargetDetailsResp.Msg.Namespace
|
|
|
+ namespace := deploymentTarget.Namespace
|
|
|
telemetry.WithAttributes(span, telemetry.AttributeKV{Key: "namespace", Value: namespace})
|
|
|
|
|
|
agent, err := c.GetAgent(r, cluster, "")
|