mirror of
https://github.com/GNS3/gns3-server
synced 2024-11-28 11:18:11 +00:00
739 lines
31 KiB
Python
739 lines
31 KiB
Python
# -*- coding: utf-8 -*-
|
|
#
|
|
# Copyright (C) 2015 GNS3 Technologies Inc.
|
|
#
|
|
# This program is free software: you can redistribute it and/or modify
|
|
# it under the terms of the GNU General Public License as published by
|
|
# the Free Software Foundation, either version 3 of the License, or
|
|
# (at your option) any later version.
|
|
#
|
|
# This program is distributed in the hope that it will be useful,
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
# GNU General Public License for more details.
|
|
#
|
|
# You should have received a copy of the GNU General Public License
|
|
# along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
"""
|
|
VMware player/workstation server module.
|
|
"""
|
|
|
|
import os
|
|
import sys
|
|
import re
|
|
import shutil
|
|
import asyncio
|
|
import subprocess
|
|
import logging
|
|
import codecs
|
|
|
|
from collections import OrderedDict
|
|
from gns3server.utils.interfaces import interfaces
|
|
from gns3server.utils.asyncio import subprocess_check_output
|
|
from gns3server.utils import parse_version, shlex_quote
|
|
|
|
log = logging.getLogger(__name__)
|
|
|
|
from gns3server.compute.base_manager import BaseManager
|
|
from gns3server.compute.vmware.vmware_vm import VMwareVM
|
|
from gns3server.compute.vmware.vmware_error import VMwareError
|
|
|
|
|
|
class VMware(BaseManager):
|
|
|
|
_NODE_CLASS = VMwareVM
|
|
|
|
def __init__(self):
|
|
|
|
super().__init__()
|
|
self._vmware_inventory_lock = asyncio.Lock()
|
|
self._vmrun_path = None
|
|
self._host_type = None
|
|
self._vmnets = []
|
|
self._vmnet_start_range = 2
|
|
if sys.platform.startswith("win"):
|
|
self._vmnet_end_range = 19
|
|
else:
|
|
self._vmnet_end_range = 255
|
|
|
|
@property
|
|
def vmrun_path(self):
|
|
"""
|
|
Returns the path vmrun utility.
|
|
|
|
:returns: path
|
|
"""
|
|
|
|
return self._vmrun_path
|
|
|
|
@staticmethod
|
|
def _find_vmrun_registry(regkey):
|
|
|
|
import winreg
|
|
try:
|
|
# default path not used, let's look in the registry
|
|
hkey = winreg.OpenKey(winreg.HKEY_LOCAL_MACHINE, regkey)
|
|
install_path, _ = winreg.QueryValueEx(hkey, "InstallPath")
|
|
vmrun_path = os.path.join(install_path, "vmrun.exe")
|
|
winreg.CloseKey(hkey)
|
|
if os.path.exists(vmrun_path):
|
|
return vmrun_path
|
|
except OSError:
|
|
pass
|
|
return None
|
|
|
|
def find_vmrun(self):
|
|
"""
|
|
Searches for vmrun.
|
|
|
|
:returns: path to vmrun
|
|
"""
|
|
|
|
# look for vmrun
|
|
vmrun_path = self.config.get_section_config("VMware").get("vmrun_path")
|
|
if not vmrun_path:
|
|
if sys.platform.startswith("win"):
|
|
vmrun_path = shutil.which("vmrun")
|
|
if vmrun_path is None:
|
|
# look for vmrun.exe using the VMware Workstation directory listed in the registry
|
|
vmrun_path = self._find_vmrun_registry(r"SOFTWARE\Wow6432Node\VMware, Inc.\VMware Workstation")
|
|
if vmrun_path is None:
|
|
# look for vmrun.exe using the VIX directory listed in the registry
|
|
vmrun_path = self._find_vmrun_registry(r"SOFTWARE\Wow6432Node\VMware, Inc.\VMware VIX")
|
|
elif sys.platform.startswith("darwin"):
|
|
vmrun_path = "/Applications/VMware Fusion.app/Contents/Library/vmrun"
|
|
else:
|
|
vmrun_path = "vmrun"
|
|
|
|
if vmrun_path and not os.path.isabs(vmrun_path):
|
|
vmrun_path = shutil.which(vmrun_path)
|
|
|
|
if not vmrun_path:
|
|
raise VMwareError("Could not find VMware vmrun, please make sure it is installed")
|
|
if not os.path.isfile(vmrun_path):
|
|
raise VMwareError("vmrun {} is not accessible".format(vmrun_path))
|
|
if not os.access(vmrun_path, os.X_OK):
|
|
raise VMwareError("vmrun is not executable")
|
|
if os.path.basename(vmrun_path).lower() not in ["vmrun", "vmrun.exe"]:
|
|
raise VMwareError("Invalid vmrun executable name {}".format(os.path.basename(vmrun_path)))
|
|
|
|
self._vmrun_path = vmrun_path
|
|
return vmrun_path
|
|
|
|
@staticmethod
|
|
def _find_vmware_version_registry(regkey):
|
|
|
|
import winreg
|
|
version = None
|
|
try:
|
|
# default path not used, let's look in the registry
|
|
hkey = winreg.OpenKey(winreg.HKEY_LOCAL_MACHINE, regkey)
|
|
version, _ = winreg.QueryValueEx(hkey, "ProductVersion")
|
|
winreg.CloseKey(hkey)
|
|
except OSError:
|
|
pass
|
|
if version is not None:
|
|
match = re.search(r"([0-9]+)\.", version)
|
|
if match:
|
|
version = match.group(1)
|
|
return version
|
|
|
|
async def _check_vmware_player_requirements(self, player_version):
|
|
"""
|
|
Check minimum requirements to use VMware Player.
|
|
|
|
VIX 1.13 was the release for Player 6.
|
|
VIX 1.14 was the release for Player 7.
|
|
VIX 1.15 was the release for Workstation Player 12.
|
|
VIX 1.17 was the release for Workstation Player 14.
|
|
|
|
:param player_version: VMware Player major version.
|
|
"""
|
|
|
|
player_version = int(player_version)
|
|
if player_version < 6:
|
|
raise VMwareError("Using VMware Player requires version 6 or above")
|
|
elif player_version == 6:
|
|
await self.check_vmrun_version(minimum_required_version="1.13.0")
|
|
elif player_version == 7:
|
|
await self.check_vmrun_version(minimum_required_version="1.14.0")
|
|
elif player_version >= 12:
|
|
await self.check_vmrun_version(minimum_required_version="1.15.0")
|
|
elif player_version >= 14:
|
|
await self.check_vmrun_version(minimum_required_version="1.17.0")
|
|
self._host_type = "player"
|
|
|
|
async def _check_vmware_workstation_requirements(self, ws_version):
|
|
"""
|
|
Check minimum requirements to use VMware Workstation.
|
|
|
|
VIX 1.13 was the release for Workstation 10.
|
|
VIX 1.14 was the release for Workstation 11.
|
|
VIX 1.15 was the release for Workstation Pro 12.
|
|
VIX 1.17 was the release for Workstation Pro 14.
|
|
|
|
:param ws_version: VMware Workstation major version.
|
|
"""
|
|
|
|
ws_version = int(ws_version)
|
|
if ws_version < 10:
|
|
raise VMwareError("Using VMware Workstation requires version 10 or above")
|
|
elif ws_version == 10:
|
|
await self.check_vmrun_version(minimum_required_version="1.13.0")
|
|
elif ws_version == 11:
|
|
await self.check_vmrun_version(minimum_required_version="1.14.0")
|
|
elif ws_version >= 12:
|
|
await self.check_vmrun_version(minimum_required_version="1.15.0")
|
|
elif ws_version >= 14:
|
|
await self.check_vmrun_version(minimum_required_version="1.17.0")
|
|
self._host_type = "ws"
|
|
|
|
async def check_vmware_version(self):
|
|
"""
|
|
Check VMware version
|
|
"""
|
|
|
|
if sys.platform.startswith("win"):
|
|
# look for vmrun.exe using the directory listed in the registry
|
|
ws_version = self._find_vmware_version_registry(r"SOFTWARE\Wow6432Node\VMware, Inc.\VMware Workstation")
|
|
if ws_version is None:
|
|
player_version = self._find_vmware_version_registry(r"SOFTWARE\Wow6432Node\VMware, Inc.\VMware Player")
|
|
if player_version:
|
|
log.debug("VMware Player version {} detected".format(player_version))
|
|
await self._check_vmware_player_requirements(player_version)
|
|
else:
|
|
log.warning("Could not find VMware version")
|
|
self._host_type = "ws"
|
|
else:
|
|
log.debug("VMware Workstation version {} detected".format(ws_version))
|
|
await self._check_vmware_workstation_requirements(ws_version)
|
|
else:
|
|
if sys.platform.startswith("darwin"):
|
|
if not os.path.isdir("/Applications/VMware Fusion.app"):
|
|
raise VMwareError("VMware Fusion is not installed in the standard location /Applications/VMware Fusion.app")
|
|
self._host_type = "fusion"
|
|
return # FIXME: no version checking on Mac OS X but we support all versions of fusion
|
|
|
|
vmware_path = VMware._get_linux_vmware_binary()
|
|
if vmware_path is None:
|
|
raise VMwareError("VMware is not installed (vmware or vmplayer executable could not be found in $PATH)")
|
|
|
|
try:
|
|
output = await subprocess_check_output(vmware_path, "-v")
|
|
match = re.search(r"VMware Workstation ([0-9]+)\.", output)
|
|
version = None
|
|
if match:
|
|
# VMware Workstation has been detected
|
|
version = match.group(1)
|
|
log.debug("VMware Workstation version {} detected".format(version))
|
|
await self._check_vmware_workstation_requirements(version)
|
|
match = re.search(r"VMware Player ([0-9]+)\.", output)
|
|
if match:
|
|
# VMware Player has been detected
|
|
version = match.group(1)
|
|
log.debug("VMware Player version {} detected".format(version))
|
|
await self._check_vmware_player_requirements(version)
|
|
if version is None:
|
|
log.warning("Could not find VMware version. Output of VMware: {}".format(output))
|
|
raise VMwareError("Could not find VMware version. Output of VMware: {}".format(output))
|
|
except (OSError, subprocess.SubprocessError) as e:
|
|
log.error("Error while looking for the VMware version: {}".format(e))
|
|
raise VMwareError("Error while looking for the VMware version: {}".format(e))
|
|
|
|
@staticmethod
|
|
def _get_vmnet_interfaces_registry():
|
|
|
|
import winreg
|
|
vmnet_interfaces = []
|
|
regkey = r"SOFTWARE\Wow6432Node\VMware, Inc.\VMnetLib\VMnetConfig"
|
|
try:
|
|
hkey = winreg.OpenKey(winreg.HKEY_LOCAL_MACHINE, regkey)
|
|
for index in range(winreg.QueryInfoKey(hkey)[0]):
|
|
vmnet = winreg.EnumKey(hkey, index)
|
|
hkeyvmnet = winreg.OpenKey(hkey, vmnet)
|
|
if winreg.QueryInfoKey(hkeyvmnet)[1]:
|
|
# the vmnet has not been configure if the key has no values
|
|
vmnet = vmnet.replace("vm", "VM")
|
|
if vmnet not in ("VMnet0", "VMnet1", "VMnet8"):
|
|
vmnet_interfaces.append(vmnet)
|
|
winreg.CloseKey(hkeyvmnet)
|
|
winreg.CloseKey(hkey)
|
|
except OSError as e:
|
|
raise VMwareError("Could not read registry key {}: {}".format(regkey, e))
|
|
return vmnet_interfaces
|
|
|
|
@staticmethod
|
|
def _get_vmnet_interfaces():
|
|
|
|
if sys.platform.startswith("win"):
|
|
return VMware._get_vmnet_interfaces_registry()
|
|
elif sys.platform.startswith("darwin"):
|
|
vmware_networking_file = "/Library/Preferences/VMware Fusion/networking"
|
|
else:
|
|
# location on Linux
|
|
vmware_networking_file = "/etc/vmware/networking"
|
|
vmnet_interfaces = []
|
|
try:
|
|
with open(vmware_networking_file, "r", encoding="utf-8") as f:
|
|
for line in f.read().splitlines():
|
|
match = re.search(r"VNET_([0-9]+)_VIRTUAL_ADAPTER", line)
|
|
if match:
|
|
vmnet = "vmnet{}".format(match.group(1))
|
|
if vmnet not in ("vmnet0", "vmnet1", "vmnet8"):
|
|
vmnet_interfaces.append(vmnet)
|
|
except OSError as e:
|
|
raise VMwareError("Cannot open {}: {}".format(vmware_networking_file, e))
|
|
return vmnet_interfaces
|
|
|
|
@staticmethod
|
|
def _get_vmnet_interfaces_ubridge():
|
|
|
|
vmnet_interfaces = []
|
|
for interface in interfaces():
|
|
if sys.platform.startswith("win"):
|
|
if "netcard" in interface:
|
|
windows_name = interface["netcard"]
|
|
else:
|
|
windows_name = interface["name"]
|
|
match = re.search(r"(VMnet[0-9]+)", windows_name)
|
|
if match:
|
|
vmnet = match.group(1)
|
|
if vmnet not in ("VMnet0", "VMnet1", "VMnet8"):
|
|
vmnet_interfaces.append(vmnet)
|
|
elif interface["name"].startswith("vmnet"):
|
|
vmnet = interface["name"]
|
|
if vmnet not in ("vmnet0", "vmnet1", "vmnet8"):
|
|
vmnet_interfaces.append(interface["name"])
|
|
return vmnet_interfaces
|
|
|
|
def is_managed_vmnet(self, vmnet):
|
|
|
|
self._vmnet_start_range = self.config.get_section_config("VMware").getint("vmnet_start_range", self._vmnet_start_range)
|
|
self._vmnet_end_range = self.config.get_section_config("VMware").getint("vmnet_end_range", self._vmnet_end_range)
|
|
match = re.search(r"vmnet([0-9]+)$", vmnet, re.IGNORECASE)
|
|
if match:
|
|
vmnet_number = match.group(1)
|
|
if self._vmnet_start_range <= int(vmnet_number) <= self._vmnet_end_range:
|
|
return True
|
|
return False
|
|
|
|
def allocate_vmnet(self):
|
|
|
|
if not self._vmnets:
|
|
raise VMwareError("No VMnet interface available between vmnet{} and vmnet{}. Go to preferences VMware / Network / Configure to add more interfaces.".format(self._vmnet_start_range, self._vmnet_end_range))
|
|
return self._vmnets.pop(0)
|
|
|
|
def refresh_vmnet_list(self, ubridge=True):
|
|
|
|
if ubridge:
|
|
# VMnet host adapters must be present when uBridge is used
|
|
vmnet_interfaces = self._get_vmnet_interfaces_ubridge()
|
|
else:
|
|
vmnet_interfaces = self._get_vmnet_interfaces()
|
|
|
|
# remove vmnets already in use
|
|
for vmware_vm in self._nodes.values():
|
|
for used_vmnet in vmware_vm.vmnets:
|
|
if used_vmnet in vmnet_interfaces:
|
|
log.debug("{} is already in use".format(used_vmnet))
|
|
vmnet_interfaces.remove(used_vmnet)
|
|
|
|
# remove vmnets that are not managed
|
|
for vmnet in vmnet_interfaces.copy():
|
|
if vmnet in vmnet_interfaces and self.is_managed_vmnet(vmnet) is False:
|
|
vmnet_interfaces.remove(vmnet)
|
|
|
|
self._vmnets = vmnet_interfaces
|
|
|
|
@property
|
|
def host_type(self):
|
|
"""
|
|
Returns the VMware host type.
|
|
player = VMware player
|
|
ws = VMware Workstation
|
|
fusion = VMware Fusion
|
|
|
|
:returns: host type (string)
|
|
"""
|
|
|
|
return self._host_type
|
|
|
|
async def execute(self, subcommand, args, timeout=120, log_level=logging.INFO):
|
|
trial = 2
|
|
|
|
while True:
|
|
try:
|
|
return (await self._execute(subcommand, args, timeout=timeout, log_level=log_level))
|
|
except VMwareError as e:
|
|
# We can fail to detect that it's VMware player instead of Workstation (due to marketing change Player is now Player Workstation)
|
|
if self.host_type == "ws" and "VIX_SERVICEPROVIDER_VMWARE_WORKSTATION" in str(e):
|
|
self._host_type = "player"
|
|
return (await self._execute(subcommand, args, timeout=timeout, log_level=log_level))
|
|
else:
|
|
if trial <= 0:
|
|
raise e
|
|
trial -= 1
|
|
await asyncio.sleep(0.5)
|
|
|
|
async def _execute(self, subcommand, args, timeout=120, log_level=logging.INFO):
|
|
if self.host_type is None:
|
|
await self.check_vmware_version()
|
|
|
|
vmrun_path = self.vmrun_path
|
|
if not vmrun_path:
|
|
vmrun_path = self.find_vmrun()
|
|
|
|
command = [vmrun_path, "-T", self.host_type, subcommand]
|
|
command.extend(args)
|
|
command_string = " ".join([shlex_quote(c) for c in command])
|
|
log.log(log_level, "Executing vmrun with command: {}".format(command_string))
|
|
try:
|
|
process = await asyncio.create_subprocess_exec(*command, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.PIPE)
|
|
except (OSError, subprocess.SubprocessError) as e:
|
|
raise VMwareError("Could not execute vmrun: {}".format(e))
|
|
|
|
try:
|
|
stdout_data, _ = await asyncio.wait_for(process.communicate(), timeout=timeout)
|
|
except asyncio.TimeoutError:
|
|
raise VMwareError("vmrun has timed out after {} seconds!\nTry to run {} in a terminal to see more details.\n\nMake sure GNS3 and VMware run under the same user and whitelist vmrun.exe in your antivirus.".format(timeout, command_string))
|
|
|
|
if process.returncode:
|
|
# vmrun print errors on stdout
|
|
vmrun_error = stdout_data.decode("utf-8", errors="ignore")
|
|
raise VMwareError("vmrun has returned an error: {}\nTry to run {} in a terminal to see more details.\nAnd make sure GNS3 and VMware run under the same user.".format(vmrun_error, command_string))
|
|
|
|
return stdout_data.decode("utf-8", errors="ignore").splitlines()
|
|
|
|
async def check_vmrun_version(self, minimum_required_version="1.13.0"):
|
|
"""
|
|
Checks the vmrun version.
|
|
|
|
VMware VIX library version must be at least >= 1.13 by default
|
|
VIX 1.13 was the release for VMware Fusion 6, Workstation 10, and Player 6.
|
|
VIX 1.14 was the release for VMware Fusion 7, Workstation 11 and Player 7.
|
|
VIX 1.15 was the release for VMware Fusion 8, Workstation Pro 12 and Workstation Player 12.
|
|
|
|
:param required_version: required vmrun version number
|
|
"""
|
|
|
|
vmrun_path = self.vmrun_path
|
|
if not vmrun_path:
|
|
vmrun_path = self.find_vmrun()
|
|
|
|
try:
|
|
output = await subprocess_check_output(vmrun_path)
|
|
match = re.search(r"vmrun version ([0-9\.]+)", output)
|
|
version = None
|
|
if match:
|
|
version = match.group(1)
|
|
log.debug("VMware vmrun version {} detected, minimum required: {}".format(version, minimum_required_version))
|
|
if parse_version(version) < parse_version(minimum_required_version):
|
|
raise VMwareError("VMware vmrun executable version must be >= version {}".format(minimum_required_version))
|
|
if version is None:
|
|
log.warning("Could not find VMware vmrun version. Output: {}".format(output))
|
|
raise VMwareError("Could not find VMware vmrun version. Output: {}".format(output))
|
|
except (OSError, subprocess.SubprocessError) as e:
|
|
log.error("Error while looking for the VMware vmrun version: {}".format(e))
|
|
raise VMwareError("Error while looking for the VMware vmrun version: {}".format(e))
|
|
|
|
async def remove_from_vmware_inventory(self, vmx_path):
|
|
"""
|
|
Removes a linked clone from the VMware inventory file.
|
|
|
|
:param vmx_path: path of the linked clone VMX file
|
|
"""
|
|
|
|
async with self._vmware_inventory_lock:
|
|
inventory_path = self.get_vmware_inventory_path()
|
|
if os.path.exists(inventory_path):
|
|
try:
|
|
inventory_pairs = self.parse_vmware_file(inventory_path)
|
|
except OSError as e:
|
|
log.warning('Could not read VMware inventory file "{}": {}'.format(inventory_path, e))
|
|
return
|
|
|
|
vmlist_entry = None
|
|
for name, value in inventory_pairs.items():
|
|
if value == vmx_path:
|
|
vmlist_entry = name.split(".", 1)[0]
|
|
break
|
|
|
|
if vmlist_entry is not None:
|
|
for name in inventory_pairs.copy().keys():
|
|
if name.startswith(vmlist_entry):
|
|
del inventory_pairs[name]
|
|
|
|
try:
|
|
self.write_vmware_file(inventory_path, inventory_pairs)
|
|
except OSError as e:
|
|
raise VMwareError('Could not write VMware inventory file "{}": {}'.format(inventory_path, e))
|
|
|
|
@staticmethod
|
|
def parse_vmware_file(path):
|
|
"""
|
|
Parses a VMware file (VMX, preferences or inventory).
|
|
|
|
:param path: path to the VMware file
|
|
|
|
:returns: dict
|
|
"""
|
|
|
|
pairs = OrderedDict()
|
|
encoding = "utf-8"
|
|
# get the first line to read the .encoding value
|
|
with open(path, "rb") as f:
|
|
line = f.readline().decode(encoding, errors="ignore")
|
|
if line.startswith("#!"):
|
|
# skip the shebang
|
|
line = f.readline().decode(encoding, errors="ignore")
|
|
try:
|
|
key, value = line.split('=', 1)
|
|
if key.strip().lower() == ".encoding":
|
|
file_encoding = value.strip('" ')
|
|
try:
|
|
codecs.lookup(file_encoding)
|
|
encoding = file_encoding
|
|
except LookupError:
|
|
log.warning("Invalid file encoding detected in '{}': {}".format(path, file_encoding))
|
|
except ValueError:
|
|
log.warning("Couldn't find file encoding in {}, using {}...".format(path, encoding))
|
|
|
|
# read the file with the correct encoding
|
|
with open(path, encoding=encoding, errors="ignore") as f:
|
|
for line in f.read().splitlines():
|
|
try:
|
|
key, value = line.split('=', 1)
|
|
pairs[key.strip().lower()] = value.strip('" ')
|
|
except ValueError:
|
|
continue
|
|
return pairs
|
|
|
|
@staticmethod
|
|
def write_vmware_file(path, pairs):
|
|
"""
|
|
Write a VMware file (excepting VMX file).
|
|
|
|
:param path: path to the VMware file
|
|
:param pairs: settings to write
|
|
"""
|
|
|
|
encoding = "utf-8"
|
|
if ".encoding" in pairs:
|
|
file_encoding = pairs[".encoding"]
|
|
try:
|
|
codecs.lookup(file_encoding)
|
|
encoding = file_encoding
|
|
except LookupError:
|
|
log.warning("Invalid file encoding detected in '{}': {}".format(path, file_encoding))
|
|
with open(path, "w", encoding=encoding, errors="ignore") as f:
|
|
for key, value in pairs.items():
|
|
entry = '{} = "{}"\n'.format(key, value)
|
|
f.write(entry)
|
|
|
|
@staticmethod
|
|
def write_vmx_file(path, pairs):
|
|
"""
|
|
Write a VMware VMX file.
|
|
|
|
:param path: path to the VMX file
|
|
:param pairs: settings to write
|
|
"""
|
|
|
|
encoding = "utf-8"
|
|
if ".encoding" in pairs:
|
|
file_encoding = pairs[".encoding"]
|
|
try:
|
|
codecs.lookup(file_encoding)
|
|
encoding = file_encoding
|
|
except LookupError:
|
|
log.warning("Invalid file encoding detected in '{}': {}".format(path, file_encoding))
|
|
with open(path, "w", encoding=encoding, errors="ignore") as f:
|
|
if sys.platform.startswith("linux"):
|
|
# write the shebang on the first line on Linux
|
|
vmware_path = VMware._get_linux_vmware_binary()
|
|
if vmware_path:
|
|
f.write("#!{}\n".format(vmware_path))
|
|
for key, value in pairs.items():
|
|
entry = '{} = "{}"\n'.format(key, value)
|
|
f.write(entry)
|
|
|
|
def _get_vms_from_inventory(self, inventory_path):
|
|
"""
|
|
Searches for VMs by parsing a VMware inventory file.
|
|
|
|
:param inventory_path: path to the inventory file
|
|
|
|
:returns: list of VMs
|
|
"""
|
|
|
|
vm_entries = {}
|
|
vmware_vms = []
|
|
log.info('Searching for VMware VMs in inventory file "{}"'.format(inventory_path))
|
|
try:
|
|
pairs = self.parse_vmware_file(inventory_path)
|
|
for key, value in pairs.items():
|
|
if key.startswith("vmlist"):
|
|
try:
|
|
vm_entry, variable_name = key.split('.', 1)
|
|
except ValueError:
|
|
continue
|
|
if vm_entry not in vm_entries:
|
|
vm_entries[vm_entry] = {}
|
|
vm_entries[vm_entry][variable_name.strip()] = value
|
|
except OSError as e:
|
|
log.warning("Could not read VMware inventory file {}: {}".format(inventory_path, e))
|
|
|
|
for vm_settings in vm_entries.values():
|
|
if "displayname" in vm_settings and "config" in vm_settings:
|
|
if os.path.exists(vm_settings["config"]):
|
|
log.debug('Found VM named "{}" with VMX file "{}"'.format(vm_settings["displayname"], vm_settings["config"]))
|
|
vmware_vms.append({"vmname": vm_settings["displayname"], "vmx_path": vm_settings["config"]})
|
|
return vmware_vms
|
|
|
|
def _get_vms_from_directory(self, directory):
|
|
"""
|
|
Searches for VMs in a given directory.
|
|
|
|
:param directory: path to the directory
|
|
|
|
:returns: list of VMs
|
|
"""
|
|
|
|
vmware_vms = []
|
|
log.info('Searching for VMware VMs in directory "{}"'.format(directory))
|
|
for path, _, filenames in os.walk(directory):
|
|
for filename in filenames:
|
|
if os.path.splitext(filename)[1] == ".vmx":
|
|
vmx_path = os.path.join(path, filename)
|
|
log.debug('Reading VMware VMX file "{}"'.format(vmx_path))
|
|
try:
|
|
pairs = self.parse_vmware_file(vmx_path)
|
|
if "displayname" in pairs:
|
|
log.debug('Found VM named "{}"'.format(pairs["displayname"]))
|
|
vmware_vms.append({"vmname": pairs["displayname"], "vmx_path": vmx_path})
|
|
except OSError as e:
|
|
log.warning('Could not read VMware VMX file "{}": {}'.format(vmx_path, e))
|
|
continue
|
|
return vmware_vms
|
|
|
|
@staticmethod
|
|
def get_vmware_inventory_path():
|
|
"""
|
|
Returns VMware inventory file path.
|
|
|
|
:returns: path to the inventory file
|
|
"""
|
|
|
|
if sys.platform.startswith("win"):
|
|
return os.path.expandvars(r"%APPDATA%\Vmware\Inventory.vmls")
|
|
elif sys.platform.startswith("darwin"):
|
|
return os.path.expanduser("~/Library/Application Support/VMware Fusion/vmInventory")
|
|
else:
|
|
return os.path.expanduser("~/.vmware/inventory.vmls")
|
|
|
|
@staticmethod
|
|
def get_vmware_preferences_path():
|
|
"""
|
|
Returns VMware preferences file path.
|
|
|
|
:returns: path to the preferences file
|
|
"""
|
|
|
|
if sys.platform.startswith("win"):
|
|
return os.path.expandvars(r"%APPDATA%\VMware\preferences.ini")
|
|
elif sys.platform.startswith("darwin"):
|
|
return os.path.expanduser("~/Library/Preferences/VMware Fusion/preferences")
|
|
else:
|
|
return os.path.expanduser("~/.vmware/preferences")
|
|
|
|
@staticmethod
|
|
def get_vmware_default_vm_paths():
|
|
"""
|
|
Returns VMware default VM directory paths.
|
|
|
|
:returns: path to the default VM directory
|
|
"""
|
|
|
|
if sys.platform.startswith("win"):
|
|
import ctypes
|
|
import ctypes.wintypes
|
|
path = ctypes.create_unicode_buffer(ctypes.wintypes.MAX_PATH)
|
|
ctypes.windll.shell32.SHGetFolderPathW(None, 5, None, 0, path)
|
|
documents_folder = path.value
|
|
return ['{}\My Virtual Machines'.format(documents_folder), '{}\Virtual Machines'.format(documents_folder)]
|
|
elif sys.platform.startswith("darwin"):
|
|
return [os.path.expanduser("~/Documents/Virtual Machines.localized")]
|
|
else:
|
|
return [os.path.expanduser("~/vmware")]
|
|
|
|
async def list_vms(self):
|
|
"""
|
|
Gets VMware VM list.
|
|
"""
|
|
|
|
# check for the right VMware version
|
|
await self.check_vmware_version()
|
|
vmware_vms = []
|
|
inventory_path = self.get_vmware_inventory_path()
|
|
if os.path.exists(inventory_path) and self.host_type != "player":
|
|
# inventory may exist for VMware player if VMware workstation has been previously installed
|
|
vmware_vms = self._get_vms_from_inventory(inventory_path)
|
|
if not vmware_vms:
|
|
# backup methods when no VMware inventory file exists or for VMware player which has no inventory file
|
|
vmware_preferences_path = self.get_vmware_preferences_path()
|
|
pairs = {}
|
|
if os.path.exists(vmware_preferences_path):
|
|
# the default vm path may be present in VMware preferences file.
|
|
try:
|
|
pairs = self.parse_vmware_file(vmware_preferences_path)
|
|
except OSError as e:
|
|
log.warning('Could not read VMware preferences file "{}": {}'.format(vmware_preferences_path, e))
|
|
if "prefvmx.defaultvmpath" in pairs:
|
|
default_vm_path = pairs["prefvmx.defaultvmpath"]
|
|
if not os.path.isdir(default_vm_path):
|
|
raise VMwareError('Could not find or access the default VM directory: "{default_vm_path}". Please change "prefvmx.defaultvmpath={default_vm_path}" in "{vmware_preferences_path}"'.format(default_vm_path=default_vm_path,
|
|
vmware_preferences_path=vmware_preferences_path))
|
|
vmware_vms = self._get_vms_from_directory(default_vm_path)
|
|
|
|
if not vmware_vms:
|
|
# the default vm path is not in the VMware preferences file or that directory is empty
|
|
# let's search the default locations for VMs
|
|
for default_vm_path in self.get_vmware_default_vm_paths():
|
|
if os.path.isdir(default_vm_path):
|
|
vmware_vms.extend(self._get_vms_from_directory(default_vm_path))
|
|
|
|
if not vmware_vms:
|
|
log.warning("Could not find any VMware VM in default locations")
|
|
|
|
# look for VMX paths in the preferences file in case not all VMs are in a default directory
|
|
for key, value in pairs.items():
|
|
m = re.match(r'pref.mruVM(\d+)\.filename', key)
|
|
if m:
|
|
display_name = "pref.mruVM{}.displayName".format(m.group(1))
|
|
if display_name in pairs:
|
|
found = False
|
|
for vmware_vm in vmware_vms:
|
|
if vmware_vm["vmname"] == display_name:
|
|
found = True
|
|
if found is False:
|
|
vmware_vms.append({"vmname": pairs[display_name], "vmx_path": value})
|
|
return vmware_vms
|
|
|
|
@staticmethod
|
|
def _get_linux_vmware_binary():
|
|
"""
|
|
Return the path of the vmware binary on Linux or None
|
|
"""
|
|
path = shutil.which("vmware")
|
|
if path is None:
|
|
path = shutil.which("vmplayer")
|
|
return path
|
|
|
|
|
|
if __name__ == '__main__':
|
|
loop = asyncio.get_event_loop()
|
|
vmware = VMware.instance()
|
|
print("=> Check version")
|
|
loop.run_until_complete(asyncio.ensure_future(vmware.check_vmware_version()))
|