mirror of
https://github.com/gryf/boxpy.git
synced 2026-02-02 22:25:53 +01:00
Compare commits
9 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 55416db13d | |||
| 86a5655025 | |||
| 259d11e409 | |||
| b2457d497e | |||
| 15a6ecb540 | |||
| 10543cb506 | |||
| 1f1084f294 | |||
| f5ed3d37ac | |||
| 1483f49461 |
20
README.rst
20
README.rst
@@ -2,8 +2,8 @@
|
||||
box.py
|
||||
======
|
||||
|
||||
Box.py is a simple automation tool meant to run Ubuntu, Fedora or Centos Stream
|
||||
cloud images on top of VirtualBox.
|
||||
Box.py is a simple automation tool meant to run Ubuntu, Fedora, Centos Stream
|
||||
or Debian cloud images on top of VirtualBox.
|
||||
|
||||
What it does is simply download official cloud image, set up VM, tweak it up
|
||||
and do the initial pre-configuration using generated config drive.
|
||||
@@ -16,7 +16,7 @@ weird named options for ``vboxmanage`` ;P)
|
||||
Requirements
|
||||
------------
|
||||
|
||||
- Python >=3.7
|
||||
- Python >=3.8
|
||||
|
||||
- `pyyaml`_
|
||||
- `requests`_
|
||||
@@ -24,7 +24,7 @@ Requirements
|
||||
- Virtualbox (obviously)
|
||||
- ``mkisofs`` or ``genisoimage`` command for generating ISO image
|
||||
- ``wget`` command for fetching images
|
||||
- ``sha256sum`` command for checksum check
|
||||
- ``sha256sum`` and ``sha512sum`` commands for checksum check
|
||||
- ``qemu-img`` from *qemu-utils* package command for converting between images
|
||||
formats
|
||||
|
||||
@@ -39,7 +39,7 @@ your operating system, or by using virtualenv for Python requirements, i.e.:
|
||||
|
||||
$ python -m virtualenv .venv
|
||||
$ . .venv/bin/activate
|
||||
(.venv) $ pip install requirements.txt
|
||||
(.venv) $ pip install -r requirements.txt
|
||||
|
||||
then you can issue:
|
||||
|
||||
@@ -91,13 +91,15 @@ use it ad-hoc, or place on your ``.bashrc`` or whatever:
|
||||
|
||||
Currently, following commands are available:
|
||||
|
||||
- ``list`` - for quickly listing all/running VMs
|
||||
- ``info`` - to get summary about VM
|
||||
- ``destroy`` - that is probably obvious one
|
||||
- ``completion`` - as described above
|
||||
- ``create`` - create new VM
|
||||
- ``destroy`` - that is probably obvious one
|
||||
- ``info`` - to get summary about VM
|
||||
- ``list`` - for quickly listing all/running VMs
|
||||
- ``rebuild`` - recreate specified VM
|
||||
- ``ssh`` - connect to the VM using ssh
|
||||
- ``completion`` - as described above
|
||||
- ``start`` - stop the running VM
|
||||
- ``stop`` - start stopped VM
|
||||
|
||||
All of the commands have a range of options, and can be examined by using
|
||||
``--help`` option.
|
||||
|
||||
170
box.py
170
box.py
@@ -18,14 +18,15 @@ import requests
|
||||
import yaml
|
||||
|
||||
|
||||
__version__ = "1.3"
|
||||
__version__ = "1.9"
|
||||
|
||||
CACHE_DIR = os.environ.get('XDG_CACHE_HOME', os.path.expanduser('~/.cache'))
|
||||
CLOUD_IMAGE = "ci.iso"
|
||||
FEDORA_RELEASE_MAP = {'32': '1.6', '33': '1.2', '34': '1.2'}
|
||||
DEBIAN_CODENAME_MAP = {'12': 'bookworm', '11': 'bullseye', '10': 'buster'}
|
||||
TYPE_MAP = {'HardDisk': 'disk', 'DVD': 'dvd', 'Floppy': 'floppy'}
|
||||
DISTRO_MAP = {'ubuntu': 'Ubuntu', 'fedora': 'Fedora',
|
||||
'centos': 'Centos Stream'}
|
||||
'centos': 'Centos Stream', 'debian': 'Debian'}
|
||||
META_DATA_TPL = string.Template('''\
|
||||
instance-id: $instance_id
|
||||
local-hostname: $vmhostname
|
||||
@@ -136,13 +137,37 @@ _boxpy() {
|
||||
if [[ ${prev} == ${cmd} ]]; then
|
||||
COMPREPLY=( $(compgen -W "bash" -- ${cur}) )
|
||||
fi
|
||||
;;
|
||||
start)
|
||||
items=(--type)
|
||||
if [[ ${prev} == ${cmd} ]]; then
|
||||
if [[ ${cmd} = "start" ]]; then
|
||||
_vms_comp vms
|
||||
else
|
||||
COMPREPLY=( $(compgen -W "${items[*]}" -- ${cur}) )
|
||||
fi
|
||||
else
|
||||
_get_excluded_items "${items[@]}"
|
||||
COMPREPLY=( $(compgen -W "$result" -- ${cur}) )
|
||||
|
||||
case "${prev}" in
|
||||
--type)
|
||||
COMPREPLY=( $(compgen -W "gui headless sdl separate" \
|
||||
-- ${cur}) )
|
||||
;;
|
||||
--*)
|
||||
COMPREPLY=( )
|
||||
;;
|
||||
esac
|
||||
fi
|
||||
|
||||
;;
|
||||
create|rebuild)
|
||||
items=(--cpus --disable-nested --disk-size --default-user --distro
|
||||
--forwarding --image --key --memory --hostname --port --config
|
||||
--version --type)
|
||||
if [[ ${prev} == ${cmd} ]]; then
|
||||
if [[ ${cmd} = "rebuild" ]]; then
|
||||
if [[ ${cmd} = "rebuild" || ${cmd} == "start" ]]; then
|
||||
_vms_comp vms
|
||||
else
|
||||
COMPREPLY=( $(compgen -W "${items[*]}" -- ${cur}) )
|
||||
@@ -160,8 +185,8 @@ _boxpy() {
|
||||
_ssh_identityfile
|
||||
;;
|
||||
--distro)
|
||||
COMPREPLY=( $(compgen -W "ubuntu fedora centos" \
|
||||
-- ${cur}) )
|
||||
COMPREPLY=( $(compgen -W "ubuntu fedora centos
|
||||
debian" -- ${cur}) )
|
||||
;;
|
||||
--type)
|
||||
COMPREPLY=( $(compgen -W "gui headless sdl separate" \
|
||||
@@ -194,11 +219,6 @@ _boxpy() {
|
||||
_vms_comp runningvms
|
||||
fi
|
||||
;;
|
||||
start)
|
||||
if [[ ${prev} == ${cmd} ]]; then
|
||||
_vms_comp vms
|
||||
fi
|
||||
;;
|
||||
stop)
|
||||
if [[ ${prev} == ${cmd} ]]; then
|
||||
_vms_comp runningvms
|
||||
@@ -585,6 +605,48 @@ class Config:
|
||||
return source
|
||||
|
||||
|
||||
class OsTypes:
|
||||
def __init__(self, conf):
|
||||
self._conf = conf
|
||||
self._ostypes = []
|
||||
|
||||
self._gather_os_types()
|
||||
|
||||
def _gather_os_types(self):
|
||||
out = Run(['vboxmanage', 'list', 'ostypes']).stdout
|
||||
for line in out.split('\n'):
|
||||
if not line.startswith('ID:'):
|
||||
continue
|
||||
self._ostypes.append(line.split(':')[1].strip())
|
||||
|
||||
def ubuntu(self):
|
||||
lts = ''
|
||||
major, minor = [int(x) for x in self._conf.version.split('.')]
|
||||
|
||||
if major % 2 == 0 and minor == 4:
|
||||
lts = '_LTS'
|
||||
name = "Ubuntu%s%s_64" % (major, lts)
|
||||
|
||||
if name not in self._ostypes:
|
||||
return 'Ubuntu_64'
|
||||
|
||||
return name
|
||||
|
||||
def fedora(self):
|
||||
return "Fedora_64"
|
||||
|
||||
def debian(self):
|
||||
name = "Debian%s_64" % self._conf.version
|
||||
if name not in self._ostypes:
|
||||
return 'Debian_64'
|
||||
|
||||
def get(self):
|
||||
if not hasattr(self, self._conf.distro):
|
||||
return "Linux_64"
|
||||
|
||||
return getattr(self, self._conf.distro)()
|
||||
|
||||
|
||||
class VBoxManage:
|
||||
"""
|
||||
Class for dealing with vboxmanage commands
|
||||
@@ -765,7 +827,11 @@ class VBoxManage:
|
||||
'--acpi', 'on',
|
||||
'--audio', 'none',
|
||||
'--nic1', 'nat',
|
||||
'--natpf1', f'boxpyssh,tcp,,{port},,22']
|
||||
'--natpf1', f'boxpyssh,tcp,,{port},,22',
|
||||
'--graphicscontroller', 'vmsvga',
|
||||
'--vram', '16',
|
||||
'--ostype', OsTypes(conf).get()]
|
||||
|
||||
for count, (hostport, vmport) in enumerate(conf.forwarding.items(),
|
||||
start=1):
|
||||
cmd.extend(['--natpf1', f'custom-pf-{count},tcp,,{hostport},'
|
||||
@@ -914,6 +980,7 @@ class VBoxManage:
|
||||
class Image:
|
||||
URL = ""
|
||||
IMG = ""
|
||||
CHECKSUMTOOL = 'sha256sum'
|
||||
|
||||
def __init__(self, vbox, version, arch, release, fname=None):
|
||||
self.vbox = vbox
|
||||
@@ -964,7 +1031,7 @@ class Image:
|
||||
return False
|
||||
|
||||
if os.path.exists(os.path.join(CACHE_DIR, self._img_fname)):
|
||||
cmd = ['sha256sum', os.path.join(CACHE_DIR, self._img_fname)]
|
||||
cmd = [self.CHECKSUMTOOL, os.path.join(CACHE_DIR, self._img_fname)]
|
||||
calulated_sum = Run(cmd).stdout.split(' ')[0]
|
||||
LOG.details('Checksum for image: %s, expected: %s', calulated_sum,
|
||||
expected_sum)
|
||||
@@ -1017,6 +1084,30 @@ class Ubuntu(Image):
|
||||
return expected_sum
|
||||
|
||||
|
||||
class Debian(Image):
|
||||
URL = "https://cloud.debian.org/images/cloud/%s/daily/latest/%s"
|
||||
IMG = "debian-%s-generic-%s-daily.qcow2"
|
||||
CHECKSUMTOOL = 'sha512sum'
|
||||
|
||||
def __init__(self, vbox, version, arch, release, fname=None):
|
||||
super().__init__(vbox, version, arch, release)
|
||||
self._img_fname = self.IMG % (version, arch)
|
||||
self._img_url = self.URL % (release, self._img_fname)
|
||||
self._checksum_file = 'SHA512SUMS'
|
||||
self._checksum_url = self.URL % (release, self._checksum_file)
|
||||
|
||||
def _get_checksum(self, fname):
|
||||
expected_sum = None
|
||||
Run(['wget', self._checksum_url, '-q', '-O', fname])
|
||||
with open(fname) as fobj:
|
||||
for line in fobj.readlines():
|
||||
if self._img_fname in line:
|
||||
expected_sum = line.split(' ')[0]
|
||||
break
|
||||
|
||||
return expected_sum
|
||||
|
||||
|
||||
class Fedora(Image):
|
||||
URL = ("https://download.fedoraproject.org/pub/fedora/linux/releases/%s/"
|
||||
"Cloud/%s/images/%s")
|
||||
@@ -1115,13 +1206,20 @@ DISTROS = {'ubuntu': {'username': 'ubuntu',
|
||||
'realname': 'centos',
|
||||
'img_class': CentosStream,
|
||||
'amd64': 'x86_64',
|
||||
'default_version': '8'}}
|
||||
'default_version': '8'},
|
||||
'debian': {'username': 'debian',
|
||||
'realname': 'debian',
|
||||
'img_class': Debian,
|
||||
'amd64': 'amd64',
|
||||
'default_version': '11'}}
|
||||
|
||||
|
||||
def get_image_object(vbox, version, image='ubuntu', arch='amd64'):
|
||||
release = None
|
||||
if image == 'fedora':
|
||||
release = FEDORA_RELEASE_MAP[version]
|
||||
if image == 'debian':
|
||||
release = DEBIAN_CODENAME_MAP[version]
|
||||
return DISTROS[image]['img_class'](vbox, version, DISTROS[image]['amd64'],
|
||||
release, DISTROS[image].get('image'))
|
||||
|
||||
@@ -1247,6 +1345,7 @@ def vmcreate(args, conf=None):
|
||||
f'ssh://{username}@localhost:{vbox.vm_info["port"]}',
|
||||
'sudo cloud-init status']
|
||||
try:
|
||||
counter = 0
|
||||
while True:
|
||||
out = Run(cmd)
|
||||
LOG.debug('Out: %s', out.stdout)
|
||||
@@ -1266,6 +1365,22 @@ def vmcreate(args, conf=None):
|
||||
f'VM with ssh for user {username}. '
|
||||
f'Check output in debug mode.')
|
||||
time.sleep(3)
|
||||
counter += 1
|
||||
|
||||
# TODO: there is something odd with debian cloud images prior
|
||||
# to 12 (bookworm), as on first run system crashes. In that
|
||||
# case after ~20 seconds there should already be panic, reset
|
||||
# machine as a workaround. Remove this after debian 12
|
||||
# stabilization later this year.
|
||||
if (counter == 8 and conf.distro == 'debian'
|
||||
and conf.version != '12'):
|
||||
LOG.debug('Resetting `%s`, due to the issue with kernel '
|
||||
'panic on Debian %s the first run', conf.name,
|
||||
conf.version)
|
||||
counter += 1
|
||||
vbox.poweroff()
|
||||
time.sleep(3)
|
||||
vbox.poweron(args.type)
|
||||
continue
|
||||
|
||||
LOG.info(' done')
|
||||
@@ -1445,6 +1560,13 @@ def vmrebuild(args):
|
||||
conf.disk_size = vbox.get_media_size(disk_path)
|
||||
|
||||
vmdestroy(args)
|
||||
|
||||
# Wait till VM is gone
|
||||
while True:
|
||||
vbox = VBoxManage(args.name)
|
||||
if not vbox.get_vm_info():
|
||||
break
|
||||
|
||||
vmcreate(args, conf)
|
||||
return 0
|
||||
|
||||
@@ -1470,14 +1592,17 @@ def connect(args):
|
||||
return 16
|
||||
|
||||
username = conf.username or DISTROS[conf.distro]["username"]
|
||||
return Run(['ssh', '-o', 'StrictHostKeyChecking=no',
|
||||
'-o', 'UserKnownHostsFile=/dev/null',
|
||||
'-i', conf.ssh_key_path[:-4],
|
||||
f'ssh://{username}'
|
||||
f'@localhost:{conf.port}'], False).returncode
|
||||
cmd = ['ssh', '-o', 'StrictHostKeyChecking=no',
|
||||
'-o', 'UserKnownHostsFile=/dev/null',
|
||||
'-i', conf.ssh_key_path[:-4],
|
||||
f'ssh://{username}'
|
||||
f'@localhost:{conf.port}']
|
||||
LOG.debug('Connecting to vm `%s` using command:\n%s', args.name,
|
||||
' '.join(cmd))
|
||||
return Run(cmd, False).returncode
|
||||
|
||||
|
||||
def _set_vmstate(name, state):
|
||||
def _set_vmstate(name, state, guitype=None):
|
||||
|
||||
vbox = VBoxManage(name)
|
||||
if not vbox.get_vm_info():
|
||||
@@ -1493,13 +1618,13 @@ def _set_vmstate(name, state):
|
||||
return
|
||||
|
||||
if state == "start":
|
||||
vbox.poweron()
|
||||
vbox.poweron(guitype)
|
||||
else:
|
||||
vbox.acpipowerbutton()
|
||||
|
||||
|
||||
def vmstart(args):
|
||||
_set_vmstate(args.name, 'start')
|
||||
_set_vmstate(args.name, 'start', args.type)
|
||||
|
||||
|
||||
def vmstop(args):
|
||||
@@ -1614,6 +1739,9 @@ def main():
|
||||
|
||||
start = subparsers.add_parser('start', help='start VM')
|
||||
start.add_argument('name', help='name or UUID of the VM')
|
||||
start.add_argument('-t', '--type', default='headless',
|
||||
help="VM run type, headless by default.",
|
||||
choices=['gui', 'headless', 'sdl', 'separate'])
|
||||
start.set_defaults(func=vmstart)
|
||||
|
||||
stop = subparsers.add_parser('stop', help='stop VM')
|
||||
|
||||
Reference in New Issue
Block a user