import Component from '@ember/component'
import ClusterDriver from 'shared/mixins/cluster-driver';
import { inject as service } from '@ember/service';
import { computed, get, set, observer } from '@ember/object';
import { alias, equal } from '@ember/object/computed';
import layout from './template';
import { isEmpty } from '@ember/utils';

const CLUSTER_ADMIN = 'kubectl create clusterrolebinding cluster-admin-binding --clusterrole cluster-admin --user [USER_ACCOUNT]';

export default Component.extend(ClusterDriver, {
  globalStore: service(),
  growl:       service(),
  settings:    service(),

  layout,
  configField:   'importedConfig',
  step:          1,
  loading:       false,
  nodeForInfo:   null,
  clusterAdmin:  CLUSTER_ADMIN,

  isEdit:       equal('mode', 'edit'),
  clusterState: alias('model.originalCluster.state'),
  isK3sCluster: equal('model.cluster.driver', 'k3s'),

  didReceiveAttrs() {
    if ( get(this, 'isEdit') &&
         get(this, 'clusterState') === 'pending'
    ) {
      this.loadToken();
    }

    if ( get(this, 'isEdit') && this.isK3sCluster ) {
      set(this, 'configField', 'k3sConfig');

      if (this.model.cluster.masterNodes.length === 1) {
        set(this, 'nodeForInfo', this.model.cluster.masterNodes.firstObject);
      }

      if (isEmpty(this.model.cluster.k3sConfig)) {
        set(this, 'model.cluster.k3sConfig', this.globalStore.createRecord({
          type:              'k3sConfig',
          serverConcurrency: 1,
          workerConcurrency: 1,
          kubernetesVersion: this.cluster.version.gitVersion
        }));
      }
    }
  },

  actions: {
    setActiveNodeForInfo(selection) {
      set(this, 'nodeForInfo', this.nodes.findBy('id', selection.id));
    },
  },

  clusterChanged: observer('originalCluster.state', function() {
    if ( get(this, 'step') >= 2 ) {
      const state = get(this, 'originalCluster.state')

      if ( !['pending', 'initializing', 'active'].includes(state) ) {
        if (this.close) {
          this.close();
        }
      }
    }
  }),

  nodes: computed('model.cluster.masterNodes.@each.{state}',  function() {
    return this.model.cluster.masterNodes;
  }),

  nodesOptions: computed('nodes.@each.{state}', function() {
    return this.nodes.map((node) => ( {
      id:          node.id,
      displayName: node.displayName
    } ));
  }),

  doneSaving() {
    if ( get(this, 'isEdit') ) {
      if (this.close) {
        this.close();
      }
    } else {
      return this.loadToken();
    }
  },

  loadToken() {
    const cluster = get(this, 'cluster');

    set(this, 'step', 2);
    set(this, 'loading', true);

    return cluster.getOrCreateToken().then((token) => {
      if ( this.isDestroyed || this.isDestroying ) {
        return;
      }

      set(this, 'token', token);
      set(this, 'loading', false);
    }).catch((err) => {
      if ( this.isDestroyed || this.isDestroying ) {
        return;
      }

      get(this, 'growl').fromError('Error getting command', err);
      set(this, 'loading', false);
    });
  }
});