forked from hybridgroup/gobot
-
Notifications
You must be signed in to change notification settings - Fork 0
/
gobot.go
76 lines (63 loc) · 1.27 KB
/
gobot.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
package gobot
import (
"log"
"os"
"os/signal"
)
type JSONGobot struct {
Robots []*JSONRobot `json:"robots"`
Commands []string `json:"commands"`
}
type Gobot struct {
robots *robots
commands commands
trap func(chan os.Signal)
}
func NewGobot() *Gobot {
return &Gobot{
robots: &robots{},
commands: make(commands),
trap: func(c chan os.Signal) {
signal.Notify(c, os.Interrupt)
},
}
}
func (g *Gobot) Commands() commands {
return g.commands
}
func (g *Gobot) Start() {
g.robots.Start()
c := make(chan os.Signal, 1)
g.trap(c)
// waiting for interrupt coming on the channel
_ = <-c
g.robots.Each(func(r *Robot) {
log.Println("Stopping Robot", r.Name, "...")
r.Devices().Halt()
r.Connections().Finalize()
})
}
func (g *Gobot) Robots() *robots {
return g.robots
}
func (g *Gobot) Robot(name string) *Robot {
for _, robot := range g.Robots().robots {
if robot.Name == name {
return robot
}
}
return nil
}
func (g *Gobot) ToJSON() *JSONGobot {
jsonGobot := &JSONGobot{
Robots: []*JSONRobot{},
Commands: []string{},
}
g.commands.Each(func(c Command) {
jsonGobot.Commands = append(jsonGobot.Commands, c.Name)
})
g.robots.Each(func(r *Robot) {
jsonGobot.Robots = append(jsonGobot.Robots, r.ToJSON())
})
return jsonGobot
}