|
Packit |
63bb0d |
package main
|
|
Packit |
63bb0d |
|
|
Packit |
63bb0d |
import (
|
|
Packit Service |
509fd4 |
"bytes"
|
|
Packit |
63bb0d |
"encoding/json"
|
|
Packit |
63bb0d |
"fmt"
|
|
Packit |
63bb0d |
"io"
|
|
Packit |
63bb0d |
"os/exec"
|
|
Packit |
63bb0d |
|
|
Packit |
63bb0d |
"github.com/osbuild/osbuild-composer/internal/distro"
|
|
Packit Service |
509fd4 |
"github.com/osbuild/osbuild-composer/internal/osbuild"
|
|
Packit |
63bb0d |
)
|
|
Packit |
63bb0d |
|
|
Packit Service |
509fd4 |
// Run an instance of osbuild, returning a parsed osbuild.Result.
|
|
Packit Service |
509fd4 |
//
|
|
Packit Service |
509fd4 |
// Note that osbuild returns non-zero when the pipeline fails. This function
|
|
Packit Service |
509fd4 |
// does not return an error in this case. Instead, the failure is communicated
|
|
Packit Service |
509fd4 |
// with its corresponding logs through osbuild.Result.
|
|
Packit Service |
509fd4 |
func RunOSBuild(manifest distro.Manifest, store, outputDirectory string, errorWriter io.Writer) (*osbuild.Result, error) {
|
|
Packit |
63bb0d |
cmd := exec.Command(
|
|
Packit |
63bb0d |
"osbuild",
|
|
Packit |
63bb0d |
"--store", store,
|
|
Packit |
63bb0d |
"--output-directory", outputDirectory,
|
|
Packit |
63bb0d |
"--json", "-",
|
|
Packit |
63bb0d |
)
|
|
Packit |
63bb0d |
cmd.Stderr = errorWriter
|
|
Packit |
63bb0d |
|
|
Packit |
63bb0d |
stdin, err := cmd.StdinPipe()
|
|
Packit |
63bb0d |
if err != nil {
|
|
Packit |
63bb0d |
return nil, fmt.Errorf("error setting up stdin for osbuild: %v", err)
|
|
Packit |
63bb0d |
}
|
|
Packit |
63bb0d |
|
|
Packit Service |
509fd4 |
var stdoutBuffer bytes.Buffer
|
|
Packit Service |
509fd4 |
cmd.Stdout = &stdoutBuffer
|
|
Packit |
63bb0d |
|
|
Packit |
63bb0d |
err = cmd.Start()
|
|
Packit |
63bb0d |
if err != nil {
|
|
Packit |
63bb0d |
return nil, fmt.Errorf("error starting osbuild: %v", err)
|
|
Packit |
63bb0d |
}
|
|
Packit |
63bb0d |
|
|
Packit |
63bb0d |
err = json.NewEncoder(stdin).Encode(manifest)
|
|
Packit |
63bb0d |
if err != nil {
|
|
Packit |
63bb0d |
return nil, fmt.Errorf("error encoding osbuild pipeline: %v", err)
|
|
Packit |
63bb0d |
}
|
|
Packit |
63bb0d |
|
|
Packit Service |
509fd4 |
err = stdin.Close()
|
|
Packit |
63bb0d |
if err != nil {
|
|
Packit Service |
509fd4 |
return nil, fmt.Errorf("error closing osbuild's stdin: %v", err)
|
|
Packit |
63bb0d |
}
|
|
Packit |
63bb0d |
|
|
Packit |
63bb0d |
err = cmd.Wait()
|
|
Packit Service |
509fd4 |
|
|
Packit Service |
509fd4 |
// try to decode the output even though the job could have failed
|
|
Packit Service |
509fd4 |
var result osbuild.Result
|
|
Packit Service |
509fd4 |
decodeErr := json.Unmarshal(stdoutBuffer.Bytes(), &result)
|
|
Packit Service |
509fd4 |
if decodeErr != nil {
|
|
Packit Service |
509fd4 |
return nil, fmt.Errorf("error decoding osbuild output: %v\nthe raw output:\n%s", decodeErr, stdoutBuffer.String())
|
|
Packit Service |
509fd4 |
}
|
|
Packit Service |
509fd4 |
|
|
Packit |
63bb0d |
if err != nil {
|
|
Packit Service |
509fd4 |
// ignore ExitError if output could be decoded correctly
|
|
Packit Service |
509fd4 |
if _, isExitError := err.(*exec.ExitError); !isExitError {
|
|
Packit Service |
509fd4 |
return nil, fmt.Errorf("running osbuild failed: %v", err)
|
|
Packit |
63bb0d |
}
|
|
Packit |
63bb0d |
}
|
|
Packit |
63bb0d |
|
|
Packit |
63bb0d |
return &result, nil
|
|
Packit |
63bb0d |
}
|