coriolis-web/src/actions/MigrationActions/MigrationActions.js

/*
Copyright (C) 2017  Cloudbase Solutions SRL

This program is free software: you can redistribute it and/or modify
it under the terms of the GNU Affero General Public License as
published by the Free Software Foundation, either version 3 of the
License, or (at your option) any later version.

This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU Affero General Public License for more details.

You should have received a copy of the GNU Affero General Public License
along with this program.  If not, see <http://www.gnu.org/licenses/>.
*/

import Reflux from 'reflux';
import Api from '../../components/ApiCaller';
import NotificationActions from '../NotificationActions'
import {servicesUrl, securityGroups} from '../../config';

let MigrationActions = Reflux.createActions({
  'loadMigrations': { children: ['completed', 'failed'], shouldEmit: () => {} },
  'loadMigration': { children: ['completed', 'failed'] }, // TODO: Reload migration action
  'addMigration': { children: ['completed', 'failed'] },
  'deleteMigration': { children: ['completed', 'failed'] },
  'executeReplica': { children: ['completed', 'failed'] },
  'cancelMigration': { children: ['completed', 'failed'] },
  'getReplicaExecutions': { children: ['completed', 'failed'] },
  'getReplicaExecutionDetail': { children: ['completed', 'failed'] },
  'createMigrationFromReplica': { children: ['completed', 'failed'] },
  'deleteReplicaExecution': { children: ['completed', 'failed'] },
  'getMigration': {},
  'setMigration': {},
  'setMigrationProperty': {}
})

MigrationActions.loadMigrations.listen(() => {
  let projectId = Reflux.GlobalState.userStore.currentUser.project.id

  Api.sendAjaxRequest({
      url: `${servicesUrl.coriolis}/${projectId}/migrations/detail`,
      method: "GET"
    })
    .then(MigrationActions.loadMigrations.completed, MigrationActions.loadMigrations.failed)
    .catch(MigrationActions.loadMigrations.failed);

  Api.sendAjaxRequest({
      url: `${servicesUrl.coriolis}/${projectId}/replicas/detail`,
      method: "GET"
    })
    .then(MigrationActions.loadMigrations.completed, MigrationActions.loadMigrations.failed)
    .catch(MigrationActions.loadMigrations.failed);
})

MigrationActions.loadMigrations.shouldEmit = () => {
  let projectId = Reflux.GlobalState.userStore.currentUser.project.id
  if (typeof projectId === "undefined") {
    return false
  }
  if (Reflux.GlobalState.migrationStore.queryInProgress) {
    return false
  }
  return true
}

MigrationActions.loadMigration.listen((migration) => {
  let projectId = Reflux.GlobalState.userStore.currentUser.project.id

  Api.sendAjaxRequest({
      url: `${servicesUrl.coriolis}/${projectId}/migrations/${migration.id}`,
      method: "GET"
    })
    .then(MigrationActions.loadMigration.completed, MigrationActions.loadMigration.failed)
    .catch(MigrationActions.loadMigration.failed);
})

MigrationActions.loadMigration.shouldEmit = () => {
  let projectId = Reflux.GlobalState.userStore.currentUser.project.id
  return typeof projectId !== "undefined"
}

MigrationActions.deleteMigration.listen((migration) => {
  let migrationType = migration.type === 'replica' ? 'replicas' : 'migrations'
  let projectId = Reflux.GlobalState.userStore.currentUser.project.id
  Api.sendAjaxRequest({
      url: `${servicesUrl.coriolis}/${projectId}/${migrationType}/${migration.id}`,
      method: "DELETE"
    })
    .then(MigrationActions.deleteMigration.completed(migration), MigrationActions.deleteMigration.failed)
    .catch(MigrationActions.deleteMigration.failed);
})

MigrationActions.executeReplica.listen((replica, callback = null) => {
  if (replica.type == 'replica') {
    let projectId = Reflux.GlobalState.userStore.currentUser.project.id

    let payload = {
      execution: {
        shutdown_instances: false
      }
    }

    Api.sendAjaxRequest({
        url: `${servicesUrl.coriolis}/${projectId}/replicas/${replica.id}/executions`,
        method: "POST",
        data: payload
      })
      .then((response) => {
        MigrationActions.executeReplica.completed(replica, response)
        if (callback) {
          callback(replica, response)
        }
      }, MigrationActions.executeReplica.failed)
      .catch(MigrationActions.executeReplica.failed);
  } else {
    NotificationActions.notify("You cannot execute a migration.", "warning")
  }
})

