plugin.go

package msm

import (
	"fmt"

	"go.uber.org/zap"
)

type ErrorResponse struct {
	Reason string
}

type PluginMockCB func(m IFSMManager, fi *FSMInstance, request RequestPayload)

type PluginMock struct {
	Manager IFSMManager
	cb      PluginMockCB
	name    string
	log     *zap.Logger
}

func PluginMockNew(manager IFSMManager, name string, cb PluginMockCB, logger *zap.Logger) *PluginMock {
	p := &PluginMock{
		Manager: manager,
		cb:      cb,
		name:    name,
		log:     logger.Named(fmt.Sprintf("mock-%s", name)),
	}

	return p
}

func (p *PluginMock) AutoMigrate() error {
	return nil
}

func (p *PluginMock) Name() string {
	return p.name
}

func (p *PluginMock) Process(fi *FSMInstance, request RequestPayload) {
	p.cb(p.Manager, fi, request)
}

func (p *PluginMock) Finish(fi *FSMInstance) {
}