diff --git a/cli/cmd/digger/main.go b/cli/cmd/digger/main.go index 6aa24ebf..bae66b0f 100644 --- a/cli/cmd/digger/main.go +++ b/cli/cmd/digger/main.go @@ -2,57 +2,11 @@ package main import ( "fmt" - "github.com/diggerhq/digger/cli/pkg/digger" "github.com/diggerhq/digger/cli/pkg/usage" - core_backend "github.com/diggerhq/digger/libs/backendapi" - "github.com/diggerhq/digger/libs/ci" - "github.com/diggerhq/digger/libs/comment_utils/reporting" - "github.com/diggerhq/digger/libs/comment_utils/summary" - "github.com/diggerhq/digger/libs/digger_config" - core_locking "github.com/diggerhq/digger/libs/locking" - core_policy "github.com/diggerhq/digger/libs/policy" - "github.com/diggerhq/digger/libs/scheduler" - "github.com/diggerhq/digger/libs/storage" "log" "os" ) -func exec(actor string, projectName string, repoNamespace string, command string, prNumber int, lock core_locking.Lock, policyChecker core_policy.Checker, prService ci.PullRequestService, orgService ci.OrgService, reporter reporting.Reporter, backendApi core_backend.Api) { - - //SCMOrganisation, SCMrepository := utils.ParseRepoNamespace(runConfig.RepoNamespace) - currentDir, err := os.Getwd() - if err != nil { - - usage.ReportErrorAndExit(actor, fmt.Sprintf("Failed to get current dir. %s", err), 4) - - } - - planStorage, err := storage.NewPlanStorage("", "", "", nil) - if err != nil { - - usage.ReportErrorAndExit(actor, fmt.Sprintf("Failed to get plan storage. %s", err), 4) - - } - - changedFiles, err := prService.GetChangedFiles(prNumber) - if err != nil { - usage.ReportErrorAndExit(actor, fmt.Sprintf("could not get changed files: %v", err), 1) - } - diggerConfig, _, dependencyGraph, err := digger_config.LoadDiggerConfig("./", true, changedFiles) - if err != nil { - usage.ReportErrorAndExit(actor, fmt.Sprintf("Failed to load digger config. %s", err), 4) - } - //impactedProjects := diggerConfig.GetModifiedProjects(strings.Split(runConfig.FilesChanged, ",")) - impactedProjects := diggerConfig.GetProjects(projectName) - jobs, _, err := scheduler.ConvertProjectsToJobs(actor, repoNamespace, command, prNumber, impactedProjects, nil, diggerConfig.Workflows) - if err != nil { - usage.ReportErrorAndExit(actor, fmt.Sprintf("Failed to convert impacted projects to commands. %s", err), 4) - } - - jobs = digger.SortedCommandsByDependency(jobs, &dependencyGraph) - _, _, err = digger.RunJobs(jobs, prService, orgService, lock, reporter, planStorage, policyChecker, comment_updater.NoopCommentUpdater{}, backendApi, "", false, false, "123", currentDir) -} - /* Exit codes: 0 - No errors @@ -77,26 +31,6 @@ func main() { } -func getImpactedProjectsAsString(projects []digger_config.Project, prNumber int) string { - msg := fmt.Sprintf("Following projects are impacted by pull request #%d\n", prNumber) - for _, p := range projects { - msg += fmt.Sprintf("- %s\n", p.Name) - } - return msg -} - -func logCommands(projectCommands []scheduler.Job) { - logMessage := fmt.Sprintf("Following commands are going to be executed:\n") - for _, pc := range projectCommands { - logMessage += fmt.Sprintf("project: %s: commands: ", pc.ProjectName) - for _, c := range pc.Commands { - logMessage += fmt.Sprintf("\"%s\", ", c) - } - logMessage += "\n" - } - log.Print(logMessage) -} - func init() { log.SetOutput(os.Stdout)