var fs = require('fs');
var ini = require('ini');
var path = require('path');
var s3 = require('s3');
var chalk = require('chalk');
var xtend = require('xtend');

module.exports = function(args) {

  var config = {
    maxAsyncS3: args.concurrency,
    s3Options: {
      accessKeyId: args.aws_key || process.env.AWS_ACCESS_KEY_ID || process.env.AWS_KEY,
      secretAccessKey: args.aws_secret || process.env.AWS_SECRET_ACCESS_KEY || process.env.AWS_SECRET,
      region: args.region
    }
  };
  if (args.endpoint) {
    config.endpoint = args.endpoint;
  }
  if (!config.s3Options.accessKeyId && !config.s3Options.secretAccessKey && args.aws_cli_profile) {
    /* User configured their access and secret keys in ~/.aws/credentials, check there */
    var iniFile = path.join(process.env.HOME, '.aws');
    var iniCredentials = ini.parse(fs.readFileSync(path.join(iniFile, 'credentials'), 'utf-8'));
    config.s3Options.accessKeyId = (iniCredentials[args.aws_cli_profile] || {}).aws_access_key_id;
    config.s3Options.secretAccessKey = (iniCredentials[args.aws_cli_profile] || {}).aws_secret_access_key;
    if (!config.s3Options.region) {
      var iniConfig = ini.parse(fs.readFileSync(path.join(iniFile, 'config'), 'utf-8'));
      var profilePath = (args.aws_cli_profile === 'default') ? args.aws_cli_profile : "profile " + args.aws_cli_profile;
      config.s3Options.region = (iniConfig[profilePath] || {}).region;
    }
  }
  var client = s3.createClient(config);

  var publicDir = this.config.public_dir;
  var log = this.log;

  var customHeaders = args.headers || {};
  var deleteRemoved = args.hasOwnProperty('delete_removed')
    ? Boolean(args.delete_removed)
    : true;

  if (!args.bucket || !config.s3Options.accessKeyId || !config.s3Options.secretAccessKey) {
    var help = '';

    help += 'You should configure deployment settings in _config.yml first!\n\n';
    help += 'Example:\n';
    help += '  deploy:\n';
    help += '    type: s3\n';
    help += '    bucket: <bucket>\n';
    help += '    [aws_key]: <aws_key>        # Optional, if provided as environment variable\n';
    help += '    [aws_secret]: <aws_secret>  # Optional, if provided as environment variable\n';
    help += '    [concurrency]: <concurrency>\n';
    help += '    [region]: <region>          # See https://github.com/LearnBoost/knox#region\n',
    help += '    [headers]: <JSON headers>   # Optional, see README.md file\n';
    help += '    [prefix]: <prefix>          # Optional, prefix ending in /\n';
    help += '    [delete_removed]: <delete>  # Optional, if true will delete removed files from S3 /\n\n';
    help += '    [endpoint]: <endpoint>      # Optional, for S3 compatiable services\n'
    help += 'For more help, you can check the docs: ' + chalk.underline('https://github.com/nt3rp/hexo-deployer-s3');

    console.log(help);
    return;
  }

  var params = {
    localDir: publicDir,
    deleteRemoved: deleteRemoved,
    s3Params: xtend({
      Bucket: args.bucket,
      Prefix: args.prefix
    },customHeaders)
  }

  var uploader = client.uploadDir(params);
  log.info('Uploading...');

  return uploader
    .on('progress', function() {
      //   log.info(uploader.progressAmount + ' / ' + uploader.progressTotal);
    }).on('end', function() {
      log.info('Done!');
    }).on('error', function(err) {
      log.error(err)
    });
};