@@ -2,57 +2,11 @@ package main
2
2
3
3
import (
4
4
"fmt"
5
- "github.com/diggerhq/digger/cli/pkg/digger"
6
5
"github.com/diggerhq/digger/cli/pkg/usage"
7
- core_backend "github.com/diggerhq/digger/libs/backendapi"
8
- "github.com/diggerhq/digger/libs/ci"
9
- "github.com/diggerhq/digger/libs/comment_utils/reporting"
10
- "github.com/diggerhq/digger/libs/comment_utils/summary"
11
- "github.com/diggerhq/digger/libs/digger_config"
12
- core_locking "github.com/diggerhq/digger/libs/locking"
13
- core_policy "github.com/diggerhq/digger/libs/policy"
14
- "github.com/diggerhq/digger/libs/scheduler"
15
- "github.com/diggerhq/digger/libs/storage"
16
6
"log"
17
7
"os"
18
8
)
19
9
20
- 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 ) {
21
-
22
- //SCMOrganisation, SCMrepository := utils.ParseRepoNamespace(runConfig.RepoNamespace)
23
- currentDir , err := os .Getwd ()
24
- if err != nil {
25
-
26
- usage .ReportErrorAndExit (actor , fmt .Sprintf ("Failed to get current dir. %s" , err ), 4 )
27
-
28
- }
29
-
30
- planStorage , err := storage .NewPlanStorage ("" , "" , "" , nil )
31
- if err != nil {
32
-
33
- usage .ReportErrorAndExit (actor , fmt .Sprintf ("Failed to get plan storage. %s" , err ), 4 )
34
-
35
- }
36
-
37
- changedFiles , err := prService .GetChangedFiles (prNumber )
38
- if err != nil {
39
- usage .ReportErrorAndExit (actor , fmt .Sprintf ("could not get changed files: %v" , err ), 1 )
40
- }
41
- diggerConfig , _ , dependencyGraph , err := digger_config .LoadDiggerConfig ("./" , true , changedFiles )
42
- if err != nil {
43
- usage .ReportErrorAndExit (actor , fmt .Sprintf ("Failed to load digger config. %s" , err ), 4 )
44
- }
45
- //impactedProjects := diggerConfig.GetModifiedProjects(strings.Split(runConfig.FilesChanged, ","))
46
- impactedProjects := diggerConfig .GetProjects (projectName )
47
- jobs , _ , err := scheduler .ConvertProjectsToJobs (actor , repoNamespace , command , prNumber , impactedProjects , nil , diggerConfig .Workflows )
48
- if err != nil {
49
- usage .ReportErrorAndExit (actor , fmt .Sprintf ("Failed to convert impacted projects to commands. %s" , err ), 4 )
50
- }
51
-
52
- jobs = digger .SortedCommandsByDependency (jobs , & dependencyGraph )
53
- _ , _ , err = digger .RunJobs (jobs , prService , orgService , lock , reporter , planStorage , policyChecker , comment_updater.NoopCommentUpdater {}, backendApi , "" , false , false , "123" , currentDir )
54
- }
55
-
56
10
/*
57
11
Exit codes:
58
12
0 - No errors
@@ -77,26 +31,6 @@ func main() {
77
31
78
32
}
79
33
80
- func getImpactedProjectsAsString (projects []digger_config.Project , prNumber int ) string {
81
- msg := fmt .Sprintf ("Following projects are impacted by pull request #%d\n " , prNumber )
82
- for _ , p := range projects {
83
- msg += fmt .Sprintf ("- %s\n " , p .Name )
84
- }
85
- return msg
86
- }
87
-
88
- func logCommands (projectCommands []scheduler.Job ) {
89
- logMessage := fmt .Sprintf ("Following commands are going to be executed:\n " )
90
- for _ , pc := range projectCommands {
91
- logMessage += fmt .Sprintf ("project: %s: commands: " , pc .ProjectName )
92
- for _ , c := range pc .Commands {
93
- logMessage += fmt .Sprintf ("\" %s\" , " , c )
94
- }
95
- logMessage += "\n "
96
- }
97
- log .Print (logMessage )
98
- }
99
-
100
34
func init () {
101
35
log .SetOutput (os .Stdout )
102
36
0 commit comments