private[kusto] def getClusterNameFromUrlIfNeeded()

in connector/src/main/scala/com/microsoft/kusto/spark/utils/KustoDataSourceUtils.scala [600:621]

21 lines of code
8 McCabe index (conditional complexity)


  private[kusto] def getClusterNameFromUrlIfNeeded(cluster: String): String = {
    if (cluster.equals(AriaClustersProxy)) {
      AriaClustersAlias
    } else if (cluster.equals(PlayFabClustersProxy)) {
      PlayFabClustersAlias
    } else if (cluster.startsWith(EnginePrefix)) {
      if (!cluster.contains(".kusto.") && !cluster.contains(".kustodev.")) {
        throw new InvalidParameterException(
          "KUSTO_CLUSTER parameter accepts either a full url with https scheme or the cluster's" +
            "alias and tries to construct the full URL from it. Parameter given: " + cluster)
      }
      val host = new URI(cluster).getHost
      val startIdx = if (host.startsWith(IngestPrefix)) IngestPrefix.length else 0
      val endIdx =
        if (cluster.contains(".kustodev.")) host.indexOf(".kustodev.")
        else host.indexOf(".kusto.")
      host.substring(startIdx, endIdx)

    } else {
      cluster
    }
  }