mirror of
https://github.com/goreleaser/goreleaser.git
synced 2025-01-24 04:16:27 +02:00
c2adc1727f
it was missing the digest parsing for the manifest, and there were no tests covering it. now the tests are there, and so is the fix. refs #3599
97 lines
2.5 KiB
Go
97 lines
2.5 KiB
Go
package docker
|
|
|
|
import (
|
|
"bytes"
|
|
"fmt"
|
|
"io"
|
|
"os/exec"
|
|
"sync"
|
|
|
|
"github.com/caarlos0/log"
|
|
"github.com/goreleaser/goreleaser/internal/gio"
|
|
"github.com/goreleaser/goreleaser/internal/logext"
|
|
"github.com/goreleaser/goreleaser/pkg/context"
|
|
)
|
|
|
|
var (
|
|
manifesters = map[string]manifester{}
|
|
imagers = map[string]imager{}
|
|
lock sync.Mutex
|
|
)
|
|
|
|
func registerManifester(use string, impl manifester) {
|
|
lock.Lock()
|
|
defer lock.Unlock()
|
|
manifesters[use] = impl
|
|
}
|
|
|
|
func registerImager(use string, impl imager) {
|
|
lock.Lock()
|
|
defer lock.Unlock()
|
|
imagers[use] = impl
|
|
}
|
|
|
|
// imager is something that can build and push docker images.
|
|
type imager interface {
|
|
Build(ctx *context.Context, root string, images, flags []string) error
|
|
Push(ctx *context.Context, image string, flags []string) (digest string, err error)
|
|
}
|
|
|
|
// manifester is something that can create and push docker manifests.
|
|
type manifester interface {
|
|
Create(ctx *context.Context, manifest string, images, flags []string) error
|
|
Push(ctx *context.Context, manifest string, flags []string) (digest string, err error)
|
|
}
|
|
|
|
// nolint: unparam
|
|
func runCommand(ctx *context.Context, dir, binary string, args ...string) error {
|
|
fields := log.Fields{
|
|
"cmd": append([]string{binary}, args[0]),
|
|
"cwd": dir,
|
|
}
|
|
|
|
/* #nosec */
|
|
cmd := exec.CommandContext(ctx, binary, args...)
|
|
cmd.Dir = dir
|
|
cmd.Env = ctx.Env.Strings()
|
|
|
|
var b bytes.Buffer
|
|
w := gio.Safe(&b)
|
|
cmd.Stderr = io.MultiWriter(logext.NewWriter(fields, logext.Error), w)
|
|
cmd.Stdout = io.MultiWriter(logext.NewWriter(fields, logext.Info), w)
|
|
|
|
log.WithFields(fields).WithField("args", args[1:]).Debug("running")
|
|
if err := cmd.Run(); err != nil {
|
|
return fmt.Errorf("%w: %s", err, b.String())
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func runCommandWithOutput(ctx *context.Context, dir, binary string, args ...string) ([]byte, error) {
|
|
fields := log.Fields{
|
|
"cmd": append([]string{binary}, args[0]),
|
|
"cwd": dir,
|
|
}
|
|
|
|
/* #nosec */
|
|
cmd := exec.CommandContext(ctx, binary, args...)
|
|
cmd.Dir = dir
|
|
cmd.Env = ctx.Env.Strings()
|
|
|
|
var b bytes.Buffer
|
|
w := gio.Safe(&b)
|
|
cmd.Stderr = io.MultiWriter(logext.NewWriter(fields, logext.Error), w)
|
|
|
|
log.WithFields(fields).WithField("args", args[1:]).Debug("running")
|
|
out, err := cmd.Output()
|
|
if out != nil {
|
|
// regardless of command success, always print stdout for backward-compatibility with runCommand()
|
|
_, _ = io.MultiWriter(logext.NewWriter(fields, logext.Error), w).Write(out)
|
|
}
|
|
if err != nil {
|
|
return nil, fmt.Errorf("%w: %s", err, b.String())
|
|
}
|
|
|
|
return out, nil
|
|
}
|