Use repository settings from piped config

Signed-off-by: golemiso <[email protected]>

pkg/app/piped/controller/planner.go

@@ -150,10 +150,12 @@ func (p *planner) Run(ctx context.Context) error {
 		p.done.Store(true)
 	}()
 
-	repoCfg := config.PipedRepository{
-		RepoID: p.deployment.GitPath.Repo.Id,
-		Remote: p.deployment.GitPath.Repo.Remote,
-		Branch: p.deployment.GitPath.Repo.Branch,
+	repoID := p.deployment.GitPath.Repo.Id
+	repoCfg, ok := p.pipedConfig.GetRepository(repoID)
+	if !ok {
+		p.doneDeploymentStatus = model.DeploymentStatus_DEPLOYMENT_FAILURE
+		reason := fmt.Sprintf("Repository %s was not found in piped configuration", repoID)
+		return p.reportDeploymentFailed(ctx, reason)
 	}
 
 	in := pln.Input{

pkg/app/piped/controller/scheduler.go

@@ -220,10 +220,12 @@ func (s *scheduler) Run(ctx context.Context) error {
 	)
 	deploymentStatus = model.DeploymentStatus_DEPLOYMENT_SUCCESS
 
-	repoCfg := config.PipedRepository{
-		RepoID: s.deployment.GitPath.Repo.Id,
-		Remote: s.deployment.GitPath.Repo.Remote,
-		Branch: s.deployment.GitPath.Repo.Branch,
+	repoID := s.deployment.GitPath.Repo.Id
+	repoCfg, ok := s.pipedConfig.GetRepository(repoID)
+	if !ok {
+		deploymentStatus := model.DeploymentStatus_DEPLOYMENT_FAILURE
+		statusReason := fmt.Sprintf("Repository %s was not found in piped configuration", repoID)
+		return s.reportDeploymentCompleted(ctx, deploymentStatus, statusReason, "")
 	}
 
 	s.targetDSP = deploysource.NewProvider(

pkg/app/piped/planpreview/builder.go

@@ -377,12 +377,6 @@ func (b *builder) listApplications(repo config.PipedRepository) []*model.Applica
 		if app.GitPath.Repo.Id != repo.RepoID {
 			continue
 		}
-		if app.GitPath.Repo.Remote != repo.Remote {
-			continue
-		}
-		if app.GitPath.Repo.Branch != repo.Branch {
-			continue
-		}
 		out = append(out, app)
 	}