mirror of
https://github.com/gravitl/netmaker.git
synced 2025-10-05 08:47:35 +08:00
leave cleanup
This commit is contained in:
Matthew R Kasun
@@ -10,6 +10,7 @@ import (
|
||||
"net"
|
||||
"net/http"
|
||||
"os"
|
||||
"path/filepath"
|
||||
"strconv"
|
||||
"strings"
|
||||
"time"
|
||||
@@ -172,145 +173,152 @@ func LeaveNetwork(network string) error {
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
node := cfg.Node
|
||||
if node.IsServer != "yes" {
|
||||
token, err := Authenticate(cfg)
|
||||
if err != nil {
|
||||
logger.Log(0, "network:", cfg.Network, "unable to authenticate: "+err.Error())
|
||||
} else {
|
||||
url := "https://" + cfg.Server.API + "/api/nodes/" + cfg.Network + "/" + cfg.Node.ID
|
||||
response, err := API("", http.MethodDelete, url, token)
|
||||
if err != nil {
|
||||
logger.Log(0, "network:", cfg.Network, "error deleting node on server: "+err.Error())
|
||||
} else {
|
||||
if response.StatusCode == http.StatusOK {
|
||||
logger.Log(0, "network:", cfg.Network, "deleted node", cfg.Node.Name, ".")
|
||||
} else {
|
||||
bodybytes, _ := io.ReadAll(response.Body)
|
||||
defer response.Body.Close()
|
||||
logger.Log(0, fmt.Sprintf("network: %s error deleting node on server %s %s", cfg.Network, response.Status, string(bodybytes)))
|
||||
}
|
||||
}
|
||||
}
|
||||
if err := deleteNodeFromServer(cfg); err != nil {
|
||||
logger.Log(0, "error deleting node from server", err.Error())
|
||||
}
|
||||
wgClient, wgErr := wgctrl.New()
|
||||
if wgErr == nil {
|
||||
removeIface := cfg.Node.Interface
|
||||
queryAddr := cfg.Node.PrimaryAddress()
|
||||
if ncutils.IsMac() {
|
||||
var macIface string
|
||||
macIface, wgErr = local.GetMacIface(queryAddr)
|
||||
if wgErr == nil && removeIface != "" {
|
||||
removeIface = macIface
|
||||
}
|
||||
}
|
||||
dev, devErr := wgClient.Device(removeIface)
|
||||
if devErr == nil {
|
||||
local.FlushPeerRoutes(removeIface, queryAddr, dev.Peers[:])
|
||||
_, cidr, cidrErr := net.ParseCIDR(cfg.NetworkSettings.AddressRange)
|
||||
if cidrErr == nil {
|
||||
local.RemoveCIDRRoute(removeIface, queryAddr, cidr)
|
||||
}
|
||||
} else {
|
||||
logger.Log(1, "could not flush peer routes when leaving network,", cfg.Node.Network)
|
||||
}
|
||||
if err := deleteLocalNetwork(cfg); err != nil {
|
||||
logger.Log(0, "error deleting local network ", err.Error())
|
||||
}
|
||||
|
||||
err = WipeLocal(node.Network)
|
||||
if err != nil {
|
||||
logger.Log(1, "network:", node.Network, "unable to wipe local config")
|
||||
} else {
|
||||
logger.Log(1, "removed", node.Network, "network locally")
|
||||
if err := WipeLocal(cfg); err != nil {
|
||||
logger.Log(0, "error deleting local network ", err.Error())
|
||||
}
|
||||
|
||||
if err := removeHostDNS(cfg.Node.Interface, ncutils.IsWindows()); err != nil {
|
||||
logger.Log(0, "failed to delete dns entries for", cfg.Node.Interface, err.Error())
|
||||
}
|
||||
//TODO remove keys if last network on server
|
||||
return daemon.Restart()
|
||||
}
|
||||
|
||||
func deleteNodeFromServer(cfg *config.ClientConfig) error {
|
||||
node := cfg.Node
|
||||
if node.IsServer == "yes" {
|
||||
return errors.New("attempt to delete server node ... not permitted")
|
||||
}
|
||||
token, err := Authenticate(cfg)
|
||||
if err != nil {
|
||||
return fmt.Errorf("unable to authenticate %w", err)
|
||||
}
|
||||
url := "https://" + cfg.Server.API + "/api/nodes/" + cfg.Network + "/" + cfg.Node.ID
|
||||
response, err := API("", http.MethodDelete, url, token)
|
||||
if err != nil {
|
||||
return fmt.Errorf("error deleting node on server: %w", err)
|
||||
}
|
||||
if response.StatusCode != http.StatusOK {
|
||||
bodybytes, _ := io.ReadAll(response.Body)
|
||||
defer response.Body.Close()
|
||||
return fmt.Errorf("error deleting node from network %s on server %s %s", cfg.Network, response.Status, string(bodybytes))
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func deleteLocalNetwork(cfg *config.ClientConfig) error {
|
||||
wgClient, wgErr := wgctrl.New()
|
||||
if wgErr != nil {
|
||||
return wgErr
|
||||
}
|
||||
removeIface := cfg.Node.Interface
|
||||
queryAddr := cfg.Node.PrimaryAddress()
|
||||
if ncutils.IsMac() {
|
||||
var macIface string
|
||||
macIface, wgErr = local.GetMacIface(queryAddr)
|
||||
if wgErr == nil && removeIface != "" {
|
||||
removeIface = macIface
|
||||
}
|
||||
}
|
||||
dev, devErr := wgClient.Device(removeIface)
|
||||
if devErr != nil {
|
||||
return fmt.Errorf("error flushing routes %w", devErr)
|
||||
}
|
||||
local.FlushPeerRoutes(removeIface, queryAddr, dev.Peers[:])
|
||||
_, cidr, cidrErr := net.ParseCIDR(cfg.NetworkSettings.AddressRange)
|
||||
if cidrErr != nil {
|
||||
return fmt.Errorf("error flushing routes %w", cidrErr)
|
||||
}
|
||||
local.RemoveCIDRRoute(removeIface, queryAddr, cidr)
|
||||
return nil
|
||||
}
|
||||
|
||||
// DeleteInterface - delete an interface of a network
|
||||
func DeleteInterface(ifacename string, postdown string) error {
|
||||
return wireguard.RemoveConf(ifacename, true)
|
||||
}
|
||||
|
||||
// WipeLocal - wipes local instance
|
||||
func WipeLocal(network string) error {
|
||||
var ifacename string
|
||||
|
||||
if network == "" {
|
||||
return errors.New("no network provided")
|
||||
}
|
||||
cfg, err := config.ReadConfig(network)
|
||||
if err == nil {
|
||||
nodecfg := cfg.Node
|
||||
ifacename = nodecfg.Interface
|
||||
if ifacename != "" {
|
||||
if err = wireguard.RemoveConf(ifacename, true); err == nil {
|
||||
logger.Log(1, "network:", nodecfg.Network, "removed WireGuard interface: ", ifacename)
|
||||
} else if strings.Contains(err.Error(), "does not exist") {
|
||||
err = nil
|
||||
}
|
||||
}
|
||||
} else {
|
||||
logger.Log(0, "failed to read "+network+" config: ", err.Error())
|
||||
func WipeLocal(cfg *config.ClientConfig) error {
|
||||
if err := wireguard.RemoveConf(cfg.Node.Interface, true); err == nil {
|
||||
logger.Log(1, "network:", cfg.Node.Network, "removed WireGuard interface: ", cfg.Node.Interface)
|
||||
} else if strings.Contains(err.Error(), "does not exist") {
|
||||
err = nil
|
||||
}
|
||||
|
||||
home := ncutils.GetNetclientPathSpecific()
|
||||
if ncutils.FileExists(home + "netconfig-" + network) {
|
||||
err = os.Remove(home + "netconfig-" + network)
|
||||
if err != nil {
|
||||
log.Println("error removing netconfig:")
|
||||
log.Println(err.Error())
|
||||
fail := false
|
||||
files, err := filepath.Glob(cfg.Node.Network)
|
||||
if err != nil {
|
||||
logger.Log(0, "no matching files", err.Error())
|
||||
fail = true
|
||||
}
|
||||
for _, file := range files {
|
||||
if err := os.Remove(file); err != nil {
|
||||
logger.Log(0, "failed to delete file", file, err.Error())
|
||||
fail = true
|
||||
}
|
||||
}
|
||||
if ncutils.FileExists(home + "backup.netconfig-" + network) {
|
||||
err = os.Remove(home + "backup.netconfig-" + network)
|
||||
if err != nil {
|
||||
log.Println("error removing backup netconfig:")
|
||||
log.Println(err.Error())
|
||||
}
|
||||
}
|
||||
if ncutils.FileExists(home + "nettoken-" + network) {
|
||||
err = os.Remove(home + "nettoken-" + network)
|
||||
if err != nil {
|
||||
log.Println("error removing nettoken:")
|
||||
log.Println(err.Error())
|
||||
}
|
||||
}
|
||||
if ncutils.FileExists(home + "secret-" + network) {
|
||||
err = os.Remove(home + "secret-" + network)
|
||||
if err != nil {
|
||||
log.Println("error removing secret:")
|
||||
log.Println(err.Error())
|
||||
}
|
||||
}
|
||||
if ncutils.FileExists(home + "traffic-" + network) {
|
||||
err = os.Remove(home + "traffic-" + network)
|
||||
if err != nil {
|
||||
log.Println("error removing traffic key:")
|
||||
log.Println(err.Error())
|
||||
}
|
||||
}
|
||||
if ncutils.FileExists(home + "wgkey-" + network) {
|
||||
err = os.Remove(home + "wgkey-" + network)
|
||||
if err != nil {
|
||||
log.Println("error removing wgkey:")
|
||||
log.Println(err.Error())
|
||||
}
|
||||
}
|
||||
if ifacename != "" {
|
||||
if ncutils.FileExists(home + ifacename + ".conf") {
|
||||
err = os.Remove(home + ifacename + ".conf")
|
||||
if err != nil {
|
||||
// if ncutils.FileExists(home + "netconfig-" + cfg.Node.Network) {
|
||||
// if err := os.Remove(home + "netconfig-" + cfg.Node.Network); err != nil {
|
||||
// log.Println("error removing netconfig:")
|
||||
// log.Println(err.Error())
|
||||
// fail = true
|
||||
// }
|
||||
// }
|
||||
// if ncutils.FileExists(home + "backup.netconfig-" + cfg.Node.Network) {
|
||||
// if err := os.Remove(home + "backup.netconfig-" + cfg.Node.Network); err != nil {
|
||||
// log.Println("error removing backup netconfig:")
|
||||
// log.Println(err.Error())
|
||||
// fail = true
|
||||
// }
|
||||
// }
|
||||
// if ncutils.FileExists(home + "nettoken-" + cfg.Node.Network) {
|
||||
// if err := os.Remove(home + "nettoken-" + cfg.Node.Network); err != nil {
|
||||
// log.Println("error removing nettoken:")
|
||||
// log.Println(err.Error())
|
||||
// fail = true
|
||||
// }
|
||||
// }
|
||||
// if ncutils.FileExists(home + "secret-" + cfg.Node.Network) {
|
||||
// if err := os.Remove(home + "secret-" + cfg.Node.Network); err != nil {
|
||||
// log.Println("error removing secret:")
|
||||
// log.Println(err.Error())
|
||||
// fail = true
|
||||
// }
|
||||
// }
|
||||
// if ncutils.FileExists(home + "traffic-" + cfg.Node.Network) {
|
||||
// if err := os.Remove(home + "traffic-" + cfg.Node.Network); err != nil {
|
||||
// log.Println("error removing traffic key:")
|
||||
// log.Println(err.Error())
|
||||
// fail = true
|
||||
// }
|
||||
// }
|
||||
// if ncutils.FileExists(home + "wgkey-" + cfg.Node.Network) {
|
||||
// if err := os.Remove(home + "wgkey-" + cfg.Node.Network); err != nil {
|
||||
// log.Println("error removing wgkey:")
|
||||
// log.Println(err.Error())
|
||||
// fail = true
|
||||
// }
|
||||
// }
|
||||
if cfg.Node.Interface != "" {
|
||||
if ncutils.FileExists(home + cfg.Node.Interface + ".conf") {
|
||||
if err := os.Remove(home + cfg.Node.Interface + ".conf"); err != nil {
|
||||
log.Println("error removing .conf:")
|
||||
log.Println(err.Error())
|
||||
fail = true
|
||||
}
|
||||
}
|
||||
err = removeHostDNS(ifacename, ncutils.IsWindows())
|
||||
if err != nil {
|
||||
logger.Log(0, "failed to delete dns entries for", ifacename, err.Error())
|
||||
}
|
||||
}
|
||||
|
||||
return err
|
||||
if fail {
|
||||
return errors.New("not all files were deleted")
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
// GetNetmakerPath - gets netmaker path locally
|
||||
|
||||
Reference in New Issue
Block a user