Merged pull request #24 from kedardave/master.

Implemented add/delete firewall rule for savvis-symphonyvpdc

providers/savvis-symphonyvpdc/src/main/java/org/jclouds/savvis/vpdc/binders/BindFirewallRuleToXmlPayload.java

@@ -0,0 +1,121 @@
+/**
+ *
+ * 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.savvis.vpdc.binders;
+
+import static com.google.common.base.Preconditions.checkArgument;
+import static com.google.common.base.Preconditions.checkNotNull;
+import static com.google.common.base.Preconditions.checkState;
+
+import java.util.Map;
+import java.util.Properties;
+
+import javax.inject.Singleton;
+import javax.ws.rs.core.MediaType;
+import javax.xml.parsers.FactoryConfigurationError;
+import javax.xml.parsers.ParserConfigurationException;
+
+import org.jclouds.http.HttpRequest;
+import org.jclouds.rest.MapBinder;
+import org.jclouds.rest.binders.BindToStringPayload;
+import org.jclouds.rest.internal.GeneratedHttpRequest;
+import org.jclouds.savvis.vpdc.domain.FirewallRule;
+
+import com.jamesmurty.utils.XMLBuilder;
+
+/**
+ * 
+ * @author Kedar Dave
+ * 
+ */
+@Singleton
+public class BindFirewallRuleToXmlPayload extends BindToStringPayload implements MapBinder {
+   @Override
+   public <R extends HttpRequest> R bindToRequest(R request, Object toBind) {
+      throw new IllegalStateException("BindFirewallRuleToXmlPayload needs parameters");
+
+   }
+
+   protected FirewallRule findRuleInArgsOrNull(GeneratedHttpRequest<?> gRequest) {
+      for (Object arg : gRequest.getArgs()) {
+         if (arg instanceof FirewallRule) {
+            return (FirewallRule) arg;
+         } else if (arg instanceof FirewallRule[]) {
+        	FirewallRule[] rules = (FirewallRule[]) arg;
+            return (rules.length > 0) ? rules[0] : null;
+         }
+      }
+      return null;
+   }
+
+   @Override
+   public <R extends HttpRequest> R bindToRequest(R request, Map<String, String> postParams) {
+      checkArgument(checkNotNull(request, "request") instanceof GeneratedHttpRequest<?>,
+            "this binder is only valid for GeneratedHttpRequests!");
+      GeneratedHttpRequest<?> gRequest = (GeneratedHttpRequest<?>) request;
+      checkState(gRequest.getArgs() != null, "args should be initialized at this point");
+
+      request = super.bindToRequest(request,
+            generateXml(findRuleInArgsOrNull(gRequest)));
+      request.getPayload().getContentMetadata().setContentType(MediaType.APPLICATION_XML);
+      return request;
+   }
+
+   public String generateXml(FirewallRule firewallRule) {
+      checkNotNull(firewallRule, "FirewallRule");
+
+      try {
+         XMLBuilder rootBuilder = buildRoot();
+         addFirewallRuleSection(rootBuilder, firewallRule);
+         Properties outputProperties = new Properties();
+         outputProperties.put(javax.xml.transform.OutputKeys.OMIT_XML_DECLARATION, "yes");
+         return rootBuilder.asString(outputProperties);
+      } catch (Exception e) {
+         return null;
+      }
+   }
+
+   void addFirewallRuleSection(XMLBuilder rootBuilder, FirewallRule firewallRule) {
+      XMLBuilder firewallRuleBuilder = rootBuilder.e("svvs:FirewallRule");
+      firewallRuleBuilder.e("svvs:IsEnabled").t(firewallRule.isEnabled() ? "true" : "false");
+      firewallRuleBuilder.e("svvs:Description").t("Server Tier Firewall Rule");
+      firewallRuleBuilder.e("svvs:Type").t(firewallRule.getFirewallType());
+      firewallRuleBuilder.e("svvs:Log").t(firewallRule.isLogged() ? "yes" : "no");
+      firewallRuleBuilder.e("svvs:Policy").t(firewallRule.getPolicy());
+      firewallRuleBuilder.e("svvs:Protocols").e("svvs:"+firewallRule.getProtocol()).t("true").up().up();
+      firewallRuleBuilder.e("svvs:Port").t(firewallRule.getPort());
+      firewallRuleBuilder.e("svvs:Destination").t(firewallRule.getDestination());
+      firewallRuleBuilder.e("svvs:Source").t(firewallRule.getSource());
+   }
+
+   protected XMLBuilder buildRoot() throws ParserConfigurationException, FactoryConfigurationError {
+      XMLBuilder rootBuilder = XMLBuilder.create("svvs:FirewallService")
+            .a("xmlns:common", "http://schemas.dmtf.org/wbem/wscim/1/common")
+            .a("xmlns:vApp", "http://www.vmware.com/vcloud/v0.8")
+            .a("xmlns:rasd", "http://schemas.dmtf.org/wbem/wscim/1/cim-schema/2/CIM_ResourceAllocationSettingData")
+            .a("xmlns:vssd", "http://schemas.dmtf.org/wbem/wscim/1/cim-schema/2/CIM_VirtualSystemSettingData")
+            .a("xmlns:ovf", "http://schemas.dmtf.org/ovf/envelope/1")
+            .a("xmlns:svvs", "http://schemas.api.sandbox.symphonyVPDC.savvis.net/vpdci");
+      return rootBuilder;
+   }
+
+   protected String ifNullDefaultTo(String value, String defaultValue) {
+      return value != null ? value : checkNotNull(defaultValue, "defaultValue");
+   }
+
+}

