Move yggdrasil command line env to separate file

This commit is contained in:
Alex Kotov 2021-08-03 11:22:27 +05:00
parent cbb6dc1b7d
commit 7b437a1dcd
3 changed files with 68 additions and 63 deletions

View file

@ -0,0 +1,45 @@
package main
import "flag"
type CmdLineEnv struct {
genconf bool
useconf bool
useconffile string
normaliseconf bool
confjson bool
autoconf bool
ver bool
logto string
getaddr bool
getsnet bool
loglevel string
}
func (cmdLineEnv *CmdLineEnv) parseFlagsAndArgs() {
genconf := flag.Bool("genconf", false, "print a new config to stdout")
useconf := flag.Bool("useconf", false, "read HJSON/JSON config from stdin")
useconffile := flag.String("useconffile", "", "read HJSON/JSON config from specified file path")
normaliseconf := flag.Bool("normaliseconf", false, "use in combination with either -useconf or -useconffile, outputs your configuration normalised")
confjson := flag.Bool("json", false, "print configuration from -genconf or -normaliseconf as JSON instead of HJSON")
autoconf := flag.Bool("autoconf", false, "automatic mode (dynamic IP, peer with IPv6 neighbors)")
ver := flag.Bool("version", false, "prints the version of this build")
logto := flag.String("logto", "stdout", "file path to log to, \"syslog\" or \"stdout\"")
getaddr := flag.Bool("address", false, "returns the IPv6 address as derived from the supplied configuration")
getsnet := flag.Bool("subnet", false, "returns the IPv6 subnet as derived from the supplied configuration")
loglevel := flag.String("loglevel", "info", "loglevel to enable")
flag.Parse()
cmdLineEnv.genconf = *genconf
cmdLineEnv.useconf = *useconf
cmdLineEnv.useconffile = *useconffile
cmdLineEnv.normaliseconf = *normaliseconf
cmdLineEnv.confjson = *confjson
cmdLineEnv.autoconf = *autoconf
cmdLineEnv.ver = *ver
cmdLineEnv.logto = *logto
cmdLineEnv.getaddr = *getaddr
cmdLineEnv.getsnet = *getsnet
cmdLineEnv.loglevel = *loglevel
}

View file

