go/r3-eventbroker_zmq/presence.go

   1 // (c) Bernhard Tittelbach, 2013
   2
   3 package main
   4
   5 import (
   6     "time"
   7     //~ "./brain"
   8     pubsub "github.com/tuxychandru/pubsub"
   9     r3events "svn.spreadspace.org/realraum/go.svn/r3events"
  10     )
  11
  12 func MetaEventRoutine_Presence(ps *pubsub.PubSub) {
  13     //~ var last_door_cmd *DoorCommandEvent
  14     var last_presence bool
  15     var last_movement, last_buttonpress int64
  16     var front_locked, front_shut, back_shut bool = true, true, true
  17
  18     events_chan := ps.Sub("door", "doorcmd", "buttons", "movement")
  19     defer ps.Unsub(events_chan, "door", "doorcmd", "buttons", "movement")
  20
  21     for event := range(events_chan) {
  22         //~ Debug_.Printf("Presence: %s - %s", event, doorstatemap)
  23         new_presence := last_presence
  24         ts := time.Now().Unix()
  25         switch evnt := event.(type) {
  26             case r3events.SomethingReallyIsMoving:
  27                 if evnt.Movement {
  28                     last_movement = evnt.Ts
  29                 } else {
  30                     last_movement = 0
  31                 }
  32             case r3events.BoreDoomButtonPressEvent:
  33                 last_buttonpress = evnt.Ts
  34                 new_presence = true
  35             //~ case DoorCommandEvent:
  36                 //~ last_door_cmd = &evnt
  37             case r3events.DoorLockUpdate:
  38                 front_locked = evnt.Locked
  39             case r3events.DoorAjarUpdate:
  40                 front_shut = evnt.Shut
  41             case r3events.BackdoorAjarUpdate:
  42                 back_shut = evnt.Shut
  43         }
  44
  45         any_door_unlocked := ! front_locked
  46         any_door_ajar := ! (front_shut && back_shut)
  47
  48         if new_presence != last_presence {
  49             //... skip state check .. we had a definite presence event
  50         } else if any_door_unlocked || any_door_ajar {
  51             new_presence = true
  52         } else if last_movement != 0 || ts - last_buttonpress < 200 {
  53             new_presence = true
  54         } else {
  55             new_presence = false
  56         }
  57         //~ Debug_.Printf("Presence: new: %s , last:%s", new_presence, last_presence)
  58         if new_presence != last_presence {
  59             last_presence = new_presence
  60             ps.Pub(r3events.PresenceUpdate{new_presence, ts} , "presence")
  61         }
  62     }
  63 }