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

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(),

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

  // ip:port
  endpoint: computed('port', 'addresses', 'allNodes', function() {
    const addresses = get(this, 'addresses');
    const allNodes = get(this, 'allNodes');

    let out = '';
    if ( allNodes ) {
      const globalStore = get(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');
        }
      }
    } else if ( addresses && addresses.length ) {
      out = addresses[0];
    }

    if (out) {
      out += ':' + get(this,'port');
    }

    return out;
  }),

  // port[/udp]
  displayEndpoint: computed('port','protocol', function() {
    let out = '';
    out += get(this,'port');
    let proto = get(this,'protocol').toLowerCase();
    out += '/' + proto;
    return out;
  }),

  linkEndpoint: computed('isTcpish', 'isMaybeSecure', 'displayEndpoint', 'port', function() {
    if (get(this,'isTcpish') && get(this, 'port') > 0 ) {
      let out = get(this,'endpoint');

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

      return out;
    }
  }),

  isTcpish: computed('protocol', function() {
    const proto = get(this, 'protocol').toLowerCase();
    return ( ['tcp','http','https'].includes(proto) );
  }),

  isMaybeSecure: computed('port', function() {
    return portMatch([get(this,'port')], [443, 8443], '443');
  }),
});

export default PublicEndpoint;