Merge pull request #54 from bostelk/server-settings

Server settings first-pass

Author: Mitch Roote

src/gameconfig.go renamed to src/factorio_config.go

@@ -0,0 +1,179 @@
+package main
+
+import (
+	"encoding/json"
+	"io"
+	"io/ioutil"
+	"log"
+	"os"
+	"os/exec"
+	"path/filepath"
+	"runtime"
+	"strconv"
+)
+
+type FactorioServer struct {
+	Cmd      *exec.Cmd
+	Savefile string
+	Latency  int  `json:"latency"`
+	Port     int  `json:"port"`
+	Running  bool `json:"running"`
+	StdOut   io.ReadCloser
+	StdErr   io.ReadCloser
+	StdIn    io.WriteCloser
+	Settings FactorioServerSettings
+}
+
+type FactorioServerSettings struct {
+	Name                                 string   `json:"name"`
+	Description                          string   `json:"description"`
+	Tags                                 []string `json:"tags"`
+	MaxPlayers                           int      `json:"max_players"`
+	Visibility                           string   `json:"visibility"`
+	Username                             string   `json:"username"`
+	Password                             string   `json:"password"`
+	Token                                string   `json:"token"`
+	GamePassword                         string   `json:"game_password"`
+	RequireUserVerification              bool     `json:"require_user_verification"`
+	MaxUploadInKilobytesPerSecond        int      `json:"max_upload_in_kilobytes_per_second"`
+	IgnorePlayerLimitForReturningPlayers bool     `json:"ignore_player_limit_for_returning_players"`
+	AllowCommands                        string   `json:"allow_commands"`
+	AutosaveInterval                     int      `json:"autosave_interval"`
+	AutosaveSlots                        int      `json:"autosave_slots"`
+	AfkAutoKickInterval                  int      `json:"afk_autokick_interval"`
+	AutoPause                            bool     `json:"auto_pause"`
+	OnlyAdminsCanPauseThegame            bool     `json:"only_admins_can_pause_the_game"`
+	Admins                               []string `json:"admins"`
+}
+
+func createSave(filePath string) (string, error) {
+	err := os.MkdirAll(filepath.Base(filePath), 0755)
+	if err != nil {
+		log.Printf("Error in creating Factorio save: %s", err)
+		return "", err
+	}
+
+	args := []string{"--create", filePath}
+	cmdOutput, err := exec.Command(config.FactorioBinary, args...).Output()
+	if err != nil {
+		log.Printf("Error in creating Factorio save: %s", err)
+		return "", err
+	}
+
+	result := string(cmdOutput)
+
+	return result, nil
+}
+
+func initFactorio() *FactorioServer {
+	f := FactorioServer{}
+
+	// default settings from server-settings.example.json
+	f.Settings = FactorioServerSettings{
+		Name:                                 "Factorio",
+		Description:                          "Created by Factorio Server Manager",
+		Tags:                                 []string{},
+		MaxPlayers:                           0,
+		Visibility:                           "public",
+		Username:                             "",
+		Password:                             "",
+		Token:                                "",
+		GamePassword:                         "",
+		RequireUserVerification:              true,
+		MaxUploadInKilobytesPerSecond:        0,
+		IgnorePlayerLimitForReturningPlayers: false,
+		AllowCommands:                        "admins-only",
+		AutosaveInterval:                     10,
+		AutosaveSlots:                        5,
+		AfkAutoKickInterval:                  0,
+		AutoPause:                            true,
+		OnlyAdminsCanPauseThegame:            true,
+		Admins: []string{},
+	}
+
+	return &f
+}
+
+func (f *FactorioServer) Run() error {
+	var err error
+
+	data, err := json.MarshalIndent(f.Settings, "", "  ")
+	if err != nil {
+		log.Println("Failed to marshal FactorioServerSettings: ", err)
+	} else {
+		ioutil.WriteFile(filepath.Join(config.FactorioDir, "server-settings.json"), data, 0755)
+	}
+
+	args := []string{
+		"--start-server", filepath.Join(config.FactorioSavesDir, f.Savefile),
+		"--port", strconv.Itoa(f.Port),
+		"--server-settings", filepath.Join(config.FactorioDir, "server-settings.json"),
+	}
+
+	log.Println("Starting server with command: ", config.FactorioBinary, args)
+
+	f.Cmd = exec.Command(config.FactorioBinary, args...)
+
+	f.StdOut, err = f.Cmd.StdoutPipe()
+	if err != nil {
+		log.Printf("Error opening stdout pipe: %s", err)
+		return err
+	}
+
+	f.StdIn, err = f.Cmd.StdinPipe()
+	if err != nil {
+		log.Printf("Error opening stdin pipe: %s", err)
+		return err
+	}
+
+	f.StdErr, err = f.Cmd.StderrPipe()
+	if err != nil {
+		log.Printf("Error opening stderr pipe: %s", err)
+		return err
+	}
+
+	go io.Copy(os.Stdout, f.StdOut)
+	go io.Copy(os.Stderr, f.StdErr)
+
+	err = f.Cmd.Start()
+	if err != nil {
+		log.Printf("Error starting server process: %s", err)
+		return err
+	}
+
+	f.Running = true
+
+	err = f.Cmd.Wait()
+	if err != nil {
+		log.Printf("Command exited with error: %s", err)
+		return err
+	}
+
+	return nil
+}
+
+func (f *FactorioServer) Stop() error {
+	// TODO: Find an alternative to os.Kill on Windows. os.Interupt
+	// is not implemented. Maps will not be saved.
+	if runtime.GOOS == "windows" {
+		err := f.Cmd.Process.Signal(os.Kill)
+		if err != nil {
+			log.Printf("Error sending SIGKILLL to Factorio process: %s", err)
+			return err
+		} else {
+			f.Running = false
+			log.Println("Sent SIGKILL to Factorio process. Factorio forced to exit.")
+		}
+	} else {
+		err := f.Cmd.Process.Signal(os.Interrupt)
+		if err != nil {
+			log.Printf("Error sending SIGINT to Factorio process: %s", err)
+			return err
+		} else {
+			f.Running = false
+			log.Printf("Sent SIGINT to Factorio process. Factorio shutting down...")
+		}
+	}
+
+	return nil
+}

