feat: add API and Dashboard servers

Author: mirkobrombin

go.mod

@@ -4,6 +4,7 @@ go 1.22
 
 require (
 	github.com/armon/go-radix v1.0.0
+	github.com/gorilla/mux v1.8.1
 	github.com/muesli/termenv v0.15.2
 	github.com/quic-go/quic-go v0.48.2
 	github.com/rivo/tview v0.0.0-20241103174730-c76f7879f592

go.sum

@@ -30,6 +30,8 @@ github.com/google/pprof v0.0.0-20210407192527-94a9f03dee38 h1:yAJXTCF9TqKcTiHJAE
 github.com/google/pprof v0.0.0-20210407192527-94a9f03dee38/go.mod h1:kpwsk12EmLew5upagYY7GY0pfYCcupk39gWOCRROcvE=
 github.com/gopherjs/gopherjs v0.0.0-20181017120253-0766667cb4d1/go.mod h1:wJfORRmW1u3UXTncJ5qlYoELFm8eSnnEO6hX4iZ3EWY=
 github.com/gopherjs/gopherjs v0.0.0-20200217142428-fce0ec30dd00/go.mod h1:wJfORRmW1u3UXTncJ5qlYoELFm8eSnnEO6hX4iZ3EWY=
+github.com/gorilla/mux v1.8.1 h1:TuBL49tXwgrFYWhqrNgrUNEY92u81SPhu7sTdzQEiWY=
+github.com/gorilla/mux v1.8.1/go.mod h1:AKf9I4AEqPTmMytcMc0KkNouC66V3BtZ4qD5fmWSiMQ=
 github.com/ianlancetaylor/demangle v0.0.0-20200824232613-28f6c0f3b639/go.mod h1:aSSvb/t6k1mPoxDqO4vJh6VOCGPwU4O0C2/Eqndh1Sc=
 github.com/inconshreveable/mousetrap v1.1.0 h1:wN+x4NVGpMsO7ErUn/mUI3vEoE6Jt13X2s0bqwp9tc8=
 github.com/inconshreveable/mousetrap v1.1.0/go.mod h1:vpF70FUmC8bwa3OWnCshd2FqLfsEA9PFc4w1p2J65bw=

internal/api/config.go

@@ -0,0 +1,34 @@
+package api
+
+import (
+	"encoding/json"
+	"net/http"
+
+	"github.com/mirkobrombin/goup/internal/config"
+)
+
+func getConfigHandler(w http.ResponseWriter, r *http.Request) {
+	if config.GlobalConf == nil {
+		http.Error(w, "Global config not loaded", http.StatusInternalServerError)
+		return
+	}
+	jsonResponse(w, config.GlobalConf)
+}
+
+func updateConfigHandler(w http.ResponseWriter, r *http.Request) {
+	if config.GlobalConf == nil {
+		http.Error(w, "Global config not loaded", http.StatusInternalServerError)
+		return
+	}
+	var newConf config.GlobalConfig
+	if err := json.NewDecoder(r.Body).Decode(&newConf); err != nil {
+		http.Error(w, "Invalid JSON", http.StatusBadRequest)
+		return
+	}
+	config.GlobalConf = &newConf
+	if err := config.SaveGlobalConfig(); err != nil {
+		http.Error(w, "Failed to save config", http.StatusInternalServerError)
+		return
+	}
+	jsonResponse(w, config.GlobalConf)
+}

internal/api/logs_metrics_status.go

@@ -0,0 +1,79 @@
+package api
+
+import (
+	"io/fs"
+	"io/ioutil"
+	"net/http"
+	"os"
+	"path/filepath"
+
+	"github.com/mirkobrombin/goup/internal/config"
+)
+
+func getLogsHandler(w http.ResponseWriter, r *http.Request) {
+	logFile := os.Getenv("GOUP_LOG_FILE")
+	if logFile == "" {
+		http.Error(w, "Log file not set", http.StatusNotFound)
+		return
+	}
+	data, err := ioutil.ReadFile(logFile)
+	if err != nil {
+		http.Error(w, "Unable to read log file", http.StatusInternalServerError)
+		return
+	}
+	w.Header().Set("Content-Type", "text/plain")
+	w.Write(data)
+}
+
+func getMetricsHandler(w http.ResponseWriter, r *http.Request) {
+	metrics := map[string]interface{}{
+		"requests_total": 1234,
+		"latency_avg_ms": 45.6,
+		"cpu_usage":      23.4,
+		"ram_usage_mb":   512,
+		"active_sites":   len(config.SiteConfigs),
+		"active_plugins": len(config.GlobalConf.EnabledPlugins),
+	}
+	jsonResponse(w, metrics)
+}
+
+func getStatusHandler(w http.ResponseWriter, r *http.Request) {
+	status := map[string]interface{}{
+		"uptime":   "72h",
+		"sites":    len(config.SiteConfigs),
+		"plugins":  config.GlobalConf.EnabledPlugins,
+		"apiAlive": true,
+	}
+	jsonResponse(w, status)
+}
+
+func getLogWeightHandler(w http.ResponseWriter, r *http.Request) {
+	logDir := config.GetLogDir()
+	var totalSize int64 = 0
+	err := filepath.Walk(logDir, func(_ string, info fs.FileInfo, err error) error {
+		if err != nil {
+			return err
+		}
+		if !info.IsDir() {
+			totalSize += info.Size()
+		}
+		return nil
+	})
+	if err != nil {
+		http.Error(w, "Error calculating log weight", http.StatusInternalServerError)
+		return
+	}
+	jsonResponse(w, map[string]interface{}{
+		"log_weight_bytes": totalSize,
+	})
+}
+
+func getPluginUsageHandler(w http.ResponseWriter, r *http.Request) {
+	usage := make(map[string]int)
+	for _, site := range config.SiteConfigs {
+		for pluginName := range site.PluginConfigs {
+			usage[pluginName]++
+		}
+	}
+	jsonResponse(w, usage)
+}

internal/api/plugins.go

@@ -0,0 +1,76 @@
+package api
+
+import (
+	"net/http"
+
+	"github.com/gorilla/mux"
+	"github.com/mirkobrombin/goup/internal/config"
+	"github.com/mirkobrombin/goup/internal/plugin"
+	"github.com/mirkobrombin/goup/internal/restart"
+)
+
+type PluginResponse struct {
+	Name    string `json:"name"`
+	Enabled bool   `json:"enabled"`
+}
+
+func getPluginsHandler(w http.ResponseWriter, r *http.Request) {
+	pm := plugin.GetPluginManagerInstance()
+	all := pm.GetRegisteredPlugins()
+	var out []PluginResponse
+	for _, name := range all {
+		out = append(out, PluginResponse{
+			Name:    name,
+			Enabled: isPluginEnabled(name),
+		})
+	}
+	jsonResponse(w, out)
+}
+
+func togglePluginHandler(w http.ResponseWriter, r *http.Request) {
+	vars := mux.Vars(r)
+	pName := vars["pluginName"]
+
+	if config.GlobalConf == nil {
+		http.Error(w, "Global config not loaded", http.StatusInternalServerError)
+		return
+	}
+	idx := -1
+	for i, n := range config.GlobalConf.EnabledPlugins {
+		if n == pName {
+			idx = i
+			break
+		}
+	}
+	if idx >= 0 {
+		config.GlobalConf.EnabledPlugins = append(
+			config.GlobalConf.EnabledPlugins[:idx],
+			config.GlobalConf.EnabledPlugins[idx+1:]...,
+		)
+	} else {
+		config.GlobalConf.EnabledPlugins = append(config.GlobalConf.EnabledPlugins, pName)
+	}
+	if err := config.SaveGlobalConfig(); err != nil {
+		http.Error(w, "Failed to save config", http.StatusInternalServerError)
+		return
+	}
+
+	jsonResponse(w, map[string]interface{}{
+		"name":    pName,
+		"enabled": isPluginEnabled(pName),
+	})
+
+	restart.ScheduleRestart(5)
+}
+
+func isPluginEnabled(name string) bool {
+	if config.GlobalConf == nil || len(config.GlobalConf.EnabledPlugins) == 0 {
+		return true
+	}
+	for _, p := range config.GlobalConf.EnabledPlugins {
+		if p == name {
+			return true
+		}
+	}
+	return false
+}

internal/api/restart.go

@@ -0,0 +1,11 @@
+package api
+
+import (
+	"net/http"
+
+	"github.com/mirkobrombin/goup/internal/restart"
+)
+
+func restartHandler(w http.ResponseWriter, r *http.Request) {
+	restart.RestartHandler(w, r)
+}

internal/api/router.go

@@ -0,0 +1,45 @@
+package api
+
+import (
+	"net/http"
+
+	"github.com/gorilla/mux"
+)
+
+// SetupRoutes returns a configured router.
+func SetupRoutes() *mux.Router {
+	r := mux.NewRouter()
+
+	// Ping
+	r.HandleFunc("/api", func(w http.ResponseWriter, r *http.Request) {
+		jsonResponse(w, map[string]string{"message": "pong"})
+	}).Methods("GET")
+
+	// Plugins
+	r.HandleFunc("/api/plugins", getPluginsHandler).Methods("GET")
+	r.HandleFunc("/api/plugins/{pluginName}/toggle", togglePluginHandler).Methods("POST")
+
+	// Global config
+	r.HandleFunc("/api/config", getConfigHandler).Methods("GET")
+	r.HandleFunc("/api/config", updateConfigHandler).Methods("PUT")
+
+	// Logs, metrics, status
+	r.HandleFunc("/api/logs", getLogsHandler).Methods("GET")
+	r.HandleFunc("/api/metrics", getMetricsHandler).Methods("GET")
+	r.HandleFunc("/api/status", getStatusHandler).Methods("GET")
+	r.HandleFunc("/api/logweight", getLogWeightHandler).Methods("GET")
+	r.HandleFunc("/api/pluginusage", getPluginUsageHandler).Methods("GET")
+
+	// Restart
+	r.HandleFunc("/api/restart", restartHandler).Methods("POST")
+
+	// Sites
+	r.HandleFunc("/api/sites", listSitesHandler).Methods("GET")
+	r.HandleFunc("/api/sites", createSiteHandler).Methods("POST")
+	r.HandleFunc("/api/sites/{domain}", getSiteHandler).Methods("GET")
+	r.HandleFunc("/api/sites/{domain}", updateSiteHandler).Methods("PUT")
+	r.HandleFunc("/api/sites/{domain}", deleteSiteHandler).Methods("DELETE")
+	r.HandleFunc("/api/sites/{domain}/validate", validateSiteHandler).Methods("GET")
+
+	return r
+}

internal/api/server.go

@@ -0,0 +1,25 @@
+package api
+
+import (
+	"fmt"
+	"net/http"
+
+	"github.com/mirkobrombin/goup/internal/config"
+)
+
+// StartAPIServer starts the GoUp API server.
+func StartAPIServer() {
+	if config.GlobalConf == nil || !config.GlobalConf.EnableAPI {
+		return
+	}
+
+	router := SetupRoutes()
+	port := config.GlobalConf.APIPort
+
+	go func() {
+		fmt.Printf("[API] Listening on :%d\n", port)
+		if err := http.ListenAndServe(fmt.Sprintf(":%d", port), router); err != nil {
+			fmt.Printf("[API] Error: %v\n", err)
+		}
+	}()
+}