X-Git-Url: https://git.realraum.at/?a=blobdiff_plain;f=r3-netstatus%2Fmain.go;h=f7828b92db8ec80b8e231252cd3fdc0460c14c60;hb=63eb752b0e125d962bcd5a4d56afb2616ab2af67;hp=abec0c18d76f20af7118263f6889d507edbc6ef3;hpb=39a41339d2ce0cc3bbbe4d270377e4e698631c1e;p=svn42.git diff --git a/r3-netstatus/main.go b/r3-netstatus/main.go index abec0c1..f7828b9 100644 --- a/r3-netstatus/main.go +++ b/r3-netstatus/main.go @@ -39,7 +39,7 @@ func init() { func EventToXMPP(ps *pubsub.PubSub, xmpp_presence_events_chan_ chan <- interface{}) { events := ps.Sub("presence","door","buttons") - var present, locked, shut bool + var present, locked, shut bool = false, true, true var who string = "Unknown" for eventinterface := range(events) { @@ -70,7 +70,7 @@ func main() { } defer bot.StopBot() - newlinequeue := make(chan string) + newlinequeue := make(chan string, 1) ps := pubsub.New(1) //~ brn := brain.New() defer close(newlinequeue) @@ -78,9 +78,9 @@ func main() { //~ defer brn.Shutdown() ticker := time.NewTicker(time.Duration(7) * time.Minute) - go ReadFromUSocket(presence_socket_path_, newlinequeue) go EventToWeb(ps) go EventToXMPP(ps, xmpp_presence_events_chan_) + go ReadFromUSocket(presence_socket_path_, newlinequeue) for { select { case e := <-newlinequeue: