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
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
|
package main
import (
"fmt"
"log"
"os"
"os/signal"
"syscall"
"time"
mqtt "github.com/eclipse/paho.mqtt.golang"
"xengineering.eu/homematic-go/homematic"
)
const (
OPENCCU = `http://127.0.0.1:8080`
BROKER = `tcp://127.0.0.1:1883`
CLIENT_ID = `siaserver`
TOPIC_PREFIX = `sia`
QOS = byte(0)
RETAINED = true
MQTT_CONNECT_TIMEOUT = time.Second * 5
MQTT_DISCONNECT_TIMEOUT_US = 500
POLLING_PERIOD = 50 * time.Millisecond
)
func main() {
log.Println("+++ Started Sia server +++")
defer log.Println("--- Stopped Sia server ---")
go func() {
req, inventory, client, err := Start()
defer Stop(client)
if err != nil {
log.Fatalf("Failed startup process: %v", err)
}
cache := NewCache(client)
for {
start := time.Now()
states, err := Poll(req, inventory)
if err != nil {
log.Fatalf("Failed to poll states: %v", err)
}
cache.Update(states)
WaitUntil(start.Add(POLLING_PERIOD))
}
}()
Await(syscall.SIGTERM, syscall.SIGINT)
}
func ConnectMQTT(broker string, id string) (mqtt.Client, error) {
opts := mqtt.NewClientOptions()
opts.AddBroker(broker)
opts.SetClientID(id)
opts.SetCleanSession(true)
client := mqtt.NewClient(opts)
token := client.Connect()
success := token.WaitTimeout(MQTT_CONNECT_TIMEOUT)
if !success {
return client, fmt.Errorf("Timed out after %v.", MQTT_CONNECT_TIMEOUT)
}
err := token.Error()
if err != nil {
return client, err
}
return client, nil
}
func Start() (homematic.Requester, homematic.Devices, mqtt.Client, error) {
var req homematic.Requester
var inventory homematic.Devices
var client mqtt.Client
var err error
req = homematic.NewRequester(OPENCCU)
log.Printf("Created Homematic requester (%s).", OPENCCU)
inventory, err = req.ListDevices()
if err != nil {
return req, inventory, client, fmt.Errorf("Failed getting initial device list: %w", err)
}
log.Printf("Retrieved Homematic inventory with %d devices.", len(inventory))
client, err = ConnectMQTT(BROKER, CLIENT_ID)
if err != nil {
return req, inventory, client, fmt.Errorf("Failed connecting to MQTT broker: %w", err)
}
log.Printf("Connected to MQTT broker (%s).", BROKER)
return req, inventory, client, nil
}
func Stop(c mqtt.Client) {
c.Disconnect(MQTT_DISCONNECT_TIMEOUT_US)
log.Println("Disconnected from MQTT broker.")
}
func Poll(req homematic.Requester, inventory homematic.Devices) (States, error) {
states := make(States)
for _, device := range inventory {
if device.Type == `SHUTTER_CONTACT` {
state, err := req.GetValue(device.Address)
if err != nil {
return states, fmt.Errorf("Failed to get value: %w", err)
}
states[device.Address] = state
}
}
return states, nil
}
func Await(signals ...syscall.Signal) {
listener := make(chan os.Signal)
for _, s := range signals {
signal.Notify(listener, s)
}
sig := <-listener
log.Printf("Received OS signal '%v'\n", sig)
}
func WaitUntil(deadline time.Time) {
duration := time.Until(deadline)
if duration > 0 {
time.Sleep(duration)
}
}
|
