Merge remote branch 'upstream/master'

Conflicts:
	blobstore/src/test/clojure/org/jclouds/blobstore_test.clj

README.txt

@@ -10,7 +10,7 @@ data.
 our current version is 1.0-beta-9b
 our dev version is 1.0-SNAPSHOT
  
-our compute api supports: aws-ec2, gogrid, cloudservers-us, stub (in-memory),
+our compute api supports: aws-ec2, gogrid, cloudservers-us, stub (in-memory), deltacloud,
                           cloudservers-uk, vcloud (generic), ec2 (generic), byon,
                           trmk-ecloud, trmk-vcloudexpress, eucalyptus (generic),
                           cloudsigma-zrh, elasticstack(generic), bluelock-vclouddirector,

allcompute/pom.xml

@@ -34,6 +34,11 @@
             <artifactId>eucalyptus-partnercloud-ec2</artifactId>
             <version>${project.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.jclouds.api</groupId>
+            <artifactId>deltacloud</artifactId>
+            <version>${project.version}</version>
+        </dependency>
         <dependency>
             <groupId>org.jclouds.provider</groupId>
             <artifactId>aws-ec2</artifactId>

apis/deltacloud/pom.xml

@@ -58,7 +58,7 @@
     <dependencies>
         <dependency>
             <groupId>org.jclouds</groupId>
-            <artifactId>jclouds-core</artifactId>
+            <artifactId>jclouds-compute</artifactId>
             <version>${project.version}</version>
         </dependency>
         <dependency>
@@ -68,6 +68,13 @@
             <type>test-jar</type>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.jclouds</groupId>
+            <artifactId>jclouds-compute</artifactId>
+            <version>${project.version}</version>
+            <type>test-jar</type>
+            <scope>test</scope>
+        </dependency>
         <dependency>
             <groupId>org.jclouds.driver</groupId>
             <artifactId>jclouds-jsch</artifactId>

apis/deltacloud/src/main/java/org/jclouds/deltacloud/DeltacloudAsyncClient.java

@@ -84,7 +84,7 @@ public interface DeltacloudAsyncClient {
    @GET
    @ExceptionParser(ReturnEmptySetOnNotFoundOr404.class)
    @XMLResponseParser(DeltacloudCollectionsHandler.class)
-   ListenableFuture<? extends Set<? extends DeltacloudCollection>> getCollections();
+   ListenableFuture<Set<DeltacloudCollection>> getCollections();
 
    /**
     * @see DeltacloudClient#getInstanceStates
@@ -93,7 +93,7 @@ public interface DeltacloudAsyncClient {
    @Endpoint(InstanceStates.class)
    @ExceptionParser(ReturnEmptyMultimapOnNotFoundOr404.class)
    @XMLResponseParser(InstanceStatesHandler.class)
-   ListenableFuture<? extends Multimap<State, ? extends Transition>> getInstanceStates();
+   ListenableFuture<Multimap<State, Transition>> getInstanceStates();
 
    /**
     * @see DeltacloudClient#listRealms
@@ -102,7 +102,7 @@ public interface DeltacloudAsyncClient {
    @Endpoint(Realms.class)
    @ExceptionParser(ReturnEmptySetOnNotFoundOr404.class)
    @XMLResponseParser(RealmsHandler.class)
-   ListenableFuture<? extends Set<? extends Realm>> listRealms();
+   ListenableFuture<Set<Realm>> listRealms();
 
    /**
     * @see DeltacloudClient#getRealm
@@ -119,7 +119,7 @@ public interface DeltacloudAsyncClient {
    @Endpoint(Images.class)
    @ExceptionParser(ReturnEmptySetOnNotFoundOr404.class)
    @XMLResponseParser(ImagesHandler.class)
-   ListenableFuture<? extends Set<? extends Image>> listImages();
+   ListenableFuture<Set<Image>> listImages();
 
    /**
     * @see DeltacloudClient#getImage
@@ -136,7 +136,7 @@ public interface DeltacloudAsyncClient {
    @Endpoint(HardwareProfiles.class)
    @ExceptionParser(ReturnEmptySetOnNotFoundOr404.class)
    @XMLResponseParser(HardwareProfilesHandler.class)
-   ListenableFuture<? extends Set<? extends HardwareProfile>> listHardwareProfiles();
+   ListenableFuture<Set<HardwareProfile>> listHardwareProfiles();
 
    /**
     * @see DeltacloudClient#getHardwareProfile
@@ -153,7 +153,7 @@ public interface DeltacloudAsyncClient {
    @Endpoint(Instances.class)
    @ExceptionParser(ReturnEmptySetOnNotFoundOr404.class)
    @XMLResponseParser(InstancesHandler.class)
-   ListenableFuture<? extends Set<? extends Instance>> listInstances();
+   ListenableFuture<Set<Instance>> listInstances();
 
    /**
     * @see DeltacloudClient#getInstance

apis/deltacloud/src/main/java/org/jclouds/deltacloud/DeltacloudClient.java

@@ -52,20 +52,20 @@ public interface DeltacloudClient {
     * 
     * @return named links to available collections, or empty set, if no collections are found
     */
-   Set<? extends DeltacloudCollection> getCollections();
+   Set<DeltacloudCollection> getCollections();
 
    /**
     * 
     * @return The possible states of an instance, and how to traverse between them
     */
-   Multimap<State, ? extends Transition> getInstanceStates();
+   Multimap<State, Transition> getInstanceStates();
 
    /**
     * The realms collection will return a set of all realms available to the current user.
     * 
     * @return realms viewable to the user or empty set
     */
-   Set<? extends Realm> listRealms();
+   Set<Realm> listRealms();
 
    /**
     * 
@@ -79,7 +79,7 @@ public interface DeltacloudClient {
     * 
     * @return images viewable to the user or empty set
     */
-   Set<? extends Image> listImages();
+   Set<Image> listImages();
 
    /**
     * 
@@ -94,7 +94,7 @@ public interface DeltacloudClient {
     * 
     * @return hardware profiles viewable to the user or empty set
     */
-   Set<? extends HardwareProfile> listHardwareProfiles();
+   Set<HardwareProfile> listHardwareProfiles();
 
    /**
     * 
@@ -108,7 +108,7 @@ public interface DeltacloudClient {
     * 
     * @return instances viewable to the user or empty set
     */
-   Set<? extends Instance> listInstances();
+   Set<Instance> listInstances();
 
    /**
     * 

apis/deltacloud/src/main/java/org/jclouds/deltacloud/DeltacloudContextBuilder.java

@@ -22,8 +22,9 @@ package org.jclouds.deltacloud;
 import java.util.List;
 import java.util.Properties;
 
+import org.jclouds.compute.ComputeServiceContextBuilder;
+import org.jclouds.deltacloud.compute.config.DeltacloudComputeServiceContextModule;
 import org.jclouds.deltacloud.config.DeltacloudRestClientModule;
-import org.jclouds.rest.RestContextBuilder;
 
 import com.google.inject.Module;
 
@@ -31,13 +32,17 @@ import com.google.inject.Module;
  * 
  * @author Adrian Cole
  */
-public class DeltacloudContextBuilder extends
-         RestContextBuilder<DeltacloudClient, DeltacloudAsyncClient> {
+public class DeltacloudContextBuilder extends ComputeServiceContextBuilder<DeltacloudClient, DeltacloudAsyncClient> {
 
    public DeltacloudContextBuilder(Properties props) {
       super(DeltacloudClient.class, DeltacloudAsyncClient.class, props);
    }
 
+   @Override
+   protected void addContextModule(List<Module> modules) {
+      modules.add(new DeltacloudComputeServiceContextModule());
+   }
+
    protected void addClientModule(List<Module> modules) {
       modules.add(new DeltacloudRestClientModule());
    }

apis/deltacloud/src/main/java/org/jclouds/deltacloud/DeltacloudPropertiesBuilder.java

@@ -20,6 +20,7 @@
 package org.jclouds.deltacloud;
 
 import static org.jclouds.Constants.PROPERTY_API_VERSION;
+import static org.jclouds.Constants.PROPERTY_ENDPOINT;
 
 import java.util.Properties;
 
@@ -35,6 +36,7 @@ public class DeltacloudPropertiesBuilder extends PropertiesBuilder {
    protected Properties defaultProperties() {
       Properties properties = super.defaultProperties();
       properties.setProperty(PROPERTY_API_VERSION, "0.3.0");
+      properties.setProperty(PROPERTY_ENDPOINT, "http://localhost:3001/api");
       return properties;
    }
 

apis/deltacloud/src/main/java/org/jclouds/deltacloud/compute/config/DeltacloudComputeServiceContextModule.java

@@ -0,0 +1,71 @@
+/**
+ *
+ * Copyright (C) 2010 Cloud Conscious, LLC. <info@cloudconscious.com>
+ *
+ * ====================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ====================================================================
+ */
+
+package org.jclouds.deltacloud.compute.config;
+
+import org.jclouds.compute.ComputeServiceAdapter;
+import org.jclouds.compute.config.ComputeServiceAdapterContextModule;
+import org.jclouds.compute.domain.NodeMetadata;
+import org.jclouds.deltacloud.DeltacloudAsyncClient;
+import org.jclouds.deltacloud.DeltacloudClient;
+import org.jclouds.deltacloud.compute.functions.DeltacloudImageToImage;
+import org.jclouds.deltacloud.compute.functions.HardwareProfileToHardware;
+import org.jclouds.deltacloud.compute.functions.InstanceToNodeMetadata;
+import org.jclouds.deltacloud.compute.functions.RealmToLocation;
+import org.jclouds.deltacloud.compute.strategy.DeltacloudComputeServiceAdapter;
+import org.jclouds.deltacloud.domain.HardwareProfile;
+import org.jclouds.deltacloud.domain.Instance;
+import org.jclouds.deltacloud.domain.Realm;
+import org.jclouds.domain.Location;
+import org.jclouds.location.suppliers.OnlyLocationOrFirstZone;
+
+import com.google.common.base.Function;
+import com.google.common.base.Supplier;
+import com.google.inject.TypeLiteral;
+
+/**
+ * 
+ * @author Adrian Cole
+ */
+public class DeltacloudComputeServiceContextModule
+         extends
+         ComputeServiceAdapterContextModule<DeltacloudClient, DeltacloudAsyncClient, Instance, HardwareProfile, org.jclouds.deltacloud.domain.Image, Realm> {
+
+   public DeltacloudComputeServiceContextModule() {
+      super(DeltacloudClient.class, DeltacloudAsyncClient.class);
+   }
+
+   @Override
+   protected void configure() {
+      super.configure();
+      bind(
+               new TypeLiteral<ComputeServiceAdapter<Instance, HardwareProfile, org.jclouds.deltacloud.domain.Image, Realm>>() {
+               }).to(DeltacloudComputeServiceAdapter.class);
+      bind(new TypeLiteral<Function<Instance, NodeMetadata>>() {
+      }).to(InstanceToNodeMetadata.class);
+      bind(new TypeLiteral<Function<org.jclouds.deltacloud.domain.Image, org.jclouds.compute.domain.Image>>() {
+      }).to(DeltacloudImageToImage.class);
+      bind(new TypeLiteral<Function<HardwareProfile, org.jclouds.compute.domain.Hardware>>() {
+      }).to(HardwareProfileToHardware.class);
+      bind(new TypeLiteral<Function<Realm, Location>>() {
+      }).to(RealmToLocation.class);
+      bind(new TypeLiteral<Supplier<Location>>() {
+      }).to(OnlyLocationOrFirstZone.class);
+   }
+}

apis/deltacloud/src/main/java/org/jclouds/deltacloud/compute/functions/DeltacloudImageToImage.java

@@ -0,0 +1,53 @@
+/**
+ *
+ * Copyright (C) 2010 Cloud Conscious, LLC. <info@cloudconscious.com>
+ *
+ * ====================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ====================================================================
+ */
+
+package org.jclouds.deltacloud.compute.functions;
+
+import javax.inject.Inject;
+import javax.inject.Singleton;
+
+import org.jclouds.compute.domain.Image;
+import org.jclouds.compute.domain.ImageBuilder;
+
+import com.google.common.base.Function;
+
+/**
+ * @author Adrian Cole
+ */
+@Singleton
+public class DeltacloudImageToImage implements Function<org.jclouds.deltacloud.domain.Image, Image> {
+   private final DeltacloudImageToOperatingSystem imageToOperatingSystem;
+
+   @Inject
+   public DeltacloudImageToImage(DeltacloudImageToOperatingSystem imageToOperatingSystem) {
+      this.imageToOperatingSystem = imageToOperatingSystem;
+   }
+
+   @Override
+   public Image apply(org.jclouds.deltacloud.domain.Image from) {
+      ImageBuilder builder = new ImageBuilder();
+      builder.id(from.getHref().toASCIIString());
+      builder.providerId(from.getId());
+      builder.uri(from.getHref());
+      builder.name(from.getName());
+      builder.description(from.getDescription());
+      builder.operatingSystem(imageToOperatingSystem.apply(from));
+      return builder.build();
+   }
+}

apis/deltacloud/src/main/java/org/jclouds/deltacloud/compute/functions/DeltacloudImageToOperatingSystem.java

@@ -0,0 +1,90 @@
+/**
+ *
+ * Copyright (C) 2010 Cloud Conscious, LLC. <info@cloudconscious.com>
+ *
+ * ====================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ====================================================================
+ */
+
+package org.jclouds.deltacloud.compute.functions;
+
+import java.util.Map;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+import javax.annotation.Resource;
+import javax.inject.Inject;
+import javax.inject.Named;
+import javax.inject.Singleton;
+
+import org.jclouds.compute.domain.OperatingSystem;
+import org.jclouds.compute.domain.OsFamily;
+import org.jclouds.compute.reference.ComputeServiceConstants;
+import org.jclouds.compute.util.ComputeServiceUtils;
+import org.jclouds.logging.Logger;
+
+import com.google.common.base.Function;
+
+/**
+ * @author Adrian Cole
+ */
+@Singleton
+public class DeltacloudImageToOperatingSystem implements Function<org.jclouds.deltacloud.domain.Image, OperatingSystem> {
+   public static final Pattern DEFAULT_PATTERN = Pattern.compile("(([^ ]*) ([0-9.]+) ?.*)");
+   // Windows Server 2008 R2 x64
+   public static final Pattern WINDOWS_PATTERN = Pattern.compile("Windows (.*) (x[86][64])");
+
+   @Resource
+   @Named(ComputeServiceConstants.COMPUTE_LOGGER)
+   protected Logger logger = Logger.NULL;
+
+   private final Map<OsFamily, Map<String, String>> osVersionMap;
+
+   @Inject
+   public DeltacloudImageToOperatingSystem(Map<OsFamily, Map<String, String>> osVersionMap) {
+      this.osVersionMap = osVersionMap;
+   }
+
+   public OperatingSystem apply(org.jclouds.deltacloud.domain.Image from) {
+      OsFamily osFamily = null;
+      String osName = null;
+      String osArch = null;
+      String osVersion = null;
+      String osDescription = from.getName();
+      boolean is64Bit = true;
+      if (from.getName().indexOf("Red Hat EL") != -1) {
+         osFamily = OsFamily.RHEL;
+      } else if (from.getName().indexOf("Oracle EL") != -1) {
+         osFamily = OsFamily.OEL;
+      } else if (from.getName().indexOf("Windows") != -1) {
+         osFamily = OsFamily.WINDOWS;
+         Matcher matcher = WINDOWS_PATTERN.matcher(from.getName());
+         if (matcher.find()) {
+            osVersion = ComputeServiceUtils.parseVersionOrReturnEmptyString(osFamily, matcher.group(1), osVersionMap);
+            is64Bit = matcher.group(2).equals("x64");
+         }
+      } else {
+         Matcher matcher = DEFAULT_PATTERN.matcher(from.getName());
+         if (matcher.find()) {
+            try {
+               osFamily = OsFamily.fromValue(matcher.group(2).toLowerCase());
+            } catch (IllegalArgumentException e) {
+               logger.debug("<< didn't match os(%s)", matcher.group(2));
+            }
+            osVersion = ComputeServiceUtils.parseVersionOrReturnEmptyString(osFamily, matcher.group(3), osVersionMap);
+         }
+      }
+      return new OperatingSystem(osFamily, osName, osVersion, osArch, osDescription, is64Bit);
+   }
+}

apis/deltacloud/src/main/java/org/jclouds/deltacloud/compute/functions/HardwareProfileToHardware.java

@@ -0,0 +1,61 @@
+/**
+ *
+ * Copyright (C) 2010 Cloud Conscious, LLC. <info@cloudconscious.com>
+ *
+ * ====================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ====================================================================
+ */
+
+package org.jclouds.deltacloud.compute.functions;
+
+import javax.inject.Singleton;
+
+import org.jclouds.compute.domain.Hardware;
+import org.jclouds.compute.domain.HardwareBuilder;
+import org.jclouds.compute.domain.Processor;
+import org.jclouds.compute.domain.Volume;
+import org.jclouds.compute.domain.VolumeBuilder;
+import org.jclouds.deltacloud.domain.HardwareProfile;
+import org.jclouds.deltacloud.domain.HardwareProperty;
+
+import com.google.common.base.Function;
+import com.google.common.collect.ImmutableList;
+
+/**
+ * @author Adrian Cole
+ */
+@Singleton
+public class HardwareProfileToHardware implements Function<HardwareProfile, Hardware> {
+
+   @Override
+   public Hardware apply(HardwareProfile from) {
+      HardwareBuilder builder = new HardwareBuilder();
+      builder.ids(from.getId());
+      builder.name(from.getName());
+      builder.uri(from.getHref());
+
+      for (HardwareProperty property : from.getProperties()) {
+         if (property.getName().equals("memory")) {
+            builder.ram(Integer.parseInt(property.getValue().toString()));
+         } else if (property.getName().equals("storage")) {
+            Float gigs = new Float(property.getValue().toString());
+            builder.processors(ImmutableList.of(new Processor(gigs / 10.0, 1.0)));
+            builder.volume(new VolumeBuilder().type(Volume.Type.LOCAL).device("/").size(gigs).bootDevice(true).durable(
+                     true).build());
+         }
+      }
+
+      return builder.build();
+   }
+}

apis/deltacloud/src/main/java/org/jclouds/deltacloud/compute/functions/InstanceToNodeMetadata.java

@@ -0,0 +1,166 @@
+/**
+ *
+ * Copyright (C) 2010 Cloud Conscious, LLC. <info@cloudconscious.com>
+ *
+ * ====================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ====================================================================
+ */
+
+package org.jclouds.deltacloud.compute.functions;
+
+import static com.google.common.base.Preconditions.checkNotNull;
+import static org.jclouds.compute.util.ComputeServiceUtils.parseGroupFromName;
+
+import java.util.Map;
+import java.util.NoSuchElementException;
+import java.util.Set;
+
+import javax.annotation.Resource;
+import javax.inject.Inject;
+import javax.inject.Named;
+import javax.inject.Singleton;
+
+import org.jclouds.collect.Memoized;
+import org.jclouds.compute.domain.Hardware;
+import org.jclouds.compute.domain.Image;
+import org.jclouds.compute.domain.NodeMetadata;
+import org.jclouds.compute.domain.NodeMetadataBuilder;
+import org.jclouds.compute.domain.NodeState;
+import org.jclouds.compute.domain.OperatingSystem;
+import org.jclouds.compute.reference.ComputeServiceConstants;
+import org.jclouds.deltacloud.domain.Instance;
+import org.jclouds.domain.Credentials;
+import org.jclouds.domain.Location;
+import org.jclouds.logging.Logger;
+
+import com.google.common.base.Function;
+import com.google.common.base.Predicate;
+import com.google.common.base.Supplier;
+import com.google.common.collect.ImmutableMap;
+import com.google.common.collect.Iterables;
+
+/**
+ * @author Adrian Cole
+ */
+@Singleton
+public class InstanceToNodeMetadata implements Function<Instance, NodeMetadata> {
+
+   public static final Map<Instance.State, NodeState> instanceToNodeState = ImmutableMap
+            .<Instance.State, NodeState> builder().put(Instance.State.STOPPED, NodeState.SUSPENDED).put(
+                     Instance.State.RUNNING, NodeState.RUNNING).put(Instance.State.PENDING, NodeState.PENDING).put(
+                     Instance.State.UNRECOGNIZED, NodeState.UNRECOGNIZED).put(Instance.State.SHUTTING_DOWN,
+                     NodeState.PENDING).put(Instance.State.START, NodeState.PENDING).build();
+
+   @Resource
+   @Named(ComputeServiceConstants.COMPUTE_LOGGER)
+   protected Logger logger = Logger.NULL;
+
+   protected final Map<String, Credentials> credentialStore;
+   protected final Supplier<Set<? extends Location>> locations;
+   protected final Supplier<Set<? extends Image>> images;
+   protected final Supplier<Set<? extends Hardware>> hardwares;
+
+   private static class FindImageForInstance implements Predicate<Image> {
+      private final Instance instance;
+
+      private FindImageForInstance(Instance instance) {
+         this.instance = instance;
+      }
+
+      @Override
+      public boolean apply(Image input) {
+         return input.getUri().equals(instance.getImage());
+      }
+   }
+
+   private static class FindHardwareForInstance implements Predicate<Hardware> {
+      private final Instance instance;
+
+      private FindHardwareForInstance(Instance instance) {
+         this.instance = instance;
+      }
+
+      @Override
+      public boolean apply(Hardware input) {
+         return input.getUri().equals(instance.getHardwareProfile());
+      }
+   }
+
+   protected Hardware parseHardware(Instance from) {
+      try {
+         return Iterables.find(hardwares.get(), new FindHardwareForInstance(from));
+      } catch (NoSuchElementException e) {
+         logger.warn("could not find a matching hardware for instance %s", from);
+      }
+      return null;
+   }
+
+   protected OperatingSystem parseOperatingSystem(Instance from) {
+      try {
+         return Iterables.find(images.get(), new FindImageForInstance(from)).getOperatingSystem();
+      } catch (NoSuchElementException e) {
+         logger.warn("could not find a matching image for instance %s", from);
+      }
+      return null;
+   }
+
+   private static class FindLocationForInstance implements Predicate<Location> {
+      private final Instance instance;
+
+      private FindLocationForInstance(Instance instance) {
+         this.instance = instance;
+      }
+
+      @Override
+      public boolean apply(Location input) {
+         return input.getId().equals(instance.getRealm().toASCIIString());
+      }
+   }
+
+   protected Location parseLocation(Instance from) {
+      try {
+         return Iterables.find(locations.get(), new FindLocationForInstance(from));
+      } catch (NoSuchElementException e) {
+         logger.warn("could not find a matching realm for instance %s", from);
+      }
+      return null;
+   }
+
+   @Inject
+   InstanceToNodeMetadata(Map<String, Credentials> credentialStore,
+            @Memoized Supplier<Set<? extends Location>> locations, @Memoized Supplier<Set<? extends Image>> images,
+            @Memoized Supplier<Set<? extends Hardware>> hardwares) {
+      this.credentialStore = checkNotNull(credentialStore, "credentialStore");
+      this.images = checkNotNull(images, "images");
+      this.locations = checkNotNull(locations, "locations");
+      this.hardwares = checkNotNull(hardwares, "hardwares");
+   }
+
+   @Override
+   public NodeMetadata apply(org.jclouds.deltacloud.domain.Instance from) {
+      NodeMetadataBuilder builder = new NodeMetadataBuilder();
+      builder.ids(from.getHref().toASCIIString());
+      builder.name(from.getName());
+      builder.location(parseLocation(from));
+      builder.group(parseGroupFromName(from.getName()));
+      builder.imageId(from.getImage().toASCIIString());
+      builder.operatingSystem(parseOperatingSystem(from));
+      builder.hardware(parseHardware(from));
+      builder.state(instanceToNodeState.get(from.getState()));
+      builder.publicAddresses(from.getPublicAddresses());
+      builder.privateAddresses(from.getPrivateAddresses());
+      builder.credentials(credentialStore.get(from.getHref().toASCIIString()));
+      return builder.build();
+   }
+}

apis/deltacloud/src/main/java/org/jclouds/deltacloud/compute/functions/RealmToLocation.java

@@ -0,0 +1,62 @@
+/**
+ *
+ * Copyright (C) 2010 Cloud Conscious, LLC. <info@cloudconscious.com>
+ *
+ * ====================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ====================================================================
+ */
+
+package org.jclouds.deltacloud.compute.functions;
+
+import static com.google.common.base.Preconditions.checkNotNull;
+
+import java.net.URI;
+import java.util.Set;
+
+import javax.inject.Inject;
+import javax.inject.Singleton;
+
+import org.jclouds.deltacloud.domain.Realm;
+import org.jclouds.domain.Location;
+import org.jclouds.domain.LocationBuilder;
+import org.jclouds.domain.LocationScope;
+import org.jclouds.location.Iso3166;
+import org.jclouds.location.Provider;
+
+import com.google.common.base.Function;
+
+/**
+ * @author Adrian Cole
+ */
+@Singleton
+public class RealmToLocation implements Function<Realm, Location> {
+
+   private final String providerName;
+   private final URI endpoint;
+   private final Set<String> isoCodes;
+
+   @Inject
+   public RealmToLocation(@Iso3166 Set<String> isoCodes, @Provider String providerName, @Provider URI endpoint) {
+      this.providerName = checkNotNull(providerName, "providerName");
+      this.endpoint = checkNotNull(endpoint, "endpoint");
+      this.isoCodes = checkNotNull(isoCodes, "isoCodes");
+   }
+
+   @Override
+   public Location apply(Realm from) {
+      return new LocationBuilder().scope(LocationScope.ZONE).id(from.getHref().toASCIIString()).description(from.getName()).parent(
+               new LocationBuilder().scope(LocationScope.PROVIDER).iso3166Codes(isoCodes).id(providerName).description(
+                        endpoint.toASCIIString()).parent(null).build()).build();
+   }
+}

apis/deltacloud/src/main/java/org/jclouds/deltacloud/compute/strategy/DeltacloudComputeServiceAdapter.java

@@ -0,0 +1,175 @@
+/**
+ *
+ * Copyright (C) 2011 Cloud Conscious, LLC. <info@cloudconscious.com>
+ *
+ * ====================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ====================================================================
+ */
+
+package org.jclouds.deltacloud.compute.strategy;
+
+import static com.google.common.base.Preconditions.checkNotNull;
+
+import java.net.URI;
+import java.util.Map;
+import java.util.concurrent.TimeUnit;
+
+import javax.annotation.Resource;
+import javax.inject.Inject;
+import javax.inject.Named;
+import javax.inject.Singleton;
+
+import org.jclouds.compute.ComputeService;
+import org.jclouds.compute.ComputeServiceAdapter;
+import org.jclouds.compute.domain.Template;
+import org.jclouds.compute.reference.ComputeServiceConstants;
+import org.jclouds.deltacloud.DeltacloudClient;
+import org.jclouds.deltacloud.domain.HardwareProfile;
+import org.jclouds.deltacloud.domain.Instance;
+import org.jclouds.deltacloud.domain.PasswordAuthentication;
+import org.jclouds.deltacloud.domain.Realm;
+import org.jclouds.deltacloud.domain.Transition;
+import org.jclouds.deltacloud.domain.TransitionOnAction;
+import org.jclouds.deltacloud.domain.Instance.State;
+import org.jclouds.deltacloud.options.CreateInstanceOptions;
+import org.jclouds.deltacloud.predicates.InstanceFinished;
+import org.jclouds.deltacloud.predicates.InstanceRunning;
+import org.jclouds.domain.Credentials;
+import org.jclouds.http.HttpRequest;
+import org.jclouds.logging.Logger;
+import org.jclouds.predicates.RetryablePredicate;
+
+import com.google.common.base.Predicate;
+import com.google.common.collect.ImmutableMap;
+import com.google.common.collect.ImmutableSet;
+import com.google.common.collect.Iterables;
+import com.google.common.collect.Multimap;
+
+/**
+ * defines the connection between the {@link DeltacloudClient} implementation and the jclouds
+ * {@link ComputeService}
+ * 
+ */
+@Singleton
+public class DeltacloudComputeServiceAdapter implements
+         ComputeServiceAdapter<Instance, HardwareProfile, org.jclouds.deltacloud.domain.Image, Realm> {
+   @Resource
+   @Named(ComputeServiceConstants.COMPUTE_LOGGER)
+   protected Logger logger = Logger.NULL;
+
+   private final org.jclouds.deltacloud.DeltacloudClient client;
+   private final ImmutableMap<State, Predicate<Instance>> stateChanges;
+
+   @Inject
+   public DeltacloudComputeServiceAdapter(DeltacloudClient client) {
+      this.client = checkNotNull(client, "client");
+      // TODO: parameterize
+      stateChanges = ImmutableMap.<Instance.State, Predicate<Instance>> of(//
+               Instance.State.RUNNING, new RetryablePredicate<Instance>(new InstanceRunning(client), 600, 1,
+                        TimeUnit.SECONDS),//
+               Instance.State.FINISH, new RetryablePredicate<Instance>(new InstanceFinished(client), 30, 1,
+                        TimeUnit.SECONDS)//
+               );
+   }
+
+   @Override
+   public Instance createNodeWithGroupEncodedIntoNameThenStoreCredentials(String tag, String name, Template template,
+            Map<String, Credentials> credentialStore) {
+      Instance instance = client.createInstance(template.getImage().getProviderId(), CreateInstanceOptions.Builder
+               .named(name).hardwareProfile(template.getHardware().getId()).realm(template.getLocation().getId()));
+      if (instance.getAuthentication() != null && instance.getAuthentication() instanceof PasswordAuthentication) {
+         Credentials creds = PasswordAuthentication.class.cast(instance.getAuthentication()).getLoginCredentials();
+         // store the credentials so that later functions can use them
+         credentialStore.put(instance.getHref().toASCIIString(), creds);
+      }
+      return instance;
+   }
+
+   @Override
+   public Iterable<HardwareProfile> listHardwareProfiles() {
+      return client.listHardwareProfiles();
+   }
+
+   @Override
+   public Iterable<org.jclouds.deltacloud.domain.Image> listImages() {
+      return client.listImages();
+   }
+
+   @Override
+   public Iterable<Instance> listNodes() {
+      return client.listInstances();
+   }
+
+   @Override
+   public Iterable<Realm> listLocations() {
+      return client.listRealms();
+   }
+
+   @Override
+   public org.jclouds.deltacloud.domain.Instance getNode(String id) {
+      return client.getInstance(URI.create(checkNotNull(id, "id")));
+   }
+
+   @Override
+   public void destroyNode(String id) {
+      Instance instance = getNode(id);
+      for (Transition transition : findChainTo(Instance.State.FINISH, instance.getState(), client.getInstanceStates())) {
+         instance = getNode(id);
+         if (instance == null)
+            break;
+         if (transition instanceof TransitionOnAction) {
+            client.performAction(instance.getActions().get(TransitionOnAction.class.cast(transition).getAction()));
+         }
+         Predicate<Instance> stateTester = stateChanges.get(transition.getTo());
+         if (stateTester != null)
+            stateTester.apply(instance);
+         else
+            logger.debug(String.format("no state tester for: %s", transition));
+      }
+   }
+
+   Iterable<Transition> findChainTo(Instance.State desired, Instance.State currentState,
+            Multimap<Instance.State, ? extends Transition> states) {
+      for (Transition transition : states.get(currentState)) {
+         if (currentState.ordinal() >= transition.getTo().ordinal())
+            continue;
+         if (transition.getTo() == desired)
+            return ImmutableSet.<Transition> of(transition);
+         Iterable<Transition> transitions = findChainTo(desired, transition.getTo(), states);
+         if (Iterables.size(transitions) > 0)
+            return Iterables.concat(ImmutableSet.of(transition), transitions);
+      }
+      return ImmutableSet.<Transition> of();
+   }
+
+   @Override
+   public void rebootNode(String id) {
+      HttpRequest rebootUri = getNode(id).getActions().get(Instance.Action.REBOOT);
+      if (rebootUri != null) {
+         client.performAction(rebootUri);
+      } else {
+         throw new UnsupportedOperationException();
+      }
+   }
+
+   @Override
+   public void resumeNode(String id) {
+      throw new UnsupportedOperationException();
+   }
+
+   @Override
+   public void suspendNode(String id) {
+      throw new UnsupportedOperationException();
+   }
+}

apis/deltacloud/src/main/java/org/jclouds/deltacloud/domain/TransitionOnAction.java

@@ -44,7 +44,7 @@ public class TransitionOnAction implements Transition {
 
    @Override
    public String toString() {
-      return "TransitionOnAction [action=" + action + ", to=" + to + "]";
+      return "[action=" + action + ", to=" + to + "]";
    }
 
    @Override

apis/deltacloud/src/main/java/org/jclouds/deltacloud/options/CreateInstanceOptions.java

@@ -32,6 +32,23 @@ public class CreateInstanceOptions extends BaseHttpRequestOptions {
       return this;
    }
 
+   /**
+    * The realm in which to launch the instance
+    * 
+    */
+   public CreateInstanceOptions realm(String realmId) {
+      formParameters.put("realm_id", checkNotNull(realmId, "realmId"));
+      return this;
+   }
+
+   /**
+    * The hardware profile upon which to launch the instance
+    */
+   public CreateInstanceOptions hardwareProfile(String hwpName) {
+      formParameters.put("hwp_name", checkNotNull(hwpName, "hwpName"));
+      return this;
+   }
+
    public String getName() {
       return this.getFirstFormOrNull("name");
    }
@@ -46,5 +63,21 @@ public class CreateInstanceOptions extends BaseHttpRequestOptions {
          return options.named(name);
       }
 
+      /**
+       * @see CreateInstanceOptions#realm
+       */
+      public static CreateInstanceOptions realm(String realmId) {
+         CreateInstanceOptions options = new CreateInstanceOptions();
+         return options.realm(realmId);
+      }
+
+      /**
+       * @see CreateInstanceOptions#hardwareProfile
+       */
+      public static CreateInstanceOptions hardwareProfile(String hwpName) {
+         CreateInstanceOptions options = new CreateInstanceOptions();
+         return options.hardwareProfile(hwpName);
+      }
+
    }
 }

apis/deltacloud/src/main/java/org/jclouds/deltacloud/predicates/InstanceFinished.java

@@ -0,0 +1,48 @@
+/**
+ *
+ * Copyright (C) 2010 Cloud Conscious, LLC. <info@cloudconscious.com>
+ *
+ * ====================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ====================================================================
+ */
+
+package org.jclouds.deltacloud.predicates;
+
+import javax.inject.Singleton;
+
+import org.jclouds.deltacloud.DeltacloudClient;
+import org.jclouds.deltacloud.domain.Instance;
+
+import com.google.inject.Inject;
+
+/**
+ * 
+ * Tests to see if a instance is terminated
+ * 
+ * @author Adrian Cole
+ */
+@Singleton
+public class InstanceFinished extends InstanceState {
+
+   @Inject
+   public InstanceFinished(DeltacloudClient client) {
+      super(client);
+   }
+
+   @Override
+   protected Instance.State getState() {
+      return Instance.State.FINISH;
+   }
+
+}

apis/deltacloud/src/main/java/org/jclouds/deltacloud/predicates/InstanceRunning.java

@@ -0,0 +1,48 @@
+/**
+ *
+ * Copyright (C) 2010 Cloud Conscious, LLC. <info@cloudconscious.com>
+ *
+ * ====================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ====================================================================
+ */
+
+package org.jclouds.deltacloud.predicates;
+
+import javax.inject.Singleton;
+
+import org.jclouds.deltacloud.DeltacloudClient;
+import org.jclouds.deltacloud.domain.Instance;
+
+import com.google.inject.Inject;
+
+/**
+ * 
+ * Tests to see if a instance is running
+ * 
+ * @author Adrian Cole
+ */
+@Singleton
+public class InstanceRunning extends InstanceState {
+
+   @Inject
+   public InstanceRunning(DeltacloudClient client) {
+      super(client);
+   }
+
+   @Override
+   protected Instance.State getState() {
+      return Instance.State.RUNNING;
+   }
+
+}

apis/deltacloud/src/main/java/org/jclouds/deltacloud/predicates/InstanceState.java

@@ -0,0 +1,68 @@
+/**
+ *
+ * Copyright (C) 2010 Cloud Conscious, LLC. <info@cloudconscious.com>
+ *
+ * ====================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ====================================================================
+ */
+
+package org.jclouds.deltacloud.predicates;
+
+import static com.google.common.base.Preconditions.checkNotNull;
+
+import javax.annotation.Resource;
+import javax.inject.Singleton;
+
+import org.jclouds.deltacloud.DeltacloudClient;
+import org.jclouds.deltacloud.domain.Instance;
+import org.jclouds.logging.Logger;
+
+import com.google.common.base.Predicate;
+import com.google.inject.Inject;
+
+/**
+ * 
+ * Tests to see if a instance is at a specific state
+ * 
+ * @author Adrian Cole
+ */
+@Singleton
+public abstract class InstanceState implements Predicate<Instance> {
+
+   private final DeltacloudClient client;
+
+   @Resource
+   protected Logger logger = Logger.NULL;
+
+   @Inject
+   public InstanceState(DeltacloudClient client) {
+      this.client = client;
+   }
+
+   public boolean apply(Instance instance) {
+      logger.trace("looking for state on instance %s", checkNotNull(instance, "instance"));
+      instance = refresh(instance);
+      if (instance == null || instance.getState() == Instance.State.FINISH)
+         return false;
+      logger.trace("%s: looking for instance state %s: currently: %s", instance.getId(), getState(), instance
+               .getState());
+      return instance.getState() == getState();
+   }
+
+   protected abstract Instance.State getState();
+
+   private Instance refresh(Instance instance) {
+      return client.getInstance(instance.getHref());
+   }
+}

apis/deltacloud/src/test/java/org/jclouds/deltacloud/DeltacloudClientLiveTest.java

@@ -27,13 +27,15 @@ import java.util.logging.Logger;
 import org.jclouds.compute.domain.ExecResponse;
 import org.jclouds.deltacloud.domain.Image;
 import org.jclouds.deltacloud.domain.Instance;
+import org.jclouds.deltacloud.domain.PasswordAuthentication;
+import org.jclouds.deltacloud.domain.Transition;
+import org.jclouds.deltacloud.domain.TransitionOnAction;
 import org.jclouds.deltacloud.options.CreateInstanceOptions;
 import org.jclouds.domain.Credentials;
 import org.jclouds.http.HttpRequest;
 import org.jclouds.net.IPSocket;
 import org.jclouds.ssh.SshClient;
 import org.jclouds.ssh.jsch.config.JschSshClientModule;
-import org.testng.annotations.AfterGroups;
 import org.testng.annotations.Test;
 
 import com.google.common.base.Predicate;
@@ -51,6 +53,7 @@ public class DeltacloudClientLiveTest extends ReadOnlyDeltacloudClientLiveTest {
 
    protected String prefix = System.getProperty("user.name") + ".test";
    protected Instance instance;
+   protected Credentials creds;
 
    public void testCreateInstance() throws Exception {
       Logger.getAnonymousLogger().info("starting instance");
@@ -61,13 +64,14 @@ public class DeltacloudClientLiveTest extends ReadOnlyDeltacloudClientLiveTest {
             return input.getDescription().toLowerCase().indexOf("fedora") != -1;
          }
 
-      }).getId(), CreateInstanceOptions.Builder.named(prefix));
-      instance = client.getInstance(instance.getHref());
+      }).getId(), CreateInstanceOptions.Builder.named(prefix).hardwareProfile("1").realm("us"));
+      if (instance.getAuthentication() != null && instance.getAuthentication() instanceof PasswordAuthentication)
+         creds = PasswordAuthentication.class.cast(instance.getAuthentication()).getLoginCredentials();
+      refreshInstance();
       checkStartedInstance();
 
       Instance newInfo = client.getInstance(instance.getHref());
       checkInstanceMatchesGet(newInfo);
