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
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
package main // import "hhvn.uk/hbspbar"
import (
"os"
"os/signal"
"strings"
"syscall"
"hhvn.uk/hbspbar/bspc"
"hhvn.uk/hbspbar/common"
"hhvn.uk/hbspbar/drw"
"hhvn.uk/hbspbar/status"
)
func main() {
signals := make(chan os.Signal, 1)
signal.Notify(signals,
syscall.SIGINT,
syscall.SIGHUP,
syscall.SIGTERM)
if drw.InitErr != nil {
common.Error("Couldn't initialize X: %s\n", drw.InitErr)
return
}
if bspc.InitErr != nil {
common.Error("Couldn't subscribe to bspwm: %s\n", bspc.InitErr)
return
}
defer bspc.Cleanup()
state := <- bspc.NewState
for _, m := range state.Monitors {
Create(state, m.ID)
}
var blocks []*status.Block = nil
mainloop: for {
select {
case s := <-signals:
common.Error("%s\n", s)
break mainloop
case e := <- drw.Events:
if e.Ev == nil && e.Err == nil {
common.Error("X connection clossed\n")
break mainloop
}
if e.Err != nil {
common.Perror("X.WaitForEvents", e.Err)
continue
}
// switch e.Ev.(type) {
// case xproto.DestroyNotifyEvent:
// Err <- fmt.Errorf("Window destroyed")
// return
// default:
// }
case err := <-bspc.EvErr:
common.Error("Couldn't read event: %s\n", err)
break mainloop
case event := <-bspc.Event:
if strings.HasPrefix(event.Name, "monitor_") {
id, err := common.Intify(event.Tokens[0])
if err == nil {
switch event.Name {
case "monitor_add":
fallthrough
case "monitor_geometry":
Create(state, id)
case "monitor_remove":
Destroy(state, id)
}
}
}
case err := <-bspc.StErr:
common.Error("Couldn't load bspwm state: %s\n", err)
break mainloop
case blocks = <- status.NewBlocks:
Redraw(state, blocks)
case state = <- bspc.NewState:
finalstate = state
Redraw(state, blocks)
}
}
Cleanup(state)
}
|