def delete_disk_offering(disk_offering_uuid, session_uuid = None):
    action = api_actions.DeleteDiskOfferingAction()
    action.uuid = disk_offering_uuid
    test_util.action_logger('Delete Disk Offering [uuid:] %s' \
            % disk_offering_uuid)
    evt = account_operations.execute_action_with_session(action, session_uuid)
    return evt

def get_vm_console_protocol(uuid, session_uuid=None):
    action = api_actions.GetVmConsoleAddressAction()
    action.timeout = 30000
    action.uuid = uuid
    evt = acc_ops.execute_action_with_session(action, session_uuid)
    test_util.action_logger('Get VM Console protocol:  %s ' % evt.protocol)
    return evt

def reconnect_host(host_uuid, session_uuid=None, timeout=120000):
    action = api_actions.ReconnectHostAction()
    action.uuid = host_uuid
    action.timeout = timeout
    test_util.action_logger('Reconnect Host [uuid:] %s' % host_uuid)
    evt = account_operations.execute_action_with_session(action, session_uuid)
    return evt.inventory

def get_trash_on_backup_storage(backup_storage_uuid, session_uuid=None):
    action = api_actions.GetTrashOnBackupStorageAction()
    action.uuid = backup_storage_uuid
    action.timeout = 6000000
    test_util.action_logger('Get Trash On Backup Storage [uuid:] %s' % backup_storage_uuid)
    evt = account_operations.execute_action_with_session(action, session_uuid)
    return evt.storageTrashSpecs

def add_zone_resource(deploy_config, zone_name):
    session_uuid = acc_ops.login_as_admin()
    try:
        test_util.test_dsc('-------add zone operation-------')
        dep_ops.add_zone(deploy_config, session_uuid, zone_name = zone_name)
        test_util.test_dsc('-------add l2 operation-------')
        dep_ops.add_l2_network(deploy_config, session_uuid, \
                zone_name = zone_name)
        test_util.test_dsc('-------add primary stroage operation-------')
        dep_ops.add_primary_storage(deploy_config, session_uuid, \
                zone_name = zone_name)
        test_util.test_dsc('-------add cluster operation-------')
        dep_ops.add_cluster(deploy_config, session_uuid, \
                zone_name = zone_name)
        test_util.test_dsc('-------add host operation-------')
        dep_ops.add_host(deploy_config, session_uuid, \
                zone_name = zone_name)
        test_util.test_dsc('-------add l3 operation-------')
        dep_ops.add_l3_network(deploy_config, session_uuid, \
                zone_name = zone_name)
        test_util.test_dsc('-------add virtual router offering operation-------')
        dep_ops.add_virtual_router(deploy_config, session_uuid, \
                zone_name = zone_name)
        zone = res_ops.get_resource(res_ops.ZONE, session_uuid, \
                name = zone_name)[0]
    except Exception as e:
        test_util.test_logger('[Error] zstack deployment meets exception when adding zone resource .')
        traceback.print_exc(file=sys.stdout)
        raise e
    finally:
        acc_ops.logout(session_uuid)

    test_util.action_logger('Complete add zone resources for [uuid:] %s' \
            % zone.uuid)

def delete_eip(eip_uuid, session_uuid=None):
    action = api_actions.DeleteEipAction()
    action.uuid = eip_uuid
    action.timeout = 12000
    evt = acc_ops.execute_action_with_session(action, session_uuid)
    test_util.action_logger("[EIP:] %s is deleted" % eip_uuid)
    return evt

def detach_l3(nic_uuid, session_uuid = None):
    action = api_actions.DetachL3NetworkFromVmAction()
    action.vmNicUuid = nic_uuid
    test_util.action_logger('[Detach L3 Network Nic]: %s' % nic_uuid)
    evt = acc_ops.execute_action_with_session(action, session_uuid)
    test_util.test_logger('[L3 Network Nic]: %s has been detached'% nic_uuid)
    return evt.inventory

