outis.go

package outis

import (
	"encoding/json"
	"fmt"
	"math/rand"
	"strconv"
)

type server struct{}

func newOutis() IOutis { return &server{} }

func (server) Go(fn func() error) { fn() }
func (server) Wait() error        { return nil }

// Init implements a business rule when initializing a routine
func (server) Init(ctx *Context) error {
	ctx.Info(fmt.Sprintf("script '%s' (rid: %s) initialized", ctx.Name, ctx.RoutineID))
	return nil
}

// Before implements a business rule before initializing script execution
func (server) Before(ctx *Context) error {
	ctx.Id = ID(strconv.FormatInt(rand.Int63(), 10))
	ctx.Info(fmt.Sprintf("script '%s' (rid: %s, id: %s) initialized", ctx.Name, ctx.RoutineID, ctx.Id))
	return nil
}

// After implements a business rule after initializing script execution
func (server) After(ctx *Context) error {
	ctx.Info(fmt.Sprintf("script '%s' (rid: %s, id: %s) finished", ctx.Name, ctx.RoutineID, ctx.Id))
	return nil
}

// Event implements a business rule for event handling
func (server) Event(ctx *Context, event Event) {
	if metric, ok := event.(EventMetric); ok {
		value, _ := json.Marshal(metric)
		ctx.Debug(string(value))
	}
}