package org.kuali.common.devops.archive.sweep.test;
   
   import static com.google.common.collect.Lists.newArrayList;
   import static java.lang.String.format;
   import static java.lang.System.currentTimeMillis;
   import static java.util.Arrays.asList;
   import static org.kuali.common.devops.archive.sweep.Functions.unixAttributesAsMap;
   import static org.kuali.common.util.encrypt.Encryption.getDefaultEncryptor;
   import static org.kuali.common.util.log.LoggerUtils.logTable;
  import static org.kuali.common.util.log.Loggers.newLogger;
  
  import java.util.List;
  import java.util.Map;
  
  import org.junit.Test;
  import org.kuali.common.aws.model.ImmutableAWSCredentials;
  import org.kuali.common.aws.s3.DefaultS3Service;
  import org.kuali.common.aws.s3.S3Service;
  import org.kuali.common.aws.s3.model.ObjectMetadata;
  import org.kuali.common.aws.s3.model.PutDirRequest;
  import org.kuali.common.devops.archive.sweep.model.UnixAttributes;
  import org.kuali.common.util.encrypt.Encryptor;
  import org.slf4j.Logger;
  
  import com.amazonaws.auth.AWSCredentials;
  import com.google.common.collect.Ordering;
  
  public class PutDirTest {
  
  	private static final Logger logger = newLogger();
  
  	@Test
  	public void test() {
  		try {
  			String bucket = "archive.kuali.org";
  			List<String> keys = asList("org/kuali/testci/home/tomcat7/.jenkins/jobs/kdo-sweep-builds/");
  			// UnixAttributes root = UnixAttributes.builder().withGid(0).withMode(16877).withMtime(currentTimeMillis()).withUid(0).build();
  			UnixAttributes tomcat7 = UnixAttributes.builder().withGid(113).withMode(16877).withMtime(currentTimeMillis()).withUid(107).build();
  			Map<String, String> user = unixAttributesAsMap().apply(tomcat7);
  			ObjectMetadata meta = ObjectMetadata.builder().withUserMetadata(user).build();
  			for (String key : keys) {
  				PutDirRequest request = PutDirRequest.builder().withBucket(bucket).withKey(key).withMetadata(meta).build();
  				S3Service s3 = DefaultS3Service.build(getFoundation());
  				s3.putDirectory(request);
  				ObjectMetadata omd = s3.getMetadata(bucket, key);
  				show(key, omd.getUserMetadata());
  			}
  		} catch (Throwable e) {
  			e.printStackTrace();
  		}
  	}
  
  	private void show(String key, Map<String, ?> map) {
  		List<String> columns = asList("key", "value");
  		List<Object[]> rows = newArrayList();
  		List<String> keys = Ordering.natural().immutableSortedCopy(map.keySet());
  		for (String element : keys) {
  			rows.add(new Object[] { element, map.get(element) });
  		}
  		logTable(key, columns, rows);
  	}
  
  	private static AWSCredentials getFoundation() {
  		Encryptor enc = getDefaultEncryptor();
  		String accessKey = enc.decrypt("U2FsdGVkX19A2e6dN/ipVfb/9n0DROCPIrLK6H8PvvPmt0h6cBqccGaJW0NSoX3S");
  		String secretKey = enc.decrypt("U2FsdGVkX19Y9SZ5GAU82/X5Z0xZdeQf7DFuVDW07R9lfyHK4VaOj5R7pviRBKmIyn7jrVT2lv8Edeu7098k1A==");
  		return new ImmutableAWSCredentials(accessKey, secretKey);
  	}
  
  	protected void info(String msg, Object... args) {
  		logger.info((args == null || args.length == 0) ? msg : format(msg, args));
  	}
  
  }