jschoubben
9c57f7afb3
The runner, the toolchain guard, the fetch, the parsers, buildcpu, the conformance kit and mesh-pack move from mesh-sdk's buildstep into modules/mesh-build-go/buildstep (own go.mod). mesh-build-go, mesh-build-node and mesh-build-image require it by a same-repository replace; what the delivery parts read (the failure contract, the fetch request, the stale sweep, the module tree shape, NewID, CapacitySetting) stays imported from mesh-sdk as sdkstep. Claude-Session: https://claude.ai/code/session_01NcbgfJ9Gum47zkFKWRaovL
43 lines
1.5 KiB
Go
43 lines
1.5 KiB
Go
package main
|
|
|
|
// The push of a done build's archive (novox/hq ADR 0498 §1 §2; issue 1587): from this module's own process, after the
|
|
// build step ended, with mesh-sdk's one client (buildstep.PushBlob), to the artifact store whose address the manifest
|
|
// binds into RegistryFile. No build step reaches the store: a run step has no network (ADR 0448).
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"net/http"
|
|
"os"
|
|
"strings"
|
|
"time"
|
|
|
|
"git.novox.be/novox/mesh-catalog/modules/mesh-build-go/buildstep"
|
|
)
|
|
|
|
// registry is the artifact store's address, host:port, as the manifest bound it into RegistryFile.
|
|
func (m *Module) registry() (string, error) {
|
|
raw, err := os.ReadFile(m.RegistryFile)
|
|
if err != nil {
|
|
return "", fmt.Errorf("the artifact store's address cannot be read: %w", err)
|
|
}
|
|
addr := strings.TrimSpace(string(raw))
|
|
if addr == "" || strings.Contains(addr, "${") || strings.HasPrefix(addr, ":") || strings.HasSuffix(addr, ":") {
|
|
return "", fmt.Errorf("the artifact store's address in %s is %q, not host:port", m.RegistryFile, addr)
|
|
}
|
|
return addr, nil
|
|
}
|
|
|
|
// push puts body into the artifact store as a blob of repository (<module>/<artifact>) by its digest: Push when a test
|
|
// set it, else buildstep.PushBlob.
|
|
func (m *Module) push(ctx context.Context, repository, digest string, body []byte) error {
|
|
addr, err := m.registry()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if m.Push != nil {
|
|
return m.Push(ctx, addr, repository, digest, body)
|
|
}
|
|
return buildstep.PushBlob(ctx, &http.Client{Timeout: 10 * time.Minute}, addr, repository, digest, body)
|
|
}
|