go/r3-eventbroker_zmq/metamovement.go

   1 // (c) Bernhard Tittelbach, 2013
   2
   3 package main
   4
   5 import (
   6     "time"
   7     pubsub "github.com/tuxychandru/pubsub"
   8     "container/ring"
   9     r3events "svn.spreadspace.org/realraum/go.svn/r3events"
  10     )
  11
  12
  13 /// Movement Meta Event Injector:
  14 ///     threshold number of movements within gran_duration*granularity seconds -> SomethingReallyIsMoving{True}
  15 ///     No movement within 3 hours but movement within the last 6 hours -> SomethingReallyIsMoving{False}
  16 ///
  17 /// Thus SomethingReallyIsMoving{True} fires regularly, but at most every gran_duration seconds
  18 /// While SomethingReallyIsMoving{False} fires only once to assure us that everybody might really be gone
  19
  20
  21 func MetaEventRoutine_Movement(ps *pubsub.PubSub, granularity, gran_duration int , threshold uint32) {
  22     var last_movement,last_movement1,last_movement2,last_movement3 int64
  23     var confidence uint8
  24     movement_window := ring.New(granularity+1)
  25     events_chan := ps.Sub("movement")
  26     defer ps.Unsub(events_chan, "movement")
  27     myticker := time.NewTicker(time.Duration(gran_duration) * time.Second)
  28
  29     for { select {
  30         case event := <- events_chan:
  31             switch event.(type) {
  32                 case r3events.MovementSensorUpdate:
  33                     movement_window.Value =  (uint32) (movement_window.Value.(uint32)  + 1)
  34             }
  35         case gots := <- myticker.C:
  36             ts := gots.Unix()
  37             movement_window.Prev().Value = (uint32) (0)
  38             movement_window = movement_window.Next()
  39             var movsum uint32 = 0
  40             movement_window.Do(func(v interface{}){if v != nil {movsum += v.(uint32)}})
  41             if movsum > threshold {
  42                 confidence = uint8(movsum)
  43                 ps.Pub( r3events.SomethingReallyIsMoving{true, confidence ,ts}, "movement")
  44                 last_movement = ts
  45                 last_movement1 = ts
  46                 last_movement2 = ts
  47                 last_movement3 = ts
  48             }
  49
  50             if last_movement > 0 && ts - last_movement < 3600*6 && ts - last_movement > 3600*3 {
  51                 last_movement = 0
  52                 ps.Pub( r3events.SomethingReallyIsMoving{false,99,ts}, "movement")
  53             }
  54             if last_movement1 > 0 && ts - last_movement < 3600*6 && ts - last_movement1 > 120 {
  55                 last_movement1 = 0
  56                 ps.Pub( r3events.SomethingReallyIsMoving{false,10,ts}, "movement")
  57             }
  58             if last_movement2 > 0 && ts - last_movement < 3600*6 && ts - last_movement2 > 1800 {
  59                 last_movement2 = 0
  60                 ps.Pub( r3events.SomethingReallyIsMoving{false,25,ts}, "movement")
  61             }
  62             if last_movement3 > 0 && ts - last_movement < 3600*6 && ts - last_movement3 > 3600 {
  63                 last_movement3 = 0
  64                 ps.Pub( r3events.SomethingReallyIsMoving{false,50,ts}, "movement")
  65             }
  66     } }
  67 }