vhad/go-hue-interface
1
0
Fork 0
mirror of https://github.com/gosticks/go-hue-interface.git synced 2025-10-16 11:45:35 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

cleanup

Browse Source
This commit is contained in:
Wlad Meixner 2019-02-12 01:26:41 +01:00
parent d7718edbc8
commit e66225b8e3
2 changed files with 40 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
monitor/listener.go Normal file
View File

@ -0,0 +1,34 @@
package monitor
import "reflect"
// ListenerType matches the Hue API types e.g. Lights, Scenes, Groups...
type ListenerType int
const (
// Light is a hue light
Light ListenerType = 0
Scene ListenerType = 1
Sensor ListenerType = 2
Group ListenerType = 3
)
// Listener stores the current state and a ref to the handler on the event of a change
type Listener struct {
CurrentState interface{}
Handler func(interface{})
}
// hasChanged chacks if the value changed compared to the value stored on the listener.
func (l *Listener) hasChanged(newState interface{}) bool {
return !reflect.DeepEqual(l.CurrentState, newState)
}
// Update is called by the monitor if the result of hasChanged is false. If the value did change state of the listener is updated and the handler is called.
func (l *Listener) Update(newState interface{}) {
oldState := l.CurrentState
l.CurrentState = newState
if oldState != nil {
l.Handler(newState)
}
}

37
monitor/monitor.go
View File

@ -2,21 +2,11 @@ package monitor
import (
"fmt"
"reflect"
"time"
"github.com/gosticks/go-hue-interface"
)
type ListenerType int
const (
Light ListenerType = 0
Scene ListenerType = 1
Sensor ListenerType = 2
Group ListenerType = 3
)
// Monitor is a interface which is used for checking events
type Monitor struct {
Listeners map[ListenerType]map[string]*Listener
@ -25,6 +15,7 @@ type Monitor struct {
ticker *time.Ticker
}
// NewMonitor creates a new monitor. The monitor can be used to observe changes to specific lamps, scenes, groups..
func NewMonitor(b *hue.Bridge, interval time.Duration) *Monitor {
return &Monitor{
Listeners: make(map[ListenerType]map[string]*Listener),
@ -33,6 +24,7 @@ func NewMonitor(b *hue.Bridge, interval time.Duration) *Monitor {
}
}
// Tick starts a update process by iterating over all the listeners for each type. Tick normally should be called by the provided Start method but can also be use manually.
func (m *Monitor) Tick() error {
st, errState := m.Bridge.GetState()
if errState != nil {
@ -53,10 +45,11 @@ func (m *Monitor) Tick() error {
return nil
}
// Start begins a monitoring loop with the interval set on the monitor
func (m *Monitor) Start() {
m.ticker = time.NewTicker(m.Interval)
go func() {
for _ = range m.ticker.C {
for range m.ticker.C {
// fmt.Println("Tick: ", t)
//Call the periodic function here.
errTick := m.Tick()
@ -67,6 +60,7 @@ func (m *Monitor) Start() {
}()
}
// AddListener adds a new listener to the listener map. The listener will only be called if the id and type match and the state has changed. If a listener for a id and type already exists it will be removed
func (m *Monitor) AddListener(id string, t ListenerType, handler func(interface{})) {
if m.Listeners[t] == nil {
m.Listeners[t] = make(map[string]*Listener)
@ -74,23 +68,4 @@ func (m *Monitor) AddListener(id string, t ListenerType, handler func(interface{
m.Listeners[t][id] = &Listener{Handler: handler}
}
type Listener struct {
CurrentState interface{}
Handler func(interface{})
}
func (l *Listener) hasChanged(newState interface{}) bool {
return !reflect.DeepEqual(l.CurrentState, newState)
}
func (l *Listener) Update(newState interface{}) {
oldState := l.CurrentState
l.CurrentState = newState
if oldState != nil {
l.Handler(newState)
}
}
// func (b *hue.Bridge) AddMonitor() {
// }
// TODO: add RemoveListener and Stop