mirror of
https://github.com/kevingruesser/bootstrap-vz.git
synced 2025-08-22 09:50:37 +00:00
Indent with 4 spaces
This commit is contained in:
The Fox in the Shell
parent
4cc9ec0d1b
commit
aecb89aab5
2 changed files with 188 additions and 188 deletions
|
|
@ -6,40 +6,40 @@ __all__ = ['Phase', 'Task', 'main']
|
|||
|
||||
|
||||
def validate_manifest(data, validator, error):
|
||||
"""Validates the manifest using the base manifest
|
||||
"""Validates the manifest using the base manifest
|
||||
|
||||
:param dict data: The data of the manifest
|
||||
:param function validator: The function that validates the manifest given the data and a path
|
||||
:param function error: The function tha raises an error when the validation fails
|
||||
"""
|
||||
import os.path
|
||||
schema_path = os.path.normpath(os.path.join(os.path.dirname(__file__), 'manifest-schema.yml'))
|
||||
validator(data, schema_path)
|
||||
:param dict data: The data of the manifest
|
||||
:param function validator: The function that validates the manifest given the data and a path
|
||||
:param function error: The function tha raises an error when the validation fails
|
||||
"""
|
||||
import os.path
|
||||
schema_path = os.path.normpath(os.path.join(os.path.dirname(__file__), 'manifest-schema.yml'))
|
||||
validator(data, schema_path)
|
||||
|
||||
from bootstrapvz.common.releases import get_release
|
||||
from bootstrapvz.common.releases import squeeze
|
||||
release = get_release(data['system']['release'])
|
||||
from bootstrapvz.common.releases import get_release
|
||||
from bootstrapvz.common.releases import squeeze
|
||||
release = get_release(data['system']['release'])
|
||||
|
||||
if release < squeeze:
|
||||
error('Only Debian squeeze and later is supported', ['system', 'release'])
|
||||
if release < squeeze:
|
||||
error('Only Debian squeeze and later is supported', ['system', 'release'])
|
||||
|
||||
# Check the bootloader/partitioning configuration.
|
||||
# Doing this via the schema is a pain and does not output a useful error message.
|
||||
if data['system']['bootloader'] == 'grub':
|
||||
# Check the bootloader/partitioning configuration.
|
||||
# Doing this via the schema is a pain and does not output a useful error message.
|
||||
if data['system']['bootloader'] == 'grub':
|
||||
|
||||
if data['volume']['partitions']['type'] == 'none':
|
||||
error('Grub cannot boot from unpartitioned disks', ['system', 'bootloader'])
|
||||
if data['volume']['partitions']['type'] == 'none':
|
||||
error('Grub cannot boot from unpartitioned disks', ['system', 'bootloader'])
|
||||
|
||||
if release == squeeze:
|
||||
error('Grub installation on squeeze is not supported', ['system', 'bootloader'])
|
||||
if release == squeeze:
|
||||
error('Grub installation on squeeze is not supported', ['system', 'bootloader'])
|
||||
|
||||
# Check the provided apt.conf(5) options
|
||||
if 'packages' in data:
|
||||
for name, val in data['packages'].get('apt.conf.d', {}).iteritems():
|
||||
from bootstrapvz.common.tools import log_call
|
||||
# Check the provided apt.conf(5) options
|
||||
if 'packages' in data:
|
||||
for name, val in data['packages'].get('apt.conf.d', {}).iteritems():
|
||||
from bootstrapvz.common.tools import log_call
|
||||
|
||||
status, _, _ = log_call(['apt-config', '-c=/dev/stdin', 'dump'],
|
||||
stdin=val + '\n')
|
||||
status, _, _ = log_call(['apt-config', '-c=/dev/stdin', 'dump'],
|
||||
stdin=val + '\n')
|
||||
|
||||
if status != 0:
|
||||
error('apt.conf(5) syntax error', ['packages', 'apt.conf.d', name])
|
||||
if status != 0:
|
||||
error('apt.conf(5) syntax error', ['packages', 'apt.conf.d', name])
|
||||
|
|
|
|||
|
|
@ -7,219 +7,219 @@ import os
|
|||
|
||||
|
||||
class AddManifestSources(Task):
|
||||
description = 'Adding sources from the manifest'
|
||||
phase = phases.preparation
|
||||
description = 'Adding sources from the manifest'
|
||||
phase = phases.preparation
|
||||
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
for name, lines in info.manifest.packages['sources'].iteritems():
|
||||
for line in lines:
|
||||
info.source_lists.add(name, line)
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
for name, lines in info.manifest.packages['sources'].iteritems():
|
||||
for line in lines:
|
||||
info.source_lists.add(name, line)
|
||||
|
||||
|
||||
class AddDefaultSources(Task):
|
||||
description = 'Adding default release sources'
|
||||
phase = phases.preparation
|
||||
predecessors = [AddManifestSources]
|
||||
description = 'Adding default release sources'
|
||||
phase = phases.preparation
|
||||
predecessors = [AddManifestSources]
|
||||
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
from bootstrapvz.common.releases import sid
|
||||
include_src = info.manifest.packages.get('include-source-type', False)
|
||||
components = ' '.join(info.manifest.packages.get('components', ['main']))
|
||||
info.source_lists.add('main', 'deb {apt_mirror} {system.release} ' + components)
|
||||
if include_src:
|
||||
info.source_lists.add('main', 'deb-src {apt_mirror} {system.release} ' + components)
|
||||
if info.manifest.release != sid:
|
||||
info.source_lists.add('main', 'deb http://security.debian.org/ {system.release}/updates ' + components)
|
||||
if include_src:
|
||||
info.source_lists.add('main', 'deb-src http://security.debian.org/ {system.release}/updates ' + components)
|
||||
info.source_lists.add('main', 'deb {apt_mirror} {system.release}-updates ' + components)
|
||||
if include_src:
|
||||
info.source_lists.add('main', 'deb-src {apt_mirror} {system.release}-updates ' + components)
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
from bootstrapvz.common.releases import sid
|
||||
include_src = info.manifest.packages.get('include-source-type', False)
|
||||
components = ' '.join(info.manifest.packages.get('components', ['main']))
|
||||
info.source_lists.add('main', 'deb {apt_mirror} {system.release} ' + components)
|
||||
if include_src:
|
||||
info.source_lists.add('main', 'deb-src {apt_mirror} {system.release} ' + components)
|
||||
if info.manifest.release != sid:
|
||||
info.source_lists.add('main', 'deb http://security.debian.org/ {system.release}/updates ' + components)
|
||||
if include_src:
|
||||
info.source_lists.add('main', 'deb-src http://security.debian.org/ {system.release}/updates ' + components)
|
||||
info.source_lists.add('main', 'deb {apt_mirror} {system.release}-updates ' + components)
|
||||
if include_src:
|
||||
info.source_lists.add('main', 'deb-src {apt_mirror} {system.release}-updates ' + components)
|
||||
|
||||
|
||||
class AddBackports(Task):
|
||||
description = 'Adding backports to the apt sources'
|
||||
phase = phases.preparation
|
||||
predecessors = [AddDefaultSources]
|
||||
description = 'Adding backports to the apt sources'
|
||||
phase = phases.preparation
|
||||
predecessors = [AddDefaultSources]
|
||||
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
from bootstrapvz.common.releases import unstable
|
||||
if info.source_lists.target_exists('{system.release}-backports'):
|
||||
msg = ('{system.release}-backports target already exists').format(**info.manifest_vars)
|
||||
logging.getLogger(__name__).info(msg)
|
||||
elif info.manifest.release == unstable:
|
||||
logging.getLogger(__name__).info('There are no backports for sid/unstable')
|
||||
else:
|
||||
info.source_lists.add('backports', 'deb {apt_mirror} {system.release}-backports main')
|
||||
info.source_lists.add('backports', 'deb-src {apt_mirror} {system.release}-backports main')
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
from bootstrapvz.common.releases import unstable
|
||||
if info.source_lists.target_exists('{system.release}-backports'):
|
||||
msg = ('{system.release}-backports target already exists').format(**info.manifest_vars)
|
||||
logging.getLogger(__name__).info(msg)
|
||||
elif info.manifest.release == unstable:
|
||||
logging.getLogger(__name__).info('There are no backports for sid/unstable')
|
||||
else:
|
||||
info.source_lists.add('backports', 'deb {apt_mirror} {system.release}-backports main')
|
||||
info.source_lists.add('backports', 'deb-src {apt_mirror} {system.release}-backports main')
|
||||
|
||||
|
||||
class AddManifestPreferences(Task):
|
||||
description = 'Adding preferences from the manifest'
|
||||
phase = phases.preparation
|
||||
description = 'Adding preferences from the manifest'
|
||||
phase = phases.preparation
|
||||
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
for name, preferences in info.manifest.packages['preferences'].iteritems():
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
for name, preferences in info.manifest.packages['preferences'].iteritems():
|
||||
info.preference_lists.add(name, preferences)
|
||||
|
||||
|
||||
class InstallTrustedKeys(Task):
|
||||
description = 'Installing trusted keys'
|
||||
phase = phases.package_installation
|
||||
description = 'Installing trusted keys'
|
||||
phase = phases.package_installation
|
||||
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
from shutil import copy
|
||||
for key_path in info.manifest.packages['trusted-keys']:
|
||||
key_name = os.path.basename(key_path)
|
||||
destination = os.path.join(info.root, 'etc/apt/trusted.gpg.d', key_name)
|
||||
copy(key_path, destination)
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
from shutil import copy
|
||||
for key_path in info.manifest.packages['trusted-keys']:
|
||||
key_name = os.path.basename(key_path)
|
||||
destination = os.path.join(info.root, 'etc/apt/trusted.gpg.d', key_name)
|
||||
copy(key_path, destination)
|
||||
|
||||
|
||||
class WriteConfiguration(Task):
|
||||
decription = 'Write configuration to apt.conf.d from the manifest'
|
||||
phase = phases.package_installation
|
||||
decription = 'Write configuration to apt.conf.d from the manifest'
|
||||
phase = phases.package_installation
|
||||
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
for name, val in info.manifest.packages.get('apt.conf.d', {}).iteritems():
|
||||
if name == 'main':
|
||||
path = os.path.join(info.root, 'etc/apt/apt.conf')
|
||||
else:
|
||||
path = os.path.join(info.root, 'etc/apt/apt.conf.d', name)
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
for name, val in info.manifest.packages.get('apt.conf.d', {}).iteritems():
|
||||
if name == 'main':
|
||||
path = os.path.join(info.root, 'etc/apt/apt.conf')
|
||||
else:
|
||||
path = os.path.join(info.root, 'etc/apt/apt.conf.d', name)
|
||||
|
||||
with open(path, 'w') as conf_file:
|
||||
conf_file.write(val + '\n')
|
||||
with open(path, 'w') as conf_file:
|
||||
conf_file.write(val + '\n')
|
||||
|
||||
|
||||
class WriteSources(Task):
|
||||
description = 'Writing aptitude sources to disk'
|
||||
phase = phases.package_installation
|
||||
predecessors = [InstallTrustedKeys]
|
||||
description = 'Writing aptitude sources to disk'
|
||||
phase = phases.package_installation
|
||||
predecessors = [InstallTrustedKeys]
|
||||
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
if not info.source_lists.target_exists(info.manifest.system['release']):
|
||||
import logging
|
||||
log = logging.getLogger(__name__)
|
||||
log.warn('No default target has been specified in the sources list, '
|
||||
'installing packages may fail')
|
||||
for name, sources in info.source_lists.sources.iteritems():
|
||||
if name == 'main':
|
||||
list_path = os.path.join(info.root, 'etc/apt/sources.list')
|
||||
else:
|
||||
list_path = os.path.join(info.root, 'etc/apt/sources.list.d/', name + '.list')
|
||||
with open(list_path, 'w') as source_list:
|
||||
for source in sources:
|
||||
source_list.write(str(source) + '\n')
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
if not info.source_lists.target_exists(info.manifest.system['release']):
|
||||
import logging
|
||||
log = logging.getLogger(__name__)
|
||||
log.warn('No default target has been specified in the sources list, '
|
||||
'installing packages may fail')
|
||||
for name, sources in info.source_lists.sources.iteritems():
|
||||
if name == 'main':
|
||||
list_path = os.path.join(info.root, 'etc/apt/sources.list')
|
||||
else:
|
||||
list_path = os.path.join(info.root, 'etc/apt/sources.list.d/', name + '.list')
|
||||
with open(list_path, 'w') as source_list:
|
||||
for source in sources:
|
||||
source_list.write(str(source) + '\n')
|
||||
|
||||
|
||||
class WritePreferences(Task):
|
||||
description = 'Writing aptitude preferences to disk'
|
||||
phase = phases.package_installation
|
||||
description = 'Writing aptitude preferences to disk'
|
||||
phase = phases.package_installation
|
||||
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
for name, preferences in info.preference_lists.preferences.iteritems():
|
||||
if name == 'main':
|
||||
list_path = os.path.join(info.root, 'etc/apt/preferences')
|
||||
else:
|
||||
list_path = os.path.join(info.root, 'etc/apt/preferences.d/', name)
|
||||
with open(list_path, 'w') as preference_list:
|
||||
for preference in preferences:
|
||||
preference_list.write(str(preference) + '\n')
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
for name, preferences in info.preference_lists.preferences.iteritems():
|
||||
if name == 'main':
|
||||
list_path = os.path.join(info.root, 'etc/apt/preferences')
|
||||
else:
|
||||
list_path = os.path.join(info.root, 'etc/apt/preferences.d/', name)
|
||||
with open(list_path, 'w') as preference_list:
|
||||
for preference in preferences:
|
||||
preference_list.write(str(preference) + '\n')
|
||||
|
||||
|
||||
class DisableDaemonAutostart(Task):
|
||||
description = 'Disabling daemon autostart'
|
||||
phase = phases.package_installation
|
||||
description = 'Disabling daemon autostart'
|
||||
phase = phases.package_installation
|
||||
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
rc_policy_path = os.path.join(info.root, 'usr/sbin/policy-rc.d')
|
||||
with open(rc_policy_path, 'w') as rc_policy:
|
||||
rc_policy.write(('#!/bin/sh\n'
|
||||
'exit 101'))
|
||||
import stat
|
||||
os.chmod(rc_policy_path,
|
||||
stat.S_IRUSR | stat.S_IWUSR | stat.S_IXUSR |
|
||||
stat.S_IRGRP | stat.S_IXGRP |
|
||||
stat.S_IROTH | stat.S_IXOTH)
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
rc_policy_path = os.path.join(info.root, 'usr/sbin/policy-rc.d')
|
||||
with open(rc_policy_path, 'w') as rc_policy:
|
||||
rc_policy.write(('#!/bin/sh\n'
|
||||
'exit 101'))
|
||||
import stat
|
||||
os.chmod(rc_policy_path,
|
||||
stat.S_IRUSR | stat.S_IWUSR | stat.S_IXUSR |
|
||||
stat.S_IRGRP | stat.S_IXGRP |
|
||||
stat.S_IROTH | stat.S_IXOTH)
|
||||
|
||||
|
||||
class AptUpdate(Task):
|
||||
description = 'Updating the package cache'
|
||||
phase = phases.package_installation
|
||||
predecessors = [locale.GenerateLocale, WriteConfiguration, WriteSources, WritePreferences]
|
||||
description = 'Updating the package cache'
|
||||
phase = phases.package_installation
|
||||
predecessors = [locale.GenerateLocale, WriteConfiguration, WriteSources, WritePreferences]
|
||||
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
log_check_call(['chroot', info.root,
|
||||
'apt-get', 'update'])
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
log_check_call(['chroot', info.root,
|
||||
'apt-get', 'update'])
|
||||
|
||||
|
||||
class AptUpgrade(Task):
|
||||
description = 'Upgrading packages and fixing broken dependencies'
|
||||
phase = phases.package_installation
|
||||
predecessors = [AptUpdate, DisableDaemonAutostart]
|
||||
description = 'Upgrading packages and fixing broken dependencies'
|
||||
phase = phases.package_installation
|
||||
predecessors = [AptUpdate, DisableDaemonAutostart]
|
||||
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
from subprocess import CalledProcessError
|
||||
try:
|
||||
log_check_call(['chroot', info.root,
|
||||
'apt-get', 'install',
|
||||
'--fix-broken',
|
||||
'--no-install-recommends',
|
||||
'--assume-yes'])
|
||||
log_check_call(['chroot', info.root,
|
||||
'apt-get', 'upgrade',
|
||||
'--no-install-recommends',
|
||||
'--assume-yes'])
|
||||
except CalledProcessError as e:
|
||||
if e.returncode == 100:
|
||||
msg = ('apt exited with status code 100. '
|
||||
'This can sometimes occur when package retrieval times out or a package extraction failed. '
|
||||
'apt might succeed if you try bootstrapping again.')
|
||||
logging.getLogger(__name__).warn(msg)
|
||||
raise
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
from subprocess import CalledProcessError
|
||||
try:
|
||||
log_check_call(['chroot', info.root,
|
||||
'apt-get', 'install',
|
||||
'--fix-broken',
|
||||
'--no-install-recommends',
|
||||
'--assume-yes'])
|
||||
log_check_call(['chroot', info.root,
|
||||
'apt-get', 'upgrade',
|
||||
'--no-install-recommends',
|
||||
'--assume-yes'])
|
||||
except CalledProcessError as e:
|
||||
if e.returncode == 100:
|
||||
msg = ('apt exited with status code 100. '
|
||||
'This can sometimes occur when package retrieval times out or a package extraction failed. '
|
||||
'apt might succeed if you try bootstrapping again.')
|
||||
logging.getLogger(__name__).warn(msg)
|
||||
raise
|
||||
|
||||
|
||||
class PurgeUnusedPackages(Task):
|
||||
description = 'Removing unused packages'
|
||||
phase = phases.system_cleaning
|
||||
description = 'Removing unused packages'
|
||||
phase = phases.system_cleaning
|
||||
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
log_check_call(['chroot', info.root,
|
||||
'apt-get', 'autoremove',
|
||||
'--purge',
|
||||
'--assume-yes'])
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
log_check_call(['chroot', info.root,
|
||||
'apt-get', 'autoremove',
|
||||
'--purge',
|
||||
'--assume-yes'])
|
||||
|
||||
|
||||
class AptClean(Task):
|
||||
description = 'Clearing the aptitude cache'
|
||||
phase = phases.system_cleaning
|
||||
description = 'Clearing the aptitude cache'
|
||||
phase = phases.system_cleaning
|
||||
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
log_check_call(['chroot', info.root,
|
||||
'apt-get', 'clean'])
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
log_check_call(['chroot', info.root,
|
||||
'apt-get', 'clean'])
|
||||
|
||||
lists = os.path.join(info.root, 'var/lib/apt/lists')
|
||||
for list_file in [os.path.join(lists, f) for f in os.listdir(lists)]:
|
||||
if os.path.isfile(list_file):
|
||||
os.remove(list_file)
|
||||
lists = os.path.join(info.root, 'var/lib/apt/lists')
|
||||
for list_file in [os.path.join(lists, f) for f in os.listdir(lists)]:
|
||||
if os.path.isfile(list_file):
|
||||
os.remove(list_file)
|
||||
|
||||
|
||||
class EnableDaemonAutostart(Task):
|
||||
description = 'Re-enabling daemon autostart after installation'
|
||||
phase = phases.system_cleaning
|
||||
description = 'Re-enabling daemon autostart after installation'
|
||||
phase = phases.system_cleaning
|
||||
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
os.remove(os.path.join(info.root, 'usr/sbin/policy-rc.d'))
|
||||
@classmethod
|
||||
def run(cls, info):
|
||||
os.remove(os.path.join(info.root, 'usr/sbin/policy-rc.d'))
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue