/**
 * The only information needed to create a client are security credentials
 * consisting of the AWS Access Key ID and Secret Access Key. All other
 * configuration,such as the service endpoints,are performed
 * automatically. Client parameters,such as proxies,can be specified in an
 * optional ClientConfiguration object when constructing a client.
 * 
 * @see com.amazonaws.auth.BasicAWSCredentials
 * @see com.amazonaws.auth.PropertiesCredentials
 * @see com.amazonaws.ClientConfiguration
 */
private PersistentStore(Region region,long readCapacity,long writeCapacity)
        throws Exception {
    /*
     * This credentials provider implementation loads your AWS credentials
     * from a properties file at the root of your classpath.
     */
    dynamoDB = new AmazonDynamoDBClient(
            new ClasspathPropertiesFileCredentialsProvider());
    dynamoDB.setRegion(region);

    try {
        if (!tablesExist()) {
            createTables(readCapacity,writeCapacity);
        }
        waitForTabletoBecomeAvailable(TABLE_NAME);
    } catch (Exception e) {
        handleException(e);
    }
}

MyCredentialsProvider() {
    super(new EnvironmentvariableCredentialsProvider(),new SystemPropertiesCredentialsProvider(),// Removed due to ElasticBeanstalk environment not being setup with a profile dir
            // new ProfileCredentialsProvider(),new InstanceProfileCredentialsProvider(),new ClasspathPropertiesFileCredentialsProvider());
}

protected AmazonDynamoDBDAO() {
    dynamoDB = new AmazonDynamoDBClient(new ClasspathPropertiesFileCredentialsProvider());
       Region usWest2 = Region.getRegion(Regions.US_WEST_2);

       String local_db = EnvironmentUtils.getInstance().getLocal_db();
       if (local_db != null && local_db.trim().length() > 0) {
        // LOCAL
        dynamoDB.setEndpoint(local_db,"local","us-west-2"); 
       } else {
        // PROD
        dynamoDB.setRegion(usWest2);
       }
       mapper = new DynamoDBMapper(dynamoDB);
}

private static void updateApp() {

    System.out.println("Downloading file (duckdns-dist) duckdns.war  --->  /var/tmp/duckdns.war");
    ClientConfiguration clientConfig = new ClientConfiguration();
    clientConfig.setProtocol(Protocol.HTTP);

    AmazonS3 conn = new AmazonS3Client(new ClasspathPropertiesFileCredentialsProvider(),clientConfig);

    conn.getobject(new GetobjectRequest("duckdns-dist","duckdns.war"),new File("/var/tmp/duckdns.war"));
    System.out.println("Done");
}

/**
 * You can choose the geographical region where Amazon S3 will store the
 * buckets you create. You might choose a region to optimize latency,* minimize costs,or address regulator requirements.
 * 
 * @param region
 */
public AmazonS3ManagerImpl(Region region) {
    LOG.info("Create an instance of the AmazonS3Client class by providing your "
            + "AWS Account or IAM user credentials (Access Key ID,Secret Access Key)");

    // Create an instance of the AmazonS3Client class by providing your AWS
    // Account or IAM user credentials (Access Key ID,Secret Access Key)
    amazonS3Client = new AmazonS3Client(new ClasspathPropertiesFileCredentialsProvider());
    amazonS3Client.setRegion(region);
}

/**
 * Creates a {@link PropertiesFileConfiguration} from values provided in a classpath properties file.
 *
 * @param propertiesFile the classpath properties file to load.
 */
public PropertiesFileConfiguration(String propertiesFile) {
    //load properties from configuration properties file
    Properties prop = loadProperty(propertiesFile);

    sqsUrl = prop.getProperty(SQS_URL);
    LibraryUtils.checkArgumentNotNull(sqsUrl,"Cannot find SQS URL in properties file.");

    String accessKey = prop.getProperty(ACCESS_KEY);
    String secretKey = prop.getProperty(SECRET_KEY);

    if (accessKey != null && secretKey != null) {
        awsCredentialsProvider = new ClasspathPropertiesFileCredentialsProvider(propertiesFile);
    }

    s3Region = prop.getProperty(S3_REGION);
    visibilityTimeout = getIntProperty(prop,VISIBILITY_TIMEOUT);

    sqsRegion = prop.getProperty(SQS_REGION);

    threadCount = getIntProperty(prop,THREAD_COUNT);
    threadTerminationDelaySeconds = getIntProperty(prop,THREAD_TERMINATION_DELAY_SECONDS);

    maxEventsPerEmit = getIntProperty(prop,MAX_EVENTS_PER_EMIT);
    enableRawEventInfo = getBooleanProperty(prop,ENABLE_RAW_EVENT_INFO);

    deleteMessageUponFailure  = getBooleanProperty(prop,DELETE_MESSAGE_UPON_FAILURE);
}

public FandomDAO() {
    client = new AmazonDynamoDBClient(
            new ClasspathPropertiesFileCredentialsProvider());
    mapper = new DynamoDBMapper(client);

    Fandom test = mapper.load(Fandom.class,"fandoms");
    if (test == null) {
        test = new Fandom();
        test.setId("fandoms");
        mapper.save(test);
    }
}

public CraftDAO(){
    client = new AmazonDynamoDBClient(new ClasspathPropertiesFileCredentialsProvider());
    mapper = new DynamoDBMapper(client);

    Craft test = mapper.load(Craft.class,"crafts");
    if(test == null){
        test = new Craft();
        test.setId("crafts");
        mapper.save(test);
    }
}

@Override
public void copyFiles(File directory,List<String> keys,boolean preserveDirectories)
{
  try
  {
    List<File> files = new LinkedList<File>();

    AmazonS3 client = new AmazonS3Client(new ClasspathPropertiesFileCredentialsProvider());

    for (String key : keys)
    {
      GetobjectRequest request = new GetobjectRequest("geodashboarddata",key);

      S3Object object = client.getobject(request);

      InputStream istream = object.getobjectContent();

      try
      {
        String targetPath = this.getTargetPath(preserveDirectories,key);

        File file = new File(directory,targetPath);

        FileUtils.copyInputStreamToFile(istream,file);

        files.add(file);
      }
      finally
      {
        // Process the objectData stream.
        istream.close();
      }
    }
  }
  catch (IOException e)
  {
    throw new ProgrammingErrorException(e);
  }
}

private List<String> listFiles(String prefix)
{
  List<String> files = new LinkedList<String>();

  try
  {
    AmazonS3 s3Client = new AmazonS3Client(new ClasspathPropertiesFileCredentialsProvider());

    ListObjectsRequest request = new ListObjectsRequest();
    request = request.withBucketName("geodashboarddata");
    request = request.withPrefix(prefix);

    ObjectListing listing;

    do
    {
      listing = s3Client.listObjects(request);

      List<S3ObjectSummary> summaries = listing.getobjectSummaries();

      for (S3ObjectSummary summary : summaries)
      {
        String key = summary.getKey();

        if (key.endsWith(".xml.gz"))
        {
          files.add(key);
        }
      }

      request.setMarker(listing.getNextMarker());
    } while (listing != null && listing.isTruncated());
  }
  catch (Exception e)
  {
    logger.error("Unable to retrieve files",e);
  }

  return files;
}

public CustomCredentialsProviderChain() {
  super(new ClasspathPropertiesFileCredentialsProvider(),new EnvironmentvariableCredentialsProvider(),new ProfileCredentialsProvider());
}

@Bean
AWSCredentialsProvider awsCredentials()
{
    return new ClasspathPropertiesFileCredentialsProvider( "aws-credentials.properties" );
}

private static void init() {
    speechCloud = new IvonaSpeechCloudClient(
            new ClasspathPropertiesFileCredentialsProvider("resources/IvonaCredentials.properties"));
    speechCloud.setEndpoint("https://tts.eu-west-1.ivonacloud.com");
}

private static void init() {
    speechCloud = new IvonaSpeechCloudClient(
            new ClasspathPropertiesFileCredentialsProvider("resources/IvonaCredentials.properties"));
    speechCloud.setEndpoint("https://tts.eu-west-1.ivonacloud.com");
}

private static void init() {
    speechCloud = new IvonaSpeechCloudClient(
            new ClasspathPropertiesFileCredentialsProvider("resources/IvonaCredentials.properties"));
    speechCloud.setEndpoint("https://tts.eu-west-1.ivonacloud.com");
}

private static void init() {
    speechCloud = new IvonaSpeechCloudClient(
            new ClasspathPropertiesFileCredentialsProvider("resources/IvonaCredentials.properties"));
    speechCloud.setEndpoint("https://tts.eu-west-1.ivonacloud.com");
}

private static void init() {
    speechCloud = new IvonaSpeechCloudClient(
            new ClasspathPropertiesFileCredentialsProvider("resources/IvonaCredentials.properties"));
    speechCloud.setEndpoint("https://tts.eu-west-1.ivonacloud.com");
}

private static void init() {
    speechCloud = new IvonaSpeechCloudClient(
            new ClasspathPropertiesFileCredentialsProvider("resources/IvonaCredentials.properties"));
    speechCloud.setEndpoint("https://tts.eu-west-1.ivonacloud.com");
}

private static void init() {
    speechCloud = new IvonaSpeechCloudClient(
            new ClasspathPropertiesFileCredentialsProvider("resources/IvonaCredentials.properties"));
    speechCloud.setEndpoint("https://tts.eu-west-1.ivonacloud.com");
}

private static void init() {
    speechCloud = new IvonaSpeechCloudClient(
            new ClasspathPropertiesFileCredentialsProvider("resources/IvonaCredentials.properties"));
    speechCloud.setEndpoint("https://tts.eu-west-1.ivonacloud.com");
}

public CustomCredentialsProviderChain() {
  super(new ClasspathPropertiesFileCredentialsProvider(),new EnvironmentvariableCredentialsProvider());
}

public CustomCredentialsProviderChain() {
    super(new EnvironmentvariableCredentialsProvider(),new ClasspathPropertiesFileCredentialsProvider(),new InstanceProfileCredentialsProvider());
}

public UserDAO() {
    client = new AmazonDynamoDBClient(
            new ClasspathPropertiesFileCredentialsProvider());
    mapper = new DynamoDBMapper(client);
}

public CommentDAO() {
    client = new AmazonDynamoDBClient(
            new ClasspathPropertiesFileCredentialsProvider());
    mapper = new DynamoDBMapper(client);
}

public PostDAO() {
    client = new AmazonDynamoDBClient(
            new ClasspathPropertiesFileCredentialsProvider());
    mapper = new DynamoDBMapper(client);
}

/**
 * The only information needed to create a client are security credentials
 * consisting of the AWS Access Key ID and Secret Access Key. All other
 * configuration,can be specified in an
 * optional ClientConfiguration object when constructing a client.
 *
 * @see com.amazonaws.auth.ClasspathPropertiesFileCredentialsProvider
 * @see com.amazonaws.regions.Region
 */
public DynamoDBServiceImpl(Region region) {
    LOG.info("Initialize Amazon DynamoDB environment...!!!");

    dynamoDBClient = new AmazonDynamoDBClient(new ClasspathPropertiesFileCredentialsProvider());
    dynamoDBClient.setRegion(region);
}

/**
 * Returns an {@link AWSCredentialsProvider} with the permissions necessary to accomplish all specified
 * tasks. At the minimum it will require read permissions for Amazon Kinesis. Additional read permissions
 * and write permissions may be required based on the Pipeline used.
 * 
 * @return
 */
public AWSCredentialsProvider getAWSCredentialsProvider() {
    return new ClasspathPropertiesFileCredentialsProvider("SumologicConnector.properties");
}