configrd/configrd-service

package io.configrd.core.git;

import java.util.Map;
import com.amazonaws.auth.AWSCredentialsProvider;
import com.amazonaws.auth.AWSStaticCredentialsProvider;
import com.amazonaws.auth.BasicAWSCredentials;
import com.amazonaws.auth.DefaultAWSCredentialsProviderChain;
import io.configrd.core.git.GitRepoDef.AuthMethod;
import io.configrd.core.source.ConfigSourceFactory;

public class GitConfigSourceFactory implements ConfigSourceFactory<GitConfigSource> {

  @Override
  public GitConfigSource newConfigSource(String name, Map<String, Object> values) {

    GitRepoDef def = new GitRepoDef(name, values);

    if (def.valid().length > 0) {
      throw new IllegalArgumentException(String.join(",", def.valid()));
    }

    GitCredentials creds = null;

    if (AuthMethod.GitHub.name().equalsIgnoreCase(def.getAuthMethod())
        || AuthMethod.GitHubToken.name().equalsIgnoreCase(def.getAuthMethod())) {

      creds = new GitHubCredentialHelper(def.getUsername(), def.getPassword());

    } else if (AuthMethod.CodeCommitGitCreds.name().equalsIgnoreCase(def.getAuthMethod())) {

      creds = def;

    } else if (AuthMethod.CodeCommitIAMUser.name().equalsIgnoreCase(def.getAuthMethod())) {

      if (io.configrd.core.util.StringUtils.hasText(def.getPassword())) {

        AWSCredentialsProvider awsCreds = new AWSStaticCredentialsProvider(
            new BasicAWSCredentials(def.getUsername(), def.getPassword()));

        creds = new CodeCommitCredentialHelper(awsCreds, def.getUri());

      } else {

        AWSCredentialsProvider awsCreds = new DefaultAWSCredentialsProviderChain();
        creds = new CodeCommitCredentialHelper(awsCreds, def.getUri());

      }
    } else if (AuthMethod.SshPubKey.name().equalsIgnoreCase(def.getAuthMethod())) {

      creds = def;

    }

    GitStreamSource source = newStreamSource(name, def);
    GitConfigSource configSource = new GitConfigSource(source, values, creds);
    configSource.init();

    return configSource;
  }

  public GitStreamSource newStreamSource(String name, GitRepoDef def) {

    GitStreamSource source = new GitStreamSource(def);
    source.init();

    return source;
  }

  @Override
  public boolean isCompatible(String path) {
    // Don't support dynamic discovery
    return false;
  }

  @Override
  public String getSourceName() {
    return GitStreamSource.GIT;
  }

}