Use network service client to query source network

Related to: harvester/harvester#7432

Signed-off-by: Volker Theile <[email protected]>

pkg/source/openstack/client.go

@@ -47,6 +47,7 @@ type Client struct {
 	storageClient *gophercloud.ServiceClient
 	computeClient *gophercloud.ServiceClient
 	imageClient   *gophercloud.ServiceClient
+	networkClient *gophercloud.ServiceClient
 	options       migration.OpenstackSourceOptions
 }
 
@@ -135,13 +136,19 @@ func NewClient(ctx context.Context, endpoint string, region string, secret *core
 		return nil, fmt.Errorf("error generating image client: %v", err)
 	}
 
+	networkClient, err := openstack.NewNetworkV2(client, endPointOpts)
+	if err != nil {
+		return nil, fmt.Errorf("error generating network client: %v", err)
+	}
+
 	return &Client{
 		ctx:           ctx,
 		pClient:       client,
 		opts:          endPointOpts,
 		storageClient: storageClient,
 		computeClient: computeClient,
 		imageClient:   imageClient,
+		networkClient: networkClient,
 		options:       options,
 	}, nil
 }
@@ -178,9 +185,24 @@ func (c *Client) Verify() error {
 
 func (c *Client) PreFlightChecks(vm *migration.VirtualMachineImport) (err error) {
 	for _, nm := range vm.Spec.Mapping {
-		_, err := networks.Get(c.computeClient, nm.SourceNetwork).Extract()
+		logrus.WithFields(logrus.Fields{
+			"name":          vm.Name,
+			"namespace":     vm.Namespace,
+			"sourceNetwork": nm.SourceNetwork,
+		}).Info("Searching for the source network in preflight check")
+
+		pgr := networks.List(c.networkClient, networks.ListOpts{Name: nm.SourceNetwork})
+		allPgs, err := pgr.AllPages()
 		if err != nil {
-			return fmt.Errorf("error getting source network '%s': %v", nm.SourceNetwork, err)
+			return fmt.Errorf("error while generating all pages during querying source network '%s': %v", nm.SourceNetwork, err)
+		}
+
+		ok, err := allPgs.IsEmpty()
+		if err != nil {
+			return fmt.Errorf("error while checking if pages were empty during querying source network '%s': %v", nm.SourceNetwork, err)
+		}
+		if ok {
+			return fmt.Errorf("source network '%s' not found", nm.SourceNetwork)
 		}
 	}
 	return nil

pkg/source/vmware/client.go

@@ -130,6 +130,12 @@ func (c *Client) PreFlightChecks(vm *migration.VirtualMachineImport) (err error)
 		dc = fmt.Sprintf("/%s", c.dc)
 	}
 	for _, nm := range vm.Spec.Mapping {
+		logrus.WithFields(logrus.Fields{
+			"name":          vm.Name,
+			"namespace":     vm.Namespace,
+			"sourceNetwork": nm.SourceNetwork,
+		}).Info("Searching for the source network in preflight check")
+
 		// The path looks like `/<datacenter>/network/<network-name>`.
 		path := filepath.Join(dc, "/network", nm.SourceNetwork)
 		_, err := f.Network(c.ctx, path)