def update_system_tag(tag_uuid, tag, session_uuid = None):
    action = api_actions.UpdateSystemTagAction()
    action.uuid = tag_uuid
    action.tag = tag
    test_util.action_logger('Update Tag [uuid:] %s to %s' % (tag_uuid, tag))
    evt = account_operations.execute_action_with_session(action, session_uuid)
    return evt.inventory

def expunge_image(image_uuid, backup_storage_uuid_list=None, session_uuid=None):
    action = api_actions.ExpungeImageAction()
    action.imageUuid = image_uuid
    action.backupStorageUuids = backup_storage_uuid_list
    test_util.action_logger('Expunge [image:] %s' % image_uuid)
    evt = account_operations.execute_action_with_session(action, session_uuid)
    return evt

def change_image_state(uuid, state, session_uuid):
    action = api_actions.ChangeImageStateAction()
    action.uuid = uuid
    action.stateEvent = state
    test_util.action_logger('Change [image %s] state' % (uuid))
    evt = account_operations.execute_action_with_session(action, session_uuid)
    return evt.inventory   

def delete_tag(tag_uuid, session_uuid=None):
    action = api_actions.DeleteTagAction()
    action.uuid = tag_uuid
    action.timeout = 30000
    test_util.action_logger('Delete Tag [uuid:] %s' % tag_uuid)
    evt = account_operations.execute_action_with_session(action, session_uuid)
    return evt

def update_image_platform(uuid, platform, session_uuid=None):
    action = api_actions.UpdateImageAction()
    action.uuid = uuid
    action.platform = platform
    test_util.action_logger('Update [image %s] platform' % (uuid))
    evt = account_operations.execute_action_with_session(action, session_uuid)
    return evt.inventory   

def delete_vcenter(vcenter_uuid, timeout=240000, session_uuid=None):
    action = api_actions.DeleteVCenterAction()
    action.uuid = vcenter_uuid
    action.timeout = timeout
    test_util.action_logger('Delete VCenter [uuid:] %s' % vcenter_uuid)
    evt = account_operations.execute_action_with_session(action, session_uuid)
    return evt.inventory

def migrate_volume(volume_uuid, host_uuid, session_uuid = None):
    action = api_actions.LocalStorageMigrateVolumeAction()
    action.destHostUuid = host_uuid
    action.volumeUuid = volume_uuid
    test_util.action_logger('Migrate Local Storage Volume: %s to Host: %s' \
            % (volume_uuid, host_uuid))
    evt = account_operations.execute_action_with_session(action, session_uuid)

def create_port_forwarding(pf_rule_creation_option):
    action = api_actions.CreatePortForwardingRuleAction()
    action.name = pf_rule_creation_option.get_name()
    if not action.name:
        action.name = 'test_port_forwarding_rule'

    action.timeout = pf_rule_creation_option.get_timeout()
    if not action.timeout:
        action.timeout = 12000

    action.description = pf_rule_creation_option.get_description()
    session_uuid = pf_rule_creation_option.get_session_uuid()

    action.vipPortStart, action.vipPortEnd = pf_rule_creation_option.get_vip_ports()
    action.privatePortStart, action.privatePortEnd = pf_rule_creation_option.get_private_ports()
    if not action.privatePortStart:
        action.privatePortStart = action.vipPortStart
        action.privatePortEnd = action.vipPortEnd

    action.vipUuid = pf_rule_creation_option.get_vip_uuid()
    action.vmNicUuid = pf_rule_creation_option.get_vm_nic_uuid()
    action.allowedCidr = pf_rule_creation_option.get_allowedCidr()
    action.protocolType = pf_rule_creation_option.get_protocol()
    test_util.action_logger("Create Port Forwarding Rule: [vipUuid:] %s [vm nic:] %s [vip start:] %s [vip end:] %s [pri start:] %s [pri end:] %s [allowedCidr:] %s" % (action.vipUuid, action.vmNicUuid, action.vipPortStart, action.vipPortEnd, action.privatePortStart, action.privatePortEnd, action.allowedCidr))
    evt = acc_ops.execute_action_with_session(action, session_uuid)
    return evt.inventory