providers/savvis-symphonyvpdc/src/main/java/org/jclouds/savvis/vpdc/features/FirewallAsyncClient.java

@@ -18,10 +18,27 @@
  */
 package org.jclouds.savvis.vpdc.features;
 
+import javax.annotation.Nullable;
+import javax.ws.rs.DELETE;
+import javax.ws.rs.PUT;
 import javax.ws.rs.Path;
+import javax.ws.rs.PathParam;
 
+import org.jclouds.rest.annotations.ExceptionParser;
+import org.jclouds.rest.annotations.MapBinder;
+import org.jclouds.rest.annotations.ParamParser;
+import org.jclouds.rest.annotations.PayloadParam;
 import org.jclouds.rest.annotations.RequestFilters;
+import org.jclouds.rest.annotations.XMLResponseParser;
+import org.jclouds.rest.functions.ReturnNullOnNotFoundOr404;
+import org.jclouds.savvis.vpdc.binders.BindFirewallRuleToXmlPayload;
+import org.jclouds.savvis.vpdc.domain.FirewallRule;
+import org.jclouds.savvis.vpdc.domain.Task;
 import org.jclouds.savvis.vpdc.filters.SetVCloudTokenCookie;
+import org.jclouds.savvis.vpdc.functions.DefaultOrgIfNull;
+import org.jclouds.savvis.vpdc.xml.TaskHandler;
+
+import com.google.common.util.concurrent.ListenableFuture;
 
 /**
  * Provides access to Symphony VPDC resources via their REST API.
@@ -31,8 +48,29 @@ import org.jclouds.savvis.vpdc.filters.SetVCloudTokenCookie;
  * @author Adrian Cole
  */
 @RequestFilters(SetVCloudTokenCookie.class)
