feat/get spec endpoint (#1615)

* add getspec endpoint and ability to perform remote execution

Author: motatoes

backend/services/spec.go

@@ -68,6 +68,7 @@ func GetSpecFromJob(job models.DiggerJob) (*spec.Spec, error) {
 	batch := job.Batch
 
 	spec := spec.Spec{
+		SpecType:  spec.SpecTypePullRequestJob,
 		JobId:     job.DiggerJobID,
 		CommentId: strconv.FormatInt(*batch.CommentId, 10),
 		Job:       jobSpec,

cli/pkg/spec/spec.go

@@ -4,10 +4,13 @@ import (
 	"fmt"
 	"github.com/diggerhq/digger/cli/pkg/digger"
 	"github.com/diggerhq/digger/cli/pkg/usage"
+	"github.com/diggerhq/digger/libs/ci"
+	"github.com/diggerhq/digger/libs/comment_utils/reporting"
 	comment_summary "github.com/diggerhq/digger/libs/comment_utils/summary"
 	"github.com/diggerhq/digger/libs/digger_config"
 	"github.com/diggerhq/digger/libs/scheduler"
 	"github.com/diggerhq/digger/libs/spec"
+	"github.com/diggerhq/digger/libs/storage"
 	"log"
 	"os"
 	"time"
@@ -113,3 +116,90 @@ func RunSpec(
 
 	return nil
 }
+
+func RunSpecManualCommand(
+	spec spec.Spec,
+	vcsProvider spec.VCSProvider,
+	jobProvider spec.JobSpecProvider,
+	lockProvider spec.LockProvider,
+	reporterProvider spec.ReporterProvider,
+	backedProvider spec.BackendApiProvider,
+	policyProvider spec.SpecPolicyProvider,
+	PlanStorageProvider spec.PlanStorageProvider,
+	commentUpdaterProvider comment_summary.CommentUpdaterProvider,
+) error {
+
+	job, err := jobProvider.GetJob(spec.Job)
+	if err != nil {
+		usage.ReportErrorAndExit(spec.VCS.Actor, fmt.Sprintf("could not get job: %v", err), 1)
+	}
+
+	lock, err := lockProvider.GetLock(spec.Lock)
+	if err != nil {
+		usage.ReportErrorAndExit(spec.VCS.Actor, fmt.Sprintf("could not get job: %v", err), 1)
+
+	}
+
+	//prService, err := vcsProvider.GetPrService(spec.VCS)
+	//if err != nil {
+	//	usage.ReportErrorAndExit(spec.VCS.Actor, fmt.Sprintf("could not get prservice: %v", err), 1)
+	//}
+
+	var prService ci.PullRequestService = ci.MockPullRequestManager{}
+	//orgService, err := vcsProvider.GetOrgService(spec.VCS)
+	//if err != nil {
+	//	usage.ReportErrorAndExit(spec.VCS.Actor, fmt.Sprintf("could not get orgservice: %v", err), 1)
+	//}
+	var orgService ci.OrgService = ci.MockPullRequestManager{}
+
+	//reporter, err := reporterProvider.GetReporter(spec.Reporter, prService, *spec.Job.PullRequestNumber)
+	//if err != nil {
+	//	usage.ReportErrorAndExit(spec.VCS.Actor, fmt.Sprintf("could not get reporter: %v", err), 1)
+	//}
+	reporter := reporting.StdOutReporter{}
+
+	backendApi, err := backedProvider.GetBackendApi(spec.Backend)
+	if err != nil {
+		usage.ReportErrorAndExit(spec.VCS.Actor, fmt.Sprintf("could not get backend api: %v", err), 1)
+	}
+
+	policyChecker, err := policyProvider.GetPolicyProvider(spec.Policy, spec.Backend.BackendHostname, spec.Backend.BackendOrganisationName, spec.Backend.BackendJobToken)
+	if err != nil {
+		usage.ReportErrorAndExit(spec.VCS.Actor, fmt.Sprintf("could not get policy provider: %v", err), 1)
+	}
+
+	//planStorage, err := PlanStorageProvider.GetPlanStorage(spec.VCS.RepoOwner, spec.VCS.RepoName, *spec.Job.PullRequestNumber)
+	//if err != nil {
+	//	usage.ReportErrorAndExit(spec.VCS.Actor, fmt.Sprintf("could not get plan storage: %v", err), 8)
+	//}
+	planStorage := storage.MockPlanStorage{}
+
+	jobs := []scheduler.Job{job}
+
+	fullRepoName := fmt.Sprintf("%v-%v", spec.VCS.RepoOwner, spec.VCS.RepoName)
+	_, err = backendApi.ReportProjectJobStatus(fullRepoName, spec.Job.ProjectName, spec.JobId, "started", time.Now(), nil, "", "")
+	if err != nil {
+		usage.ReportErrorAndExit(spec.VCS.Actor, fmt.Sprintf("Failed to report jobSpec status to backend. Exiting. %v", err), 4)
+	}
+
+	commentId := spec.CommentId
+	if err != nil {
+		usage.ReportErrorAndExit(spec.VCS.Actor, fmt.Sprintf("failed to get comment ID: %v", err), 4)
+	}
+
+	currentDir, err := os.Getwd()
+	if err != nil {
+		usage.ReportErrorAndExit(spec.VCS.Actor, fmt.Sprintf("Failed to get current dir. %s", err), 4)
+	}
+
+	commentUpdater := comment_summary.NoopCommentUpdater{}
+	// TODO: do not require conversion to gh service
+	allAppliesSuccess, _, err := digger.RunJobs(jobs, prService, orgService, lock, reporter, planStorage, policyChecker, commentUpdater, backendApi, spec.JobId, false, false, commentId, currentDir)
+	if err != nil || allAppliesSuccess == false {
+		usage.ReportErrorAndExit(spec.VCS.RepoOwner, "Terraform execution failed", 1)
+	}
+
+	usage.ReportErrorAndExit(spec.VCS.RepoOwner, "Digger finished successfully", 0)
+
+	return nil
+}

dgctl/.gitignore

@@ -1,4 +1,5 @@
 .archive
 generated/
 dgctl.generated.json
-.dgctl
+.dgctl
+dgctl