mesh-catalog/modules/mesh-build-go/buildstep/step.go

// Package buildstep is what the build modules share: the runner of a long step that answers a tool call at once
// and ends on its key in the module's `steps` state (novox/hq ADR 0469 §2; issue 1471), the toolchain guard
// (issue 1473), the fetch of one commit over SSH (issue 1474), and the failure contract of a test level with the parsers
// of go test -json and node --test's TAP that fill it (failure.go, issue 1901; its conformance kit is package conformance).
package buildstep

import (
	"context"
	"encoding/json"
	"errors"
	"fmt"
	"log"
	"time"

	sdkstep "git.novox.be/novox/mesh-sdk/go/buildstep"
	"git.novox.be/novox/mesh-sdk/go/delivery"
)

// Put writes one key of a state: stdio.State(delivery.StepsState).Put's shape (go/state.go).
type Put func(key string, value any) (uint64, error)

// EndAttempts and EndRetry bound how a step's end is written: a write that fails is tried again, since the end
// is the only way the step's reader learns it is over.
var (
	EndAttempts = 5
	EndRetry    = 2 * time.Second
)

var now = time.Now

// Start begins a step of tool on node and answers its id at once: the key <node>.<id> holds state running when
// Start returns. run is then called in a goroutine of its own, under ctx (the process's, not the tool call's: the
// call is cut at 30 s, the step is not). When it returns, the key is written passed with run's result, failed with
// the error's text, or refused when the error is a *Refusal; a panic in run ends the step failed, naming it, and
// the process goes on. If the running write fails, nothing was started and Start answers the error.
func Start(ctx context.Context, put Put, node, tool string, run func(ctx context.Context) (result any, err error)) (string, error) {
	step, key, err := begin(put, node, tool, sdkstep.NewID(), "")
	if err != nil {
		return "", err
	}
	go end(ctx, put, key, step, run)
	return step.ID, nil
}

// begin writes the step running under id, owned by this process (Owner).
func begin(put Put, node, tool, id, what string) (delivery.Step, string, error) {
	step := delivery.Step{ID: id, Tool: tool, Node: node, State: delivery.StepRunning, Started: now().UTC(), What: what, Owner: sdkstep.Owner}
	key, err := delivery.StepKey(node, step.ID)
	if err != nil {
		return delivery.Step{}, "", err
	}
	if err := write(put, key, step); err != nil {
		return delivery.Step{}, "", fmt.Errorf("buildstep: writing the running step %s: %w", key, err)
	}
	return step, key, nil
}

// end runs run and writes the step's end.
func end(ctx context.Context, put Put, key string, step delivery.Step, run func(ctx context.Context) (any, error)) {
	result, err := protect(ctx, run)
	_ = finish(put, key, step, result, err, log.Printf) // finish says a refused end itself
}

// finish writes the step's end from run's result or error: passed, failed or refused (a *Refusal). A write that fails is
// tried EndAttempts times. When the whole end is refused every time (a result the state will not take: issue 1930), the
// refusal is logged and a small failed end without the result is written instead, naming the write's error, so the
// step's reader learns it is over and why. finish answers an error only when no end could be written at all, and then
// the step's ask is not acknowledged as done.
func finish(put Put, key string, step delivery.Step, result any, err error, logf func(format string, args ...any)) error {
	step.Ended = now().UTC()
	switch ref := (*Refusal)(nil); {
	case err == nil:
		step.State = delivery.StepPassed
		if result != nil {
			raw, merr := json.Marshal(result)
			if merr != nil {
				step.State, step.Reason = delivery.StepFailed, "the result is not JSON: "+merr.Error()
			} else {
				step.Result = raw
			}
		}
	case errors.As(err, &ref):
		step.State, step.Reason = delivery.StepRefused, err.Error()
	default:
		step.State, step.Reason = delivery.StepFailed, err.Error()
	}
	werr := writeEnd(put, key, step)
	if werr == nil {
		return nil
	}
	if logf != nil {
		logf("the end of the step %s (%s) could not be written in %d tries: %v", key, step.State, EndAttempts, werr)
	}
	ended := step.State
	why := fmt.Sprintf("the step ended %s, and its end could not be written: %v", ended, werr)
	if step.Reason != "" {
		why = fmt.Sprintf("the step ended %s (%s), and its end could not be written: %v", ended, step.Reason, werr)
	}
	step.State, step.Reason, step.Result = delivery.StepFailed, why, nil
	if ferr := writeEnd(put, key, step); ferr != nil {
		if logf != nil {
			logf("the failed end of the step %s could not be written either: %v", key, ferr)
		}
		return fmt.Errorf("buildstep: no end of the step %s could be written: %w", key, ferr)
	}
	return nil
}

// writeEnd writes the step's end, trying EndAttempts times.
func writeEnd(put Put, key string, step delivery.Step) error {
	for attempt := 1; ; attempt++ {
		werr := write(put, key, step)
		if werr == nil || attempt >= EndAttempts {
			return werr
		}
		time.Sleep(EndRetry)
	}
}

// protect is run with a panic turned into the error that ends the step.
func protect(ctx context.Context, run func(ctx context.Context) (any, error)) (result any, err error) {
	defer func() {
		if p := recover(); p != nil {
			result, err = nil, fmt.Errorf("the step panicked: %v", p)
		}
	}()
	return run(ctx)
}

func write(put Put, key string, step delivery.Step) error {
	raw, err := delivery.EncodeStep(step)
	if err != nil {
		return err
	}
	_, err = put(key, json.RawMessage(raw))
	return err
}