-@Path("v{jclouds.api-version}")
 public interface FirewallAsyncClient {
 
+	/**
+    * @see FirewallClient#addFirewallRule
+    */
+   @PUT
+   @XMLResponseParser(TaskHandler.class)
+   @Path("v{jclouds.api-version}/org/{billingSiteId}/vdc/{vpdcId}/FirewallService/")
+   @MapBinder(BindFirewallRuleToXmlPayload.class)
+   ListenableFuture<Task> addFirewallRule(
+            @PathParam("billingSiteId") @Nullable @ParamParser(DefaultOrgIfNull.class) String billingSiteId,
+            @PathParam("vpdcId") String vpdcId, @PayloadParam("firewallRule") FirewallRule firewallRule);
+	   
+   /**
+    * @see FirewallClient#deleteFirewallRule
+    */
+   @DELETE
+   @XMLResponseParser(TaskHandler.class)
+   @Path("v{jclouds.api-version}/org/{billingSiteId}/vdc/{vpdcId}/FirewallService/")
+   @MapBinder(BindFirewallRuleToXmlPayload.class)
+   @ExceptionParser(ReturnNullOnNotFoundOr404.class)
+   ListenableFuture<Task> deleteFirewallRule(
+            @PathParam("billingSiteId") @Nullable @ParamParser(DefaultOrgIfNull.class) String billingSiteId,
+            @PathParam("vpdcId") String vpdcId, @PayloadParam("firewallRule") FirewallRule firewallRule);
 
 }

providers/savvis-symphonyvpdc/src/main/java/org/jclouds/savvis/vpdc/features/FirewallClient.java

@@ -21,6 +21,8 @@ package org.jclouds.savvis.vpdc.features;
 import java.util.concurrent.TimeUnit;
 
 import org.jclouds.concurrent.Timeout;
+import org.jclouds.savvis.vpdc.domain.FirewallRule;
+import org.jclouds.savvis.vpdc.domain.Task;
 
 /**
  * Provides access to Symphony VPDC resources via their REST API.
@@ -31,5 +33,30 @@ import org.jclouds.concurrent.Timeout;
  */
 @Timeout(duration = 300, timeUnit = TimeUnit.SECONDS)
 public interface FirewallClient {
-
+	
+	/**
+	 * Add a new firewall rule
+	 * 		
+	 * @param billingSiteId
+	 * 		billing site Id, or null for default
+	 * @param vpdcId
+	 * 		vpdc Id
+	 * @param firewallRule
+	 * 		firewall rule to be added
+	 * @return
+	 */
+	Task addFirewallRule(String billingSiteId, String vpdcId, FirewallRule firewallRule);
+	
+	/**
+	 * Delete a firewall rule
+	 * 		
+	 * @param billingSiteId
+	 * 		billing site Id, or null for default
+	 * @param vpdcId
+	 * 		vpdc Id
+	 * @param firewallRule
+	 * 		firewall rule to be deleted
+	 * @return
+	 */
+	Task deleteFirewallRule(String billingSiteId, String vpdcId, FirewallRule firewallRule);
 }

providers/savvis-symphonyvpdc/src/main/java/org/jclouds/savvis/vpdc/features/VMAsyncClient.java

@@ -23,6 +23,7 @@ import java.net.URI;
 import javax.annotation.Nullable;
 import javax.ws.rs.DELETE;
 import javax.ws.rs.GET;
+import javax.ws.rs.POST;
 import javax.ws.rs.Path;
 import javax.ws.rs.PathParam;
 
@@ -93,4 +94,22 @@ public interface VMAsyncClient {
    @XMLResponseParser(TaskHandler.class)
    @ExceptionParser(ReturnNullOnNotFoundOr404.class)
    ListenableFuture<Task> removeVM(@EndpointParam URI vm);
+   
+   /**
+    * @see VMClient#powerOffVM
+    */
+   @POST
+   @XMLResponseParser(TaskHandler.class)
+   @Path("action/powerOff")
+   @ExceptionParser(ReturnNullOnNotFoundOr404.class)
+   ListenableFuture<Task> powerOffVM(@EndpointParam URI vm);
+   
+   /**
+    * @see VMClient#powerOnVM
+    */
+   @POST
+   @XMLResponseParser(TaskHandler.class)
+   @Path("action/powerOn")
+   @ExceptionParser(ReturnNullOnNotFoundOr404.class)
+   ListenableFuture<Task> powerOnVM(@EndpointParam URI vm);
 }

providers/savvis-symphonyvpdc/src/main/java/org/jclouds/savvis/vpdc/features/VMClient.java

