Add Hue service

Author: jakewright

home-automation/04-hue-lights/docker-compose.yml

@@ -0,0 +1,25 @@
+version: '3'
+
+services:
+  service.config:
+    build: ./service.config
+    volumes:
+      - ./service.config:/go/src/github.com/jakewright/tutorials/home-automation/04-hue-lights/service.config
+      - ./service.config/config.yaml:/data/config.yaml
+    ports:
+      - 7000:80
+
+  service.registry.device:
+    build: ./service.registry.device
+    volumes:
+      - ./service.registry.device:/usr/src/app
+    ports:
+      - 7001:80
+
+  service.controller.hue:
+    build: ./service.controller.hue
+    volumes:
+     - ./service.controller.hue:/usr/src/app
+     - /usr/src/app/node_modules
+    ports:
+     - 7003:80

home-automation/04-hue-lights/service.config/Dockerfile

@@ -0,0 +1,11 @@
+FROM golang:latest
+RUN go get -u golang.org/x/lint/golint
+RUN go get github.com/githubnemo/CompileDaemon
+
+WORKDIR /go/src/github.com/jakewright/tutorials/home-automation/04-hue-lights/service.config
+COPY . .
+
+RUN go get -d -v ./...
+RUN go install -v ./...
+
+CMD CompileDaemon -build="go install ." -command="/go/bin/service.config"

home-automation/04-hue-lights/service.config/config.yaml

@@ -0,0 +1,4 @@
+service.controller.hue:
+  hueBridge:
+    host: http://192.168.1.110
+    username: g3avkmfKYFZtxwb6Ny7DNQgQXJtn7Sl3VzEcbJDi

home-automation/04-hue-lights/service.config/controller/controller.go

@@ -0,0 +1,45 @@
+package controller
+
+import (
+	"encoding/json"
+	"fmt"
+	"net/http"
+
+	"github.com/gorilla/mux"
+	"github.com/jakewright/tutorials/home-automation/04-hue-lights/service.config/domain"
+)
+
+// Controller exports the handlers for the endpoints
+type Controller struct {
+	Config *domain.Config
+}
+
+// ReadConfig writes the config for the given service to the ResponseWriter
+func (c *Controller) ReadConfig(w http.ResponseWriter, r *http.Request) {
+	w.Header().Set("Content-Type", "application/json; charset=UTF-8")
+
+	vars := mux.Vars(r)
+	serviceName, ok := vars["serviceName"]
+	if !ok {
+		w.WriteHeader(http.StatusBadRequest)
+		fmt.Fprintf(w, "serviceName not set")
+		return
+	}
+
+	config, err := c.Config.Get(serviceName)
+	if err != nil {
+		w.WriteHeader(http.StatusInternalServerError)
+		fmt.Fprintf(w, err.Error())
+		return
+	}
+
+	rsp, err := json.Marshal(&config)
+	if err != nil {
+		w.WriteHeader(http.StatusInternalServerError)
+		fmt.Fprintf(w, err.Error())
+		return
+	}
+
+	w.WriteHeader(http.StatusOK)
+	fmt.Fprintf(w, string(rsp))
+}

home-automation/04-hue-lights/service.config/domain/config.go

@@ -0,0 +1,97 @@
+package domain
+
+import (
+	"fmt"
+	"sync"
+
+	"gopkg.in/yaml.v2"
+)
+
+// Config is an abstraction around the map that holds the config values
+type Config struct {
+	config map[string]interface{}
+	lock   sync.RWMutex
+}
+
+// SetFromBytes sets the internal config based on a byte array of YAML
+func (c *Config) SetFromBytes(data []byte) error {
+	var rawConfig interface{}
+	if err := yaml.Unmarshal(data, &rawConfig); err != nil {
+		return err
+	}
+
+	untypedConfig, ok := rawConfig.(map[interface{}]interface{})
+	if !ok {
+		return fmt.Errorf("config is not a map")
+	}
+
+	config, err := convertKeysToStrings(untypedConfig)
+	if err != nil {
+		return err
+	}
+
+	c.lock.Lock()
+	defer c.lock.Unlock()
+
+	c.config = config
+	return nil
+}
+
+// Get returns the config for a particular service
+func (c *Config) Get(serviceName string) (map[string]interface{}, error) {
+	c.lock.RLock()
+	defer c.lock.RUnlock()
+
+	var a map[string]interface{}
+	if _, ok := c.config["base"]; ok {
+		a, ok = c.config["base"].(map[string]interface{})
+		if !ok {
+			return nil, fmt.Errorf("base config is not a map")
+		}
+	}
+
+	// If no config is defined for the service
+	if _, ok := c.config[serviceName]; !ok {
+		// Return the base config
+		return a, nil
+	}
+
+	b, ok := c.config[serviceName].(map[string]interface{})
+	if !ok {
+		return nil, fmt.Errorf("service %q config is not a map", serviceName)
+	}
+
+	// Merge the maps with the service config taking precedence
+	config := make(map[string]interface{})
+	for k, v := range a {
+		config[k] = v
+	}
+	for k, v := range b {
+		config[k] = v
+	}
+
+	return config, nil
+}
+
+func convertKeysToStrings(m map[interface{}]interface{}) (map[string]interface{}, error) {
+	n := make(map[string]interface{})
+
+	for k, v := range m {
+		str, ok := k.(string)
+		if !ok {
+			return nil, fmt.Errorf("config key is not a string")
+		}
+
+		if vMap, ok := v.(map[interface{}]interface{}); ok {
+			var err error
+			v, err = convertKeysToStrings(vMap)
+			if err != nil {
+				return nil, err
+			}
+		}
+
+		n[str] = v
+	}
+
+	return n, nil
+}

