/*
 * Copyright 2000-2015 JetBrains s.r.o.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package jetbrains.buildServer.agent.ruby.rvm;

import com.intellij.openapi.diagnostic.Logger;
import com.intellij.openapi.util.Condition;
import com.intellij.openapi.util.SystemInfo;
import jetbrains.buildServer.ExecResult;
import jetbrains.buildServer.agent.rakerunner.utils.FileUtil2;
import jetbrains.buildServer.agent.rakerunner.utils.RunnerUtil;
import jetbrains.buildServer.agent.ruby.RubyVersionManager;
import jetbrains.buildServer.agent.ruby.rvm.util.RVMUtil;
import jetbrains.buildServer.util.CollectionsUtil;
import jetbrains.buildServer.util.Converter;
import jetbrains.buildServer.util.FileUtil;
import jetbrains.buildServer.util.StringUtil;
import jetbrains.buildServer.util.filters.Filter;
import jetbrains.buildServer.util.impl.Lazy;
import org.jetbrains.annotations.NotNull;
import org.jetbrains.annotations.Nullable;
import org.jetbrains.plugins.ruby.rvm.SharedRVMUtil;

import java.io.File;
import java.util.*;
import java.util.regex.Pattern;

import static org.jetbrains.plugins.ruby.rvm.SharedRVMUtil.Constants.RVM_GEMS_FOLDER_NAME;
import static org.jetbrains.plugins.ruby.rvm.SharedRVMUtil.Constants.RVM_RUBIES_FOLDER_NAME;

/**
 * @author Vladislav.Rassokhin
 */
public class InstalledRVM extends RubyVersionManager {
  public static final String NAME = "rvm";
  private static final Logger LOG = Logger.getInstance(InstalledRVM.class.getName());
  @NotNull
  private final String myPath;
  @NotNull
  private final Type myType;

  @NotNull
  public String getPath() {
    return myPath;
  }

  @NotNull
  public Type getType() {
    return myType;
  }

  @NotNull
  @Override
  public File getHome() {
    return new File(getPath());
  }

  @NotNull
  @Override
  public File getRubiesFolder() {
    return new File(getHome(), SharedRVMUtil.Constants.RVM_RUBIES_FOLDER_NAME);
  }

  @Nullable
  public File getHomeForVersionName(@NotNull final String name) {
    final List<File> rubies = FileUtil.getSubDirectories(getRubiesFolder());
    for (File file : rubies) {
      if (file.getName().equalsIgnoreCase(name)) {
        return file;
      }
    }
    return null;
  }

  @Override
  public boolean isSupportedByOs() {
    return SystemInfo.isUnix;
  }

  public enum Type {
    Local,
    Global,
    Special
  }

  public InstalledRVM(final @NotNull String path, final @NotNull Type type) {
    super(NAME);
    this.myPath = path;
    this.myType = type;
    determineRVMConfigData();
  }

  private void determineRVMConfigData() {
    // TODO: exec rvm for data collecting
  }

  private String getExecutablePath() {
    return myPath + "/bin/rvm";
  }

  @NotNull
  public String executeCommandLine(@NotNull final String... query) {
    final ExecResult output = RunnerUtil.run(null, null, query);
    if (output.getExitCode() != 0 || output.getException() != null || !output.getStderr().isEmpty()) {
      LOG.warn("Running " + Arrays.asList(query) + " returned strange result " + output);
    } else if (LOG.isDebugEnabled()) {
      LOG.debug("Running " + Arrays.asList(query) + " exited with result" + output);
    }
    return output.getStdout();
  }

  @NotNull
  public SharedRVMUtil.RubyDistToGemsetTable getInterpreterDistName2GemSetsTable() {
    final String rubyGemsFolderPath = getGemsFolderPath();
    final String rubySdksRootPath = getSdksRootPath();

    if (!FileUtil2.checkIfDirExists(rubyGemsFolderPath) || !FileUtil2.checkIfDirExists(rubySdksRootPath)) {
      return SharedRVMUtil.RubyDistToGemsetTable.emptyTable();
    }

    final File rubyGemsFolder = new File(rubyGemsFolderPath);
    final File rubySdksRoot = new File(rubySdksRootPath);

    final HashSet<String> distSet = new HashSet<String>(Arrays.asList(rubySdksRoot.list()));
    if (distSet.isEmpty()) {
      return SharedRVMUtil.RubyDistToGemsetTable.emptyTable();
    }

    final Condition<String> isRVMDistCond = new Condition<String>() {
      public boolean value(final String distName) {
        return distSet.contains(distName);
      }
    };

    final SharedRVMUtil.RubyDistToGemsetTable rubyDist2Gemset = new SharedRVMUtil.RubyDistToGemsetTable();

    // 1. scan .rvm/gems directory and find all existing (sdk, gemset) pairs
    final File[] files = rubyGemsFolder.listFiles();
    if (files != null) {
      for (File folder : files) {
        // ignore ordinary files
        if (!folder.isDirectory()) {
          continue;
        }

        // 2. Register if folder is a valid gempath for some sdk
        SharedRVMUtil.registerGemset(folder.getName(), isRVMDistCond, rubyDist2Gemset);
      }
    }

    return rubyDist2Gemset;
  }

