coriolis-web/src/stores/WizardStore/WizardStore.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 WizardActions from '../../actions/WizardActions';
import ConnectionsActions from '../../actions/ConnectionsActions';
import { servicesUrl, itemsPerPage } from '../../config';
import Api from '../../components/ApiCaller';

class WizardStore extends Reflux.Store
{
  blankState = {
    sourceCloud: null,
    targetCloud: null,
    breadcrumbs: [],
    currentStep: "WizardMigrationType",
    nextStep: null,
    nextCallback: null,
    backCallback: null,
    valid: false,
    migrationName: null,
    autoFlavors: true,
    diskFormat: "VHD",
    migrationType: "migration",
    fipPool: null,
    schedules: [],
    instances: null,
    selectedInstances: [],
    vms: null,
    showAdvancedOptions: false,
    destination_environment: {},
    networks: null,
    targetNetworks: null,
    selected: false,
    wizardStarted: false
  }

  constructor() {
    super()
    this.listenables = [WizardActions, ConnectionsActions]

    this.state = Object.assign({}, this.blankState)
  }

  onLoadInstances(endpoint, page = 0, queryText = "", cache = true, clearSelection = false) {
    if (cache && (this.state.instances && this.state.instances[page * itemsPerPage])) {
      return;
    }
    if (!cache) {
      this.setState({ instances: null })
    }
    let projectId = Reflux.GlobalState.userStore.currentUser.project.id

    if (clearSelection) {
      this.setState({ selectedInstances: [] })
    }

    let markerId = null
    if (page > 0 && this.state.instances[(page - 1) * itemsPerPage + itemsPerPage - 1]) {
      markerId = this.state.instances[(page - 1) * itemsPerPage + itemsPerPage - 1].id
    }

    let url = `${servicesUrl.coriolis}/${projectId}/endpoints/${endpoint.id}/instances?limit=${itemsPerPage}`
    if (markerId != null) {
      url = `${url}&marker=${markerId}`
    }
    if (queryText != "") {
      url = `${url}&name=${queryText}`
    }

    Api.sendAjaxRequest({
      url: url,
      method: "GET"
    }).then(response => {
      ConnectionsActions.loadInstances.completed(response, page)
    }, ConnectionsActions.loadInstances.failed)
      .catch(ConnectionsActions.loadInstances.failed);
  }

  onLoadInstancesCompleted(response, page) {
    let instances = this.state.instances

    if (instances == null) {
      instances = []
    }
    response.data.instances.forEach((instance, index) => {
      instances[(page * itemsPerPage) + index] = instance
    })

    this.setState({ instances: instances })
  }

  onLoadInstancesFailed() {
    this.setState({ instances: [] })
  }

  onLoadInstanceDetail(endpoint, instance) {
    let projectId = Reflux.GlobalState.userStore.currentUser.project.id
    let instanceNameBase64 = btoa(instance.name)
    let url = `${servicesUrl.coriolis}/${projectId}/endpoints/${endpoint.id}/instances/${instanceNameBase64}`

    Api.sendAjaxRequest({
      url: url,
      method: "GET"
    }).then(response => {
      ConnectionsActions.loadInstanceDetail.completed(response)
    }, ConnectionsActions.loadInstanceDetail.failed)
      .catch(ConnectionsActions.loadInstanceDetail.failed);
  }

  onLoadInstanceDetailCompleted(response) {
    let selectedInstances = this.state.selectedInstances
    selectedInstances.forEach((item, index) => {
      if (item.id === response.data.instance.id) {
        selectedInstances[index] = response.data.instance
      }
    })
    this.setState({ selectedInstances: selectedInstances })
  }

  onLoadNetworks() {
    this.setState({
      targetNetworks: null
    })
  }

  onLoadNetworksCompleted(response) {
    if (response.data.networks) {
      this.setState({
        targetNetworks: response.data.networks
      })
    }
  }

  onNewState() {
    this.setState(this.blankState)
  }

  onUpdateWizardState(state, callback = null) {
    this.setState(state)
    if (callback) callback()
  }

}

WizardStore.id = "wizardStore"

export default WizardStore;