tork Job middleware #1

tork-job-middleware-1.go

package main

import (
	"context"
	"fmt"
	"os"

	"github.com/runabol/tork/cli"
	"github.com/runabol/tork/conf"
	"github.com/runabol/tork/engine"
	"github.com/rs/zerolog/log"
	"github.com/runabol/tork"
	"github.com/runabol/tork/middleware/job"
)

func main() {
	if err := conf.LoadConfig(); err != nil {
		fmt.Println(err)
		os.Exit(1)
	}

	mw := func(next job.HandlerFunc) job.HandlerFunc {
		return func(ctx context.Context, et job.EventType, j *tork.Job) error {
			log.Debug().
				Msgf("received job %s at state %s (%s)", j.ID, j.State, et)
			return next(ctx, et, j)
		}
	}

	engine.RegisterJobMiddleware(mw)

	if err := cli.New().Run(); err != nil {
		fmt.Println(err)
		os.Exit(1)
	}
}

Job with a failed task

name: my failing job
tasks:
  - name: my first task
    run: echo hello world
  - name: do some real work
    run: exit 1
  - name: my second task
    run: echo bye world

Relevant output from middleware (no RUNNING state)

{"level":"debug","time":1702025778,"message":"received job ed83c87901d24b14a7ed44735b130a8a at state PENDING (STATE_CHANGE)"}
{"level":"debug","time":1702025778,"message":"received job ed83c87901d24b14a7ed44735b130a8a at state FAILED (STATE_CHANGE)"}
{"level":"debug","time":1702025779,"message":"received job ed83c87901d24b14a7ed44735b130a8a at state FAILED (READ)"}
{"level":"debug","time":1702026006,"message":"received job ed83c87901d24b14a7ed44735b130a8a at state FAILED (READ)"}

Successful job

name: my job
tasks:
  - name: my first task
    run: echo hello world
  - name: do some real work
    run: sleep 5
  - name: my second task
    run: echo bye world

Relevant output from middleware (no STATE_CHANGE -> RUNNING)

"level":"debug","time":1702026162,"message":"received job dd1349b191cf4840afa3ead0655efabb at state PENDING (STATE_CHANGE)"}
{"level":"debug","time":1702026162,"message":"received job dd1349b191cf4840afa3ead0655efabb at state RUNNING (READ)"}
{"level":"debug","time":1702026163,"message":"received job dd1349b191cf4840afa3ead0655efabb at state RUNNING (READ)"}
{"level":"debug","time":1702026167,"message":"received job dd1349b191cf4840afa3ead0655efabb at state COMPLETED (STATE_CHANGE)"}