init

apps/control-plane/Dockerfile

@@ -0,0 +1,15 @@
+FROM golang:1.26-alpine AS build
+
+WORKDIR /src
+COPY apps/control-plane ./apps/control-plane
+
+WORKDIR /src/apps/control-plane
+RUN CGO_ENABLED=0 GOOS=linux go build -o /out/control-plane ./cmd/control-plane
+
+FROM alpine:3.21
+
+WORKDIR /app
+COPY --from=build /out/control-plane /usr/local/bin/control-plane
+
+EXPOSE 3000
+CMD ["control-plane"]

apps/control-plane/README.md

@@ -0,0 +1,15 @@
+# betterNAS Control Plane
+
+Go service that owns the product control plane.
+
+It is intentionally small for now:
+
+- `GET /health`
+- `GET /version`
+- `POST /api/v1/nodes/register`
+- `GET /api/v1/exports`
+- `POST /api/v1/mount-profiles/issue`
+- `POST /api/v1/cloud-profiles/issue`
+
+The request and response shapes must follow the contracts in
+[`packages/contracts`](/home/rathi/Documents/GitHub/betterNAS/packages/contracts).

apps/control-plane/cmd/control-plane/main.go

@@ -0,0 +1,103 @@
+package main
+
+import (
+	"encoding/json"
+	"log"
+	"net/http"
+	"os"
+	"time"
+)
+
+type jsonObject map[string]any
+
+func main() {
+	port := env("PORT", "8081")
+	startedAt := time.Now()
+
+	mux := http.NewServeMux()
+	mux.HandleFunc("/health", func(w http.ResponseWriter, r *http.Request) {
+		writeJSON(w, http.StatusOK, jsonObject{
+			"service":       "control-plane",
+			"status":        "ok",
+			"timestamp":     time.Now().UTC().Format(time.RFC3339),
+			"uptimeSeconds": int(time.Since(startedAt).Seconds()),
+			"nextcloud": jsonObject{
+				"configured": false,
+				"baseUrl":    env("NEXTCLOUD_BASE_URL", ""),
+				"provider":   "nextcloud",
+			},
+		})
+	})
+	mux.HandleFunc("/version", func(w http.ResponseWriter, r *http.Request) {
+		writeJSON(w, http.StatusOK, jsonObject{
+			"service":    "control-plane",
+			"version":    env("BETTERNAS_VERSION", "0.1.0-dev"),
+			"apiVersion": "v1",
+		})
+	})
+	mux.HandleFunc("/api/v1/exports", func(w http.ResponseWriter, r *http.Request) {
+		writeJSON(w, http.StatusOK, []jsonObject{})
+	})
+	mux.HandleFunc("/api/v1/mount-profiles/issue", func(w http.ResponseWriter, r *http.Request) {
+		writeJSON(w, http.StatusOK, jsonObject{
+			"id":             "dev-profile",
+			"exportId":       "dev-export",
+			"protocol":       "webdav",
+			"displayName":    "Example export",
+			"mountUrl":       env("BETTERNAS_EXAMPLE_MOUNT_URL", "http://localhost:8090/dav"),
+			"readonly":       false,
+			"credentialMode": "session-token",
+		})
+	})
+	mux.HandleFunc("/api/v1/cloud-profiles/issue", func(w http.ResponseWriter, r *http.Request) {
+		writeJSON(w, http.StatusOK, jsonObject{
+			"id":       "dev-cloud",
+			"exportId": "dev-export",
+			"provider": "nextcloud",
+			"baseUrl":  env("NEXTCLOUD_BASE_URL", "http://localhost:8080"),
+			"path":     "/apps/files/files",
+		})
+	})
+	mux.HandleFunc("/api/v1/nodes/register", func(w http.ResponseWriter, r *http.Request) {
+		writeJSON(w, http.StatusOK, jsonObject{
+			"id":           "dev-node",
+			"machineId":    "dev-machine",
+			"displayName":  "Development NAS",
+			"agentVersion": "0.1.0-dev",
+			"status":       "online",
+			"lastSeenAt":   time.Now().UTC().Format(time.RFC3339),
+			"directAddress": env("BETTERNAS_NODE_DIRECT_ADDRESS", "http://localhost:8090"),
+			"relayAddress":  nil,
+		})
+	})
+	mux.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
+		http.NotFound(w, r)
+	})
+
+	server := &http.Server{
+		Addr:              ":" + port,
+		Handler:           mux,
+		ReadHeaderTimeout: 5 * time.Second,
+	}
+
+	log.Printf("betterNAS control plane listening on :%s", port)
+	log.Fatal(server.ListenAndServe())
+}
+
+func env(key, fallback string) string {
+	value, ok := os.LookupEnv(key)
+	if !ok || value == "" {
+		return fallback
+	}
+
+	return value
+}
+
+func writeJSON(w http.ResponseWriter, statusCode int, payload any) {
+	w.Header().Set("Content-Type", "application/json; charset=utf-8")
+	w.WriteHeader(statusCode)
+
+	if err := json.NewEncoder(w).Encode(payload); err != nil {
+		http.Error(w, err.Error(), http.StatusInternalServerError)
+	}
+}

apps/control-plane/go.mod

@@ -0,0 +1,3 @@
+module github.com/rathi/betternas/apps/control-plane
+
+go 1.26.0

apps/control-plane/package.json

@@ -0,0 +1,12 @@
+{
+  "name": "@betternas/control-plane",
+  "version": "0.1.0",
+  "private": true,
+  "scripts": {
+    "dev": "CGO_ENABLED=0 go run ./cmd/control-plane",
+    "build": "mkdir -p dist && CGO_ENABLED=0 go build -o dist/control-plane ./cmd/control-plane",
+    "lint": "CGO_ENABLED=0 go vet ./...",
+    "check-types": "CGO_ENABLED=0 go test ./...",
+    "test": "CGO_ENABLED=0 go test ./..."
+  }
+}