def create_template_from_snapshot(image_creation_option, session_uuid=None):
    action = api_actions.CreateRootVolumeTemplateFromVolumeSnapshotAction()
    action.snapshotUuid = image_creation_option.get_root_volume_uuid()
    action.backupStorageUuids = image_creation_option.get_backup_storage_uuid_list()

    action.guestOsType = image_creation_option.get_guest_os_type()
    action.system = image_creation_option.get_system()
    action.platform = image_creation_option.get_platform()

    name = image_creation_option.get_name()
    if not name:
        action.name = 'test_template_image_by_snapshot'
    else:
        action.name = name

    description = image_creation_option.get_description()
    if not description:
        action.description = "test create template from snapshot: %s" % \
                action.snapshotUuid
    else:
        action.description = description

    test_util.action_logger('Create Image Template from [snapshot:] %s in [backup Storage:] %s' % (action.snapshotUuid, action.backupStorageUuids))
    evt = account_operations.execute_action_with_session(action, image_creation_option.get_session_uuid())
    return evt.inventory

def attach_port_forwarding(pf_rule_uuid, vm_nic_uuid, session_uuid=None):
    action = api_actions.AttachPortForwardingRuleAction()
    action.ruleUuid = pf_rule_uuid
    action.vmNicUuid = vm_nic_uuid
    evt = acc_ops.execute_action_with_session(action, session_uuid)
    test_util.action_logger("Port Forwarding Rule [uuid:] %s is attached to %s" % (pf_rule_uuid, vm_nic_uuid))
    return evt.inventory

def add_root_volume_template(image_creation_option):
    '''
    Add root volume template
    '''
    action = api_actions.AddImageAction()
    action.name = image_creation_option.get_name()
    action.guest_os_type = image_creation_option.get_guest_os_type()
    action.mediaType = 'RootVolumeTemplate'
    if image_creation_option.get_mediaType() and \
            action.mediaType != image_creation_option.get_mediaType():
        test_util.test_warn('image type %s was not %s' % \
                (image_creation_option.get_mediaType(), action.mediaType))

    action.backupStorageUuids = \
            image_creation_option.get_backup_storage_uuid_list()
    action.bits = image_creation_option.get_bits()
    action.description = image_creation_option.get_description()
    action.format = image_creation_option.get_format()
    if image_creation_option.get_system_tags() != None:
        action.systemTags = image_creation_option.get_system_tags().split(',')
    action.url = image_creation_option.get_url()
    action.timeout = image_creation_option.get_timeout()
    test_util.action_logger('Add Root Volume Template from url: %s in [backup Storage:] %s' % (action.url, action.backupStorageUuids))
    evt = account_operations.execute_action_with_session(action, \
            image_creation_option.get_session_uuid())
    return evt.inventory

def get_ip_capacity_by_l3s(l3_network_list, session_uuid = None):
    action = api_actions.GetIpAddressCapacityAction()
    action.l3NetworkUuids = l3_network_list
    evt = acc_ops.execute_action_with_session(action, session_uuid)
    test_util.action_logger('Get L3s: [%s] IP Capacity' % \
            l3_network_list)
    return evt

def create_root_volume_template(image_creation_option):
    '''
    Create Root Volume Template from a root volume
    '''
    action = api_actions.CreateRootVolumeTemplateFromRootVolumeAction()
    action.rootVolumeUuid = image_creation_option.get_root_volume_uuid()
    action.backupStorageUuids = image_creation_option.get_backup_storage_uuid_list()

    name = image_creation_option.get_name()
    if not name:
        action.name = 'test_template_image'
    else:
        action.name = name

    action.guestOsType = image_creation_option.get_guest_os_type()
    action.system = image_creation_option.get_system()
    action.platform = image_creation_option.get_platform()

    description = image_creation_option.get_description()
    if not description:
        action.description = "test create template from volume"
    else:
        action.description = description

    test_util.action_logger('Create Image Template from [root Volume:] %s in [backup Storage:] %s' % (action.rootVolumeUuid, action.backupStorageUuids))
    evt = account_operations.execute_action_with_session(action, image_creation_option.get_session_uuid())
    return evt.inventory