From 93350b9e9f0313fe100dcc3ae4cdc02d1af0872e Mon Sep 17 00:00:00 2001
From: baude <bbaude@redhat.com>
Date: Sat, 28 Dec 2019 13:48:16 -0600
Subject: refactor network commands

move core of network commands from pkg/adapter to pkg/network to assist
with api development and remote podman commands.

Signed-off-by: baude <bbaude@redhat.com>
---
 pkg/adapter/network.go | 64 ++++++++++++--------------------------------------
 1 file changed, 15 insertions(+), 49 deletions(-)

(limited to 'pkg/adapter')

diff --git a/pkg/adapter/network.go b/pkg/adapter/network.go
index 160e334e9..b25f54a13 100644
--- a/pkg/adapter/network.go
+++ b/pkg/adapter/network.go
@@ -67,14 +67,10 @@ func (r *LocalRuntime) NetworkInspect(cli *cliconfig.NetworkInspectValues) error
 		rawCNINetworks []map[string]interface{}
 	)
 	for _, name := range cli.InputArgs {
-		b, err := network.ReadRawCNIConfByName(name)
+		rawList, err := network.InspectNetwork(name)
 		if err != nil {
 			return err
 		}
-		rawList := make(map[string]interface{})
-		if err := json.Unmarshal(b, &rawList); err != nil {
-			return fmt.Errorf("error parsing configuration list: %s", err)
-		}
 		rawCNINetworks = append(rawCNINetworks, rawList)
 	}
 	out, err := json.MarshalIndent(rawCNINetworks, "", "\t")
@@ -98,7 +94,20 @@ func (r *LocalRuntime) NetworkRemove(ctx context.Context, cli *cliconfig.Network
 		if err != nil {
 			return networkRmSuccesses, networkRmErrors, err
 		}
-		if err := r.removeNetwork(ctx, name, containers, cli.Force); err != nil {
+		// We need to iterate containers looking to see if they belong to the given network
+		for _, c := range containers {
+			if util.StringInSlice(name, c.Config().Networks) {
+				// if user passes force, we nuke containers
+				if !cli.Force {
+					// Without the force option, we return an error
+					return nil, nil, errors.Errorf("%q has associated containers with it. Use -f to forcibly delete containers", name)
+				}
+				if err := r.RemoveContainer(ctx, c.Container, true, true); err != nil {
+					return nil, nil, err
+				}
+			}
+		}
+		if err := network.RemoveNetwork(name); err != nil {
 			if lastError != nil {
 				networkRmErrors[name] = lastError
 			}
@@ -110,49 +119,6 @@ func (r *LocalRuntime) NetworkRemove(ctx context.Context, cli *cliconfig.Network
 	return networkRmSuccesses, networkRmErrors, lastError
 }
 
-// removeNetwork removes a single network and its containers given a force bool
-func (r *LocalRuntime) removeNetwork(ctx context.Context, name string, containers []*Container, force bool) error {
-	cniPath, err := network.GetCNIConfigPathByName(name)
-	if err != nil {
-		return err
-	}
-	// We need to iterate containers looking to see if they belong to the given network
-	for _, c := range containers {
-		if util.StringInSlice(name, c.Config().Networks) {
-			// if user passes force, we nuke containers
-			if force {
-				if err := r.RemoveContainer(ctx, c.Container, true, true); err != nil {
-					return err
-				}
-			} else {
-				// Without the the force option, we return an error
-				return errors.Errorf("%q has associated containers with it. use -f to forcibly delete containers", name)
-			}
-
-		}
-	}
-	// Before we delete the configuration file, we need to make sure we can read and parse
-	// it to get the network interface name so we can remove that too
-	interfaceName, err := network.GetInterfaceNameFromConfig(cniPath)
-	if err != nil {
-		return errors.Wrapf(err, "failed to find network interface name in %q", cniPath)
-	}
-	liveNetworkNames, err := network.GetLiveNetworkNames()
-	if err != nil {
-		return errors.Wrapf(err, "failed to get live network names")
-	}
-	if util.StringInSlice(interfaceName, liveNetworkNames) {
-		if err := network.RemoveInterface(interfaceName); err != nil {
-			return errors.Wrapf(err, "failed to delete the network interface %q", interfaceName)
-		}
-	}
-	// Remove the configuration file
-	if err := os.Remove(cniPath); err != nil {
-		return errors.Wrapf(err, "failed to remove network configuration file %q", cniPath)
-	}
-	return nil
-}
-
 // NetworkCreateBridge creates a CNI network
 func (r *LocalRuntime) NetworkCreateBridge(cli *cliconfig.NetworkCreateValues) (string, error) {
 	isGateway := true
-- 
cgit v1.2.3-54-g00ecf