package org.kuali.maven.wagon;
   
   import java.io.File;
   
   import org.slf4j.Logger;
   import org.slf4j.LoggerFactory;
   
   import com.amazonaws.services.s3.AmazonS3Client;
   import com.amazonaws.services.s3.model.AmazonS3Exception;
  import com.amazonaws.services.s3.model.PutObjectRequest;
  import com.amazonaws.services.s3.transfer.TransferManager;
  import com.amazonaws.services.s3.transfer.Upload;
  
  public class S3Utils {
  	private static final int KILOBYTE = 1024;
  	private static final int MEGABYTE = 1024 * KILOBYTE;
  	private static final int MULTI_PART_UPLOAD_THRESHOLD = 100 * MEGABYTE;
  	private static final Logger log = LoggerFactory.getLogger(S3Utils.class);
  
  	public static final void upload(File file, PutObjectRequest request, AmazonS3Client client, TransferManager manager) {
  
  		// Store the file on S3
  		if (file.length() > MULTI_PART_UPLOAD_THRESHOLD) {
  			log.debug("Multi-part: " + file.getAbsolutePath());
  			// Use multi-part upload for large files
  			Upload upload = manager.upload(request);
  			try {
  				// Block and wait for the upload to finish
  				upload.waitForCompletion();
  			} catch (Exception e) {
  				throw new AmazonS3Exception("Unexpected error uploading file", e);
  			}
  		} else {
  			// Use normal upload for small files
  			client.putObject(request);
  		}
  
  	}
  
  }