MigrationActions.cancelMigration.listen((migration, callback = null) => {
  let projectId = Reflux.GlobalState.userStore.currentUser.project.id
  let url = null
  if (migration.type == 'migration') {
    url = `${servicesUrl.coriolis}/${projectId}/migrations/${migration.id}/actions`
  } else {
    if (migration.executions.length) {
      let executionId = migration.executions[migration.executions.length - 1].id
      url = `${servicesUrl.coriolis}/${projectId}/replicas/${migration.id}/executions/${executionId}/actions`
    } else {
      NotificationActions.notify("No executions to cancel on this replica")
    }
  }

  let payload = {
    cancel: null
  }

  Api.sendAjaxRequest({
      url: url,
      method: "POST",
      data: payload
    })
    .then((response) => {
      if (callback) {
        callback(migration, response)
      }
        MigrationActions.cancelMigration.completed(migration, response)
      }, MigrationActions.cancelMigration.failed
    )
    .catch(MigrationActions.cancelMigration.failed);

})

MigrationActions.getReplicaExecutions.listen((replica, callback) => {
  let projectId = Reflux.GlobalState.userStore.currentUser.project.id
  Api.sendAjaxRequest({
      url: `${servicesUrl.coriolis}/${projectId}/replicas/${replica.id}/executions/detail`,
      method: "GET"
    })
    .then((response) => {
      MigrationActions.getReplicaExecutions.completed(replica, response)
      if (callback) callback()
    }, MigrationActions.getReplicaExecutions.failed)
    .catch(MigrationActions.getReplicaExecutions.failed);
})


MigrationActions.getReplicaExecutionDetail.listen((replica, executionId, callback = null) => {
  let projectId = Reflux.GlobalState.userStore.currentUser.project.id
  Api.sendAjaxRequest({
      url: `${servicesUrl.coriolis}/${projectId}/replicas/${replica.id}/executions/${executionId}`,
      method: "GET"
    })
    .then((response) => {
      MigrationActions.getReplicaExecutionDetail.completed(replica, executionId, response)
      if (callback) {
        callback(replica, executionId, response)
      }
    }, MigrationActions.getReplicaExecutionDetail.failed)
    .catch(MigrationActions.getReplicaExecutionDetail.failed);
})

MigrationActions.deleteReplicaExecution.listen((replica, executionId, callback = null) => {
  let projectId = Reflux.GlobalState.userStore.currentUser.project.id
  Api.sendAjaxRequest({
    url: `${servicesUrl.coriolis}/${projectId}/replicas/${replica.id}/executions/${executionId}`,
    method: "DELETE"
  })
    .then((response) => {
      MigrationActions.deleteReplicaExecution.completed(replica, executionId, response)
      if (callback) {
        callback(replica, executionId, response)
      }
    }, MigrationActions.deleteReplicaExecution.failed)
    .catch(MigrationActions.deleteReplicaExecution.failed);
})

MigrationActions.addMigration.listen((migration) => {
  let payload = {}
  let instances = []

  migration.selectedInstances.forEach(instance => {
    if (migration.selectedInstances.indexOf(instance.id)) {
      instances.push(instance.instance_name)
    }
  })

  let network_map = {}
  migration.networks.forEach(network => {
    network_map[network.name] = network.migrateNetwork
  })

  let destinationEnv = {}

  for (var i in migration.destination_environment) {
    if (migration.destination_environment[i].label) { // removing label from dropdown if present
      destinationEnv[i] = migration.destination_environment[i].value
    } else {
      destinationEnv[i] = migration.destination_environment[i]
    }
  }

  destinationEnv["network_map"] = network_map

  payload[migration.migrationType] = {
    "origin_endpoint_id": migration.sourceCloud.credential.id,
    "destination_endpoint_id": migration.targetCloud.credential.id,
    "destination_environment": destinationEnv,
    "instances": instances,
    "notes": migration.notes,
    "security_groups": securityGroups
  }

  let migrationType = migration.migrationType === 'replica' ? 'replicas' : 'migrations'
  let projectId = Reflux.GlobalState.userStore.currentUser.project.id
  Api.sendAjaxRequest({
    url: `${servicesUrl.coriolis}/${projectId}/${migrationType}`,
    method: "POST",
    data: payload
  })
    .then(MigrationActions.addMigration.completed, MigrationActions.addMigration.failed)
    .catch(MigrationActions.addMigration.failed);

})

MigrationActions.createMigrationFromReplica.listen((replica) => {
  let payload = {
    migration: {
      replica_id: replica.id,
      force: false,
      clone_disks: true
    }
  }

  let projectId = Reflux.GlobalState.userStore.currentUser.project.id

  Api.sendAjaxRequest({
      url: `${servicesUrl.coriolis}/${projectId}/migrations`,
      method: "POST",
      data: payload
    })
    .then(MigrationActions.createMigrationFromReplica.completed, MigrationActions.createMigrationFromReplica.failed)
    .catch(MigrationActions.createMigrationFromReplica.failed);

})


export default MigrationActions;