add -apply flag, add webserver

api/apply.go

@@ -0,0 +1,23 @@
+package main
+
+import (
+	"fmt"
+
+	"golang.org/x/exp/slog"
+	"nfsense.net/nfsense/pkg/definitions"
+	"nfsense.net/nfsense/pkg/nftables"
+)
+
+func apply(conf *definitions.Config) error {
+	fileContent, err := nftables.GenerateNfTablesFile(*conf)
+	if err != nil {
+		return fmt.Errorf("Generating nftables file %w", err)
+	}
+
+	err = nftables.ApplyNfTablesFile(fileContent)
+	if err != nil {
+		return fmt.Errorf("Applying nftables %w", err)
+	}
+	slog.Info("Wrote nftables File!")
+	return nil
+}

api/main.go

@@ -1,29 +1,57 @@
 package main
 
 import (
+	"context"
+	"flag"
+	"os"
+	"os/signal"
+	"syscall"
+	"time"
+
 	"golang.org/x/exp/slog"
-	"nfsense.net/nfsense/pkg/nftables"
+	"nfsense.net/nfsense/pkg/server"
 )
 
 func main() {
+	applyPtr := flag.Bool("apply", false, "apply config and stop")
+	flag.Parse()
+
 	slog.Info("Starting...")
+
 	conf, err := LoadConfiguration("config.json")
 	if err != nil {
 		slog.Error("Loading Config", err)
 		return
 	}
+
 	slog.Info("Config Loaded", "config", conf)
 
-	fileContent, err := nftables.GenerateNfTablesFile(*conf)
+	if *applyPtr {
+		slog.Info("Applying Config...")
+		err := apply(conf)
 		if err != nil {
-		slog.Error("Generating nftables file", err)
+			slog.Error("Applying Config", err)
+			return
+		}
+		slog.Info("Config Applied, Exiting...")
 		return
 	}
 
-	err = nftables.ApplyNfTablesFile(fileContent)
+	slog.Info("Starting Webserver...")
-	if err != nil {
+	server.StartWebserver(conf)
-		slog.Error("Applying nftables", err)
+
-		return
+	slog.Info("Ready")
-	}
+
-	slog.Info("Wrote nftables File!")
+	// Handle Exit Signal
+	sigChan := make(chan os.Signal, 1)
+	signal.Notify(sigChan, syscall.SIGINT, syscall.SIGTERM)
+	<-sigChan
+	slog.Info("Got Signal, Exiting...")
+
+	shutdownCtx, shutdownRelease := context.WithTimeout(context.Background(), 10*time.Second)
+	defer shutdownRelease()
+
+	server.ShutdownWebserver(shutdownCtx)
+
+	slog.Info("Done")
 }

pkg/server/server.go

@@ -0,0 +1,32 @@
+package server
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"net/http"
+
+	"golang.org/x/exp/slog"
+
+	"nfsense.net/nfsense/pkg/definitions"
+)
+
+var server http.Server
+
+func StartWebserver(conf *definitions.Config) {
+	server.Addr = ":8080"
+	go func() {
+		if err := server.ListenAndServe(); !errors.Is(err, http.ErrServerClosed) {
+			slog.Error("Webserver error", err)
+		}
+		slog.Info("Webserver Stopped")
+	}()
+}
+
+func ShutdownWebserver(ctx context.Context) error {
+	err := server.Shutdown(ctx)
+	if err != nil {
+		return fmt.Errorf("Shutting down: %w", err)
+	}
+	return nil
+}