feat: bootstapping and systemd

main.go

@@ -10,6 +10,21 @@ import (
 	"strings"
 )
 
+var systemdServiceUnit = strings.TrimSpace(`
+[Unit]
+Description=Stats Server
+After=network.target
+
+[Service]
+Type=simple
+Restart=always
+RestartSec=15
+ExecStart=/usr/local/bin/stats-server serve
+
+[Install]
+WantedBy=default.target
+`)
+
 var commands = map[string]string{
 	"cpu":     `top -bn1 | grep "Cpu(s)" | sed "s/.*, *\([0-9.]*\)%* id.*/\1/" | sed "s/^/100 - /" | bc`,
 	"memory":  `free -m | awk '/Mem/{print $3 " " $2}'`,
@@ -18,15 +33,19 @@ var commands = map[string]string{
 	"uptime":  `cut -f1 -d. /proc/uptime`,
 }
 
-// executeCommand runs a system command and returns its output
-func executeCommand(command string) string {
+func init() {
+	log.SetFlags(0)
+}
+
+// runShellCommand runs a system command and returns its output
+func runShellCommand(command string) (string, error) {
 	cmd := exec.Command("bash", "-c", command)
 	output, err := cmd.CombinedOutput()
 	if err != nil {
-		return err.Error()
+		return string(output), err
 	}
 
-	return string(output)
+	return string(output), nil
 }
 
 // handleConnection handles one command per connection
@@ -35,23 +54,70 @@ func handleConnection(conn net.Conn) {
 
 	scanner := bufio.NewScanner(conn)
 	if !scanner.Scan() {
-		log.Printf("Error reading from %s, %s", conn.RemoteAddr(), scanner.Err())
+		log.Printf("error reading from %s, %s", conn.RemoteAddr(), scanner.Err())
 		return
 	}
 
 	command := scanner.Text()
+	log.Printf("received command %s from %s", command, conn.RemoteAddr())
 
-	cmd, valid := commands[strings.TrimSpace(string(command))]
+	shellCmd, valid := commands[strings.TrimSpace(string(command))]
 	if !valid {
 		fmt.Fprintln(conn, "invalid command")
 		return
 	}
 
-	output := executeCommand(cmd)
+	output, err := runShellCommand(shellCmd)
+	if err != nil {
+		log.Fatal(err)
+		return
+	}
+
 	fmt.Fprintln(conn, output)
 }
 
-func main() {
+func runCommand(args ...string) error {
+	cmd := exec.Command(args[0], args[1:]...)
+	if err := cmd.Run(); err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func setupSystemdService() error {
+	// copy itself to /usr/bin
+	log.Println("copying itself to /usr/local/bin/stats-server")
+	if err := runCommand("cp", os.Args[0], "/usr/local/bin/stats-server"); err != nil {
+		return err
+	}
+
+	// write systemd service unit
+	log.Println("generating /etc/systemd/system/stats-server.service")
+	if err := os.WriteFile(
+		"/etc/systemd/system/stats-server.service",
+		[]byte(systemdServiceUnit),
+		os.ModePerm,
+	); err != nil {
+		return err
+	}
+
+	// reload systemd
+	log.Println("running systemctl daemon-reload")
+	if err := runCommand("systemctl", "daemon-reload"); err != nil {
+		return err
+	}
+
+	// enable and start the service
+	log.Println("running systemctl enable --now stats-server.service")
+	if err := runCommand("systemctl", "enable", "--now", "stats-server.service"); err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func startTCPServer() error {
 	host, ok := os.LookupEnv("HOST")
 	if !ok {
 		host = ":12345"
@@ -59,20 +125,50 @@ func main() {
 
 	ln, err := net.Listen("tcp", host)
 	if err != nil {
-		fmt.Println("Error:", err)
-		os.Exit(1)
+		return err
 	}
 	defer ln.Close()
 
-	log.Printf("Listening on %s...", host)
+	log.Printf("listening on %s...", host)
 	for {
 		conn, err := ln.Accept()
 		if err != nil {
-			fmt.Println("Error:", err)
+			log.Printf("error accepting connection: %s", err)
 			continue
 		}
 
-		log.Printf("Connection from %s", conn.RemoteAddr())
+		log.Printf("connection from %s", conn.RemoteAddr())
 		go handleConnection(conn)
 	}
 }
+
+func showHelp() {
+	fmt.Println("usage: stats-server [setup|serve]")
+	fmt.Println("  setup: setup systemd service")
+	fmt.Println("  serve: start tcp server")
+
+	os.Exit(1)
+}
+
+func main() {
+	if len(os.Args) != 2 {
+		showHelp()
+	}
+
+	switch os.Args[1] {
+	case "setup":
+		if err := setupSystemdService(); err != nil {
+			log.Fatal(err)
+		}
+
+		log.Println("setup complete")
+	case "serve":
+		if err := startTCPServer(); err != nil {
+			log.Fatal(err)
+		}
+
+		log.Println("server exited")
+	default:
+		showHelp()
+	}
+}