src/factorio_server.go

@@ -529,12 +529,11 @@ func LoadConfig(w http.ResponseWriter, r *http.Request) {
 		if err := json.NewEncoder(w).Encode(resp); err != nil {
 			log.Printf("Error tailing logfile", err)
 		}
-		return
+	} else {
+		resp.Data = configContents
+		resp.Success = true
 	}
 
-	resp.Data = configContents
-	resp.Success = true
-
 	if err := json.NewEncoder(w).Encode(resp); err != nil {
 		log.Printf("Error encoding config file JSON reponse: ", err)
 	}
@@ -931,3 +930,21 @@ func RemoveUser(w http.ResponseWriter, r *http.Request) {
 		}
 	}
 }
+
+// Return JSON response of config.ini file
+func GetServerSettings(w http.ResponseWriter, r *http.Request) {
+	resp := JSONResponse{
+		Success: false,
+	}
+
+	w.Header().Set("Content-Type", "application/json;charset=UTF-8")
+
+	resp.Data = FactorioServ.Settings
+	resp.Success = true
+
+	if err := json.NewEncoder(w).Encode(resp); err != nil {
+		log.Printf("Error encoding server settings JSON reponse: ", err)
+	}
+
+	log.Printf("Sent server settings response")
+}

src/handlers.go

@@ -220,5 +220,10 @@ var apiRoutes = Routes{
 		"POST",
 		"/mods/packs/add",
 		CreateModPackHandler,
+	}, {
+		"GetServerSettings",
+		"GET",
+		"/settings",
+		GetServerSettings,
 	},
 }