base.go

package msm

import "reflect"

type State string               // Name of state ; ToDo: make States able to contain their sub-FSM
type Event interface{}          // pointer to any struct, json'able
type RequestPayload interface{} // pointer to any struct, json'able
type DstNotFound struct{}       // Event, generated if sent request with wrong destination

type Action interface{} // func(fsm *Fsm, state State, source string, event Event)
type Guard interface{}  // func(fsm *Fsm, state State, source string, event Event) bool

type Storage interface{} // DO NOT USE OBJECTS WITH TAG "json:-"

type StorageFactory interface{} // func() Storage

type None struct{} // Anonymous action, fired immediately after entering state

type TerminationCB func(id FsmID, state State)

const (
	StartState  State = "start"
	FinishState State = "finish"
)

var (
	NoAction         Action         = func(fsm *FSMInstance, storage Storage, state State, source string, event Event) {}
	NoGuard          Guard          = func(fsm *FSMInstance, storage Storage, state State, source string, event Event) bool { return true }
	NoStorageFactory StorageFactory = func() Storage { return &struct{}{} }
)

type TransitionKey struct {
	State State
	Event reflect.Type
}

type TransitionValue struct {
	NewState State
	Action   Action
	Guard    Guard
}

type Transition struct {
	TransitionKey
	TransitionValue
}

type FsmID struct {
	Fsm string
	Id  int64
}

type Response struct {
	ID     FsmID
	Source string
	Event  Event // json
}

type ICallback interface {
	NoTransition(fsm *FSMInstance, state State, source string, event Event)
	ChangeState(fsm *FSMInstance, state State, source string, event Event, newState State)
	AutoMigrate() error
}

type IPlugin interface {
	Name() string
	Process(fsm *FSMInstance, request RequestPayload)
	Finish(fsm *FSMInstance)
	AutoMigrate() error
}

type IFSMManager interface {
	CreateFSMInstance(fsmName string) FsmID
	Process(id FsmID, src string, event Event)
	IsTerminated(id FsmID) bool
	AutoMigrate() error
}

type TimeoutEvent struct {
}

type Ponger struct {
	Event
	ch chan struct{}
}

func (p *Ponger) Pong() {
	close(p.ch)
}