[werft] Added werft compatible reporter

Author: Christian Weichel

cmd/build.go

@@ -85,11 +85,23 @@ var buildCmd = &cobra.Command{
 			}
 		}
 
+		werftlog, err := cmd.Flags().GetBool("werft")
+		if err != nil {
+			log.Fatal(err)
+		}
+		var reporter leeway.Reporter
+		if werftlog {
+			reporter = leeway.NewWerftReporter()
+		} else {
+			reporter = leeway.NewConsoleReporter()
+		}
+
 		err = leeway.Build(pkg,
 			leeway.WithLocalCache(localCache),
 			leeway.WithRemoteCache(remoteCache),
 			leeway.WithDryRun(dryrun),
 			leeway.WithBuildPlan(planOutlet),
+			leeway.WithReporter(reporter),
 		)
 		if err != nil {
 			log.Fatal(err)
@@ -157,6 +169,7 @@ func init() {
 	buildCmd.Flags().String("serve", "", "After a successful build this starts a webserver on the given address serving the build result (e.g. --serve localhost:8080)")
 	buildCmd.Flags().String("save", "", "After a successful build this saves the build result as tar.gz file in the local filesystem (e.g. --save build-result.tar.gz)")
 	buildCmd.Flags().String("dump-plan", "", "Writes the build plan as JSON to a file. Use \"-\" to write the build plan to stderr.")
+	buildCmd.Flags().Bool("werft", false, "Produce werft CI compatible output")
 }
 
 type pushOnlyRemoteCache struct {

pkg/leeway/reporter.go

@@ -164,3 +164,52 @@ func (r *ConsoleReporter) PackageBuildFinished(pkg *Package, err error) {
 func getRunPrefix(p *Package) string {
 	return color.Gray.Render(fmt.Sprintf("[%s] ", p.FullName()))
 }
+
+// NewWerftReporter craetes a new werft compatible reporter
+func NewWerftReporter() *WerftReporter {
+	return &WerftReporter{
+		ConsoleReporter: NewConsoleReporter(),
+	}
+}
+
+// WerftReporter works like the console reporter but adds werft output
+type WerftReporter struct {
+	*ConsoleReporter
+}
+
+// BuildStarted is called when the build of a package is started by the user.
+func (r *WerftReporter) BuildStarted(pkg *Package, status map[*Package]PackageBuildStatus) {
+	r.ConsoleReporter.BuildStarted(pkg, status)
+
+	for p, s := range status {
+		if s != PackageNotBuiltYet {
+			continue
+		}
+
+		fmt.Printf("[%s|START] will be built\n", p.FullName())
+	}
+}
+
+// PackageBuildFinished is called when the package build has finished.
+func (r *WerftReporter) PackageBuildFinished(pkg *Package, err error) {
+	r.ConsoleReporter.PackageBuildFinished(pkg, err)
+
+	if cfg, ok := pkg.Config.(DockerPkgConfig); ok && pkg.Type == DockerPackage {
+		for _, img := range cfg.Image {
+			fmt.Printf("[docker|RESULT] %s\n", img)
+		}
+	}
+
+	var (
+		status string
+		msg    string
+	)
+	if err == nil {
+		status = "DONE"
+		msg = "build succeeded"
+	} else {
+		status = "FAIL"
+		msg = err.Error()
+	}
+	fmt.Printf("[%s|%s] %s\n", pkg.FullName(), status, msg)
+}