mirror of
https://github.com/gryf/boxpy.git
synced 2026-02-01 21:45:46 +01:00
Compare commits
8 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 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.
|
||||
|
||||
130
box.py
130
box.py
@@ -18,14 +18,15 @@ import requests
|
||||
import yaml
|
||||
|
||||
|
||||
__version__ = "1.3"
|
||||
__version__ = "1.8"
|
||||
|
||||
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
|
||||
@@ -160,8 +161,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" \
|
||||
@@ -585,6 +586,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 +808,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 +961,7 @@ class VBoxManage:
|
||||
class Image:
|
||||
URL = ""
|
||||
IMG = ""
|
||||
CHECKSUMTOOL = 'sha256sum'
|
||||
|
||||
def __init__(self, vbox, version, arch, release, fname=None):
|
||||
self.vbox = vbox
|
||||
@@ -964,7 +1012,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 +1065,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 +1187,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 +1326,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 +1346,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 +1541,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,11 +1573,14 @@ 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):
|
||||
|
||||
Reference in New Issue
Block a user