spindle/engines: add dummy engine that logs to stdout #1263

+1

.gitignore

reviewed

··· 24 24 blog/build/ 25 25 build/ 26 26 .wrangler/ 27 27 + .claude/

+92

spindle/engines/dummy/engine.go

reviewed

··· 1 1 + package dummy 2 2 + 3 3 + import ( 4 4 + "context" 5 5 + "fmt" 6 6 + "log/slog" 7 7 + "time" 8 8 + 9 9 + "gopkg.in/yaml.v3" 10 10 + "tangled.org/core/api/tangled" 11 11 + "tangled.org/core/spindle/models" 12 12 + "tangled.org/core/spindle/secrets" 13 13 + ) 14 14 + 15 15 + // DummyEngine is a no-op engine that logs all lifecycle events via slog and writes 16 16 + // step output to the workflow logger. Useful for testing pipeline plumbing 17 17 + // without a real execution backend. 18 18 + type DummyEngine struct { 19 19 + l *slog.Logger 20 20 + } 21 21 + 22 22 + func New(l *slog.Logger) *DummyEngine { 23 23 + return &DummyEngine{l: l.With("engine", "dummy")} 24 24 + } 25 25 + 26 26 + type Step struct { 27 27 + name string 28 28 + kind models.StepKind 29 29 + command string 30 30 + } 31 31 + 32 32 + func (s Step) Name() string { return s.name } 33 33 + func (s Step) Command() string { return s.command } 34 34 + func (s Step) Kind() models.StepKind { return s.kind } 35 35 + 36 36 + func (e *DummyEngine) InitWorkflow(twf tangled.Pipeline_Workflow, _ tangled.Pipeline) (*models.Workflow, error) { 37 37 + dwf := &struct { 38 38 + Steps []struct { 39 39 + Name string `yaml:"name"` 40 40 + Command string `yaml:"command"` 41 41 + } `yaml:"steps"` 42 42 + Environment map[string]string `yaml:"environment"` 43 43 + }{} 44 44 + 45 45 + if err := yaml.Unmarshal([]byte(twf.Raw), dwf); err != nil { 46 46 + return nil, err 47 47 + } 48 48 + 49 49 + wf := &models.Workflow{ 50 50 + Name: twf.Name, 51 51 + Environment: dwf.Environment, 52 52 + } 53 53 + for _, ds := range dwf.Steps { 54 54 + wf.Steps = append(wf.Steps, Step{ 55 55 + name: ds.Name, 56 56 + kind: models.StepKindUser, 57 57 + command: ds.Command, 58 58 + }) 59 59 + } 60 60 + 61 61 + e.l.Info("workflow initialised", "name", twf.Name, "steps", len(wf.Steps)) 62 62 + return wf, nil 63 63 + } 64 64 + 65 65 + func (e *DummyEngine) SetupWorkflow(_ context.Context, wid models.WorkflowId, wf *models.Workflow, wfLogger models.WorkflowLogger) error { 66 66 + e.l.Info("setting up workflow", "wid", wid) 67 67 + 68 68 + setupStep := Step{name: "dummy setup", kind: models.StepKindSystem} 69 69 + const setupIdx = -1 70 70 + 71 71 + wfLogger.ControlWriter(setupIdx, setupStep, models.StepStatusStart).Write([]byte{0}) 72 72 + defer wfLogger.ControlWriter(setupIdx, setupStep, models.StepStatusEnd).Write([]byte{0}) 73 73 + 74 74 + fmt.Fprintf(wfLogger.DataWriter(setupIdx, "stdout"), "dummy engine: workflow %q ready", wf.Name) 75 75 + return nil 76 76 + } 77 77 + 78 78 + func (e *DummyEngine) WorkflowTimeout() time.Duration { 79 79 + return 5 * time.Minute 80 80 + } 81 81 + 82 82 + func (e *DummyEngine) DestroyWorkflow(_ context.Context, wid models.WorkflowId) error { 83 83 + e.l.Info("destroying workflow", "wid", wid) 84 84 + return nil 85 85 + } 86 86 + 87 87 + func (e *DummyEngine) RunStep(_ context.Context, wid models.WorkflowId, w *models.Workflow, idx int, _ []secrets.UnlockedSecret, wfLogger models.WorkflowLogger) error { 88 88 + step := w.Steps[idx] 89 89 + e.l.Info("running step", "wid", wid, "step", step.Name(), "command", step.Command()) 90 90 + fmt.Fprintf(wfLogger.DataWriter(idx, "stdout"), "$ %s", step.Command()) 91 91 + return nil 92 92 + }

+2

spindle/server.go

reviewed

··· 22 22 "tangled.org/core/spindle/config" 23 23 "tangled.org/core/spindle/db" 24 24 "tangled.org/core/spindle/engine" 25 25 + "tangled.org/core/spindle/engines/dummy" 25 26 "tangled.org/core/spindle/engines/nixery" 26 27 "tangled.org/core/spindle/models" 27 28 "tangled.org/core/spindle/queue" ··· 252 253 253 254 s, err := New(ctx, cfg, map[string]models.Engine{ 254 255 "nixery": nixeryEng, 256 256 + "dummy": dummy.New(log.FromContext(ctx)), 255 257 }) 256 258 if err != nil { 257 259 return err