import { isArray } from '@ember/array';
import { get, computed } from '@ember/object';
import Resource from '@rancher/ember-api-store/models/resource';
import { inject as service } from '@ember/service';
import C from 'shared/utils/constants';

function portMatch(ports, equals, endsWith) {
  if (!isArray(ports)) {
    ports = [ports];
  }

  if (!isArray(equals)) {
    equals = [equals];
  }

  if (!isArray(endsWith)) {
    endsWith = [endsWith];
  }

  for (let i = 0; i < ports.length; i++) {
    let port = ports[i];

    if (equals.includes(port)) {
      return true;
    }

    for (let j = 0; j < endsWith.length; j++) {
      let suffix = `${ endsWith[j]  }`;
      let portStr = `${ port  }`;

      if (portStr !== suffix && portStr.endsWith(suffix)) {
        return true;
      }
    }
  }

  return false;
}

var PublicEndpoint = Resource.extend({
  globalStore: service(),
  scope:       service(),
  settings:    service(),

  portProto: computed('port', 'protocol', function() {
    let out = `${ this.port  }/${  this.protocol.toLowerCase() }`;

    return out;
  }),

  // ip:port
  endpoint: computed('addresses', 'allNodes', 'hostname', 'isIngress', 'port', 'scope.currentCluster.id', function() {
    const addresses = this.addresses;
    const allNodes = this.allNodes;
    const hostname = this.hostname || '';

    let out = '';

    if (this.isIngress && hostname !== '' ) {
      out = hostname;
    } else if ( addresses && addresses.length ) {
      out = addresses[0];
    } else if ( allNodes ) {
      const globalStore = this.globalStore;
      const nodes = globalStore.all('node').filterBy('clusterId', get(this, 'scope.currentCluster.id'));
      let node = nodes.findBy('externalIpAddress');

      if ( node ) {
        out = get(node, 'externalIpAddress');
      } else {
        node = nodes.findBy('ipAddress');
        if ( node ) {
          out = get(node, 'ipAddress');
        }
      }
    }

    if (out) {
      out += `:${  this.port }`;
    }

    return out;
  }),

  // port[/udp]
  displayEndpoint: computed('port', 'protocol', 'path', function() {
    let path = this.path || '';

    if ( path && path !== '/' ) {
      return path;
    }

    let out = '';

    out += this.port;
    let proto = this.protocol.toLowerCase();

    out += `/${  proto }`;

    return out;
  }),

  linkEndpoint: computed('displayEndpoint', 'endpoint', 'isIngress', 'isMaybeSecure', 'isTcpish', 'path', 'port', function() {
    let path = this.path || '';

    if (this.isTcpish && this.port > 0 ) {
      let out = this.endpoint;

      if (this.isMaybeSecure) {
        out = `https://${  out.replace(/:443$/, '') }`;
      } else {
        out = `http://${  out.replace(/:80$/, '') }`;
      }

      if (this.isIngress) {
        out = out + path;
      }

      return out;
    }

    return;
  }),

  isTcpish: computed('protocol', function() {
    const proto = this.protocol.toLowerCase();

    return ( ['tcp', 'http', 'https'].includes(proto) );
  }),

  isMaybeSecure: computed('port', 'protocol', function() {
    const proto = this.protocol.toLowerCase();

    return portMatch([this.port], [443, 8443], '443') || proto === 'https';
  }),

  isIngress: computed('ingressId', function(){
    return this.ingressId !== '' && this.ingressId !== null;
  }),

  isReady: computed('hostname', 'isIngress', function(){
    const xip = get(this, `settings.${ C.SETTING.INGRESS_IP_DOMAIN }`);
    const hostname = this.hostname || '';

    if ( this.isIngress ){
      if ( xip === hostname ){
        return false
      }
    }

    return true
  }),
});

export default PublicEndpoint;