@@ -89,4 +89,22 @@ public interface VMClient {
     * @see #removeVMFromVDC
     */
    Task removeVM(URI vm);
+   
+   /**
+    * Power off a VM
+    * 
+    * @param vm
+    * 			href of the vm
+    * @return
+    */
+   Task powerOffVM(URI vm);
+   
+   /**
+    * Power on a VM
+    * 
+    * @param vm
+    * 			href of the vm
+    * @return
+    */
+   Task powerOnVM(URI vm);
 }

providers/savvis-symphonyvpdc/src/test/java/org/jclouds/savvis/vpdc/binders/BindFirewallRuleToXmlPayloadTest.java

@@ -0,0 +1,45 @@
+/**
+ *
+ * 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.savvis.vpdc.binders;
+
+import static org.testng.Assert.assertEquals;
+
+import java.io.IOException;
+
+import org.jclouds.savvis.vpdc.domain.FirewallRule;
+import org.jclouds.util.Strings2;
+import org.testng.annotations.Test;
+
+/**
+ * Tests behavior of {@code BindVMSpecToXmlPayload}
+ * 
+ * @author Kedar Dave
+ */
+@Test(groups = "unit")
+public class BindFirewallRuleToXmlPayloadTest {
+
+   public void test() throws IOException {
+      String expected = Strings2.toStringAndClose(getClass().getResourceAsStream("/firewallService-default.xml"));
+
+      FirewallRule firewallRule = FirewallRule.builder().firewallType("SERVER_TIER_FIREWALL").isEnabled(true).source("internet")
+	  	.destination("VM Tier01").port("22").protocol("Tcp").policy("allow").description("Server Tier Firewall Rule").isLogged(false).build();
+
+      assertEquals(new BindFirewallRuleToXmlPayload().generateXml(firewallRule), expected);
+   }
+}

providers/savvis-symphonyvpdc/src/test/java/org/jclouds/savvis/vpdc/features/BaseVPDCClientLiveTest.java

@@ -89,7 +89,7 @@ public class BaseVPDCClientLiveTest {
       context = new ComputeServiceContextFactory().createContext(provider, ImmutableSet.<Module> of(
                new Log4JLoggingModule(), new JschSshClientModule()), overrides);
       restContext = context.getProviderSpecificContext();
-      taskTester = new RetryablePredicate<String>(new TaskSuccess(restContext.getApi()), 650, 10, TimeUnit.SECONDS);
+      taskTester = new RetryablePredicate<String>(new TaskSuccess(restContext.getApi()), 1200, 10, TimeUnit.SECONDS);
    }
 
    @AfterGroups(groups = "live")

providers/savvis-symphonyvpdc/src/test/java/org/jclouds/savvis/vpdc/features/FirewallAsyncClientTest.java

@@ -18,7 +18,16 @@
  */
 package org.jclouds.savvis.vpdc.features;
 
+import java.io.IOException;
+import java.lang.reflect.Method;
+
+import org.jclouds.http.HttpRequest;
+import org.jclouds.http.functions.ParseSax;
+import org.jclouds.rest.functions.ReturnNullOnNotFoundOr404;
 import org.jclouds.rest.internal.RestAnnotationProcessor;
+import org.jclouds.savvis.vpdc.domain.FirewallRule;
+import org.jclouds.savvis.vpdc.xml.TaskHandler;
+import org.jclouds.util.Strings2;
 import org.testng.annotations.Test;
 
 import com.google.inject.TypeLiteral;