home-automation/04-hue-lights/service.config/main.go

@@ -0,0 +1,31 @@
+package main
+
+import (
+	"log"
+	"time"
+
+	"github.com/jakewright/muxinator"
+
+	"github.com/jakewright/tutorials/home-automation/04-hue-lights/service.config/controller"
+	"github.com/jakewright/tutorials/home-automation/04-hue-lights/service.config/domain"
+	"github.com/jakewright/tutorials/home-automation/04-hue-lights/service.config/service"
+)
+
+func main() {
+	config := domain.Config{}
+
+	configService := service.ConfigService{
+		Config:   &config,
+		Location: "/data/config.yaml",
+	}
+
+	go configService.Watch(time.Second * 30)
+
+	c := controller.Controller{
+		Config: &config,
+	}
+
+	router := muxinator.NewRouter()
+	router.Get("/read/{serviceName}", c.ReadConfig)
+	log.Fatal(router.ListenAndServe(":80"))
+}

home-automation/04-hue-lights/service.config/service/service.go

@@ -0,0 +1,41 @@
+package service
+
+import (
+	"io/ioutil"
+	"log"
+	"time"
+
+	"github.com/jakewright/tutorials/home-automation/04-hue-lights/service.config/domain"
+)
+
+type ConfigService struct {
+	Config   *domain.Config
+	Location string
+}
+
+// Watch reloads the config every d duration
+func (s *ConfigService) Watch(d time.Duration) {
+	for {
+		err := s.Reload()
+		if err != nil {
+			log.Print(err)
+		}
+
+		time.Sleep(d)
+	}
+}
+
+// Reload reads the config and applies changes
+func (s *ConfigService) Reload() error {
+	data, err := ioutil.ReadFile(s.Location)
+	if err != nil {
+		return err
+	}
+
+	err = s.Config.SetFromBytes(data)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}

home-automation/04-hue-lights/service.controller.hue/Dockerfile

@@ -0,0 +1,14 @@
+FROM node:8.11
+
+# Install nodemon
+RUN npm install -g nodemon
+
+# Create app directory
+RUN mkdir -p /usr/src/app
+WORKDIR /usr/src/app
+
+# Install app dependencies
+COPY package.json .
+RUN npm install
+
+CMD [ "npm", "start" ]

home-automation/04-hue-lights/service.controller.hue/api/hueClient.js

@@ -0,0 +1,44 @@
+const axios = require("axios");
+
+class HueClient {
+    get hueUrl() {
+        return `${this.host}/api/${this.username}`;
+    }
+
+    async fetchAllState() {
+        const rsp = await axios.get(`${this.hueUrl}/lights`);
+
+        const lights = {};
+
+        for (const hueId in rsp.data) {
+            lights[hueId] = {
+                power: rsp.data[hueId].state.on,
+                brightness: rsp.data[hueId].state.bri
+            };
+        }
+
+        return lights;
+    }
+
+    async fetchState(hueId) {
+        const rsp = await axios.get(`${this.hueUrl}/lights/${hueId}`);
+
+        return {
+            power: rsp.data.state.on,
+            brightness: rsp.data.state.bri
+        };
+    }
+
+    async applyState(hueId, state) {
+        const hueState = {
+            on: state.power,
+            bri: state.brightness,
+        };
+
+        await axios.put(`${this.hueUrl}/lights/${hueId}/state`, hueState);
+        return this.fetchState(hueId);
+    }
+}
+
+const hueClient = new HueClient();
+exports = module.exports = hueClient;

home-automation/04-hue-lights/service.controller.hue/dao/index.js

@@ -0,0 +1,33 @@
+const axios = require("axios");
+const hueClient = require("../api/hueClient");
+
+let devices = [];
+
+const findByHueId = (hueId) => {
+    return devices.find(device => device.attributes["hue_id"] === hueId);
+};
+
+const findByIdentifier = (identifier) => {
+    return devices.find(device => device.identifier === identifier);
+};
+
+const fetchAllState = async () => {
+    const rsp = await axios.get("http://service.registry.device/devices");
+    devices = rsp.data.data;
+
+    const hueIdToState = await hueClient.fetchAllState();
+
+    for (const hueId in hueIdToState) {
+        const device = findByHueId(hueId);
+        if (device === undefined) continue;
+
+        Object.assign(device, hueIdToState[hueId]);
+    }
+};
+
+const applyState = async (device, state) => {
+    const newState = await hueClient.applyState(device.attributes["hue_id"], state);
+    Object.assign(device, newState);
+};
+
+exports = module.exports = { findByIdentifier, fetchAllState, applyState };

home-automation/04-hue-lights/service.controller.hue/index.js

@@ -0,0 +1,32 @@
+const axios = require("axios");
+const express = require("express");
+const dao = require("./dao");
+const hueClient = require("./api/hueClient");
+const routes = require("./routes");
+
+const port = 80;
+
+axios.get("http://service.config/read/service.controller.hue")
+    .then(rsp => {
+        hueClient.host = rsp.data.hueBridge.host;
+        hueClient.username = rsp.data.hueBridge.username;
+
+        return dao.fetchAllState();
+    })
+    .then(() => {
+        const app = express();
+        routes.register(app);
+        app.listen(port, () => console.log(`Listening on port ${port}`));
+    })
+    .catch(err => {
+        console.error("Error initialising service", err);
+    });
+
+
+
+
+
+
+
+
+