vms.service.js

/* eslint camelcase: "off" */

/** @ngInject */
export function VmsService(CollectionsApi, RBAC) {
  const collection = 'vms';
  const sort = {
    isAscending: true,
    currentField: {id: 'name', title: __('Name'), sortType: 'alpha'},
  };
  let filters = [];

  return {
    getVm: getVm,
    getSort: getSort,
    setSort: setSort,
    getFilters: getFilters,
    setFilters: setFilters,
    getInstance: getInstance,
    getSnapshots: getSnapshots,
    getPermissions: getPermissions,
    revertSnapshot: revertSnapshot,
    createSnapshots: createSnapshots,
    deleteSnapshots: deleteSnapshots,
  };

  function getSnapshots(vmId) {
    const options = {
      attributes: [],
      expand: ['resources'],
      filter: getQueryFilters(getFilters()),
    };

    options.sort_by = getSort().currentField.id;
    options.sort_options = getSort().currentField.sortType === 'alpha' ? 'ignore_case' : '';
    options.sort_order = getSort().isAscending ? 'asc' : 'desc';

    return CollectionsApi.query(collection + '/' + vmId + '/snapshots', options);
  }

  function getVm(vmId) {
    const options = {
      attributes: [
        'advanced_settings',
        'boot_time',
        'cloud',
        'compliances',
        'cpu_affinity',
        'created_on',
        'custom_actions',
        'custom_action_buttons',
        'disks',
        'disks_aligned',
        'drift_states',
        'ems_cluster',
        'ext_management_system',
        'evm_owner',
        'files',
        'guest_applications',
        'groups',
        'guid',
        'hardware',
        'host',
        'hostnames',
        'id',
        'ipaddresses',
        'kernel_drivers',
        'lans',
        'last_sync_on',
        'linux_initprocesses',
        'last_compliance_status',
        'miq_group',
        'miq_provision',
        'miq_provision_requests',
        'miq_provision_vms',
        'name',
        'num_disks',
        'parent_resource_pool',
        'power_state',
        'retired',
        'retires_on',
        'scan_histories',
        'service',
        'service.miq_request',
        'service_resources',
        'snapshots',
        'state_changed_on',
        'storages',
        'tags',
        'template',
        'thin_provisioned',
        'tools_status',
        'uid_ems',
        'users',
        'vendor',
        'v_total_snapshots',
        'vmsafe_enable',
      ],
      expand: [],
    };

    return CollectionsApi.query(collection + '/' + vmId, options);
  }

  function setSort(currentField, isAscending) {
    sort.isAscending = isAscending;
    sort.currentField = currentField;
  }

  function getSort() {
    return sort;
  }

  function setFilters(filterArray) {
    filters = filterArray;
  }

  function getFilters() {
    return filters;
  }

  function getPermissions() {
    return {
      create: RBAC.hasAny(['vm_snapshot_add']),
      delete: RBAC.hasAny(['vm_snapshot_delete']),
      deleteAll: RBAC.hasAny(['vm_snapshot_delete_all']),
      revert: RBAC.hasAny(['vm_snapshot_revert']),
    };
  }

  function deleteSnapshots(vmId, data) {
    const options = {
      "action": "delete",
      "resources": data,
    };

    return CollectionsApi.post(collection + '/' + vmId + '/snapshots/', null, {}, options);
  }

  function createSnapshots(vmId, data) {
    const options = {
      "action": "create",
      "resources": [data],
    };

    return CollectionsApi.post(collection + '/' + vmId + '/snapshots/', null, {}, options);
  }

  function revertSnapshot(vmId, snapshotId) {
    const options = {
      "action": "revert",
    };

    return CollectionsApi.post(collection + '/' + vmId + '/snapshots/' + snapshotId, null, {}, options);
  }

  function getInstance(vmId) {
    const options = {
      attributes: [
        'availability_zone',
        'cloud_networks',
        'cloud_subnets',
        'cloud_tenant',
        'cloud_volumes',
        'flavor',
        'floating_ip_addresses',
        'key_pairs',
        'load_balancers',
        'mac_addresses',
        'network_ports',
        'network_routers',
        'miq_provision_template',
        'orchestration_stack',
        'security_groups',
      ],
    };

    return CollectionsApi.get('instances', vmId, options);
  }

  // Private
  function getQueryFilters(filters) {
    const queryFilters = [];

    filters.forEach((nextFilter) => {
      if (nextFilter.id === 'name' || nextFilter.id === 'description') {
        queryFilters.push(nextFilter.id + "='%" + nextFilter.value + "%'");
      } else {
        queryFilters.push(nextFilter.id + '=' + nextFilter.value);
      }
    });

    return queryFilters;
  }
}