package mage.client.remote;

import com.amazonaws.AmazonClientException;
import com.amazonaws.auth.BasicAWSCredentials;
import com.amazonaws.services.s3.transfer.TransferManager;
import com.amazonaws.services.s3.transfer.Upload;
import java.io.File;
import org.apache.log4j.Logger;

public class S3Uploader {

    private static final Logger logger = Logger.getLogger(S3Uploader.class);

    public static Boolean upload(String filePath, String keyName) throws Exception {
        String existingBucketName = System.getenv("S3_BUCKET") != null ? System.getenv("S3_BUCKET")
                : "xmage-game-logs-dev";

        String accessKeyId = System.getenv("AWS_ACCESS_ID");
        String secretKeyId = System.getenv("AWS_SECRET_KEY");

        if (accessKeyId == null || "".equals(accessKeyId)
                || secretKeyId == null || "".equals(secretKeyId)
                || existingBucketName == null || "".equals(existingBucketName)) {
            logger.info("Aborting json log sync.");
            return false;
        }

        String path = new File("./" + filePath).getCanonicalPath();
        logger.info("Syncing " + path + " to bucket: " + existingBucketName + " with AWS Access Id: " + accessKeyId);

        BasicAWSCredentials awsCreds = new BasicAWSCredentials(accessKeyId, secretKeyId);
        TransferManager tm = new TransferManager(awsCreds);
        Upload upload = tm.upload(existingBucketName, "/game/" + keyName + ".json", new File(path));

        try {
            upload.waitForUploadResult();
            logger.info("Sync Complete For " + path + " to bucket: " + existingBucketName + " with AWS Access Id: " + accessKeyId);
            new File(path);
            return true;
        } catch (AmazonClientException amazonClientException) {
            logger.fatal("Unable to upload file, upload was aborted.", amazonClientException);
            return false;
        }
    }
}