@@ -31,6 +40,38 @@ import com.google.inject.TypeLiteral;
 @Test(groups = "unit")
 public class FirewallAsyncClientTest extends BaseVPDCAsyncClientTest<FirewallAsyncClient> {
 
+	public void testAddFirewallRule() throws NoSuchMethodException, IOException{
+		Method method = FirewallAsyncClient.class.getMethod("addFirewallRule", String.class, String.class, FirewallRule.class);
+		HttpRequest request = processor.createRequest(method, "11", "22", FirewallRule.builder().firewallType("SERVER_TIER_FIREWALL").isEnabled(true).source("internet")
+			  	.destination("VM Tier01").port("22").protocol("Tcp").policy("allow").description("Server Tier Firewall Rule").isLogged(false).build());
+
+		assertRequestLineEquals(request, "PUT https://api.symphonyvpdc.savvis.net/rest/api/v0.8/org/11/vdc/22/FirewallService/ HTTP/1.1");
+		assertNonPayloadHeadersEqual(request, "");
+		assertPayloadEquals(request, Strings2.toStringAndClose(getClass().getResourceAsStream("/firewallService-default.xml")),
+	               "application/xml", false);
+
+		assertResponseParserClassEquals(method, request, ParseSax.class);
+		assertSaxResponseParserClassEquals(method, TaskHandler.class);
+
+		checkFilters(request);
+	}
+	
+	public void testDeleteFirewallRule() throws NoSuchMethodException, IOException{
+		Method method = FirewallAsyncClient.class.getMethod("deleteFirewallRule", String.class, String.class, FirewallRule.class);
+		HttpRequest request = processor.createRequest(method, "11", "22", FirewallRule.builder().firewallType("SERVER_TIER_FIREWALL").isEnabled(true).source("internet")
+			  	.destination("VM Tier01").port("22").protocol("Tcp").policy("allow").description("Server Tier Firewall Rule").isLogged(false).build());
+
+		assertRequestLineEquals(request, "DELETE https://api.symphonyvpdc.savvis.net/rest/api/v0.8/org/11/vdc/22/FirewallService/ HTTP/1.1");
+		assertNonPayloadHeadersEqual(request, "");
+		assertPayloadEquals(request, Strings2.toStringAndClose(getClass().getResourceAsStream("/firewallService-default.xml")),
+	               "application/xml", false);
+
+		assertResponseParserClassEquals(method, request, ParseSax.class);
+		assertSaxResponseParserClassEquals(method, TaskHandler.class);
+		assertExceptionParserClassEquals(method, ReturnNullOnNotFoundOr404.class);
+
+		checkFilters(request);
+	}
 
    @Override
    protected TypeLiteral<RestAnnotationProcessor<FirewallAsyncClient>> createTypeLiteral() {

providers/savvis-symphonyvpdc/src/test/java/org/jclouds/savvis/vpdc/features/FirewallClientLiveTest.java

@@ -18,14 +18,21 @@
  */
 package org.jclouds.savvis.vpdc.features;
 
+import org.jclouds.savvis.vpdc.domain.FirewallRule;
+import org.jclouds.savvis.vpdc.domain.Resource;
+import org.jclouds.savvis.vpdc.domain.Task;
 import org.testng.annotations.AfterGroups;
 import org.testng.annotations.BeforeGroups;
 import org.testng.annotations.Test;
 
-@Test(groups = "live")
+import com.google.common.base.Predicate;
+import com.google.common.collect.Iterables;
+
 public class FirewallClientLiveTest extends BaseVPDCClientLiveTest {
 
    private FirewallClient client;
+   private String billingSiteId;
+   private String vpdcId;
 
    @Override
    @BeforeGroups(groups = { "live" })
@@ -33,7 +40,76 @@ public class FirewallClientLiveTest extends BaseVPDCClientLiveTest {
       super.setupClient();
       client = restContext.getApi().getFirewallClient();
    }
+   
+   @Test(groups = "live")
+   public void testAddFirewallRule() throws Exception {
+	  billingSiteId = restContext.getApi().getBrowsingClient().getOrg(null).getId();// default
+	  vpdcId = Iterables.find(restContext.getApi().getBrowsingClient().getOrg(billingSiteId).getVDCs(),
+	           new Predicate<Resource>() {
+	
+	              // try to find the first VDC owned by the current user
+	              // check here for what the email property might be, or in
+	              // the jclouds-wire.log
+	              @Override
+	              public boolean apply(Resource arg0) {
+	                 String description = restContext.getApi().getBrowsingClient().getVDCInOrg(billingSiteId,
+	                          arg0.getId()).getDescription();
+	                 return description.indexOf(email) != -1;
+	              }
+	
+	           }).getId();
+	   
+      String networkTierName = Iterables.get(
+               restContext.getApi().getBrowsingClient().getVDCInOrg(billingSiteId, vpdcId).getAvailableNetworks(), 0)
+               .getName();   
+	      
+	   FirewallRule firewallRule = FirewallRule.builder().firewallType("SERVER_TIER_FIREWALL").isEnabled(true).source("internet")
+	  	.destination(networkTierName).port("10000").protocol("Tcp").policy("allow").description("Server Tier Firewall Rule").isLogged(false).build();
+	   
+	   System.out.printf("adding firewall rule:%s %n", firewallRule.toString());
+	   
+	   Task task = client.addFirewallRule(billingSiteId, vpdcId, firewallRule);
+	   
+	   // make sure there's no error
+	   assert task.getId() != null && task.getError() == null : task;
+	   
+	   assert this.taskTester.apply(task.getId());
+   }
+   
+   @Test(groups = "live", dependsOnMethods = {"testAddFirewallRule"})
+   public void testDeleteFirewallRule() throws Exception {
+	   billingSiteId = restContext.getApi().getBrowsingClient().getOrg(null).getId();// default
+	   vpdcId = Iterables.find(restContext.getApi().getBrowsingClient().getOrg(billingSiteId).getVDCs(),
+	               new Predicate<Resource>() {
 
+	                  // try to find the first VDC owned by the current user
+	                  // check here for what the email property might be, or in
+	                  // the jclouds-wire.log
+	                  @Override
+	                  public boolean apply(Resource arg0) {
+	                     String description = restContext.getApi().getBrowsingClient().getVDCInOrg(billingSiteId,
+	                              arg0.getId()).getDescription();
+	                     return description.indexOf(email) != -1;
+	                  }
+
+	               }).getId();
+	      
+      String networkTierName = Iterables.get(
+               restContext.getApi().getBrowsingClient().getVDCInOrg(billingSiteId, vpdcId).getAvailableNetworks(), 0)
+               .getName();
+	      
+	   FirewallRule firewallRule = FirewallRule.builder().firewallType("SERVER_TIER_FIREWALL").isEnabled(true).source("internet")
+	  	.destination(networkTierName).port("10000").protocol("Tcp").policy("allow").description("Server Tier Firewall Rule").isLogged(false).build();
+
+	   System.out.printf("deleting firewall rule:%s %n", firewallRule.toString());
+	   
+	   Task task = client.deleteFirewallRule(billingSiteId, vpdcId, firewallRule);
+	   
+	   // make sure there's no error
+	   assert task.getId() != null && task.getError() == null : task;
+
+	   assert this.taskTester.apply(task.getId());
+   }
 
    @AfterGroups(groups = "live")
    protected void tearDown() {

providers/savvis-symphonyvpdc/src/test/java/org/jclouds/savvis/vpdc/features/VMAsyncClientTest.java

@@ -141,6 +141,40 @@ public class VMAsyncClientTest extends BaseVPDCAsyncClientTest<VMAsyncClient> {
 
       checkFilters(request);
    }
+   
+   public void testPowerOffVM() throws SecurityException, NoSuchMethodException, IOException {
+      Method method = VMAsyncClient.class.getMethod("powerOffVM", URI.class);
+      HttpRequest request = processor.createRequest(method, URI
+               .create("https://api.symphonyvpdc.savvis.net/rest/api/v0.8/org/11/vdc/22/vApp/33"));
+
+      assertRequestLineEquals(request,
+               "POST https://api.symphonyvpdc.savvis.net/rest/api/v0.8/org/11/vdc/22/vApp/33/action/powerOff HTTP/1.1");
+      assertNonPayloadHeadersEqual(request, "");
+      assertPayloadEquals(request, null, null, false);
+
+      assertResponseParserClassEquals(method, request, ParseSax.class);
+      assertSaxResponseParserClassEquals(method, TaskHandler.class);
+      assertExceptionParserClassEquals(method, ReturnNullOnNotFoundOr404.class);
+
+      checkFilters(request);
+   }
+   
+   public void testPowerOnVM() throws SecurityException, NoSuchMethodException, IOException {
+	      Method method = VMAsyncClient.class.getMethod("powerOnVM", URI.class);
+	      HttpRequest request = processor.createRequest(method, URI
+	               .create("https://api.symphonyvpdc.savvis.net/rest/api/v0.8/org/11/vdc/22/vApp/33"));
+
+	      assertRequestLineEquals(request,
+	               "POST https://api.symphonyvpdc.savvis.net/rest/api/v0.8/org/11/vdc/22/vApp/33/action/powerOn HTTP/1.1");
+	      assertNonPayloadHeadersEqual(request, "");
+	      assertPayloadEquals(request, null, null, false);
+
+	      assertResponseParserClassEquals(method, request, ParseSax.class);
+	      assertSaxResponseParserClassEquals(method, TaskHandler.class);
+	      assertExceptionParserClassEquals(method, ReturnNullOnNotFoundOr404.class);
+
+	      checkFilters(request);
+	   }
 
    @Override
    protected TypeLiteral<RestAnnotationProcessor<VMAsyncClient>> createTypeLiteral() {

providers/savvis-symphonyvpdc/src/test/java/org/jclouds/savvis/vpdc/features/VMClientLiveTest.java

@@ -21,6 +21,7 @@ package org.jclouds.savvis.vpdc.features;
 import static com.google.common.base.Preconditions.checkNotNull;
 import static org.testng.Assert.assertEquals;
 
+import java.net.URI;
 import java.util.concurrent.TimeUnit;
 
 import org.jclouds.cim.OSType;
@@ -34,7 +35,10 @@ import org.jclouds.savvis.vpdc.domain.Resource;
 import org.jclouds.savvis.vpdc.domain.Task;
 import org.jclouds.savvis.vpdc.domain.VDC;
 import org.jclouds.savvis.vpdc.domain.VM;
+import org.jclouds.savvis.vpdc.domain.VM.Status;
 import org.jclouds.savvis.vpdc.domain.VMSpec;
+import org.jclouds.savvis.vpdc.options.GetVMOptions;
+import org.jclouds.savvis.vpdc.reference.VCloudMediaType;
 import org.jclouds.ssh.SshClient;
 import org.jclouds.util.InetAddresses2;
 import org.testng.annotations.AfterGroups;
@@ -114,7 +118,7 @@ public class VMClientLiveTest extends BaseVPDCClientLiveTest {
                .operatingSystem(os).memoryInGig(2).addDataDrive("/data01", 25).build());
 
       // make sure there's no error
-      assert task.getId() != null && task.getError() != null : task;
+      assert task.getId() != null && task.getError() == null : task;
 
       assert this.taskTester.apply(task.getId());
       vm = restContext.getApi().getBrowsingClient().getVMInVDC(billingSiteId, vpdcId, task.getOwner().getId());
@@ -148,6 +152,88 @@ public class VMClientLiveTest extends BaseVPDCClientLiveTest {
       }
    }
 
+   public void testPowerOffVM() throws Exception {
+	   billingSiteId = restContext.getApi().getBrowsingClient().getOrg(null).getId();// default
+	   vpdcId = Iterables.find(restContext.getApi().getBrowsingClient().getOrg(billingSiteId).getVDCs(),
+	               new Predicate<Resource>() {
+	
+	                  // try to find the first VDC owned by the current user
+	                  // check here for what the email property might be, or in
+	                  // the jclouds-wire.log
+	                  @Override
+	                  public boolean apply(Resource arg0) {
+	                     String description = restContext.getApi().getBrowsingClient().getVDCInOrg(billingSiteId,
+	                              arg0.getId()).getDescription();
+	                     return description.indexOf(email) != -1;
+	                  }
+	
+	               }).getId();
+
+      VDC vpdc = restContext.getApi().getBrowsingClient().getVDCInOrg(billingSiteId, vpdcId);
+      URI vmURI = Iterables.find(vpdc.getResourceEntities(), new Predicate<Resource>() {
+			  		@Override
+			  		public boolean apply(Resource arg0) {
+			  			if(VCloudMediaType.VAPP_XML.equals(arg0.getType())){
+			  				VM response1 = restContext.getApi().getBrowsingClient().getVM(arg0.getHref(), (GetVMOptions[]) null);
+			  				System.out.printf("powering off vm - %s%n", response1.getName());
+			  				if(response1.getStatus().equals(Status.ON)){
+			  					return true;
+			  				}
+			  			}
+			  			return false;
+			  		}
+			  		
+			  	}).getHref();
+      
+      Task task = client.powerOffVM(vmURI);
+      
+      // make sure there's no error
+      assert task.getId() != null && task.getError() == null : task;
+
+      assert this.taskTester.apply(task.getId());
+   }
+   
+   public void testPowerOnVM() throws Exception {
+	   billingSiteId = restContext.getApi().getBrowsingClient().getOrg(null).getId();// default
+	   vpdcId = Iterables.find(restContext.getApi().getBrowsingClient().getOrg(billingSiteId).getVDCs(),
+	               new Predicate<Resource>() {
+	
+	                  // try to find the first VDC owned by the current user
+	                  // check here for what the email property might be, or in
+	                  // the jclouds-wire.log
+	                  @Override
+	                  public boolean apply(Resource arg0) {
+	                     String description = restContext.getApi().getBrowsingClient().getVDCInOrg(billingSiteId,
+	                              arg0.getId()).getDescription();
+	                     return description.indexOf(email) != -1;
+	                  }
+	
+	               }).getId();
+
+      VDC vpdc = restContext.getApi().getBrowsingClient().getVDCInOrg(billingSiteId, vpdcId);
+      URI vmURI = Iterables.find(vpdc.getResourceEntities(), new Predicate<Resource>() {
+			  		@Override
+			  		public boolean apply(Resource arg0) {
+			  			if(VCloudMediaType.VAPP_XML.equals(arg0.getType())){
+			  				VM response1 = restContext.getApi().getBrowsingClient().getVM(arg0.getHref(), (GetVMOptions[]) null);
+			  				System.out.printf("powering on vm - %s%n", response1.getName());
+			  				if(response1.getStatus().equals(Status.OFF)){
+			  					return true;
+			  				}
+			  			}
+			  			return false;
+			  		}
+			  		
+			  	}).getHref();
+      
+      Task task = client.powerOnVM(vmURI);
+      
+      // make sure there's no error
+      assert task.getId() != null && task.getError() == null : task;
+
+      assert this.taskTester.apply(task.getId());
+   }
+   
    @AfterGroups(groups = "live")
    protected void tearDown() {
       if (vm != null) {

providers/savvis-symphonyvpdc/src/test/resources/firewallService-default.xml

@@ -0,0 +1 @@
+<svvs:FirewallService xmlns:svvs="http://schemas.api.sandbox.symphonyVPDC.savvis.net/vpdci" xmlns:common="http://schemas.dmtf.org/wbem/wscim/1/common" xmlns:ovf="http://schemas.dmtf.org/ovf/envelope/1" xmlns:rasd="http://schemas.dmtf.org/wbem/wscim/1/cim-schema/2/CIM_ResourceAllocationSettingData" xmlns:vApp="http://www.vmware.com/vcloud/v0.8" xmlns:vssd="http://schemas.dmtf.org/wbem/wscim/1/cim-schema/2/CIM_VirtualSystemSettingData"><svvs:FirewallRule><svvs:IsEnabled>true</svvs:IsEnabled><svvs:Description>Server Tier Firewall Rule</svvs:Description><svvs:Type>SERVER_TIER_FIREWALL</svvs:Type><svvs:Log>no</svvs:Log><svvs:Policy>allow</svvs:Policy><svvs:Protocols><svvs:Tcp>true</svvs:Tcp></svvs:Protocols><svvs:Port>22</svvs:Port><svvs:Destination>VM Tier01</svvs:Destination><svvs:Source>internet</svvs:Source></svvs:FirewallRule></svvs:FirewallService>