diff options
author | Ethel Morgan <eth@ethulhu.co.uk> | 2020-06-20 00:13:53 +0100 |
---|---|---|
committer | Ethel Morgan <eth@ethulhu.co.uk> | 2020-06-20 00:13:53 +0100 |
commit | 0905fc55e7427a4e024fc5dc73f10be45200f110 (patch) | |
tree | fb8762831a470e423cd97b89868b48628d2b0d32 /main.go | |
parent | a119a07983cf24db0bf9715c5625ebb90d915f16 (diff) |
rename the project to catbus-wakeonlan
Diffstat (limited to 'main.go')
-rw-r--r-- | main.go | 81 |
1 files changed, 0 insertions, 81 deletions
diff --git a/main.go b/main.go deleted file mode 100644 index a3ca9d3..0000000 --- a/main.go +++ /dev/null @@ -1,81 +0,0 @@ -// SPDX-FileCopyrightText: 2020 Ethel Morgan -// -// SPDX-License-Identifier: MIT - -package main - -import ( - "context" - "flag" - "log" - - "go.eth.moe/catbus-actuator-wakeonlan/config" - "go.eth.moe/catbus-actuator-wakeonlan/logger" - "go.eth.moe/catbus-actuator-wakeonlan/mqtt" - "go.eth.moe/catbus-actuator-wakeonlan/wakeonlan" -) - -var ( - configPath = flag.String("config-path", "", "path to config") -) - -func main() { - flag.Parse() - - if *configPath == "" { - log.Fatal("must set -config-path") - } - - log, _ := logger.FromContext(context.Background()) - - config, err := config.ParseFile(*configPath) - if err != nil { - log.AddField("config-path", *configPath) - log.WithError(err).Fatal("could not parse config file") - } - - log.AddField("broker-uri", config.Broker) - - brokerOptions := mqtt.NewClientOptions() - brokerOptions.AddBroker(config.Broker) - brokerOptions.SetAutoReconnect(true) - brokerOptions.SetConnectionLostHandler(func(_ mqtt.Client, err error) { - log := log - if err != nil { - log = log.WithError(err) - } - log.Error("disconnected from MQTT broker") - }) - brokerOptions.SetOnConnectHandler(func(broker mqtt.Client) { - log.Info("connected to MQTT broker") - - for topic := range config.MACsByTopic { - token := broker.Subscribe(topic, mqtt.AtLeastOnce, func(_ mqtt.Client, msg mqtt.Message) { - mac, ok := config.MACsByTopic[msg.Topic()] - if !ok { - return - } - - log.AddField("mac", mac) - log.AddField("topic", topic) - if err := wakeonlan.Wake(mac); err != nil { - log.WithError(err).Error("could not send wake-on-lan packet") - return - } - log.Info("sent wake-on-lan packet") - }) - if err := token.Error(); err != nil { - log := log.WithError(err) - log.AddField("topic", topic) - log.Error("could not subscribe to MQTT topic") - } - } - }) - - broker := mqtt.NewClient(brokerOptions) - if token := broker.Connect(); token.Error() != nil { - log.WithError(token.Error()).Fatal("could not connect to MQTT broker") - } - - select {} -} |