summaryrefslogtreecommitdiff
path: root/src/state.go
diff options
context:
space:
mode:
Diffstat (limited to 'src/state.go')
-rw-r--r--src/state.go33
1 files changed, 12 insertions, 21 deletions
diff --git a/src/state.go b/src/state.go
index 5970ba8..10c35ef 100644
--- a/src/state.go
+++ b/src/state.go
@@ -4,7 +4,6 @@ package main
import (
"log"
- "time"
)
// This struct represents the statemachine.
@@ -15,6 +14,7 @@ type Machine struct {
states StateMap
api chan string
state_listeners []*(chan string)
+ hook HookFunction
}
type StateMap map[string]MachineState
@@ -29,6 +29,8 @@ type MachineTransition struct {
to string
}
+type HookFunction func(string, string)
+
// This will run the statemachine (blocking).
func (m *Machine) Run() {
var event string
@@ -100,28 +102,17 @@ func (m *Machine) deregisterListener(listener *(chan string)) {
func (m *Machine) processEvent(event string) string {
current := m.GetState()
next := m.states[current].on[event].to
- if next != "" {
+ if next != "" { // check if transition is possible
log.Printf("State machine '%s' changes from '%s' to '%s'\n", m.name, current, next)
- m.current = next
- m.runHooks(current, next)
- return next
- }
- return current
-}
-// In this function one can implement callback functions
-// which will be triggered on certain transitions.
-func (m *Machine) runHooks(last string, next string) {
-
- for _,listener := range(m.state_listeners) {
- *listener <- next
- }
+ // inform all state listeners
+ for _,listener := range(m.state_listeners) {
+ *listener <- next
+ }
- if last == "idle" && next == "single_picture" {
- // TODO implement launch of python subprocess here
- go func() {
- time.Sleep(1 * time.Second)
- m.SendEvent("single_picture_taken")
- }()
+ m.hook(current, next) // execute registered callback function
+ m.current = next // set new state
+ return next
}
+ return current
}