  private String getSdksRootPath() {
    // TODO: detect via environment (may be non standard or using mixed installation)
    return getPath() + File.separatorChar + RVM_RUBIES_FOLDER_NAME;
  }

  private String getGemsFolderPath() {
    // TODO: detect via environment (may be non standard or using mixed installation)
    return getPath() + File.separatorChar + RVM_GEMS_FOLDER_NAME;
  }

  @NotNull
  public SortedSet<String> getInstalledRubies() {
    return myInstalledRubies.getValue();
  }

  @Nullable
  public String getDefaultInterpreter() {
    return myDefualtInterpreter.getValue();
  }

  private final Lazy<SortedSet<String>> myInstalledRubies = new Lazy<SortedSet<String>>() {
    @Nullable
    @Override
    protected SortedSet<String> createValue() {
      final String stdout = executeCommandLine(getExecutablePath(), "list", "strings");
      List<String> split = StringUtil.split(stdout, true, '\n', '\r');
      split = CollectionsUtil.convertCollection(split, new Converter<String, String>() {
        public String createFrom(@NotNull final String source) {
          return source.trim();
        }
      });
      split = CollectionsUtil.filterCollection(split, new Filter<String>() {
        public boolean accept(@NotNull final String data) {
          return !data.contains(" ");
        }
      });
      return new TreeSet<String>(split);
    }
  };

  private final Lazy<String> myDefualtInterpreter = new Lazy<String>() {
    @Nullable
    @Override
    protected String createValue() {
      // Also in ~/.rvm/config/alias
      final String stdout = executeCommandLine(getExecutablePath(), "list", "default", "string");
      List<String> split = StringUtil.split(stdout, true, '\n', '\r');
      // Filter garbage
      split = CollectionsUtil.convertCollection(split, new Converter<String, String>() {
        public String createFrom(@NotNull final String source) {
          return source.trim();
        }
      });
      split = CollectionsUtil.filterCollection(split, new Filter<String>() {
        public boolean accept(@NotNull final String data) {
          return !data.contains(" ");
        }
      });
      if (split.isEmpty()) {
        return null;
      }
      return split.iterator().next();
    }
  };

  private final Lazy<Map<Pattern, String>> myNamesResolvingReference = new Lazy<Map<Pattern, String>>() {
    @Nullable
    @Override
    protected Map<Pattern, String> createValue() {
      final Map<Pattern, String> map = new LinkedHashMap<Pattern, String>();
      // References from all known repositories ('rvm list known')
      {
        final String stdout = executeCommandLine(getExecutablePath(), "list", "known");
        map.putAll(RVMUtil.convertListKnownIntoResolvingMap(stdout));
      }

      // Reference for default one ('rvm list default string')
      {
        final String value = getDefaultInterpreter();
        if (value != null) {
          map.put(Pattern.compile(Pattern.quote("default")), value);
        }
      }

      // Ensure there are references for installed interpreters (at least add them in full form)
      {
        final SortedSet<String> installed = getInstalledRubies();
        for (String s : installed) {
          map.put(Pattern.compile(Pattern.quote(s)), s);
        }
      }

      return map;
    }
  };

  /**
   * @param name
   * @return null when cannot convert to properly name
   */
  @Nullable
  public String getDistrForName(@NotNull final String name) {
    final Map<Pattern, String> map = myNamesResolvingReference.getValue();
    return getDistrForNameFromMap(name, map);
  }

  public static String getDistrForNameFromMap(final String name, final Map<Pattern, String> map) {
    for (Map.Entry<Pattern, String> entry : map.entrySet()) {
      if (entry.getKey().matcher(name).matches()) {
        return entry.getValue();
      }
    }
    return null;
  }
}