108 lines
2.7 KiB
Go
108 lines
2.7 KiB
Go
package warewulfconf
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
"net"
|
|
"os"
|
|
"path"
|
|
|
|
"github.com/brotherpowers/ipsubnet"
|
|
"github.com/creasty/defaults"
|
|
"github.com/hpcng/warewulf/internal/pkg/buildconfig"
|
|
"github.com/hpcng/warewulf/internal/pkg/wwlog"
|
|
|
|
"gopkg.in/yaml.v2"
|
|
)
|
|
|
|
var cachedConf ControllerConf
|
|
|
|
var ConfigFile string
|
|
|
|
func init() {
|
|
if ConfigFile == "" {
|
|
ConfigFile = path.Join(buildconfig.SYSCONFDIR(), "warewulf/warewulf.conf")
|
|
}
|
|
}
|
|
|
|
func New() (ControllerConf, error) {
|
|
var ret ControllerConf
|
|
var warewulfconf WarewulfConf
|
|
var dhpdconf DhcpConf
|
|
var tftpconf TftpConf
|
|
var nfsConf NfsConf
|
|
ret.Warewulf = &warewulfconf
|
|
ret.Dhcp = &dhpdconf
|
|
ret.Tftp = &tftpconf
|
|
ret.Nfs = &nfsConf
|
|
err := defaults.Set(&ret)
|
|
if err != nil {
|
|
wwlog.Error("Coult initialize default variables")
|
|
return ret, err
|
|
}
|
|
// Check if cached config is old before re-reading config file
|
|
if !cachedConf.current {
|
|
wwlog.Debug("Opening Warewulf configuration file: %s", ConfigFile)
|
|
data, err := os.ReadFile(ConfigFile)
|
|
if err != nil {
|
|
wwlog.Warn("Error reading Warewulf configuration file")
|
|
}
|
|
|
|
wwlog.Debug("Unmarshaling the Warewulf configuration")
|
|
err = yaml.Unmarshal(data, &ret)
|
|
if err != nil {
|
|
return ret, err
|
|
}
|
|
|
|
if ret.Ipaddr == "" || ret.Netmask == "" {
|
|
conn, error := net.Dial("udp", "8.8.8.8:80")
|
|
if error != nil {
|
|
return ret, err
|
|
}
|
|
defer conn.Close()
|
|
localIp := conn.LocalAddr().(*net.UDPAddr)
|
|
if ret.Ipaddr == "" {
|
|
ret.Ipaddr = localIp.IP.String()
|
|
wwlog.Warn("IP address is not configured in warewulfd.conf, using %s", ret.Ipaddr)
|
|
}
|
|
if ret.Netmask == "" {
|
|
mask := localIp.IP.DefaultMask()
|
|
ret.Netmask = fmt.Sprintf("%d.%d.%d.%d", mask[0], mask[1], mask[2], mask[3])
|
|
wwlog.Warn("Netmask address is not configured in warewulfd.conf, using %s", ret.Netmask)
|
|
}
|
|
}
|
|
|
|
if ret.Network == "" {
|
|
mask := net.IPMask(net.ParseIP(ret.Netmask).To4())
|
|
size, _ := mask.Size()
|
|
|
|
sub := ipsubnet.SubnetCalculator(ret.Ipaddr, size)
|
|
|
|
ret.Network = sub.GetNetworkPortion()
|
|
}
|
|
// check validity of ipv6 net
|
|
if ret.Ipaddr6 != "" {
|
|
_, ipv6net, err := net.ParseCIDR(ret.Ipaddr6)
|
|
if err != nil {
|
|
wwlog.Error("Invalid ipv6 address specified, mut be CIDR notation: %s", ret.Ipaddr6)
|
|
return ret, errors.New("invalid ipv6 network")
|
|
}
|
|
if msize, _ := ipv6net.Mask.Size(); msize > 64 {
|
|
wwlog.Error("ipv6 mask size must be smaller than 64")
|
|
return ret, errors.New("invalid ipv6 network size")
|
|
}
|
|
}
|
|
|
|
wwlog.Debug("Returning warewulf config object")
|
|
cachedConf = ret
|
|
cachedConf.current = true
|
|
|
|
} else {
|
|
wwlog.Debug("Returning cached warewulf config object")
|
|
// If cached struct isn't empty, use it as the return value
|
|
ret = cachedConf
|
|
}
|
|
|
|
return ret, nil
|
|
}
|