Skip to content
Snippets Groups Projects
controller.go 1.23 KiB
Newer Older
  • Learn to ignore specific revisions
  • package nucleus
    
    import (
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	"code.fbi.h-da.de/cocsn/gosdn/database"
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	"code.fbi.h-da.de/cocsn/gosdn/nucleus/interfaces"
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	"github.com/BurntSushi/toml"
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	"log"
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	"os"
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    type controllerConfig struct {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	CliSocket        string
    	DatabaseSocket   string
    	DatabaseUser     string
    	DatabasePassword string
    	DatabaseCrypto   bool
    	ConfigPath       string
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    }
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    type Core struct {
    	clients  []interfaces.Client
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	database database.Database
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	config   controllerConfig
    }
    
    func (c *Core) Init(socket, configfile string) {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	if configfile == "" {
    		configfile = "gosdn.toml"
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	}
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	_, err := os.Stat(configfile)
    
    	if err != nil {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    		log.Fatal("Config file is missing: ", configfile)
    
    Martin Stiemerling's avatar
    Martin Stiemerling committed
    
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	c.config = controllerConfig{}
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	if _, err := toml.DecodeFile(configfile, &c.config); err != nil {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    		log.Fatal(err)
    	}
    	if socket != "localhost:55055" {
    		c.config.CliSocket = socket
    
    Martin Stiemerling's avatar
    Martin Stiemerling committed
    	}
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	if c.config.ConfigPath == "" {
    		c.config.ConfigPath = configfile
    	}
    
    Martin Stiemerling's avatar
    Martin Stiemerling committed
    
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	c.database = database.NewDatabaseClient(c.config.DatabaseSocket, c.config.DatabaseUser, c.config.DatabasePassword, c.config.DatabaseCrypto)
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    }
    
    
    func (c *Core) Shutdown() {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	f, err := os.Create(c.config.ConfigPath)
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	if err != nil {
    		log.Fatal(err)
    	}
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    	enc := toml.NewEncoder(f)
    	if err := enc.Encode(c.config); err != nil {
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    		log.Fatal(err)
    	}
    
    Manuel Kieweg's avatar
    Manuel Kieweg committed
    }