raise CodeError('"%s" on "control %s create %s'
% (err, machine.name, cdtype))
-def createVm(owner, contact, name, memory, disk_size, machine_type, cdrom, clone_from):
+def createVm(username, state, owner, contact, name, memory, disksize, machine_type, cdrom, clone_from):
"""Create a VM and put it in the database"""
# put stuff in the table
transaction = ctx.current.create_transaction()
try:
- validation.validMemory(owner, memory)
- validation.validDisk(owner, disk_size * 1. / 1024)
- validation.validAddVm(owner)
+ validation.Validate(username, state, name=name, owner=owner, memory=memory, disksize=disksize/1024.)
res = meta.engine.execute('select nextval('
'\'"machines_machine_id_seq"\')')
id = res.fetchone()[0]
machine.type_id = machine_type.type_id
ctx.current.save(machine)
disk = Disk(machine_id=machine.machine_id,
- guest_device_name='hda', size=disk_size)
+ guest_device_name='hda', size=disksize)
open_nics = NIC.select_by(machine_id=None)
if not open_nics: #No IPs left!
raise CodeError("No IP addresses left! "
for mname, dname in delete_disk_pairs:
remctl('web', 'lvremove', mname, dname)
-def commandResult(user, fields):
+def commandResult(username, state, fields):
start_time = 0
- machine = validation.testMachineId(user, fields.getfirst('machine_id'))
+ machine = validation.Validate(username, state, machine_id=fields.getfirst('machine_id')).machine
action = fields.getfirst('action')
cdrom = fields.getfirst('cdrom')
if cdrom is not None and not CDROM.get(cdrom):
raise CodeError('ERROR on remctl')
elif action == 'Power on':
- if validation.maxMemory(user, machine) < machine.memory:
+ if validation.maxMemory(username, state, machine) < machine.memory:
raise InvalidInput('action', 'Power on',
"You don't have enough free RAM quota "
"to turn on this machine.")
elif action == 'Delete VM':
deleteVM(machine)
- d = dict(user=user,
+ d = dict(user=username,
command=action,
machine=machine)
return d