Implementation for com.rultor.agents.ec2.Amazon interface - Issue #755

pom.xml

@@ -99,7 +99,7 @@
             <groupId>com.amazonaws</groupId>
             <artifactId>aws-java-sdk-core</artifactId>
             <version>1.9.17</version>
-            <scope>runtime</scope>
+            <scope>compile</scope>
         </dependency>
         <dependency>
             <groupId>com.amazonaws</groupId>

src/main/java/com/rultor/agents/ec2/Amazon.java

@@ -39,12 +39,6 @@
  * @author Yuriy Alevohin ([email protected])
  * @version $Id$
  * @since 2.0
- * @todo #629 Add implementation for com.rultor.agents.ec2.Amazon.
- *  It must create com.amazonaws.services.ec2.AmazonEC2 client
- *  with config params "credentials", "zone", "type", "key". Use
- *  client.runInstances(com.amazonaws.services.ec2.model.RunInstancesRequest)
- *  to run on-demand instance. Method runOnDemand must finally
- *  wait for started instance and check if start was successful.
  */
 @Immutable
 public interface Amazon {

src/main/java/com/rultor/agents/ec2/AmazonEC2.java

@@ -0,0 +1,133 @@
+/**
+ * Copyright (c) 2009-2015, rultor.com
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met: 1) Redistributions of source code must retain the above
+ * copyright notice, this list of conditions and the following
+ * disclaimer. 2) Redistributions in binary form must reproduce the above
+ * copyright notice, this list of conditions and the following
+ * disclaimer in the documentation and/or other materials provided
+ * with the distribution. 3) Neither the name of the rultor.com nor
+ * the names of its contributors may be used to endorse or promote
+ * products derived from this software without specific prior written
+ * permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT
+ * NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND
+ * FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL
+ * THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT,
+ * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+ * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+ * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
+ * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
+ * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
+ * OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+package com.rultor.agents.ec2;
+
+import com.amazonaws.auth.AWSCredentials;
+import com.amazonaws.services.ec2.AmazonEC2Client;
+import com.amazonaws.services.ec2.model.DescribeInstanceStatusRequest;
+import com.amazonaws.services.ec2.model.DescribeInstanceStatusResult;
+import com.amazonaws.services.ec2.model.Instance;
+import com.amazonaws.services.ec2.model.InstanceState;
+import com.amazonaws.services.ec2.model.RunInstancesRequest;
+import com.jcabi.aspects.Tv;
+import java.io.IOException;
+import java.util.List;
+import java.util.concurrent.TimeUnit;
+import javax.validation.constraints.NotNull;
+
+/**
+ * Amazon EC2 instance on demand. Takes all the mandatory data for running
+ * an EC2 instance in a defined region when it's needed.
+ *
+ * @author Marton Horvath ([email protected])
+ * @version $Id$
+ * @since 2.0
+ */
+public class AmazonEC2 implements Amazon {
+    /**
+     * The integer value of the Running {@link InstanceState}.
+     */
+    private static final int RUNNING_STATE = 16;
+    /**
+     * AWS credentials used when authenticating at AWS.
+     */
+    private final transient AWSCredentials credentials;
+    /**
+     * AWS region to be used for the instance to be run.
+     */
+    private final transient String region;
+    /**
+     * EC2 instance type (like <i>t1.micro</i>, <i>m1.small</i> etc.).
+     */
+    private final transient String type;
+    /**
+     * EC2 instance key pair name.
+     */
+    private final transient String keyname;
+
+    /**
+     * Public ctor.
+     * @param cred Credentials for AWS
+     * @param zone AWS region
+     * @param instype Instance type
+     * @param key Instance key pair name
+     * @checkstyle ParameterNumberCheck (12 lines)
+     */
+    public AmazonEC2(
+        @NotNull final AWSCredentials cred,
+        @NotNull final String zone,
+        @NotNull final String instype,
+        @NotNull final String key) {
+        super();
+        this.credentials = cred;
+        this.region = zone;
+        this.type = instype;
+        this.keyname = key;
+    }
+
+    @Override
+    public final Instance runOnDemand() throws IOException {
+        final AmazonEC2Client client = new AmazonEC2Client(
+            this.credentials
+        );
+        client.setEndpoint(this.region);
+        final List<Instance> instances = client.runInstances(
+            new RunInstancesRequest()
+                .withKeyName(this.keyname)
+                .withMinCount(1)
+                .withMaxCount(1)
+                .withInstanceType(this.type)
+        ).getReservation().getInstances();
+        if (instances.isEmpty()) {
+            throw new IllegalStateException(
+                "No Instance was available in the RunInstanceRequest reply!"
+            );
+        }
+        final Instance instance = instances.get(0);
+        InstanceState state = instance.getState();
+        if (state.getCode() < RUNNING_STATE) {
+            final DescribeInstanceStatusRequest req =
+                new DescribeInstanceStatusRequest();
+            req.withInstanceIds(instance.getInstanceId());
+            while (state.getCode() < RUNNING_STATE) {
+                try {
+                    TimeUnit.SECONDS.sleep(Tv.FIFTEEN);
+                } catch (final InterruptedException ex) {
+                    throw new IllegalArgumentException(ex);
+                }
+                final DescribeInstanceStatusResult instanceStatus = client
+                    .describeInstanceStatus(req);
+                state = instanceStatus.getInstanceStatuses().get(0)
+                    .getInstanceState();
+            }
+        }
+        return instance;
+    }
+}