package org.kuali.common.devops.ubuntu;
   
   import static com.amazonaws.regions.Region.getRegion;
   import static com.amazonaws.regions.Regions.US_WEST_1;
   import static com.google.common.base.Stopwatch.createStarted;
   import static java.lang.String.format;
   import static org.kuali.common.util.encrypt.Encryption.getDefaultEncryptor;
   import static org.kuali.common.util.log.Loggers.newLogger;
   
  import java.util.List;
  
  import org.junit.Test;
  import org.kuali.common.aws.ec2.api.EC2Service;
  import org.kuali.common.aws.ec2.impl.DefaultEC2Service;
  import org.kuali.common.aws.ec2.model.ImmutableTag;
  import org.kuali.common.aws.ec2.model.VolumeRequest;
  import org.kuali.common.aws.model.ImmutableAWSCredentials;
  import org.kuali.common.core.json.api.JsonService;
  import org.kuali.common.core.json.jackson.JacksonJsonService;
  import org.kuali.common.core.ssh.KeyPair;
  import org.kuali.common.core.system.VirtualSystem;
  import org.kuali.common.util.channel.api.ChannelService;
  import org.kuali.common.util.channel.api.SecureChannel;
  import org.kuali.common.util.channel.impl.DefaultChannelService;
  import org.kuali.common.util.channel.model.ChannelContext;
  import org.kuali.common.util.encrypt.Encryptor;
  import org.slf4j.Logger;
  
  import com.amazonaws.auth.AWSCredentials;
  import com.amazonaws.regions.Region;
  import com.amazonaws.services.ec2.model.Instance;
  import com.amazonaws.services.ec2.model.Tag;
  import com.google.common.base.Stopwatch;
  import com.google.common.collect.ImmutableList;
  
  public class MuckWithVolumes {
  
  	private static final Logger logger = newLogger();
  
  	@Test
  	public void test() {
  		try {
  			Stopwatch sw = createStarted();
  			Region region = getRegion(US_WEST_1);
  			VirtualSystem vs = VirtualSystem.build();
  			String instanceId = vs.getProperty("instance", "i-df5b6581");
  			JsonService json = new JacksonJsonService();
  			AWSCredentials credentials = getFoundation();
  			EC2Service ec2 = new DefaultEC2Service(credentials, region.getName());
  			Instance instance = ec2.getInstance(instanceId);
  			Tag name = new ImmutableTag("Name", "ci.master.jobs");
  			Tag stack = new ImmutableTag("Stack", "test");
  			List<Tag> tags = ImmutableList.of(name, stack);
  			ChannelContext ctx = ChannelContext.builder(instance.getPublicDnsName()).privateKey(getPrivateKey()).username("root").build();
  			ChannelService cs = new DefaultChannelService();
  			SecureChannel channel = cs.openChannel(ctx);
  
  			info("instance -> %s", instance.getInstanceId());
  			info("hostname -> %s", instance.getPublicDnsName());
  
  			String zone = instance.getPlacement().getAvailabilityZone();
  			String volumeId = ec2.createVolume(zone, 1024);
  			info("create   -> %s", volumeId);
  			ec2.tag(volumeId, tags);
  			String device = "/dev/xvdf";
  			String dir = "/home/tomcat7/.jenkins/jobs";
  			VolumeRequest request = VolumeRequest.builder().withDevice(device).withInstanceId(instanceId).withVolumeId(volumeId).build();
  			info("attach   -> %s %s:%s", request.getVolumeId(), instance.getPublicDnsName(), device);
  			ec2.attachVolume(request);
  			// create the file system
  			channel.exec(format("mkfs -t ext4 %s", device));
  			channel.exec(format("mkdir -p %s", dir));
  			channel.exec(format("chown -R tomcat7:tomcat7 %s", dir));
  			channel.exec(format("mount %s %s", device, dir));
  			// channel.exec(format("umount %s", dir));
  			// info("detach   -> %s %s:%s", request.getVolumeId(), instance.getPublicDnsName(), device);
  			// ec2.detachVolume(request);
  			// info("delete   -> %s", volumeId);
  			// ec2.deleteVolume(volumeId);
  			// info("elapsed  -> %s", getTime(sw));
  		} catch (Throwable e) {
  			e.printStackTrace();
  		}
  	}
  
  	protected static void debug(String msg, Object... args) {
  		logger.debug((args == null || args.length == 0) ? msg : format(msg, args));
  	}
  
  	protected static void info(String msg, Object... args) {
  		logger.info((args == null || args.length == 0) ? msg : format(msg, args));
  	}
  
  	private static String getPrivateKey() {
  		Encryptor enc = getDefaultEncryptor();
  		String publicKey = enc
  				.decrypt("U2FsdGVkX1/mOVOU9KiA43fWz10qtG08ixrGGBk+DsuFEikZ1N3bz5BUiPD4G7okAeQgen+RQ4E40/AybeLRjJUuOgLUdeOCpcK6u/H+EZs+N820xZe1Hpq/wchfs13npj6gWpOWylQAhl5DSioe5wHxkQC3hORV13sr5Mhaf+SorF/NPyzvERsJZ/FoScV+RcGxLfwVmlAUEVdsYNfgUepXPUWwTDmNu4FcRO/8ud7Kth7E3BkwG7sTN9n7pkEbA632ZdjcccBIptOfurArMLORN8VsCbiQU8uFo2leudzsa5zdx6JsxiGHHQeybogZ95lLwxAl48ka4YfpyVDaDA7Bf3nUp2xMbqvTaoPYMXrp8Y0Qk/aDhsDIhfSd72Sk/XE/RI/sjlzO2Owp0wp9Wb9uT3AsSAu44qjqCr8/AY9BUTn/SSc/+2COnO7YUgMSbo/fy3WK2twIyTd/YiF+qjaNjLUdYwxZDiD0s/g0pk46rnKdTy406KRO5W4uGIvVO5WpLsMk3chLctas3KJYreZ1pUV4gnnC8R2baqRzkgg=");
  		String privateKey = enc
  				.decrypt("U2FsdGVkX1964V6ECejulb3AbuYHUecurrami/7OaBZrxLR9G6bgPH15arwbsYvDw0oUkn087EwqL6rDosVVj1sF7AogWLsIHmInSSWEgm1PGv1C80DS4GMbunPErekVXts4xlu8uO8I+LsnPVaYhByknSQlcdnz5PFmYblgLC42a5oYsSMZ4KfnlbP80vveC6ypMlsT8xMtyP9c1CIsu76KPI9pv+/Ca9cFdCEyZEkPC/12BAf4N4d6YK9OMFppAUfYuVLHCBE+QK/ubdqAmpZJ/hW1t0LN8Yh0JRL3KgmCkRNhvc7fRKgL6n0eT67tx6S7xELAQ1f6G6a0+Q3WRkFH4bAoy8wRRHK8sSkxr6Vl0mCr2Y71ki1LfQP5BGu56rVRjSSnDBLeoIvSuNQUGuaZ9FpdMBGQ3EXVoiyIyghukdo2dOg9BIw4ANWdXNbYoyFWrEdaaKU7yLYL6qnUOrrEGnE044RyEP9gGyzcDFcReBbOp74QV3Zyt2E/T7f4TzazB8WjN5q7fuUm0SiWW0kzFK2UKl8olql8Em3rvVGLw+gkdjt9F7NS3u3a/T2Ca3+PKbTt8yYvaqAqaVwCn3W5Oy9tPSX5sohW6b9F7jbI2ZPTxIlsRHAnju0Z5/f2HjcgNvi1tF3jyGhjqGBJoKMV/UF7faN0zA5fLoASPQY653EbY7ZRxYYiwpoKliuPvVDCSS07KBU/81D0CIZHGsxY8VOJ/HBQmkT08FQNXrL1KIi1tN/1ZIkVdyc5zUrTBFl5gHf2KWTXdV/KTfo2PGyUGNYLVVBJ4eof3DN1nlRPazmt95OxqCq0CyZsxOVnne4v/pKa8u0OUFgRd/pvPfPN3Qywkuk1VgV9Qww4WUAZydjPqSVKlK9vOQtQyfBfKBEWy4QYL8z2GliX9b3MbWNaJYMX/Cg+Irb8nktoF2vZ9dxM6yp2pW7T8+3aVuJE7bcDCYpHswR6J0zIUhDdPsDoIoIHXbsBC83/gi/uNkUFe1E+R5tDYXTEOiB/2vs0KSdl2PNaPzl5xRuhTn58XOvtpYnlRBvERNMfdTCsO2ItiTEMY91Giseo0eaONCsbPe+UjMnbN1S91/TuQ07iOnxEr+tV7WwIHXGGV/XGg6TMktr5St1NCbCLM3XdI1hS9eVrHfUpnLmEEumR+3aEaC2JPGFfdL4xeDpbg3Er0Rq1Z7EivRU0C8jK04mgnHQ6gpas+1IRd0PkTYnsxOvdAEchEqZCgQBNCgX2ZD3OszvGhnO/qv5DNo+BlhUlW2Ahz9M/RirfYWvYKbZTitOZy/TL55iFfScK8TULDC5xuV1yDpiQrxP0su2tDNAOicMFQwsjr8+KAbyb1c1cBx4QsMENcXhDgXlqSVTBf2sDRQiaQ47CWHX1erc/1f9blTTBP5c8HMbTr1VLK42YlUE8T5gRvzdHFwVElDI5yYXGA5LtXwDbq9a7e0xisiZ7vpyn49+NlOKh4UHFzNhOgQJRmzz+Zq+3398PmMQZt7cng151Wi9L3MZClm4ZdUOewywIcwLAszY4q1gozMl8kI/HleaeOKdpxgI11lLQEEpxPs/528Jql4QBNcaQm2yO2vVRR2eEANYA6XYMjbYa9XhkCwzlEGGZVjCtjDrfX49+DqcSwsuWDt5PcgEBx7yNGABp5IiumrrT0BIXjxqEEedKoY15kGO2Ykp3wz6p2JNyWUigYzLfXi69Rw0uOvpjvZPgc+nCd29dG1mgl+rya071RzoK9Pse8Bq3ZpPNyblFuh7KKzq+z3fx++W1O+DhPPUf9IGlwOal6AeSOq1C8lid6Sms6m4Q3D6+nO4QKgGAHWv7Gya1WidpQB5a7aHaDOeG/FN1CZsF4QXmAbz9EHzAgrrV93ZMUgypO7KEVvGeXvDPghMiPOhwpGBlullTxNORYDwiTi+WiG9CgSNh6nWZlW8w8+W6mKQeaximfAL/VN+c7QUCQpONBPsPjYcZ8WuJmJn0YxrPJoS3n0mOuOfbe+Uq9mBfU5WZfvma+1KlYK+gNUdbLmv1HZiUwcwAO2HYW/EQOfU5YBjS97PO4MReqDzI7tY3pz2toxs5qHiy4hs0/PwOe2duWj/fDlsNFAKQnR6uuIAUBLt2S1ipAW6dxvYMzj5LhPXz4nDVnImsbSZw8zcViJlzylxrJZNBJYLeShAHm+VcIISoxED89/lL7kSWGlEHBrpMnpAdr77jmY0mkEHvOYsdw0G/S0tRTS8rACvP+tRRdmIj+QLQCRWY8w==");
 		return KeyPair.builder("kuali-devops").withPublicKey(publicKey).withPrivateKey(privateKey).build().getPrivateKey();
 	}
 
 	private static AWSCredentials getFoundation() {
 		Encryptor enc = getDefaultEncryptor();
 		String accessKey = enc.decrypt("U2FsdGVkX19A2e6dN/ipVfb/9n0DROCPIrLK6H8PvvPmt0h6cBqccGaJW0NSoX3S");
 		String secretKey = enc.decrypt("U2FsdGVkX19Y9SZ5GAU82/X5Z0xZdeQf7DFuVDW07R9lfyHK4VaOj5R7pviRBKmIyn7jrVT2lv8Edeu7098k1A==");
 		return ImmutableAWSCredentials.build(accessKey, secretKey);
 	}
 
 }