mirror of
https://github.com/kevingruesser/bootstrap-vz.git
synced 2025-08-24 15:36:27 +00:00
ff7c04c120
MAJOR refactor. The volume is now abstracted into a model along with a partitionmap and partitions. Volumes and partitions are now controlled via an FSM to ensure that commands are called in the proper sequence. GRUB can now be installed properly onto loop devices by using dmsetup to fake a proper harddisk.
52 lines
1.6 KiB
Python
52 lines
1.6 KiB
Python
from tasks import Snapshot
|
|
from tasks import CopyImage
|
|
from tasks import CreateFromSnapshot
|
|
from tasks import CreateFromImage
|
|
from providers.ec2.tasks import ebs
|
|
from common.tasks import loopback
|
|
from common.tasks import volume
|
|
from common.tasks import bootstrap
|
|
from common.tasks import filesystem
|
|
from common.tasks import partitioning
|
|
|
|
|
|
def tasks(tasklist, manifest):
|
|
settings = manifest.plugins['prebootstrapped']
|
|
skip_tasks = [filesystem.Format,
|
|
partitioning.PartitionVolume,
|
|
filesystem.TuneVolumeFS,
|
|
filesystem.AddXFSProgs,
|
|
filesystem.CreateBootMountDir,
|
|
bootstrap.MakeTarball,
|
|
bootstrap.Bootstrap]
|
|
if manifest.volume['backing'] == 'ebs':
|
|
if 'snapshot' in settings and settings['snapshot'] is not None:
|
|
tasklist.replace(ebs.Create, CreateFromSnapshot())
|
|
tasklist.remove(*skip_tasks)
|
|
else:
|
|
tasklist.add(Snapshot())
|
|
else:
|
|
if 'image' in settings and settings['image'] is not None:
|
|
tasklist.replace(loopback.Create, CreateFromImage())
|
|
tasklist.remove(*skip_tasks)
|
|
else:
|
|
tasklist.add(CopyImage())
|
|
|
|
|
|
def rollback_tasks(tasklist, tasks_completed, manifest):
|
|
completed = [type(task) for task in tasks_completed]
|
|
|
|
def counter_task(task, counter):
|
|
if task in completed and counter not in completed:
|
|
tasklist.add(counter())
|
|
|
|
if manifest.volume['backing'] == 'ebs':
|
|
counter_task(CreateFromSnapshot, volume.Delete)
|
|
else:
|
|
counter_task(CreateFromImage, volume.Delete)
|
|
|
|
|
|
def validate_manifest(data, schema_validate):
|
|
from os import path
|
|
schema_path = path.normpath(path.join(path.dirname(__file__), 'manifest-schema.json'))
|
|
schema_validate(data, schema_path)
|