@ -182,54 +182,12 @@ func setLogLevel(loglevel string, logger *log.Logger) {
} }
} }
type yggArgs struct {
genconf bool
useconf bool
useconffile string
normaliseconf bool
confjson bool
autoconf bool
ver bool
logto string
getaddr bool
getsnet bool
loglevel string
}
func getArgs() yggArgs {
genconf := flag.Bool("genconf", false, "print a new config to stdout")
useconf := flag.Bool("useconf", false, "read HJSON/JSON config from stdin")
useconffile := flag.String("useconffile", "", "read HJSON/JSON config from specified file path")
normaliseconf := flag.Bool("normaliseconf", false, "use in combination with either -useconf or -useconffile, outputs your configuration normalised")
confjson := flag.Bool("json", false, "print configuration from -genconf or -normaliseconf as JSON instead of HJSON")
autoconf := flag.Bool("autoconf", false, "automatic mode (dynamic IP, peer with IPv6 neighbors)")
ver := flag.Bool("version", false, "prints the version of this build")
logto := flag.String("logto", "stdout", "file path to log to, \"syslog\" or \"stdout\"")
getaddr := flag.Bool("address", false, "returns the IPv6 address as derived from the supplied configuration")
getsnet := flag.Bool("subnet", false, "returns the IPv6 subnet as derived from the supplied configuration")
loglevel := flag.String("loglevel", "info", "loglevel to enable")
flag.Parse()
return yggArgs{
genconf: *genconf,
useconf: *useconf,
useconffile: *useconffile,
normaliseconf: *normaliseconf,
confjson: *confjson,
autoconf: *autoconf,
ver: *ver,
logto: *logto,
getaddr: *getaddr,
getsnet: *getsnet,
loglevel: *loglevel,
}
}
// The main function is responsible for configuring and starting Yggdrasil. // The main function is responsible for configuring and starting Yggdrasil.
func run(args yggArgs, ctx context.Context, done chan struct{}) { func run(cmdLineEnv CmdLineEnv, ctx context.Context, done chan struct{}) {
defer close(done) defer close(done)
// Create a new logger that logs output to stdout. // Create a new logger that logs output to stdout.
var logger *log.Logger var logger *log.Logger
switch args.logto { switch cmdLineEnv.logto {
case "stdout": case "stdout":
logger = log.New(os.Stdout, "", log.Flags()) logger = log.New(os.Stdout, "", log.Flags())
case "syslog": case "syslog":
@ -237,7 +195,7 @@ func run(args yggArgs, ctx context.Context, done chan struct{}) {
logger = log.New(syslogger, "", log.Flags()) logger = log.New(syslogger, "", log.Flags())
} }
default: default:
if logfd, err := os.OpenFile(args.logto, os.O_APPEND|os.O_CREATE|os.O_WRONLY, 0644); err == nil { if logfd, err := os.OpenFile(cmdLineEnv.logto, os.O_APPEND|os.O_CREATE|os.O_WRONLY, 0644); err == nil {
logger = log.New(logfd, "", log.Flags()) logger = log.New(logfd, "", log.Flags())
} }
} }
@ -246,33 +204,33 @@ func run(args yggArgs, ctx context.Context, done chan struct{}) {
logger.Warnln("Logging defaulting to stdout") logger.Warnln("Logging defaulting to stdout")
} }
if args.normaliseconf { if cmdLineEnv.normaliseconf {
setLogLevel("error", logger) setLogLevel("error", logger)
} else { } else {
setLogLevel(args.loglevel, logger) setLogLevel(cmdLineEnv.loglevel, logger)
} }
var cfg *config.NodeConfig var cfg *config.NodeConfig
var err error var err error
switch { switch {
case args.ver: case cmdLineEnv.ver:
fmt.Println("Build name:", version.BuildName()) fmt.Println("Build name:", version.BuildName())
fmt.Println("Build version:", version.BuildVersion()) fmt.Println("Build version:", version.BuildVersion())
return return
case args.autoconf: case cmdLineEnv.autoconf:
// Use an autoconf-generated config, this will give us random keys and // Use an autoconf-generated config, this will give us random keys and
// port numbers, and will use an automatically selected TUN/TAP interface. // port numbers, and will use an automatically selected TUN/TAP interface.
cfg = defaults.GenerateConfig() cfg = defaults.GenerateConfig()
case args.useconffile != "" || args.useconf: case cmdLineEnv.useconffile != "" || cmdLineEnv.useconf:
// Read the configuration from either stdin or from the filesystem // Read the configuration from either stdin or from the filesystem
cfg = readConfig(logger, args.useconf, args.useconffile, args.normaliseconf) cfg = readConfig(logger, cmdLineEnv.useconf, cmdLineEnv.useconffile, cmdLineEnv.normaliseconf)
// If the -normaliseconf option was specified then remarshal the above // If the -normaliseconf option was specified then remarshal the above
// configuration and print it back to stdout. This lets the user update // configuration and print it back to stdout. This lets the user update
// their configuration file with newly mapped names (like above) or to // their configuration file with newly mapped names (like above) or to
// convert from plain JSON to commented HJSON. // convert from plain JSON to commented HJSON.
if args.normaliseconf { if cmdLineEnv.normaliseconf {
var bs []byte var bs []byte
if args.confjson { if cmdLineEnv.confjson {
bs, err = json.MarshalIndent(cfg, "", " ") bs, err = json.MarshalIndent(cfg, "", " ")
} else { } else {
bs, err = hjson.Marshal(cfg) bs, err = hjson.Marshal(cfg)
@ -283,9 +241,9 @@ func run(args yggArgs, ctx context.Context, done chan struct{}) {
fmt.Println(string(bs)) fmt.Println(string(bs))
return return
} }
case args.genconf: case cmdLineEnv.genconf:
// Generate a new configuration and print it to stdout. // Generate a new configuration and print it to stdout.
fmt.Println(doGenconf(args.confjson)) fmt.Println(doGenconf(cmdLineEnv.confjson))
return return
default: default:
// No flags were provided, therefore print the list of flags to stdout. // No flags were provided, therefore print the list of flags to stdout.
@ -305,14 +263,14 @@ func run(args yggArgs, ctx context.Context, done chan struct{}) {
return nil return nil
} }
switch { switch {
case args.getaddr: case cmdLineEnv.getaddr:
if key := getNodeKey(); key != nil { if key := getNodeKey(); key != nil {
addr := address.AddrForKey(key) addr := address.AddrForKey(key)
ip := net.IP(addr[:]) ip := net.IP(addr[:])
fmt.Println(ip.String()) fmt.Println(ip.String())
} }
return return
case args.getsnet: case cmdLineEnv.getsnet:
if key := getNodeKey(); key != nil { if key := getNodeKey(); key != nil {
snet := address.SubnetForKey(key) snet := address.SubnetForKey(key)
ipnet := net.IPNet{ ipnet := net.IPNet{
@ -384,7 +342,9 @@ func (n *node) shutdown() {
} }
func main() { func main() {
args := getArgs() var cmdLineEnv CmdLineEnv
cmdLineEnv.parseFlagsAndArgs()
hup := make(chan os.Signal, 1) hup := make(chan os.Signal, 1)
//signal.Notify(hup, os.Interrupt, syscall.SIGHUP) //signal.Notify(hup, os.Interrupt, syscall.SIGHUP)
term := make(chan os.Signal, 1) term := make(chan os.Signal, 1)
@ -392,7 +352,7 @@ func main() {
for { for {
done := make(chan struct{}) done := make(chan struct{})
ctx, cancel := context.WithCancel(context.Background()) ctx, cancel := context.WithCancel(context.Background())
go run(args, ctx, done) go run(cmdLineEnv, ctx, done)
select { select {
case <-hup: case <-hup:
cancel() cancel()