implement simple API

Author: bartekpacia

.run/fhomed --homekit --debug.run.xml renamed to .run/fhomed (HomeKit + webserver).run.xml

@@ -1,8 +1,8 @@
 <component name="ProjectRunConfigurationManager">
-  <configuration default="false" name="fhomed --homekit --debug" type="GoApplicationRunConfiguration" factoryName="Go Application" focusToolWindowBeforeRun="true">
+  <configuration default="false" name="fhomed (HomeKit + webserver)" type="GoApplicationRunConfiguration" factoryName="Go Application" focusToolWindowBeforeRun="true">
     <module name="fhome" />
     <working_directory value="$PROJECT_DIR$" />
-    <parameters value="--homekit --debug" />
+    <parameters value="--homekit --webserver --debug" />
     <kind value="PACKAGE" />
     <package value="github.com/bartekpacia/fhome/cmd/fhomed" />
     <directory value="$PROJECT_DIR$" />

api/client.go

@@ -332,6 +332,8 @@ func (c *Client) SendAction(ctx context.Context, actionName string) (*Message, e
 
 // SendEvent sends an event containing value to the cell.
 //
+// This is a more specific variant of SendAction.
+//
 // Events are named "Xevents" in F&Home's terminology.
 func (c *Client) SendEvent(ctx context.Context, cellID int, value string) error {
 	actionName := ActionEvent

cmd/fhome/commands.go

@@ -140,7 +140,7 @@ var configCommand = cli.Command{
 						log.Println()
 					}
 				} else if cmd.Bool("glance") {
-					// We want to see real values of the system resources.
+					// We want to see the real values of the system resources.
 					// To do that, we need to send the "statustouches" action and
 					// wait for its response.
 

cmd/fhomed/requests/devices.http

@@ -0,0 +1,2 @@
+GET http://localhost:9001/api/devices
+Authorization: Passphrase: my-passphrase

cmd/fhomed/requests/toggle.http

@@ -0,0 +1,3 @@
+POST http://localhost:9001/api/devices/291
+Authorization: Passphrase: my-passphrase
+# 291 = bartek sufit 1

cmd/fhomed/webserver/api.go

@@ -0,0 +1,84 @@
+package webserver
+
+import (
+	"encoding/json"
+	"fmt"
+	"github.com/bartekpacia/fhome/api"
+	"net/http"
+	"strconv"
+)
+
+type Api struct {
+	fhomeClient *api.Client
+}
+
+func NewApi(fhomeClient *api.Client) *Api {
+	return &Api{
+		fhomeClient: fhomeClient,
+	}
+}
+
+func (a *Api) Mux() http.Handler {
+	mux := http.NewServeMux()
+
+	mux.HandleFunc("GET /devices", a.getDevices)
+	mux.HandleFunc("POST /devices/{id}", a.toggleDevice)
+
+	authMux := withPassphrase(mux, "my-passphrase")
+	return authMux
+}
+
+func (a *Api) getDevices(w http.ResponseWriter, r *http.Request) {
+	userConfig, err := a.fhomeClient.GetUserConfig(r.Context())
+	if err != nil {
+		http.Error(w, "failed to get user config"+err.Error(), http.StatusInternalServerError)
+		return
+	}
+
+	response := make([]device, 0)
+
+	for _, cell := range userConfig.Cells {
+		response = append(response, device{
+			Name: cell.Name,
+			ID:   cell.ObjectID,
+		})
+	}
+
+	w.Header().Set("Content-Type", "application/json")
+	err = json.NewEncoder(w).Encode(response)
+	if err != nil {
+		http.Error(w, "failed to encode user into json"+err.Error(), http.StatusInternalServerError)
+		return
+	}
+}
+
+func (a *Api) toggleDevice(w http.ResponseWriter, r *http.Request) {
+	objectID, err := strconv.ParseInt(r.PathValue("id"), 10, 64)
+	if err != nil {
+		http.Error(w, err.Error(), http.StatusBadRequest)
+		return
+	}
+
+	err = a.fhomeClient.SendEvent(r.Context(), int(objectID), api.ValueToggle)
+	if err != nil {
+		msg := fmt.Sprintf("failed to send event to object with %d: %v\n", objectID, err)
+		http.Error(w, msg, http.StatusInternalServerError)
+		return
+	}
+}
+
+func withPassphrase(next http.Handler, passphrase string) http.Handler {
+	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		if r.Header.Get("Authorization") != "Passphrase: "+passphrase {
+			http.Error(w, "Unauthorized", http.StatusUnauthorized)
+			return
+		}
+
+		next.ServeHTTP(w, r)
+	})
+}
+
+type device struct {
+	Name string
+	ID   int
+}

cmd/fhomed/webserver/templates/index.html.tmpl

@@ -16,7 +16,7 @@
             <h2>{{$panel.Name}} ({{len $panel.Cells }} objects) </h2>
             <ul>
                 {{range $j, $cell := $panel.Cells}}
-                    <li>{{$cell.Name}}</li>
+                    <li>{{$cell.Name}} / {{$cell.ID}}</li>
                 {{end}}
             </ul>
         {{end}}

cmd/fhomed/webserver/webserver.go

@@ -54,6 +54,8 @@ func Run(ctx context.Context, client *api.Client, homeConfig *api.Config, email
 	})
 
 	mux.Handle("GET /public", http.StripPrefix("/public/", http.FileServer(http.FS(assets))))
+	app := NewApi(client)
+	mux.Handle("/api/", http.StripPrefix("/api", app.Mux()))
 	addr := fmt.Sprint("0.0.0.0:", port)
 	httpServer := http.Server{Addr: addr, Handler: mux}