Profitbricks Snapshot api
Project: http://git-wip-us.apache.org/repos/asf/jclouds/repo Commit: http://git-wip-us.apache.org/repos/asf/jclouds/commit/36d499b4 Tree: http://git-wip-us.apache.org/repos/asf/jclouds/tree/36d499b4 Diff: http://git-wip-us.apache.org/repos/asf/jclouds/diff/36d499b4 Branch: refs/heads/master Commit: 36d499b47ff784b6dad1fdf700fa9e84f7359b37 Parents: de2e5e0 Author: jasminSPC <[email protected]> Authored: Mon Mar 2 18:03:54 2015 +0100 Committer: Ignasi Barrera <[email protected]> Committed: Sun Mar 8 21:10:20 2015 +0100 ---------------------------------------------------------------------- .../jclouds/profitbricks/ProfitBricksApi.java | 5 +- .../snapshot/CreateSnapshotRequestBinder.java | 44 ++ .../snapshot/RollbackSnapshotRequestBinder.java | 43 ++ .../snapshot/UpdateSnapshotRequestBinder.java | 53 +++ .../internal/ProvisioningStatusAware.java | 2 +- .../ProvisioningStatusPollingPredicate.java | 2 + .../jclouds/profitbricks/domain/Snapshot.java | 432 +++++++++++++++++++ .../profitbricks/features/SnapshotApi.java | 87 ++++ .../snapshot/BaseSnapshotResponseHandler.java | 83 ++++ .../snapshot/SnapshotListResponseHandler.java | 52 +++ .../snapshot/SnapshotResponseHandler.java | 48 +++ .../CreateSnapshotRequestBinderTest.java | 47 ++ .../RollbackSnapshotRequestBinderTest.java | 47 ++ .../UpdateSnapshotRequestBinderTest.java | 60 +++ .../ProvisioningStatusPollingPredicateTest.java | 33 ++ .../features/SnapshotApiLiveTest.java | 132 ++++++ .../features/SnapshotApiMockTest.java | 262 +++++++++++ .../SnapshotListResponseHandlerTest.java | 100 +++++ .../snapshot/SnapshotResponseHandlerTest.java | 76 ++++ .../test/resources/snapshot/snapshot-create.xml | 11 + .../test/resources/snapshot/snapshot-delete.xml | 10 + .../resources/snapshot/snapshot-rollback.xml | 12 + .../snapshot/snapshot-state-inprocess.xml | 27 ++ .../test/resources/snapshot/snapshot-update.xml | 10 + .../src/test/resources/snapshot/snapshot.xml | 27 ++ .../src/test/resources/snapshot/snapshots.xml | 47 ++ 26 files changed, 1750 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/main/java/org/jclouds/profitbricks/ProfitBricksApi.java ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/main/java/org/jclouds/profitbricks/ProfitBricksApi.java b/providers/profitbricks/src/main/java/org/jclouds/profitbricks/ProfitBricksApi.java index 49d7e8c..af7a31d 100644 --- a/providers/profitbricks/src/main/java/org/jclouds/profitbricks/ProfitBricksApi.java +++ b/providers/profitbricks/src/main/java/org/jclouds/profitbricks/ProfitBricksApi.java @@ -17,12 +17,12 @@ package org.jclouds.profitbricks; import java.io.Closeable; - import org.jclouds.profitbricks.features.DataCenterApi; import org.jclouds.profitbricks.features.FirewallApi; import org.jclouds.profitbricks.features.ImageApi; import org.jclouds.profitbricks.features.NicApi; import org.jclouds.profitbricks.features.ServerApi; +import org.jclouds.profitbricks.features.SnapshotApi; import org.jclouds.profitbricks.features.StorageApi; import org.jclouds.rest.annotations.Delegate; @@ -45,4 +45,7 @@ public interface ProfitBricksApi extends Closeable { @Delegate FirewallApi firewallApi(); + + @Delegate + SnapshotApi snapshotApi(); } http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/main/java/org/jclouds/profitbricks/binder/snapshot/CreateSnapshotRequestBinder.java ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/main/java/org/jclouds/profitbricks/binder/snapshot/CreateSnapshotRequestBinder.java b/providers/profitbricks/src/main/java/org/jclouds/profitbricks/binder/snapshot/CreateSnapshotRequestBinder.java new file mode 100644 index 0000000..213a3a8 --- /dev/null +++ b/providers/profitbricks/src/main/java/org/jclouds/profitbricks/binder/snapshot/CreateSnapshotRequestBinder.java @@ -0,0 +1,44 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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.profitbricks.binder.snapshot; + +import org.jclouds.profitbricks.binder.BaseProfitBricksRequestBinder; +import org.jclouds.profitbricks.domain.Snapshot; + +import static java.lang.String.format; + +public class CreateSnapshotRequestBinder extends BaseProfitBricksRequestBinder<Snapshot.Request.CreatePayload> { + + protected final StringBuilder requestBuilder; + + protected CreateSnapshotRequestBinder() { + super("snapshot"); + this.requestBuilder = new StringBuilder(128); + } + + @Override + protected String createPayload(Snapshot.Request.CreatePayload payload) { + requestBuilder.append("<ws:createSnapshot>") + .append("<request>") + .append(format("<storageId>%s</storageId>", payload.storageId())) + .append(formatIfNotEmpty("<description>%s</description>", payload.description())) + .append(formatIfNotEmpty("<snapshotName>%s</snapshotName>", payload.name())) + .append("</request>") + .append("</ws:createSnapshot>"); + return requestBuilder.toString(); + } +} http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/main/java/org/jclouds/profitbricks/binder/snapshot/RollbackSnapshotRequestBinder.java ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/main/java/org/jclouds/profitbricks/binder/snapshot/RollbackSnapshotRequestBinder.java b/providers/profitbricks/src/main/java/org/jclouds/profitbricks/binder/snapshot/RollbackSnapshotRequestBinder.java new file mode 100644 index 0000000..a9997cb --- /dev/null +++ b/providers/profitbricks/src/main/java/org/jclouds/profitbricks/binder/snapshot/RollbackSnapshotRequestBinder.java @@ -0,0 +1,43 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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.profitbricks.binder.snapshot; + +import org.jclouds.profitbricks.binder.BaseProfitBricksRequestBinder; +import org.jclouds.profitbricks.domain.Snapshot; + +import static java.lang.String.format; + +public class RollbackSnapshotRequestBinder extends BaseProfitBricksRequestBinder<Snapshot.Request.RollbackPayload> { + + protected final StringBuilder requestBuilder; + + protected RollbackSnapshotRequestBinder() { + super("snapshot"); + this.requestBuilder = new StringBuilder(128); + } + + @Override + protected String createPayload(Snapshot.Request.RollbackPayload payload) { + requestBuilder.append("<ws:rollbackSnapshot>") + .append("<request>") + .append(format("<snapshotId>%s</snapshotId>", payload.snapshotId())) + .append(format("<storageId>%s</storageId>", payload.storageId())) + .append("</request>") + .append("</ws:rollbackSnapshot>"); + return requestBuilder.toString(); + } +} http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/main/java/org/jclouds/profitbricks/binder/snapshot/UpdateSnapshotRequestBinder.java ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/main/java/org/jclouds/profitbricks/binder/snapshot/UpdateSnapshotRequestBinder.java b/providers/profitbricks/src/main/java/org/jclouds/profitbricks/binder/snapshot/UpdateSnapshotRequestBinder.java new file mode 100644 index 0000000..e396715 --- /dev/null +++ b/providers/profitbricks/src/main/java/org/jclouds/profitbricks/binder/snapshot/UpdateSnapshotRequestBinder.java @@ -0,0 +1,53 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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.profitbricks.binder.snapshot; + +import static java.lang.String.format; +import org.jclouds.profitbricks.binder.BaseProfitBricksRequestBinder; +import org.jclouds.profitbricks.domain.Snapshot; + +public class UpdateSnapshotRequestBinder extends BaseProfitBricksRequestBinder<Snapshot.Request.UpdatePayload> { + + protected final StringBuilder requestBuilder; + + protected UpdateSnapshotRequestBinder() { + super("snapshot"); + this.requestBuilder = new StringBuilder(128); + } + + @Override + protected String createPayload(Snapshot.Request.UpdatePayload payload) { + requestBuilder.append("<ws:updateSnapshot>") + .append("<request>") + .append(format("<snapshotId>%s</snapshotId>", payload.snapshotId())) + .append(format("<description>%s</description>", payload.description())) + .append(format("<snapshotName>%s</snapshotName>", payload.name())) + .append(formatIfNotEmpty("<bootable>%s</bootable>", payload.bootable())) + .append(formatIfNotEmpty("<osType>%s</osType>", payload.osType())) + .append(formatIfNotEmpty("<cpuHotPlug>%s</cpuHotPlug>", payload.cpuHotplug())) + .append(formatIfNotEmpty("<cpuHotUnPlug>%s</cpuHotUnPlug>", payload.cpuHotunplug())) + .append(formatIfNotEmpty("<ramHotPlug>%s</ramHotPlug>", payload.ramHotplug())) + .append(formatIfNotEmpty("<ramHotUnPlug>%s</ramHotUnPlug>", payload.ramHotunplug())) + .append(formatIfNotEmpty("<nicHotPlug>%s</nicHotPlug>", payload.nicHotplug())) + .append(formatIfNotEmpty("<nicHotUnPlug>%s</nicHotUnPlug>", payload.nicHotunplug())) + .append(formatIfNotEmpty("<discVirtioHotPlug>%s</discVirtioHotPlug>", payload.discVirtioHotplug())) + .append(formatIfNotEmpty("<discVirtioHotUnPlug>%s</discVirtioHotUnPlug>", payload.discVirtioHotunplug())) + .append("</request>") + .append("</ws:updateSnapshot>"); + return requestBuilder.toString(); + } +} http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/main/java/org/jclouds/profitbricks/compute/internal/ProvisioningStatusAware.java ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/main/java/org/jclouds/profitbricks/compute/internal/ProvisioningStatusAware.java b/providers/profitbricks/src/main/java/org/jclouds/profitbricks/compute/internal/ProvisioningStatusAware.java index 7a11009..bd00a3d 100644 --- a/providers/profitbricks/src/main/java/org/jclouds/profitbricks/compute/internal/ProvisioningStatusAware.java +++ b/providers/profitbricks/src/main/java/org/jclouds/profitbricks/compute/internal/ProvisioningStatusAware.java @@ -23,5 +23,5 @@ package org.jclouds.profitbricks.compute.internal; */ public enum ProvisioningStatusAware { - DATACENTER, SERVER, STORAGE, NIC; + DATACENTER, SERVER, STORAGE, NIC, SNAPSHOT; } http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/main/java/org/jclouds/profitbricks/compute/internal/ProvisioningStatusPollingPredicate.java ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/main/java/org/jclouds/profitbricks/compute/internal/ProvisioningStatusPollingPredicate.java b/providers/profitbricks/src/main/java/org/jclouds/profitbricks/compute/internal/ProvisioningStatusPollingPredicate.java index 7606cac..f38abad 100644 --- a/providers/profitbricks/src/main/java/org/jclouds/profitbricks/compute/internal/ProvisioningStatusPollingPredicate.java +++ b/providers/profitbricks/src/main/java/org/jclouds/profitbricks/compute/internal/ProvisioningStatusPollingPredicate.java @@ -54,6 +54,8 @@ public class ProvisioningStatusPollingPredicate implements Predicate<String> { return expect == api.storageApi().getStorage(input).state(); case NIC: return expect == api.nicApi().getNic(input).state(); + case SNAPSHOT: + return expect == api.snapshotApi().getSnapshot(input).state(); default: throw new IllegalArgumentException("Unknown domain '" + domain + "'"); } http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/main/java/org/jclouds/profitbricks/domain/Snapshot.java ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/main/java/org/jclouds/profitbricks/domain/Snapshot.java b/providers/profitbricks/src/main/java/org/jclouds/profitbricks/domain/Snapshot.java new file mode 100644 index 0000000..3182711 --- /dev/null +++ b/providers/profitbricks/src/main/java/org/jclouds/profitbricks/domain/Snapshot.java @@ -0,0 +1,432 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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.profitbricks.domain; + +import com.google.auto.value.AutoValue; +import org.jclouds.javax.annotation.Nullable; + +import java.util.Date; + +@AutoValue +public abstract class Snapshot { + + @Nullable + public abstract String id(); + + @Nullable + public abstract String name(); + + public abstract float size(); + + public abstract boolean bootable(); + + @Nullable + public abstract String description(); + + @Nullable + public abstract OsType osType(); + + public abstract boolean cpuHotPlug(); + + public abstract boolean cpuHotUnPlug(); + + public abstract boolean discVirtioHotPlug(); + + public abstract boolean discVirtioHotUnPlug(); + + public abstract boolean ramHotPlug(); + + public abstract boolean ramHotUnPlug(); + + public abstract boolean nicHotPlug(); + + public abstract boolean nicHotUnPlug(); + + @Nullable + public abstract Date creationTime(); + + @Nullable + public abstract Date lastModificationTime(); + + @Nullable + public abstract ProvisioningState state(); + + @Nullable + public abstract Location location(); + + public static Snapshot create(String id, String name, float size, boolean bootable, String description, OsType osType, boolean cpuHotPlug, boolean cpuHotUnPlug, + boolean discVirtioHotPlug, boolean discVirtioHotUnPlug, boolean ramHotPlug, boolean ramHotUnPlug, + boolean nicHotPlug, boolean nicHotUnPlug, Date creationTime, Date lastModificationTime, ProvisioningState state, Location location) { + return new AutoValue_Snapshot(id, name, size, bootable, description, osType, cpuHotPlug, cpuHotUnPlug, + discVirtioHotPlug, discVirtioHotUnPlug, ramHotPlug, ramHotUnPlug, + nicHotPlug, nicHotUnPlug, creationTime, lastModificationTime, state, location); + } + + public static Builder builder() { + return new Builder(); + } + + public static class Builder { + + private String id; + @Nullable + private String name; + private float size; + private Date creationTime; + private Date lastModificationTime; + private ProvisioningState state; + private boolean bootable; + @Nullable + private String description; + private OsType osType; + private boolean cpuHotPlug; + private boolean cpuHotUnPlug; + private boolean discVirtioHotPlug; + private boolean discVirtioHotUnPlug; + private boolean ramHotPlug; + private boolean ramHotUnPlug; + private boolean nicHotPlug; + private boolean nicHotUnPlug; + private Location location; + + public Builder id(String id) { + this.id = id; + return this; + } + + public Builder name(String name) { + this.name = name; + return this; + } + + public Builder size(float size) { + this.size = size; + return this; + } + + public Builder creationTime(Date creationTime) { + this.creationTime = creationTime; + return this; + } + + public Builder lastModificationTime(Date lastModificationTime) { + this.lastModificationTime = lastModificationTime; + return this; + } + + public Builder state(ProvisioningState state) { + this.state = state; + return this; + } + + public Builder description(String description) { + this.description = description; + return this; + } + + public Builder bootable(Boolean bootable) { + this.bootable = bootable; + return this; + } + + public Builder osType(OsType osType) { + this.osType = osType; + return this; + } + + public Builder cpuHotPlug(boolean cpuHotPlug) { + this.cpuHotPlug = cpuHotPlug; + return this; + } + + public Builder cpuHotUnPlug(boolean cpuHotUnPlug) { + this.cpuHotUnPlug = cpuHotUnPlug; + return this; + } + + public Builder discVirtioHotPlug(boolean discVirtioHotPlug) { + this.discVirtioHotPlug = discVirtioHotPlug; + return this; + } + + public Builder discVirtioHotUnPlug(boolean discVirtioHotUnPlug) { + this.discVirtioHotUnPlug = discVirtioHotUnPlug; + return this; + } + + public Builder ramHotPlug(boolean ramHotPlug) { + this.ramHotPlug = ramHotPlug; + return this; + } + + public Builder ramHotUnPlug(boolean ramHotUnPlug) { + this.ramHotUnPlug = ramHotUnPlug; + return this; + } + + public Builder nicHotPlug(boolean nicHotPlug) { + this.nicHotPlug = nicHotPlug; + return this; + } + + public Builder nicHotUnPlug(boolean nicHotUnPlug) { + this.nicHotUnPlug = nicHotUnPlug; + return this; + } + + public Builder location(Location location) { + this.location = location; + return this; + } + + private Builder fromSnapshot(Snapshot in) { + return this.id(in.id()).name(in.name()).size(in.size()).creationTime(in.creationTime()) + .lastModificationTime(in.lastModificationTime()).state(in.state()).bootable(in.bootable()).description(in.description()) + .cpuHotPlug(in.cpuHotPlug()).cpuHotUnPlug(in.cpuHotUnPlug()).discVirtioHotPlug(in.discVirtioHotPlug()) + .discVirtioHotUnPlug(in.discVirtioHotUnPlug()).ramHotPlug(in.ramHotPlug()).ramHotUnPlug(in.ramHotUnPlug()) + .nicHotPlug(in.nicHotPlug()).nicHotUnPlug(in.nicHotUnPlug()); + } + + public Snapshot build() { + return Snapshot.create(id, name, size, bootable, description, osType, cpuHotPlug, cpuHotUnPlug, discVirtioHotPlug, discVirtioHotUnPlug, ramHotPlug, ramHotUnPlug, nicHotPlug, nicHotUnPlug, creationTime, lastModificationTime, state, location); + } + } + + public static final class Request { + + public static CreatePayload.Builder creatingBuilder() { + return new CreatePayload.Builder(); + } + + public static UpdatePayload.Builder updatingBuilder() { + return new UpdatePayload.Builder(); + } + + public static RollbackPayload.Builder rollbackBuilder() { + return new RollbackPayload.Builder(); + } + + @AutoValue + public abstract static class CreatePayload { + + public abstract String storageId(); + + public abstract String description(); + + public abstract String name(); + + public static CreatePayload create(String storageId, String description, String name) { + return new AutoValue_Snapshot_Request_CreatePayload(storageId, description, name); + } + + public static class Builder { + + private String storageId; + private String description; + private String name; + + public Builder storageId(String storageId) { + this.storageId = storageId; + return this; + } + + public Builder description(String description) { + this.description = description; + return this; + } + + public Builder name(String name) { + this.name = name; + return this; + } + + public CreatePayload build() { + return CreatePayload.create(storageId, description, name); + } + } + } + + @AutoValue + public abstract static class UpdatePayload { + + public abstract String snapshotId(); + + public abstract String description(); + + public abstract String name(); + + public abstract boolean bootable(); + + @Nullable + public abstract OsType osType(); + + public abstract boolean cpuHotplug(); + + public abstract boolean cpuHotunplug(); + + public abstract boolean ramHotplug(); + + public abstract boolean ramHotunplug(); + + public abstract boolean nicHotplug(); + + public abstract boolean nicHotunplug(); + + public abstract boolean discVirtioHotplug(); + + public abstract boolean discVirtioHotunplug(); + + public static UpdatePayload create(String snapshotId, String description, String name, boolean bootable, OsType osType, boolean cpuHotplug, boolean cpuHotunplug, boolean ramHotplug, boolean ramHotunplug, boolean nicHotplug, boolean nicHotunplug, boolean discVirtioHotplug, boolean discVirtioHotunplug) { + return new AutoValue_Snapshot_Request_UpdatePayload(snapshotId, description, name, bootable, osType, cpuHotplug, cpuHotunplug, ramHotplug, ramHotunplug, nicHotplug, nicHotunplug, discVirtioHotplug, discVirtioHotunplug); + } + + public static class Builder { + + private String snapshotId; + + @Nullable + private String description; + + @Nullable + private String name; + + private boolean bootable; + + private OsType osType; + + private boolean cpuHotplug; + + private boolean cpuHotunplug; + + private boolean ramHotplug; + + private boolean ramHotunplug; + + private boolean nicHotplug; + + private boolean nicHotunplug; + + private boolean discVirtioHotplug; + + private boolean discVirtioHotunplug; + + public Builder snapshotId(String snapshotId) { + this.snapshotId = snapshotId; + return this; + } + + public Builder description(String description) { + this.description = description; + return this; + } + + public Builder name(String name) { + this.name = name; + return this; + } + + public Builder bootable(boolean bootable) { + this.bootable = bootable; + return this; + } + + public Builder osType(OsType osType) { + this.osType = osType; + return this; + } + + public Builder cpuHotplug(boolean cpuHotplug) { + this.cpuHotplug = cpuHotplug; + return this; + } + + public Builder cpuHotunplug(boolean cpuHotunplug) { + this.cpuHotunplug = cpuHotunplug; + return this; + } + + public Builder ramHotplug(boolean ramHotplug) { + this.ramHotplug = ramHotplug; + return this; + } + + public Builder ramHotunplug(boolean ramHotunplug) { + this.ramHotunplug = ramHotunplug; + return this; + } + + public Builder nicHotplug(boolean nicHotplug) { + this.nicHotplug = nicHotplug; + return this; + } + + public Builder nicHotunplug(boolean nicHotunplug) { + this.nicHotunplug = nicHotunplug; + return this; + } + + public Builder discVirtioHotplug(boolean discVirtioHotplug) { + this.discVirtioHotplug = discVirtioHotplug; + return this; + } + + public Builder discVirtioHotunplug(boolean discVirtioHotunplug) { + this.discVirtioHotunplug = discVirtioHotunplug; + return this; + } + + public UpdatePayload build() { + return UpdatePayload.create(snapshotId, description, name, bootable, osType, cpuHotplug, cpuHotunplug, ramHotplug, ramHotunplug, nicHotplug, nicHotunplug, discVirtioHotplug, discVirtioHotunplug); + } + } + + } + + @AutoValue + public abstract static class RollbackPayload { + + public abstract String snapshotId(); + + public abstract String storageId(); + + public static RollbackPayload create(String snapshotId, String storageId) { + return new AutoValue_Snapshot_Request_RollbackPayload(snapshotId, storageId); + } + + public static class Builder { + + private String snapshotId; + + private String storageId; + + public Builder snapshotId(String snapshotId) { + this.snapshotId = snapshotId; + return this; + } + + public Builder storageId(String storageId) { + this.storageId = storageId; + return this; + } + + public RollbackPayload build() { + return RollbackPayload.create(snapshotId, storageId); + } + } + } + } +} http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/main/java/org/jclouds/profitbricks/features/SnapshotApi.java ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/main/java/org/jclouds/profitbricks/features/SnapshotApi.java b/providers/profitbricks/src/main/java/org/jclouds/profitbricks/features/SnapshotApi.java new file mode 100644 index 0000000..3faa386 --- /dev/null +++ b/providers/profitbricks/src/main/java/org/jclouds/profitbricks/features/SnapshotApi.java @@ -0,0 +1,87 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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.profitbricks.features; + +import java.util.List; + +import javax.inject.Named; +import javax.ws.rs.Consumes; +import javax.ws.rs.POST; +import javax.ws.rs.Produces; +import javax.ws.rs.core.MediaType; + +import org.jclouds.Fallbacks; +import org.jclouds.http.filters.BasicAuthentication; +import org.jclouds.profitbricks.binder.snapshot.CreateSnapshotRequestBinder; +import org.jclouds.profitbricks.binder.snapshot.RollbackSnapshotRequestBinder; +import org.jclouds.profitbricks.binder.snapshot.UpdateSnapshotRequestBinder; +import org.jclouds.profitbricks.domain.Snapshot; +import org.jclouds.profitbricks.http.filters.ProfitBricksSoapMessageEnvelope; +import org.jclouds.profitbricks.http.parser.RequestIdOnlyResponseHandler; +import org.jclouds.profitbricks.http.parser.snapshot.SnapshotResponseHandler; +import org.jclouds.profitbricks.http.parser.snapshot.SnapshotListResponseHandler; +import org.jclouds.rest.annotations.Fallback; +import org.jclouds.rest.annotations.MapBinder; +import org.jclouds.rest.annotations.Payload; +import org.jclouds.rest.annotations.PayloadParam; +import org.jclouds.rest.annotations.RequestFilters; +import org.jclouds.rest.annotations.XMLResponseParser; + +@RequestFilters({BasicAuthentication.class, ProfitBricksSoapMessageEnvelope.class}) +@Consumes(MediaType.TEXT_XML) +@Produces(MediaType.TEXT_XML) +public interface SnapshotApi { + + @POST + @Named("snapshot:getall") + @Payload("<ws:getAllSnapshots/>") + @XMLResponseParser(SnapshotListResponseHandler.class) + @Fallback(Fallbacks.EmptyListOnNotFoundOr404.class) + List<Snapshot> getAllSnapshots(); + + @POST + @Named("snapshot:get") + @Payload("<ws:getSnapshot><snapshotId>{snapshotId}</snapshotId></ws:getSnapshot>") + @XMLResponseParser(SnapshotResponseHandler.class) + @Fallback(Fallbacks.NullOnNotFoundOr404.class) + Snapshot getSnapshot(@PayloadParam("snapshotId") String identifier); + + @POST + @Named("snapshot:create") + @MapBinder(CreateSnapshotRequestBinder.class) + @XMLResponseParser(SnapshotResponseHandler.class) + Snapshot createSnapshot(@PayloadParam("snapshot") Snapshot.Request.CreatePayload payload); + + @POST + @Named("snapshot:update") + @MapBinder(UpdateSnapshotRequestBinder.class) + @XMLResponseParser(RequestIdOnlyResponseHandler.class) + String updateSnapshot(@PayloadParam("snapshot") Snapshot.Request.UpdatePayload payload); + + @POST + @Named("snapshot:delete") + @Payload("<ws:deleteSnapshot><snapshotId>{id}</snapshotId></ws:deleteSnapshot>") + @Fallback(Fallbacks.FalseOnNotFoundOr404.class) + boolean deleteSnapshot(@PayloadParam("id") String id); + + @POST + @Named("snapshot:rollback") + @MapBinder(RollbackSnapshotRequestBinder.class) + @XMLResponseParser(RequestIdOnlyResponseHandler.class) + String rollbackSnapshot(@PayloadParam("snapshot") Snapshot.Request.RollbackPayload payload); + +} http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/main/java/org/jclouds/profitbricks/http/parser/snapshot/BaseSnapshotResponseHandler.java ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/main/java/org/jclouds/profitbricks/http/parser/snapshot/BaseSnapshotResponseHandler.java b/providers/profitbricks/src/main/java/org/jclouds/profitbricks/http/parser/snapshot/BaseSnapshotResponseHandler.java new file mode 100644 index 0000000..0fa7fd6 --- /dev/null +++ b/providers/profitbricks/src/main/java/org/jclouds/profitbricks/http/parser/snapshot/BaseSnapshotResponseHandler.java @@ -0,0 +1,83 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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.profitbricks.http.parser.snapshot; + +import java.util.Date; +import org.jclouds.date.DateCodec; +import org.jclouds.date.DateCodecFactory; +import org.jclouds.profitbricks.domain.Location; +import org.jclouds.profitbricks.domain.OsType; +import org.jclouds.profitbricks.domain.ProvisioningState; +import org.jclouds.profitbricks.domain.Snapshot; +import org.jclouds.profitbricks.http.parser.BaseProfitBricksResponseHandler; + +public abstract class BaseSnapshotResponseHandler<T> extends BaseProfitBricksResponseHandler<T> { + + protected Snapshot.Builder builder; + + protected final DateCodec dateCodec; + + BaseSnapshotResponseHandler(DateCodecFactory dateCodec) { + this.dateCodec = dateCodec.iso8601(); + this.builder = Snapshot.builder(); + } + + protected final Date textToIso8601Date() { + return dateCodec.toDate(textToStringValue()); + } + + @Override + protected void setPropertyOnEndTag(String qName) { + if ("snapshotId".equals(qName)) + builder.id(textToStringValue()); + else if ("snapshotName".equals(qName)) + builder.name(textToStringValue()); + else if ("snapshotSize".equals(qName)) + builder.size(textToFloatValue()); + else if ("osType".equals(qName)) + builder.osType(OsType.fromValue(textToStringValue())); + else if ("location".equals(qName)) + builder.location(Location.fromId(textToStringValue())); + else if ("description".equals(qName)) + builder.description(qName); + else if ("bootable".equals(qName)) + builder.bootable(textToBooleanValue()); + else if ("cpuHotPlug".equals(qName)) + builder.cpuHotPlug(textToBooleanValue()); + else if ("cpuHotUnPlug".equals(qName)) + builder.cpuHotUnPlug(textToBooleanValue()); + else if ("ramHotPlug".equals(qName)) + builder.ramHotPlug(textToBooleanValue()); + else if ("ramHotUnPlug".equals(qName)) + builder.ramHotUnPlug(textToBooleanValue()); + else if ("nicHotPlug".equals(qName)) + builder.nicHotPlug(textToBooleanValue()); + else if ("nicHotUnPlug".equals(qName)) + builder.nicHotUnPlug(textToBooleanValue()); + else if ("discVirtioHotPlug".equals(qName)) + builder.discVirtioHotPlug(textToBooleanValue()); + else if ("discVirtioHotUnPlug".equals(qName)) + builder.discVirtioHotUnPlug(textToBooleanValue()); + else if ("provisioningState".equals(qName)) + builder.state(ProvisioningState.fromValue(textToStringValue())); + else if ("creationTimestamp".equals(qName)) + builder.creationTime(textToIso8601Date()); + else if ("modificationTimestamp".equals(qName)) + builder.lastModificationTime(textToIso8601Date()); + } + +} http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/main/java/org/jclouds/profitbricks/http/parser/snapshot/SnapshotListResponseHandler.java ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/main/java/org/jclouds/profitbricks/http/parser/snapshot/SnapshotListResponseHandler.java b/providers/profitbricks/src/main/java/org/jclouds/profitbricks/http/parser/snapshot/SnapshotListResponseHandler.java new file mode 100644 index 0000000..ae7a355 --- /dev/null +++ b/providers/profitbricks/src/main/java/org/jclouds/profitbricks/http/parser/snapshot/SnapshotListResponseHandler.java @@ -0,0 +1,52 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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.profitbricks.http.parser.snapshot; + +import com.google.common.collect.Lists; +import com.google.inject.Inject; +import org.jclouds.profitbricks.domain.Snapshot; +import org.xml.sax.SAXException; + +import java.util.List; +import org.jclouds.date.DateCodecFactory; + +public class SnapshotListResponseHandler extends BaseSnapshotResponseHandler<List<Snapshot>> { + + private final List<Snapshot> snapshots; + + @Inject + SnapshotListResponseHandler(DateCodecFactory dateCodec) { + super(dateCodec); + this.snapshots = Lists.newArrayList(); + } + + @Override + public void endElement(String uri, String localName, String qName) throws SAXException { + setPropertyOnEndTag(qName); + if ("return".equals(qName)) { + snapshots.add(builder.build()); + builder = Snapshot.builder(); + } + clearTextBuffer(); + } + + @Override + public List<Snapshot> getResult() { + return snapshots; + } + +} http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/main/java/org/jclouds/profitbricks/http/parser/snapshot/SnapshotResponseHandler.java ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/main/java/org/jclouds/profitbricks/http/parser/snapshot/SnapshotResponseHandler.java b/providers/profitbricks/src/main/java/org/jclouds/profitbricks/http/parser/snapshot/SnapshotResponseHandler.java new file mode 100644 index 0000000..84316f8 --- /dev/null +++ b/providers/profitbricks/src/main/java/org/jclouds/profitbricks/http/parser/snapshot/SnapshotResponseHandler.java @@ -0,0 +1,48 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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.profitbricks.http.parser.snapshot; + +import com.google.inject.Inject; +import org.jclouds.date.DateCodecFactory; +import org.jclouds.profitbricks.domain.Snapshot; +import org.xml.sax.SAXException; + +public class SnapshotResponseHandler extends BaseSnapshotResponseHandler<Snapshot> { + + private boolean done = false; + + @Inject + SnapshotResponseHandler(DateCodecFactory dateCodec) { + super(dateCodec); + } + + @Override + public void endElement(String uri, String localName, String qName) throws SAXException { + if (done) + return; + setPropertyOnEndTag(qName); + if ("return".equals(qName)) + done = true; + clearTextBuffer(); + } + + @Override + public Snapshot getResult() { + return builder.build(); + } + +} http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/test/java/org/jclouds/profitbricks/binder/snapshot/CreateSnapshotRequestBinderTest.java ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/test/java/org/jclouds/profitbricks/binder/snapshot/CreateSnapshotRequestBinderTest.java b/providers/profitbricks/src/test/java/org/jclouds/profitbricks/binder/snapshot/CreateSnapshotRequestBinderTest.java new file mode 100644 index 0000000..dda2ed6 --- /dev/null +++ b/providers/profitbricks/src/test/java/org/jclouds/profitbricks/binder/snapshot/CreateSnapshotRequestBinderTest.java @@ -0,0 +1,47 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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.profitbricks.binder.snapshot; + +import org.jclouds.profitbricks.domain.Snapshot; +import org.testng.annotations.Test; + +import static org.testng.Assert.assertEquals; +import static org.testng.Assert.assertNotNull; + +@Test(groups = "unit", testName = "CreateSnapshotRequestBinderTest") +public class CreateSnapshotRequestBinderTest { + + @Test + public void testCreatePayload() { + CreateSnapshotRequestBinder binder = new CreateSnapshotRequestBinder(); + + Snapshot.Request.CreatePayload payload = Snapshot.Request.CreatePayload.create("123-1233-1324", "describingthesnapshot", "snapshotname"); + + String actual = binder.createPayload(payload); + assertNotNull(actual, "Binder returned null payload"); + assertEquals(expectedPayload, actual); + } + + private final String expectedPayload + = (" <ws:createSnapshot>\n" + + "<request>\n" + + "<storageId>123-1233-1324</storageId>\n" + + "<description>describing the snapshot</description>\n" + + "<snapshotName>snapshot name</snapshotName>\n" + + "</request>\n" + + "</ws:createSnapshot>").replaceAll("\\s+", ""); +} http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/test/java/org/jclouds/profitbricks/binder/snapshot/RollbackSnapshotRequestBinderTest.java ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/test/java/org/jclouds/profitbricks/binder/snapshot/RollbackSnapshotRequestBinderTest.java b/providers/profitbricks/src/test/java/org/jclouds/profitbricks/binder/snapshot/RollbackSnapshotRequestBinderTest.java new file mode 100644 index 0000000..206cd79 --- /dev/null +++ b/providers/profitbricks/src/test/java/org/jclouds/profitbricks/binder/snapshot/RollbackSnapshotRequestBinderTest.java @@ -0,0 +1,47 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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.profitbricks.binder.snapshot; + +import org.jclouds.profitbricks.domain.Snapshot; +import static org.testng.Assert.assertEquals; +import static org.testng.Assert.assertNotNull; +import org.testng.annotations.Test; + +@Test(groups = "unit", testName = "RollbackSnapshotRequestBinderTest") +public class RollbackSnapshotRequestBinderTest { + + @Test + public void testRollbackPayload() { + RollbackSnapshotRequestBinder binder = new RollbackSnapshotRequestBinder(); + + Snapshot.Request.RollbackPayload payload = Snapshot.Request.rollbackBuilder() + .snapshotId("snapshot-id") + .storageId("storage-id") + .build(); + + String actual = binder.createPayload(payload); + assertNotNull(actual, "Binder returned null payload"); + assertEquals(expectedPayload, actual); + } + + private final String expectedPayload = "<ws:rollbackSnapshot>" + + "<request>" + + "<snapshotId>snapshot-id</snapshotId>" + + "<storageId>storage-id</storageId>" + + "</request>" + + "</ws:rollbackSnapshot>".replaceAll("\\s", ""); +} http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/test/java/org/jclouds/profitbricks/binder/snapshot/UpdateSnapshotRequestBinderTest.java ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/test/java/org/jclouds/profitbricks/binder/snapshot/UpdateSnapshotRequestBinderTest.java b/providers/profitbricks/src/test/java/org/jclouds/profitbricks/binder/snapshot/UpdateSnapshotRequestBinderTest.java new file mode 100644 index 0000000..3acb8e1 --- /dev/null +++ b/providers/profitbricks/src/test/java/org/jclouds/profitbricks/binder/snapshot/UpdateSnapshotRequestBinderTest.java @@ -0,0 +1,60 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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.profitbricks.binder.snapshot; + +import org.jclouds.profitbricks.domain.OsType; +import org.jclouds.profitbricks.domain.Snapshot; +import org.testng.annotations.Test; + +import static org.testng.Assert.assertEquals; +import static org.testng.Assert.assertNotNull; + +@Test(groups = "unit", testName = "UpdateSnapshotRequestBinderTest") +public class UpdateSnapshotRequestBinderTest { + + @Test + public void testUpdatePayload() { + UpdateSnapshotRequestBinder binder = new UpdateSnapshotRequestBinder(); + + Snapshot.Request.UpdatePayload payload = Snapshot.Request.UpdatePayload.create("qswdefrg-qaws-qaws-defe-rgrgdsvcxbrh", "description", "snapshot-name", true, OsType.LINUX, true, true, true, true, true, true, true, true); + + String actual = binder.createPayload(payload); + assertNotNull(actual, "Binder returned null payload"); + assertEquals(expectedPayload, actual); + + } + + private final String expectedPayload + = "<ws:updateSnapshot>" + + "<request>" + + "<snapshotId>qswdefrg-qaws-qaws-defe-rgrgdsvcxbrh</snapshotId>" + + "<description>description</description>" + + "<snapshotName>snapshot-name</snapshotName>" + + "<bootable>true</bootable>" + + "<osType>LINUX</osType>" + + "<cpuHotPlug>true</cpuHotPlug>" + + "<cpuHotUnPlug>true</cpuHotUnPlug>" + + "<ramHotPlug>true</ramHotPlug>" + + "<ramHotUnPlug>true</ramHotUnPlug>" + + "<nicHotPlug>true</nicHotPlug>" + + "<nicHotUnPlug>true</nicHotUnPlug>" + + "<discVirtioHotPlug>true</discVirtioHotPlug>" + + "<discVirtioHotUnPlug>true</discVirtioHotUnPlug>" + + "</request>" + + "</ws:updateSnapshot>".replaceAll("\\s", ""); + +} http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/test/java/org/jclouds/profitbricks/compute/internal/ProvisioningStatusPollingPredicateTest.java ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/test/java/org/jclouds/profitbricks/compute/internal/ProvisioningStatusPollingPredicateTest.java b/providers/profitbricks/src/test/java/org/jclouds/profitbricks/compute/internal/ProvisioningStatusPollingPredicateTest.java index f69fc02..857a8ff 100644 --- a/providers/profitbricks/src/test/java/org/jclouds/profitbricks/compute/internal/ProvisioningStatusPollingPredicateTest.java +++ b/providers/profitbricks/src/test/java/org/jclouds/profitbricks/compute/internal/ProvisioningStatusPollingPredicateTest.java @@ -136,5 +136,38 @@ public class ProvisioningStatusPollingPredicateTest extends BaseProfitBricksMock server.shutdown(); } } + + @Test + public void testSnapshotPredicate() throws Exception{ + MockWebServer server = mockWebServer(); + + byte[] payloadInProcess = payloadFromResource("/snapshot/snapshot-state-inprocess.xml"); + byte[] payloadAvailable = payloadFromResource("/snapshot/snapshot.xml"); + + // wait 3 times + server.enqueue(new MockResponse().setBody(payloadInProcess)); + server.enqueue(new MockResponse().setBody(payloadInProcess)); + server.enqueue(new MockResponse().setBody(payloadInProcess)); + server.enqueue(new MockResponse().setBody(payloadAvailable)); + + server.enqueue(new MockResponse().setBody(payloadAvailable)); + + ProfitBricksApi pbApi = api(server.getUrl(rootUrl)); + + Predicate<String> waitUntilAvailable = Predicates2.retry( + new ProvisioningStatusPollingPredicate(pbApi, ProvisioningStatusAware.SNAPSHOT, ProvisioningState.AVAILABLE), + 30l, 1l, TimeUnit.SECONDS); + + String id = "qswdefrg-qaws-qaws-defe-rgrgdsvcxbrh"; + try { + waitUntilAvailable.apply(id); + ProvisioningState finalState = pbApi.snapshotApi().getSnapshot(id).state(); + assertRequestHasCommonProperties(server.takeRequest()); + assertEquals(finalState, ProvisioningState.AVAILABLE); + } finally { + pbApi.close(); + server.shutdown(); + } + } } http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/test/java/org/jclouds/profitbricks/features/SnapshotApiLiveTest.java ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/test/java/org/jclouds/profitbricks/features/SnapshotApiLiveTest.java b/providers/profitbricks/src/test/java/org/jclouds/profitbricks/features/SnapshotApiLiveTest.java new file mode 100644 index 0000000..957555b --- /dev/null +++ b/providers/profitbricks/src/test/java/org/jclouds/profitbricks/features/SnapshotApiLiveTest.java @@ -0,0 +1,132 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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.profitbricks.features; + +import com.google.common.base.Predicate; +import com.google.common.collect.Iterables; +import org.jclouds.profitbricks.BaseProfitBricksLiveTest; +import org.jclouds.profitbricks.domain.OsType; +import org.jclouds.profitbricks.domain.Snapshot; +import org.testng.annotations.Test; + +import java.util.List; +import java.util.concurrent.TimeUnit; +import org.jclouds.profitbricks.compute.internal.ProvisioningStatusAware; +import org.jclouds.profitbricks.compute.internal.ProvisioningStatusPollingPredicate; +import org.jclouds.profitbricks.domain.ProvisioningState; +import org.jclouds.profitbricks.domain.Storage; +import org.jclouds.util.Predicates2; +import static org.testng.Assert.assertEquals; +import static org.testng.Assert.assertFalse; + +import static org.testng.Assert.assertNotNull; +import static org.testng.Assert.assertTrue; +import org.testng.annotations.AfterClass; + +@Test(groups = "live", testName = "SnapshotApiLiveTest", singleThreaded = true) +public class SnapshotApiLiveTest extends BaseProfitBricksLiveTest { + + protected Predicate<String> snapshotWaitingPredicate; + private String snapshotId; + private String storageId; + + @Override + protected void initialize() { + super.initialize(); + + initializeWaitPredicate(); + + List<Storage> storages = api.storageApi().getAllStorages(); + assertFalse(storages.isEmpty(), "Must atleast have 1 storage available for snapshot testing."); + + storageId = Iterables.getFirst(storages, null).id(); + } + + @Test + public void testCreateSnapshot() { + Snapshot snapshot = api.snapshotApi().createSnapshot(Snapshot.Request.CreatePayload.create(storageId, "my description", "test snapshot")); + + assertNotNull(snapshot); + + snapshotWaitingPredicate.apply(snapshot.id()); + + snapshotId = snapshot.id(); + } + + @Test(dependsOnMethods = "testCreateSnapshot") + public void testGetAllSnapshots() { + List<Snapshot> snapshots = api.snapshotApi().getAllSnapshots(); + + assertNotNull(snapshots); + assertTrue(snapshots.size() > 0); + } + + @Test(dependsOnMethods = "testCreateSnapshot") + public void testGetSnapshot() { + Snapshot snapshot = api.snapshotApi().getSnapshot(snapshotId); + + assertNotNull(snapshot); + assertEquals(snapshot.id(), snapshotId); + } + + @Test(dependsOnMethods = "testCreateSnapshot") + public void testUpdateSnapshot() { + + String newName = "new name"; + + api.snapshotApi().updateSnapshot(Snapshot.Request.updatingBuilder() + .snapshotId(snapshotId) + .description("new description") + .name(newName) + .bootable(true) + .osType(OsType.LINUX) + .cpuHotplug(true) + .cpuHotunplug(true) + .discVirtioHotplug(true) + .discVirtioHotunplug(true) + .nicHotplug(true) + .nicHotunplug(true) + .ramHotplug(true) + .ramHotunplug(true) + .build()); + + Snapshot snapshot = api.snapshotApi().getSnapshot(snapshotId); + + assertNotNull(snapshot); + assertEquals(snapshot.name(), newName); + } + + @Test(dependsOnMethods = "testCreateSnapshot") + public void testRollbackSnapshot() { + String result = api.snapshotApi().rollbackSnapshot(Snapshot.Request.RollbackPayload.create(snapshotId, storageId)); + + assertNotNull(result); + } + + @AfterClass(alwaysRun = true) + public void testDeleteSnapshot() { + boolean result = api.snapshotApi().deleteSnapshot(snapshotId); + + assertTrue(result); + } + + private void initializeWaitPredicate() { + this.snapshotWaitingPredicate = Predicates2.retry( + new ProvisioningStatusPollingPredicate(api, ProvisioningStatusAware.SNAPSHOT, ProvisioningState.AVAILABLE), + 2l * 60l, 2l, TimeUnit.SECONDS); + } +} http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/test/java/org/jclouds/profitbricks/features/SnapshotApiMockTest.java ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/test/java/org/jclouds/profitbricks/features/SnapshotApiMockTest.java b/providers/profitbricks/src/test/java/org/jclouds/profitbricks/features/SnapshotApiMockTest.java new file mode 100644 index 0000000..80342b0 --- /dev/null +++ b/providers/profitbricks/src/test/java/org/jclouds/profitbricks/features/SnapshotApiMockTest.java @@ -0,0 +1,262 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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.profitbricks.features; + +import com.squareup.okhttp.mockwebserver.MockResponse; +import com.squareup.okhttp.mockwebserver.MockWebServer; +import org.jclouds.profitbricks.ProfitBricksApi; +import org.jclouds.profitbricks.domain.OsType; +import org.jclouds.profitbricks.domain.Snapshot; +import org.jclouds.profitbricks.internal.BaseProfitBricksMockTest; +import org.testng.annotations.Test; + +import java.util.List; +import static org.jclouds.profitbricks.internal.BaseProfitBricksMockTest.mockWebServer; +import org.testng.Assert; +import static org.testng.Assert.assertEquals; +import static org.testng.Assert.assertNotNull; +import static org.testng.Assert.assertNull; +import static org.testng.Assert.assertTrue; + +/** + * Mock tests for the {@link org.jclouds.profitbricks.features.DataCenterApi} class + */ +@Test(groups = "unit", testName = "SnapshotApiMockTest") +public class SnapshotApiMockTest extends BaseProfitBricksMockTest { + + @Test + public void testGetAllSnapshots() throws Exception { + MockWebServer server = mockWebServer(); + server.enqueue(new MockResponse().setBody(payloadFromResource("/snapshot/snapshots.xml"))); + + ProfitBricksApi pbApi = api(server.getUrl(rootUrl)); + SnapshotApi api = pbApi.snapshotApi(); + + try { + List<Snapshot> snapshots = api.getAllSnapshots(); + assertRequestHasCommonProperties(server.takeRequest(), "<ws:getAllSnapshots/>"); + assertNotNull(snapshots); + assertEquals(snapshots.size(), 2); + } finally { + pbApi.close(); + server.shutdown(); + } + } + + @Test + public void testGetAllSnapshotsReturning404() throws Exception { + MockWebServer server = mockWebServer(); + server.enqueue(new MockResponse().setResponseCode(404)); + + ProfitBricksApi pbApi = api(server.getUrl(rootUrl)); + SnapshotApi api = pbApi.snapshotApi(); + + try { + List<Snapshot> snapshots = api.getAllSnapshots(); + assertRequestHasCommonProperties(server.takeRequest()); + assertTrue(snapshots.isEmpty()); + } finally { + pbApi.close(); + server.shutdown(); + } + } + + @Test + public void testGetSnapshot() throws Exception { + MockWebServer server = mockWebServer(); + server.enqueue(new MockResponse().setBody(payloadFromResource("/snapshot/snapshot.xml"))); + + ProfitBricksApi pbApi = api(server.getUrl(rootUrl)); + SnapshotApi api = pbApi.snapshotApi(); + + String id = "qswdefrg-qaws-qaws-defe-rgrgdsvcxbrh"; + + String content = "<ws:getSnapshot><snapshotId>" + id + "</snapshotId></ws:getSnapshot>"; + + try { + Snapshot snapshot = api.getSnapshot(id); + assertRequestHasCommonProperties(server.takeRequest(), content); + assertNotNull(snapshot); + assertEquals(snapshot.id(), id); + } finally { + pbApi.close(); + server.shutdown(); + } + } + + @Test + public void testGetNonExistingSnapshot() throws Exception { + MockWebServer server = mockWebServer(); + server.enqueue(new MockResponse().setResponseCode(404)); + + ProfitBricksApi pbApi = api(server.getUrl(rootUrl)); + SnapshotApi api = pbApi.snapshotApi(); + + String id = "random-non-existing-id"; + try { + Snapshot snapshot = api.getSnapshot(id); + assertRequestHasCommonProperties(server.takeRequest()); + assertNull(snapshot); + } finally { + pbApi.close(); + server.shutdown(); + } + } + + @Test + public void testCreateSnapshot() throws Exception { + MockWebServer server = mockWebServer(); + server.enqueue(new MockResponse().setBody(payloadFromResource("/snapshot/snapshot-create.xml"))); + + ProfitBricksApi pbApi = api(server.getUrl(rootUrl)); + SnapshotApi api = pbApi.snapshotApi(); + + String storageId = "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee"; + + String content = "<ws:createSnapshot>" + + "<request>" + + "<storageId>" + storageId + "</storageId>" + + "<description>description</description>" + + "<snapshotName>snapshot-name</snapshotName>" + + "</request>" + + "</ws:createSnapshot>"; + + try { + Snapshot snapshot = api.createSnapshot( + Snapshot.Request.creatingBuilder() + .storageId(storageId) + .description("description") + .name("snapshot-name") + .build()); + assertRequestHasCommonProperties(server.takeRequest(), content); + assertNotNull(snapshot.id()); + assertEquals(snapshot.id(), "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee"); + + } finally { + pbApi.close(); + server.shutdown(); + } + } + + @Test + public void testUpdateSnapshot() throws Exception { + MockWebServer server = mockWebServer(); + server.enqueue(new MockResponse().setBody(payloadFromResource("/snapshot/snapshot-update.xml"))); + + ProfitBricksApi pbApi = api(server.getUrl(rootUrl)); + SnapshotApi api = pbApi.snapshotApi(); + + String snapshotId = "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee"; + + String content = "<ws:updateSnapshot>" + + "<request>" + + "<snapshotId>" + snapshotId + "</snapshotId>" + + "<description>description</description>" + + "<snapshotName>snapshot-name</snapshotName>" + + "<bootable>false</bootable>" + + "<osType>LINUX</osType>" + + "<cpuHotPlug>false</cpuHotPlug>" + + "<cpuHotUnPlug>false</cpuHotUnPlug>" + + "<ramHotPlug>false</ramHotPlug>" + + "<ramHotUnPlug>false</ramHotUnPlug>" + + "<nicHotPlug>false</nicHotPlug>" + + "<nicHotUnPlug>false</nicHotUnPlug>" + + "<discVirtioHotPlug>false</discVirtioHotPlug>" + + "<discVirtioHotUnPlug>false</discVirtioHotUnPlug>" + + "</request>" + + "</ws:updateSnapshot>"; + + try { + String requestId = api.updateSnapshot(Snapshot.Request.updatingBuilder() + .snapshotId(snapshotId) + .name("snapshot-name") + .description("description") + .osType(OsType.LINUX) + .build()); + assertRequestHasCommonProperties(server.takeRequest(), content); + assertNotNull(requestId); + } finally { + pbApi.close(); + server.shutdown(); + } + } + + @Test + public void testDeleteSnapshot() throws Exception { + MockWebServer server = mockWebServer(); + server.enqueue(new MockResponse().setBody(payloadFromResource("/snapshot/snapshot-delete.xml"))); + + ProfitBricksApi pbApi = api(server.getUrl(rootUrl)); + SnapshotApi api = pbApi.snapshotApi(); + + String snapshotId = "qswdefrg-qaws-qaws-defe-rgrgdsvcxbrh"; + String content = "<ws:deleteSnapshot><snapshotId>" + snapshotId + "</snapshotId></ws:deleteSnapshot>"; + + try { + boolean result = api.deleteSnapshot(snapshotId); + assertRequestHasCommonProperties(server.takeRequest(), content); + assertTrue(result); + } finally { + pbApi.close(); + server.shutdown(); + } + } + + @Test + public void testDeleteNonExistingSnapshot() throws Exception { + MockWebServer server = mockWebServer(); + server.enqueue(new MockResponse().setResponseCode(404)); + + ProfitBricksApi pbApi = api(server.getUrl(rootUrl)); + SnapshotApi api = pbApi.snapshotApi(); + + String id = "random-non-existing-id"; + try { + boolean result = api.deleteSnapshot(id); + assertRequestHasCommonProperties(server.takeRequest()); + Assert.assertFalse(result); + } finally { + pbApi.close(); + server.shutdown(); + } + } + + @Test + public void testRollbackSnapshot() throws Exception { + MockWebServer server = mockWebServer(); + server.enqueue(new MockResponse().setBody(payloadFromResource("/snapshot/snapshot-rollback.xml"))); + + ProfitBricksApi pbApi = api(server.getUrl(rootUrl)); + SnapshotApi api = pbApi.snapshotApi(); + + String snapshotId = "qswdefrg-qaws-qaws-defe-rgrgdsvcxbrh"; + String storageId = "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee"; + + String content = "<ws:rollbackSnapshot><request><snapshotId>" + snapshotId + "</snapshotId><storageId>" + storageId + "</storageId></request></ws:rollbackSnapshot>"; + try { + String result = api.rollbackSnapshot(Snapshot.Request.rollbackBuilder() + .snapshotId(snapshotId) + .storageId(storageId) + .build()); + assertRequestHasCommonProperties(server.takeRequest(), content); + assertNotNull(result); + } finally { + pbApi.close(); + server.shutdown(); + } + } +} http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/test/java/org/jclouds/profitbricks/http/parser/snapshot/SnapshotListResponseHandlerTest.java ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/test/java/org/jclouds/profitbricks/http/parser/snapshot/SnapshotListResponseHandlerTest.java b/providers/profitbricks/src/test/java/org/jclouds/profitbricks/http/parser/snapshot/SnapshotListResponseHandlerTest.java new file mode 100644 index 0000000..38dfa1e --- /dev/null +++ b/providers/profitbricks/src/test/java/org/jclouds/profitbricks/http/parser/snapshot/SnapshotListResponseHandlerTest.java @@ -0,0 +1,100 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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.profitbricks.http.parser.snapshot; + +import com.google.common.collect.Lists; +import java.util.List; +import org.jclouds.date.DateCodec; +import org.jclouds.date.DateCodecFactory; +import org.jclouds.http.functions.ParseSax; +import org.jclouds.profitbricks.domain.Location; +import org.jclouds.profitbricks.domain.OsType; +import org.jclouds.profitbricks.domain.ProvisioningState; +import org.jclouds.profitbricks.domain.Snapshot; +import org.jclouds.profitbricks.http.parser.BaseResponseHandlerTest; +import static org.testng.Assert.assertEquals; +import static org.testng.Assert.assertNotNull; +import org.testng.annotations.Test; + +@Test(groups = "unit", testName = "SnapshotListResponseHandlerTest") +public class SnapshotListResponseHandlerTest extends BaseResponseHandlerTest<List<Snapshot>> { + + @Override + protected ParseSax<List<Snapshot>> createParser() { + return factory.create(injector.getInstance(SnapshotListResponseHandler.class)); + } + + protected DateCodecFactory createDateParser() { + return injector.getInstance(DateCodecFactory.class); + } + + @Test + public void testParseResponseFromGetSnapshot() { + ParseSax<List<Snapshot>> parser = createParser(); + + List<Snapshot> actual = parser.parse(payloadFromResource("/snapshot/snapshots.xml")); + assertNotNull(actual); + + DateCodec dateParser = createDateParser().iso8601(); + + List<Snapshot> expected = Lists.newArrayList(); + + expected.add(Snapshot.builder() + .id("aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee") + .description("description") + .size(1024) + .name("snapshot01") + .state(ProvisioningState.AVAILABLE) + .bootable(true) + .osType(OsType.LINUX) + .cpuHotPlug(true) + .cpuHotUnPlug(true) + .discVirtioHotPlug(true) + .discVirtioHotUnPlug(true) + .ramHotPlug(true) + .ramHotUnPlug(true) + .nicHotPlug(true) + .nicHotUnPlug(true) + .location(Location.US_LAS) + .creationTime(dateParser.toDate("2015-01-26T07:09:23.138Z")) + .lastModificationTime(dateParser.toDate("2015-01-26T07:09:23.138Z")) + .build()); + + expected.add(Snapshot.builder() + .id("qqqqqqqq-wwww-rrrr-tttt-yyyyyyyyyyyy") + .description("description") + .size(1024) + .name("snapshot02") + .state(ProvisioningState.AVAILABLE) + .bootable(true) + .osType(OsType.LINUX) + .cpuHotPlug(true) + .cpuHotUnPlug(true) + .discVirtioHotPlug(true) + .discVirtioHotUnPlug(true) + .ramHotPlug(true) + .ramHotUnPlug(true) + .nicHotPlug(true) + .nicHotUnPlug(true) + .location(Location.US_LAS) + .creationTime(dateParser.toDate("2015-01-26T07:09:23.138Z")) + .lastModificationTime(dateParser.toDate("2015-01-26T07:09:23.138Z")) + .build()); + + assertEquals(actual, expected); + } +} http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/test/java/org/jclouds/profitbricks/http/parser/snapshot/SnapshotResponseHandlerTest.java ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/test/java/org/jclouds/profitbricks/http/parser/snapshot/SnapshotResponseHandlerTest.java b/providers/profitbricks/src/test/java/org/jclouds/profitbricks/http/parser/snapshot/SnapshotResponseHandlerTest.java new file mode 100644 index 0000000..9928e92 --- /dev/null +++ b/providers/profitbricks/src/test/java/org/jclouds/profitbricks/http/parser/snapshot/SnapshotResponseHandlerTest.java @@ -0,0 +1,76 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You 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.profitbricks.http.parser.snapshot; + +import org.jclouds.date.DateCodec; +import org.jclouds.date.DateCodecFactory; +import org.jclouds.http.functions.ParseSax; +import org.jclouds.profitbricks.domain.Location; +import org.jclouds.profitbricks.domain.OsType; +import org.jclouds.profitbricks.domain.ProvisioningState; +import org.jclouds.profitbricks.domain.Snapshot; +import org.jclouds.profitbricks.http.parser.BaseResponseHandlerTest; +import static org.testng.Assert.assertEquals; +import static org.testng.Assert.assertNotNull; +import org.testng.annotations.Test; + +@Test(groups = "unit", testName = "ServerResponseHandlerTest") +public class SnapshotResponseHandlerTest extends BaseResponseHandlerTest<Snapshot> { + + @Override + protected ParseSax<Snapshot> createParser() { + return factory.create(injector.getInstance(SnapshotResponseHandler.class)); + } + + protected DateCodecFactory createDateParser() { + return injector.getInstance(DateCodecFactory.class); + } + + @Test + public void testParseResponseFromGetSnapshot() { + ParseSax<Snapshot> parser = createParser(); + + Snapshot actual = parser.parse(payloadFromResource("/snapshot/snapshot.xml")); + assertNotNull(actual, "Parsed content returned null"); + + DateCodec dateParser = createDateParser().iso8601(); + + Snapshot expected = Snapshot.builder() + .id("qswdefrg-qaws-qaws-defe-rgrgdsvcxbrh") + .description("description") + .size(1024) + .name("snapshot01") + .state(ProvisioningState.AVAILABLE) + .bootable(true) + .osType(OsType.LINUX) + .cpuHotPlug(true) + .cpuHotUnPlug(true) + .discVirtioHotPlug(true) + .discVirtioHotUnPlug(true) + .ramHotPlug(true) + .ramHotUnPlug(true) + .nicHotPlug(true) + .nicHotUnPlug(true) + .location(Location.US_LAS) + .creationTime(dateParser.toDate("2015-01-26T07:09:23.138Z")) + .lastModificationTime(dateParser.toDate("2015-01-26T07:09:23.138Z")) + .build(); + + assertEquals(actual, expected); + + } +} http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/test/resources/snapshot/snapshot-create.xml ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/test/resources/snapshot/snapshot-create.xml b/providers/profitbricks/src/test/resources/snapshot/snapshot-create.xml new file mode 100644 index 0000000..06a537d --- /dev/null +++ b/providers/profitbricks/src/test/resources/snapshot/snapshot-create.xml @@ -0,0 +1,11 @@ +<?xml version="1.0" encoding="UTF-8"?> +<S:Envelope xmlns:S="http://schemas.xmlsoap.org/soap/envelope/";> + <S:Body> + <ns2:createSnapshotReturn xmlns:ns2="http://ws.api.profitbricks.com/";> + <return> + <requestId>12345678</requestId> + <snapshotId>aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee</snapshotId> + </return> + </ns2:createSnapshotReturn> + </S:Body> +</S:Envelope> http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/test/resources/snapshot/snapshot-delete.xml ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/test/resources/snapshot/snapshot-delete.xml b/providers/profitbricks/src/test/resources/snapshot/snapshot-delete.xml new file mode 100644 index 0000000..45bf1a3 --- /dev/null +++ b/providers/profitbricks/src/test/resources/snapshot/snapshot-delete.xml @@ -0,0 +1,10 @@ +<?xml version="1.0" encoding="UTF-8"?> +<S:Envelope xmlns:S="http://schemas.xmlsoap.org/soap/envelope/";> + <S:Body> + <ns2:deleteSnapshotResponse xmlns:ns2="http://ws.api.profitbricks.com/";> + <return> + <requestId>123456789</requestId> + </return> + </ns2:deleteSnapshotResponse> + </S:Body> +</S:Envelope> http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/test/resources/snapshot/snapshot-rollback.xml ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/test/resources/snapshot/snapshot-rollback.xml b/providers/profitbricks/src/test/resources/snapshot/snapshot-rollback.xml new file mode 100644 index 0000000..661ce21 --- /dev/null +++ b/providers/profitbricks/src/test/resources/snapshot/snapshot-rollback.xml @@ -0,0 +1,12 @@ +<?xml version="1.0" encoding="UTF-8"?> +<S:Envelope xmlns:S="http://schemas.xmlsoap.org/soap/envelope/";> + <S:Body> + <ns2:rollbackSnapshotResponse xmlns:ns2="http://ws.api.profitbricks.com/";> + <return> + <requestId>1234567890</requestId> + <dataCenterId>qswdefrg-qaws-qaws-defe-rgrgdsvcxbrh</dataCenterId> + <dataCenterVersion>1</dataCenterVersion> + </return> + </ns2:rollbackSnapshotResponse> + </S:Body> +</S:Envelope> http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/test/resources/snapshot/snapshot-state-inprocess.xml ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/test/resources/snapshot/snapshot-state-inprocess.xml b/providers/profitbricks/src/test/resources/snapshot/snapshot-state-inprocess.xml new file mode 100644 index 0000000..9f8acff --- /dev/null +++ b/providers/profitbricks/src/test/resources/snapshot/snapshot-state-inprocess.xml @@ -0,0 +1,27 @@ +<?xml version="1.0" encoding="UTF-8"?> +<S:Envelope xmlns:S="http://schemas.xmlsoap.org/soap/envelope/";> + <S:Body> + <ns2:getSnapshotResponse xmlns:ns2="http://ws.api.profitbricks.com/";> + <return> + <snapshotId>qswdefrg-qaws-qaws-defe-rgrgdsvcxbrh</snapshotId> + <description>description</description> + <snapshotSize>1024</snapshotSize> + <snapshotName>snapshot01</snapshotName> + <provisioningState>INPROCESS</provisioningState> + <bootable>true</bootable> + <osType>LINUX</osType> + <cpuHotPlug>true</cpuHotPlug> + <cpuHotUnPlug>true</cpuHotUnPlug> + <discVirtioHotPlug>true</discVirtioHotPlug> + <discVirtioHotUnPlug>true</discVirtioHotUnPlug> + <ramHotPlug>true</ramHotPlug> + <ramHotUnPlug>true</ramHotUnPlug> + <nicHotPlug>true</nicHotPlug> + <nicHotUnPlug>true</nicHotUnPlug> + <creationTimestamp>2015-01-26T07:09:23.138Z</creationTimestamp> + <modificationTimestamp>2015-01-26T07:09:23.138Z</modificationTimestamp> + <location>us/las</location> + </return> + </ns2:getSnapshotResponse> + </S:Body> +</S:Envelope> http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/test/resources/snapshot/snapshot-update.xml ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/test/resources/snapshot/snapshot-update.xml b/providers/profitbricks/src/test/resources/snapshot/snapshot-update.xml new file mode 100644 index 0000000..028cce0 --- /dev/null +++ b/providers/profitbricks/src/test/resources/snapshot/snapshot-update.xml @@ -0,0 +1,10 @@ +<?xml version="1.0" encoding="UTF-8"?> +<S:Envelope xmlns:S="http://schemas.xmlsoap.org/soap/envelope/";> + <S:Body> + <ns2:updateSnapshotResponse xmlns:ns2="http://ws.api.profitbricks.com/";> + <return> + <requestId>12345678</requestId> + </return> + </ns2:updateSnapshotResponse> + </S:Body> +</S:Envelope> http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/test/resources/snapshot/snapshot.xml ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/test/resources/snapshot/snapshot.xml b/providers/profitbricks/src/test/resources/snapshot/snapshot.xml new file mode 100644 index 0000000..d406be1 --- /dev/null +++ b/providers/profitbricks/src/test/resources/snapshot/snapshot.xml @@ -0,0 +1,27 @@ +<?xml version="1.0" encoding="UTF-8"?> +<S:Envelope xmlns:S="http://schemas.xmlsoap.org/soap/envelope/";> + <S:Body> + <ns2:getSnapshotResponse xmlns:ns2="http://ws.api.profitbricks.com/";> + <return> + <snapshotId>qswdefrg-qaws-qaws-defe-rgrgdsvcxbrh</snapshotId> + <description>description</description> + <snapshotSize>1024</snapshotSize> + <snapshotName>snapshot01</snapshotName> + <provisioningState>AVAILABLE</provisioningState> + <bootable>true</bootable> + <osType>LINUX</osType> + <cpuHotPlug>true</cpuHotPlug> + <cpuHotUnPlug>true</cpuHotUnPlug> + <discVirtioHotPlug>true</discVirtioHotPlug> + <discVirtioHotUnPlug>true</discVirtioHotUnPlug> + <ramHotPlug>true</ramHotPlug> + <ramHotUnPlug>true</ramHotUnPlug> + <nicHotPlug>true</nicHotPlug> + <nicHotUnPlug>true</nicHotUnPlug> + <creationTimestamp>2015-01-26T07:09:23.138Z</creationTimestamp> + <modificationTimestamp>2015-01-26T07:09:23.138Z</modificationTimestamp> + <location>us/las</location> + </return> + </ns2:getSnapshotResponse> + </S:Body> +</S:Envelope> http://git-wip-us.apache.org/repos/asf/jclouds/blob/36d499b4/providers/profitbricks/src/test/resources/snapshot/snapshots.xml ---------------------------------------------------------------------- diff --git a/providers/profitbricks/src/test/resources/snapshot/snapshots.xml b/providers/profitbricks/src/test/resources/snapshot/snapshots.xml new file mode 100644 index 0000000..d59826a --- /dev/null +++ b/providers/profitbricks/src/test/resources/snapshot/snapshots.xml @@ -0,0 +1,47 @@ +<?xml version="1.0" encoding="UTF-8"?> +<S:Envelope xmlns:S="http://schemas.xmlsoap.org/soap/envelope/";> + <S:Body> + <ns2:getAllSnapshotsResponse xmlns:ns2="http://ws.api.profitbricks.com/";> + <return> + <snapshotId>aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee</snapshotId> + <description>description</description> + <snapshotSize>1024</snapshotSize> + <snapshotName>snapshot01</snapshotName> + <provisioningState>AVAILABLE</provisioningState> + <bootable>true</bootable> + <osType>LINUX</osType> + <cpuHotPlug>true</cpuHotPlug> + <cpuHotUnPlug>true</cpuHotUnPlug> + <discVirtioHotPlug>true</discVirtioHotPlug> + <discVirtioHotUnPlug>true</discVirtioHotUnPlug> + <ramHotPlug>true</ramHotPlug> + <ramHotUnPlug>true</ramHotUnPlug> + <nicHotPlug>true</nicHotPlug> + <nicHotUnPlug>true</nicHotUnPlug> + <creationTimestamp>2015-01-26T07:09:23.138Z</creationTimestamp> + <modificationTimestamp>2015-01-26T07:09:23.138Z</modificationTimestamp> + <location>us/las</location> + </return> + <return> + <snapshotId>qqqqqqqq-wwww-rrrr-tttt-yyyyyyyyyyyy</snapshotId> + <description>description</description> + <snapshotSize>1024</snapshotSize> + <snapshotName>snapshot02</snapshotName> + <provisioningState>AVAILABLE</provisioningState> + <bootable>true</bootable> + <osType>LINUX</osType> + <cpuHotPlug>true</cpuHotPlug> + <cpuHotUnPlug>true</cpuHotUnPlug> + <discVirtioHotPlug>true</discVirtioHotPlug> + <discVirtioHotUnPlug>true</discVirtioHotUnPlug> + <ramHotPlug>true</ramHotPlug> + <ramHotUnPlug>true</ramHotUnPlug> + <nicHotPlug>true</nicHotPlug> + <nicHotUnPlug>true</nicHotUnPlug> + <creationTimestamp>2015-01-26T07:09:23.138Z</creationTimestamp> + <modificationTimestamp>2015-01-26T07:09:23.138Z</modificationTimestamp> + <location>us/las</location> + </return> + </ns2:getAllSnapshotsResponse> + </S:Body> +</S:Envelope>
