start creating API

Author: bartekpacia

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/webserver/api.go

@@ -0,0 +1,45 @@
+package webserver
+
+import (
+	"github.com/bartekpacia/fhome/api"
+	"net/http"
+)
+
+type Api struct {
+	fhomeClient *api.Client
+}
+
+func NewApi() *Api {
+	return &Api{}
+}
+
+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) {
+	a.fhomeClient.SendEvent()
+
+	w.Header().Set("Content-Type", "application/json")
+}
+
+func (a *Api) toggleDevice(w http.ResponseWriter, r *http.Request) {
+
+}
+
+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)
+	})
+}

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))))
+
+	mux.Handle("/api/", http.StripPrefix("/api", api.Mux()))
 	addr := fmt.Sprint("0.0.0.0:", port)
 	httpServer := http.Server{Addr: addr, Handler: mux}