71 lines
1.9 KiB
Go
71 lines
1.9 KiB
Go
|
package cmd
|
||
|
|
|
||
|
|
import (
|
||
|
|
"log"
|
||
|
|
"os"
|
||
|
|
"os/signal"
|
||
|
|
"syscall"
|
||
|
|
"time"
|
||
|
|
|
||
|
|
"github.com/FreifunkBremen/yanic/database"
|
||
|
|
"github.com/FreifunkBremen/yanic/database/all"
|
||
|
|
"github.com/FreifunkBremen/yanic/meshviewer"
|
||
|
|
"github.com/FreifunkBremen/yanic/respond"
|
||
|
|
"github.com/FreifunkBremen/yanic/runtime"
|
||
|
|
"github.com/FreifunkBremen/yanic/webserver"
|
||
|
|
"github.com/spf13/cobra"
|
||
|
|
)
|
||
|
|
|
||
|
|
// serveCmd represents the serve command
|
||
|
|
var serveCmd = &cobra.Command{
|
||
|
|
Use: "serve",
|
||
|
|
Short: "Runs the yanic server",
|
||
|
|
Example: "yanic serve -config /etc/yanic.toml",
|
||
|
|
Run: func(cmd *cobra.Command, args []string) {
|
||
|
|
config := loadConfig()
|
||
|
|
|
||
|
|
connections, err := all.Connect(config.Database.Connection)
|
||
|
|
if err != nil {
|
||
|
|
panic(err)
|
||
|
|
}
|
||
|
|
database.Start(connections, config)
|
||
|
|
defer database.Close(connections)
|
||
|
|
|
||
|
|
nodes = runtime.NewNodes(config)
|
||
|
|
nodes.Start()
|
||
|
|
meshviewer.Start(config, nodes)
|
||
|
|
|
||
|
|
if config.Webserver.Enable {
|
||
|
|
log.Println("starting webserver on", config.Webserver.Bind)
|
||
|
|
srv := webserver.New(config.Webserver.Bind, config.Webserver.Webroot)
|
||
|
|
go srv.Close()
|
||
|
|
}
|
||
|
|
|
||
|
|
if config.Respondd.Enable {
|
||
|
|
// Delaying startup to start at a multiple of `duration` since the zero time.
|
||
|
|
if duration := config.Respondd.Synchronize.Duration; duration > 0 {
|
||
|
|
now := time.Now()
|
||
|
|
delay := duration - now.Sub(now.Truncate(duration))
|
||
|
|
log.Printf("delaying %0.1f seconds", delay.Seconds())
|
||
|
|
time.Sleep(delay)
|
||
|
|
}
|
||
|
|
|
||
|
|
collector = respond.NewCollector(connections, nodes, config.Respondd.Interface, config.Respondd.Port)
|
||
|
|
collector.Start(config.Respondd.CollectInterval.Duration)
|
||
|
|
defer collector.Close()
|
||
|
|
}
|
||
|
|
|
||
|
|
// Wait for INT/TERM
|
||
|
|
sigs := make(chan os.Signal, 1)
|
||
|
|
signal.Notify(sigs, syscall.SIGINT, syscall.SIGTERM)
|
||
|
|
sig := <-sigs
|
||
|
|
log.Println("received", sig)
|
||
|
|
|
||
|
|
},
|
||
|
|
}
|
||
|
|
|
||
|
|
func init() {
|
||
|
|
RootCmd.AddCommand(serveCmd)
|
||
|
|
serveCmd.Flags().StringVarP(&configPath, "config", "c", "config.toml", "Path to configuration file")
|
||
|
|
}
|