-
    }
 
    protected void checkInstanceMatchesGet(Instance newInfo) {
@@ -77,49 +81,57 @@ public class DeltacloudClientLiveTest extends ReadOnlyDeltacloudClientLiveTest {
    protected void checkStartedInstance() {
       System.out.println(new Gson().toJson(instance));
       assertEquals(instance.getName(), prefix);
+      assert stateChanges.get(Instance.State.RUNNING).apply(instance) : instance;
+      refreshInstance();
       assertEquals(instance.getState(), Instance.State.RUNNING);
    }
 
+   private Instance refreshInstance() {
+      if (instance != null)
+         return instance = client.getInstance(instance.getHref());
+      return null;
+   }
+
    @Test(dependsOnMethods = "testCreateInstance")
    public void testConnectivity() throws Exception {
       Logger.getAnonymousLogger().info("awaiting ssh");
-      // TODO
-      // assert socketTester.apply(new IPSocket(Iterables.get(instance.getPublicAddresses(), 0),
-      // 22)) : instance;
-      // doConnectViaSsh(instance, getSshCredentials(instance));
+      assert socketTester.apply(new IPSocket(Iterables.get(instance.getPublicAddresses(), 0), 22)) : instance;
+      if (creds != null) {
+         Logger.getAnonymousLogger().info("will connect ssh");
+         doConnectViaSsh(instance, creds);
+      }
    }
 
-   private Credentials getSshCredentials(Instance instance2) {
-      // TODO
-      return null;
-   }
-
-   public HttpRequest refreshInstanceAndGetAction(Instance.Action action) {
-      return client.getInstance(instance.getHref()).getActions().get(action);
+   public HttpRequest getAction(Instance.Action action) {
+      return instance.getActions().get(action);
    }
 
    @Test(dependsOnMethods = "testConnectivity")
    public void testLifeCycle() {
-      client.performAction(refreshInstanceAndGetAction(Instance.Action.STOP));
-      assertEquals(client.getInstance(instance.getHref()).getState(), Instance.State.STOPPED);
-
-      client.performAction(refreshInstanceAndGetAction(Instance.Action.START));
-      assertEquals(client.getInstance(instance.getHref()).getState(), Instance.State.RUNNING);
-
-      client.performAction(refreshInstanceAndGetAction(Instance.Action.REBOOT));
-      assertEquals(client.getInstance(instance.getHref()).getState(), Instance.State.RUNNING);
 
+      HttpRequest rebootUri = getAction(Instance.Action.REBOOT);
+      if (rebootUri != null) {
+         client.performAction(rebootUri);
+         assert stateChanges.get(Instance.State.RUNNING).apply(instance) : instance;
+      }
    }
 
    @Test(dependsOnMethods = "testLifeCycle")
    public void testDestroyInstance() {
-      try {
-         client.performAction(refreshInstanceAndGetAction(Instance.Action.STOP));
-         assertEquals(client.getInstance(instance.getHref()).getState(), Instance.State.STOPPED);
-      } catch (IllegalArgumentException e) {
+      for (Transition transition : findChainTo(Instance.State.FINISH, refreshInstance().getState(), client
+               .getInstanceStates())) {
+         if (refreshInstance() == null)
+            break;
+         if (transition instanceof TransitionOnAction) {
+            client.performAction(getAction(TransitionOnAction.class.cast(transition).getAction()));
          }
-      client.performAction(refreshInstanceAndGetAction(Instance.Action.DESTROY));
-      assertEquals(client.getInstance(instance.getHref()), null);
+         Predicate<Instance> stateTester = stateChanges.get(transition.getTo());
+         if (stateTester != null)
+            assert stateTester.apply(instance) : transition + " : " + instance;
+         else
+            Logger.getAnonymousLogger().warning(String.format("no state tester for: %s", transition));
+      }
+      assert refreshInstance() == null;
    }
 
    protected void doConnectViaSsh(Instance instance, Credentials creds) throws IOException {
@@ -138,14 +150,9 @@ public class DeltacloudClientLiveTest extends ReadOnlyDeltacloudClientLiveTest {
       }
    }
 
-   @AfterGroups(groups = "live")
    @Override
    protected void tearDown() {
-      try {
       testDestroyInstance();
-      } catch (NullPointerException e) {
-         // no need to check null or anything as we swallow all
-      }
       super.tearDown();
    }
 

apis/deltacloud/src/test/java/org/jclouds/deltacloud/ReadOnlyDeltacloudClientLiveTest.java

@@ -28,24 +28,28 @@ import java.util.Set;
 import java.util.concurrent.TimeUnit;
 
 import org.jclouds.Constants;
+import org.jclouds.compute.ComputeServiceContextFactory;
 import org.jclouds.deltacloud.domain.DeltacloudCollection;
 import org.jclouds.deltacloud.domain.HardwareProfile;
 import org.jclouds.deltacloud.domain.Image;
 import org.jclouds.deltacloud.domain.Instance;
 import org.jclouds.deltacloud.domain.Realm;
 import org.jclouds.deltacloud.domain.Transition;
+import org.jclouds.deltacloud.domain.Instance.State;
+import org.jclouds.deltacloud.predicates.InstanceFinished;
+import org.jclouds.deltacloud.predicates.InstanceRunning;
 import org.jclouds.logging.log4j.config.Log4JLoggingModule;
 import org.jclouds.net.IPSocket;
 import org.jclouds.predicates.InetSocketAddressConnect;
 import org.jclouds.predicates.RetryablePredicate;
 import org.jclouds.rest.RestContext;
-import org.jclouds.rest.RestContextFactory;
 import org.testng.annotations.AfterGroups;
 import org.testng.annotations.BeforeGroups;
 import org.testng.annotations.Test;
 
 import com.google.common.base.Predicate;
 import com.google.common.collect.ImmutableList;
+import com.google.common.collect.ImmutableMap;
 import com.google.common.collect.ImmutableSet;
 import com.google.common.collect.Iterables;
 import com.google.common.collect.Multimap;
@@ -68,6 +72,7 @@ public class ReadOnlyDeltacloudClientLiveTest {
    protected String endpoint;
    protected String apiversion;
    protected Predicate<IPSocket> socketTester;
+   protected ImmutableMap<State, Predicate<Instance>> stateChanges;
 
    protected void setupCredentials() {
       identity = System.getProperty("test." + provider + ".identity", "mockuser");
@@ -94,11 +99,17 @@ public class ReadOnlyDeltacloudClientLiveTest {
    public void setupClient() {
       setupCredentials();
       Properties overrides = setupProperties();
-      context = new RestContextFactory().createContext(provider, ImmutableSet.<Module> of(new Log4JLoggingModule()),
-               overrides);
+      context = new ComputeServiceContextFactory().createContext(provider, ImmutableSet.<Module> of(new Log4JLoggingModule()),
+               overrides).getProviderSpecificContext();
 
       client = context.getApi();
       socketTester = new RetryablePredicate<IPSocket>(new InetSocketAddressConnect(), 180, 1, TimeUnit.SECONDS);
+      stateChanges = ImmutableMap.<Instance.State, Predicate<Instance>> of(//
+               Instance.State.RUNNING, new RetryablePredicate<Instance>(new InstanceRunning(client), 600, 1,
+                        TimeUnit.SECONDS),//
+               Instance.State.FINISH, new RetryablePredicate<Instance>(new InstanceFinished(client), 30, 1,
+                        TimeUnit.SECONDS)//
+               );
    }
 
    @Test

apis/deltacloud/src/test/java/org/jclouds/deltacloud/compute/DeltacloudComputeServiceLiveTest.java

@@ -0,0 +1,88 @@
+/**
+ *
+ * Copyright (C) 2010 Cloud Conscious, LLC. <info@cloudconscious.com>
+ *
+ * ====================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ====================================================================
+ */
+
+package org.jclouds.deltacloud.compute;
+
+import static org.testng.Assert.assertEquals;
+
+import java.io.IOException;
+
+import org.jclouds.compute.BaseComputeServiceLiveTest;
+import org.jclouds.compute.ComputeServiceContextFactory;
+import org.jclouds.compute.domain.NodeMetadata;
+import org.jclouds.deltacloud.DeltacloudAsyncClient;
+import org.jclouds.deltacloud.DeltacloudClient;
+import org.jclouds.domain.LocationScope;
+import org.jclouds.rest.RestContext;
+import org.jclouds.ssh.jsch.config.JschSshClientModule;
+import org.testng.annotations.Test;
+
+/**
+ * 
+ * 
+ * @author Adrian Cole
+ */
+@Test(groups = "live", enabled = true, sequential = true)
+public class DeltacloudComputeServiceLiveTest extends BaseComputeServiceLiveTest {
+   public DeltacloudComputeServiceLiveTest() {
+      provider = "deltacloud";
+   }
+
+   @Override
+   protected JschSshClientModule getSshModule() {
+      return new JschSshClientModule();
+   }
+
+   public void testAssignability() throws Exception {
+      @SuppressWarnings("unused")
+      RestContext<DeltacloudClient, DeltacloudAsyncClient> tmContext = new ComputeServiceContextFactory()
+               .createContext(provider, identity, credential).getProviderSpecificContext();
+   }
+
+   @Override
+   protected void checkNodes(Iterable<? extends NodeMetadata> nodes, String tag) throws IOException {
+      super.checkNodes(nodes, tag);
+      for (NodeMetadata node : nodes) {
+         assertEquals(node.getLocation().getScope(), LocationScope.ZONE);
+      }
+   }
+
+   @Test(enabled = true, dependsOnMethods = "testReboot", expectedExceptions = UnsupportedOperationException.class)
+   public void testSuspendResume() throws Exception {
+      super.testSuspendResume();
+   }
+
+   @Test(enabled = true, dependsOnMethods = "testSuspendResume")
+   @Override
+   public void testGetNodesWithDetails() throws Exception {
+      super.testGetNodesWithDetails();
+   }
+
+   @Test(enabled = true, dependsOnMethods = "testSuspendResume")
+   @Override
+   public void testListNodes() throws Exception {
+      super.testListNodes();
+   }
+
+   @Test(enabled = true, dependsOnMethods = { "testListNodes", "testGetNodesWithDetails" })
+   @Override
+   public void testDestroyNodes() {
+      super.testDestroyNodes();
+   }
+}

apis/deltacloud/src/test/java/org/jclouds/deltacloud/compute/DeltacloudTemplateBuilderLiveTest.java

@@ -0,0 +1,83 @@
+/**
+ *
+ * Copyright (C) 2010 Cloud Conscious, LLC. <info@cloudconscious.com>
+ *
+ * ====================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ====================================================================
+ */
+
+package org.jclouds.deltacloud.compute;
+
+import static org.jclouds.compute.util.ComputeServiceUtils.getCores;
+import static org.testng.Assert.assertEquals;
+
+import java.util.Set;
+
+import org.jclouds.compute.BaseTemplateBuilderLiveTest;
+import org.jclouds.compute.domain.OsFamily;
+import org.jclouds.compute.domain.OsFamilyVersion64Bit;
+import org.jclouds.compute.domain.Template;
+import org.testng.annotations.Test;
+
+import com.google.common.base.Predicate;
+import com.google.common.collect.ImmutableSet;
+
+/**
+ * 
+ * @author Adrian Cole
+ */
+@Test(groups = "live")
+public class DeltacloudTemplateBuilderLiveTest extends BaseTemplateBuilderLiveTest {
+
+   public DeltacloudTemplateBuilderLiveTest() {
+      provider = "deltacloud";
+   }
+
+   @Override
+   protected Predicate<OsFamilyVersion64Bit> defineUnsupportedOperatingSystems() {
+      return new Predicate<OsFamilyVersion64Bit>() {
+
+         @Override
+         public boolean apply(OsFamilyVersion64Bit input) {
+            switch (input.family) {
+               case UBUNTU:
+                  return input.version.equals("11.04") || input.version.equals("8.04") || !input.is64Bit;
+               case CENTOS:
+                  return input.version.matches("5.[023]") || !input.is64Bit;
+               case WINDOWS:
+                  return input.version.equals("2008") || input.version.indexOf("2003") != -1
+                           || (input.version.equals("2008 R2") && !input.is64Bit);
+               default:
+                  return true;
+            }
+         }
+
+      };
+   }
+
+   @Test
+   public void testTemplateBuilder() {
+      Template defaultTemplate = this.context.getComputeService().templateBuilder().build();
+      assertEquals(defaultTemplate.getImage().getOperatingSystem().is64Bit(), true);
+      assertEquals(defaultTemplate.getImage().getOperatingSystem().getVersion(), "10.04");
+      assertEquals(defaultTemplate.getImage().getOperatingSystem().getFamily(), OsFamily.UBUNTU);
+      assertEquals(defaultTemplate.getLocation().getId(), "http://localhost:3001/api/realms/us");
+      assertEquals(getCores(defaultTemplate.getHardware()), 1.0d);
+   }
+
+   @Override
+   protected Set<String> getIso3166Codes() {
+      return ImmutableSet.<String> of();
+   }
+}

apis/ec2/src/main/java/org/jclouds/ec2/predicates/InstanceStateStopped.java

@@ -52,7 +52,6 @@ public class InstanceStateStopped implements Predicate<RunningInstance> {
 
    public boolean apply(RunningInstance instance) {
       logger.trace("looking for state on instance %s", instance);
-
       instance = refresh(instance);
       logger.trace("%s: looking for instance state %s: currently: %s", instance.getId(),
                InstanceState.STOPPED, instance.getInstanceState());

apis/pom.xml

@@ -37,6 +37,7 @@
        <module>byon</module>
        <module>s3</module>
        <module>ec2</module>
+       <module>deltacloud</module>
        <module>walrus</module>
        <module>scality-rs2</module>
        <module>eucalyptus</module>

blobstore/src/test/clojure/org/jclouds/blobstore_test.clj

@@ -82,6 +82,15 @@
   (is (empty? (list-blobs "container")))
   (is (empty? (list-blobs "container" "/a" *blobstore*))))
 
+(deftest large-container-list-test
+  (let [container-name "test"
+        total-blobs 10000]
+    ;; create a container full of blobs
+    (create-container container-name)
+    (dotimes [i total-blobs] (upload-blob container-name (str i) (str i)))
+    ;; verify
+    (is (= total-blobs (count-blobs  container-name)))))
+
 (deftest get-blob-test
   (is (create-container "blob"))
   (is (upload-blob "blob" "blob1" "blob1"))

compute/src/main/clojure/org/jclouds/compute.clj

@@ -25,7 +25,7 @@ Current supported providers are:
     cloudservers-uk, cloudservers-us, byon, cloudsigma-zrh, stub,
     trmk-ecloud, trmk-vcloudexpress, vcloud, bluelock, eucalyptus,
     slicehost, elastichosts-lon-p, elastichosts-sat-p, elastichosts,
-    openhosting-east1, serverlove-z1-man, skalicloud-sdg-my]
+    openhosting-east1, serverlove-z1-man, skalicloud-sdg-my, deltacloud]
 
 Here's an example of getting some compute configuration from rackspace:
 

compute/src/test/java/org/jclouds/compute/BaseComputeServiceLiveTest.java

@@ -35,8 +35,8 @@ import static org.jclouds.compute.options.TemplateOptions.Builder.blockOnComplet
 import static org.jclouds.compute.options.TemplateOptions.Builder.overrideCredentialsWith;
 import static org.jclouds.compute.predicates.NodePredicates.TERMINATED;
 import static org.jclouds.compute.predicates.NodePredicates.all;
-import static org.jclouds.compute.predicates.NodePredicates.runningInGroup;
 import static org.jclouds.compute.predicates.NodePredicates.inGroup;
+import static org.jclouds.compute.predicates.NodePredicates.runningInGroup;
 import static org.jclouds.compute.util.ComputeServiceUtils.getCores;
 import static org.testng.Assert.assertEquals;
 import static org.testng.Assert.assertNotNull;
@@ -64,7 +64,6 @@ import org.jclouds.compute.domain.Image;
 import org.jclouds.compute.domain.NodeMetadata;
 import org.jclouds.compute.domain.NodeState;
 import org.jclouds.compute.domain.OperatingSystem;
-import org.jclouds.compute.domain.OperatingSystemBuilder;
 import org.jclouds.compute.domain.OsFamily;
 import org.jclouds.compute.domain.Template;
 import org.jclouds.compute.domain.TemplateBuilder;
@@ -207,7 +206,7 @@ public abstract class BaseComputeServiceLiveTest {
 
    @Test(enabled = true, expectedExceptions = NoSuchElementException.class)
    public void testCorrectExceptionRunningNodesNotFound() throws Exception {
-      client.runScriptOnNodesMatching(runningInGroup("zebras-are-awesome"), buildScript(new OperatingSystemBuilder()
+      client.runScriptOnNodesMatching(runningInGroup("zebras-are-awesome"), buildScript(new OperatingSystem.Builder()
                .family(OsFamily.UBUNTU).description("ffoo").build()));
    }
 

compute/src/test/java/org/jclouds/compute/RunScriptData.java

@@ -76,9 +76,9 @@ public class RunScriptData {
                envVariables,
                ImmutableList.<Statement> of(new AuthorizeRSAPublicKey(publicKey),//
                         installJavaAndCurl(os),//
-                        authorizePortInIpTables(8080),//
+                        authorizePortInIpTables(8080),
                         extractTargzIntoDirectory(URI.create(System.getProperty("test.jboss-url",
-                                 "http://d19xvfg065k8li.cloudfront.net/jboss-6.0.0.Final.tar.gz")), "/usr/local"),//
+                                 "http://d37gkgjhl3prlk.cloudfront.net/jboss-6.0.0.Final.tar.gz")), "/usr/local"),//
                         exec("{md} " + jbossHome), exec("mv /usr/local/jboss-*/* " + jbossHome),//
                         exec("chmod -R oug+r+w " + jbossHome)),//
                ImmutableList

compute/src/test/resources/initscript_with_jboss.sh

@@ -72,7 +72,7 @@ END_OF_FILE
    iptables -I INPUT 1 -p tcp --dport 8080 -j ACCEPT
    iptables -I RH-Firewall-1-INPUT 1 -p tcp --dport 8080 -j ACCEPT
    iptables-save
-   curl -X GET -s --retry 20  http://d19xvfg065k8li.cloudfront.net/jboss-6.0.0.Final.tar.gz |(mkdir -p /usr/local &&cd /usr/local &&tar -xpzf -)
+   curl -X GET -s --retry 20  http://d37gkgjhl3prlk.cloudfront.net/jboss-6.0.0.Final.tar.gz |(mkdir -p /usr/local &&cd /usr/local &&tar -xpzf -)
    mkdir -p /usr/local/jboss
    mv /usr/local/jboss-*/* /usr/local/jboss
    chmod -R oug+r+w /usr/local/jboss

providers/cloudservers-us/src/test/java/org/jclouds/rackspace/cloudservers/compute/CloudServersUSTemplateBuilderLiveTest.java

@@ -1,22 +1,3 @@
-/**
- *
- * Copyright (C) 2010 Cloud Conscious, LLC. <info@cloudconscious.com>
- *
- * ====================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ====================================================================
- */
-
 package org.jclouds.rackspace.cloudservers.compute;
 
 import static org.jclouds.compute.util.ComputeServiceUtils.getCores;