Updating to BP API 5.2 commit 1755379 (#581)

Author: RachelTucker

build.gradle

@@ -36,7 +36,7 @@ plugins {
 
 allprojects {
     group = 'com.spectralogic.ds3'
-    version = '5.1.3'
+    version = '5.2.0'
 }
 
 subprojects {

ds3-sdk/src/main/java/com/spectralogic/ds3client/Ds3Client.java

@@ -965,6 +965,13 @@ ModifyNodeSpectraS3Response modifyNodeSpectraS3(final ModifyNodeSpectraS3Request
     PutAzureTargetFailureNotificationRegistrationSpectraS3Response putAzureTargetFailureNotificationRegistrationSpectraS3(final PutAzureTargetFailureNotificationRegistrationSpectraS3Request request)
             throws IOException;
 
+    @ResponsePayloadModel("BucketChangesNotificationRegistration")
+    @Action("CREATE")
+    @Resource("BUCKET_CHANGES_NOTIFICATION_REGISTRATION")
+    
+    PutBucketChangesNotificationRegistrationSpectraS3Response putBucketChangesNotificationRegistrationSpectraS3(final PutBucketChangesNotificationRegistrationSpectraS3Request request)
+            throws IOException;
+
     @ResponsePayloadModel("Ds3TargetFailureNotificationRegistration")
     @Action("CREATE")
     @Resource("DS3_TARGET_FAILURE_NOTIFICATION_REGISTRATION")
@@ -1062,6 +1069,12 @@ PutTapePartitionFailureNotificationRegistrationSpectraS3Response putTapePartitio
     DeleteAzureTargetFailureNotificationRegistrationSpectraS3Response deleteAzureTargetFailureNotificationRegistrationSpectraS3(final DeleteAzureTargetFailureNotificationRegistrationSpectraS3Request request)
             throws IOException;
 
+    @Action("DELETE")
+    @Resource("BUCKET_CHANGES_NOTIFICATION_REGISTRATION")
+    
+    DeleteBucketChangesNotificationRegistrationSpectraS3Response deleteBucketChangesNotificationRegistrationSpectraS3(final DeleteBucketChangesNotificationRegistrationSpectraS3Request request)
+            throws IOException;
+
     @Action("DELETE")
     @Resource("DS3_TARGET_FAILURE_NOTIFICATION_REGISTRATION")
 
@@ -1154,6 +1167,27 @@ GetAzureTargetFailureNotificationRegistrationSpectraS3Response getAzureTargetFai
     GetAzureTargetFailureNotificationRegistrationsSpectraS3Response getAzureTargetFailureNotificationRegistrationsSpectraS3(final GetAzureTargetFailureNotificationRegistrationsSpectraS3Request request)
             throws IOException;
 
+    @ResponsePayloadModel("BucketChangesNotificationRegistration")
+    @Action("SHOW")
+    @Resource("BUCKET_CHANGES_NOTIFICATION_REGISTRATION")
+    
+    GetBucketChangesNotificationRegistrationSpectraS3Response getBucketChangesNotificationRegistrationSpectraS3(final GetBucketChangesNotificationRegistrationSpectraS3Request request)
+            throws IOException;
+
+    @ResponsePayloadModel("BucketChangesNotificationRegistrationList")
+    @Action("LIST")
+    @Resource("BUCKET_CHANGES_NOTIFICATION_REGISTRATION")
+    
+    GetBucketChangesNotificationRegistrationsSpectraS3Response getBucketChangesNotificationRegistrationsSpectraS3(final GetBucketChangesNotificationRegistrationsSpectraS3Request request)
+            throws IOException;
+
+    @ResponsePayloadModel("BucketHistoryEventList")
+    @Action("LIST")
+    @Resource("BUCKET_HISTORY")
+    
+    GetBucketHistorySpectraS3Response getBucketHistorySpectraS3(final GetBucketHistorySpectraS3Request request)
+            throws IOException;
+
     @ResponsePayloadModel("Ds3TargetFailureNotificationRegistration")
     @Action("SHOW")
     @Resource("DS3_TARGET_FAILURE_NOTIFICATION_REGISTRATION")

ds3-sdk/src/main/java/com/spectralogic/ds3client/Ds3ClientImpl.java

@@ -614,6 +614,10 @@ public PutAzureTargetFailureNotificationRegistrationSpectraS3Response putAzureTa
         return new PutAzureTargetFailureNotificationRegistrationSpectraS3ResponseParser().response(this.netClient.getResponse(request));
     }
     @Override
+    public PutBucketChangesNotificationRegistrationSpectraS3Response putBucketChangesNotificationRegistrationSpectraS3(final PutBucketChangesNotificationRegistrationSpectraS3Request request) throws IOException {
+        return new PutBucketChangesNotificationRegistrationSpectraS3ResponseParser().response(this.netClient.getResponse(request));
+    }
+    @Override
     public PutDs3TargetFailureNotificationRegistrationSpectraS3Response putDs3TargetFailureNotificationRegistrationSpectraS3(final PutDs3TargetFailureNotificationRegistrationSpectraS3Request request) throws IOException {
         return new PutDs3TargetFailureNotificationRegistrationSpectraS3ResponseParser().response(this.netClient.getResponse(request));
     }
@@ -670,6 +674,10 @@ public DeleteAzureTargetFailureNotificationRegistrationSpectraS3Response deleteA
         return new DeleteAzureTargetFailureNotificationRegistrationSpectraS3ResponseParser().response(this.netClient.getResponse(request));
     }
     @Override
+    public DeleteBucketChangesNotificationRegistrationSpectraS3Response deleteBucketChangesNotificationRegistrationSpectraS3(final DeleteBucketChangesNotificationRegistrationSpectraS3Request request) throws IOException {
+        return new DeleteBucketChangesNotificationRegistrationSpectraS3ResponseParser().response(this.netClient.getResponse(request));
+    }
+    @Override
     public DeleteDs3TargetFailureNotificationRegistrationSpectraS3Response deleteDs3TargetFailureNotificationRegistrationSpectraS3(final DeleteDs3TargetFailureNotificationRegistrationSpectraS3Request request) throws IOException {
         return new DeleteDs3TargetFailureNotificationRegistrationSpectraS3ResponseParser().response(this.netClient.getResponse(request));
     }
@@ -730,6 +738,18 @@ public GetAzureTargetFailureNotificationRegistrationsSpectraS3Response getAzureT
         return new GetAzureTargetFailureNotificationRegistrationsSpectraS3ResponseParser().response(this.netClient.getResponse(request));
     }
     @Override
+    public GetBucketChangesNotificationRegistrationSpectraS3Response getBucketChangesNotificationRegistrationSpectraS3(final GetBucketChangesNotificationRegistrationSpectraS3Request request) throws IOException {
+        return new GetBucketChangesNotificationRegistrationSpectraS3ResponseParser().response(this.netClient.getResponse(request));
+    }
+    @Override
+    public GetBucketChangesNotificationRegistrationsSpectraS3Response getBucketChangesNotificationRegistrationsSpectraS3(final GetBucketChangesNotificationRegistrationsSpectraS3Request request) throws IOException {
+        return new GetBucketChangesNotificationRegistrationsSpectraS3ResponseParser().response(this.netClient.getResponse(request));
+    }
+    @Override
+    public GetBucketHistorySpectraS3Response getBucketHistorySpectraS3(final GetBucketHistorySpectraS3Request request) throws IOException {
+        return new GetBucketHistorySpectraS3ResponseParser().response(this.netClient.getResponse(request));
+    }
+    @Override
     public GetDs3TargetFailureNotificationRegistrationSpectraS3Response getDs3TargetFailureNotificationRegistrationSpectraS3(final GetDs3TargetFailureNotificationRegistrationSpectraS3Request request) throws IOException {
         return new GetDs3TargetFailureNotificationRegistrationSpectraS3ResponseParser().response(this.netClient.getResponse(request));
     }

ds3-sdk/src/main/java/com/spectralogic/ds3client/commands/CompleteBlobRequest.java

@@ -33,6 +33,8 @@ public class CompleteBlobRequest extends AbstractRequest {
 
     private final String job;
 
+    private long size;
+
     // Constructor
 
 
@@ -61,6 +63,13 @@ public CompleteBlobRequest(final String bucketName, final String objectName, fin
 
     }
 
+    public CompleteBlobRequest withSize(final long size) {
+        this.size = size;
+        this.updateQueryParam("size", size);
+        return this;
+    }
+
+
 
     @Override
     public HttpVerb getVerb() {
@@ -91,4 +100,9 @@ public String getJob() {
         return this.job;
     }
 
+
+    public long getSize() {
+        return this.size;
+    }
+
 }

ds3-sdk/src/main/java/com/spectralogic/ds3client/commands/GetObjectRequest.java

@@ -43,6 +43,8 @@ public class GetObjectRequest extends AbstractRequest {
 
     private final String objectName;
 
+    private boolean cachedOnly;
+
     private String job;
 
     private long offset;
@@ -130,6 +132,17 @@ public GetObjectRequest(final String bucketName, final String objectName, final
     }
 
 
+    public GetObjectRequest withCachedOnly(final boolean cachedOnly) {
+        this.cachedOnly = cachedOnly;
+        if (this.cachedOnly) {
+            this.getQueryParams().put("cached_only", null);
+        } else {
+            this.getQueryParams().remove("cached_only");
+        }
+        return this;
+    }
+
+
     public GetObjectRequest withJob(final UUID job) {
         this.job = job.toString();
         this.updateQueryParam("job", job);
@@ -256,6 +269,11 @@ public String getObjectName() {
     }
 
 
+    public boolean getCachedOnly() {
+        return this.cachedOnly;
+    }
+
+
     public String getJob() {
         return this.job;
     }

ds3-sdk/src/main/java/com/spectralogic/ds3client/commands/HeadObjectRequest.java

@@ -18,6 +18,8 @@
 
 import com.spectralogic.ds3client.networking.HttpVerb;
 import com.spectralogic.ds3client.commands.interfaces.AbstractRequest;
+import java.util.UUID;
+import com.google.common.net.UrlEscapers;
 
 public class HeadObjectRequest extends AbstractRequest {
 
@@ -27,6 +29,8 @@ public class HeadObjectRequest extends AbstractRequest {
 
     private final String objectName;
 
+    private String versionId;
+
     // Constructor
 
 
@@ -36,6 +40,20 @@ public HeadObjectRequest(final String bucketName, final String objectName) {
 
     }
 
+    public HeadObjectRequest withVersionId(final UUID versionId) {
+        this.versionId = versionId.toString();
+        this.updateQueryParam("version_id", versionId);
+        return this;
+    }
+
+
+    public HeadObjectRequest withVersionId(final String versionId) {
+        this.versionId = versionId;
+        this.updateQueryParam("version_id", versionId);
+        return this;
+    }
+
+
 
     @Override
     public HttpVerb getVerb() {
@@ -56,4 +74,9 @@ public String getObjectName() {
         return this.objectName;
     }
 
+
+    public String getVersionId() {
+        return this.versionId;
+    }
+
 }

ds3-sdk/src/main/java/com/spectralogic/ds3client/commands/PutMultiPartUploadPartRequest.java

@@ -19,6 +19,7 @@
 import com.spectralogic.ds3client.networking.HttpVerb;
 import com.spectralogic.ds3client.commands.interfaces.AbstractRequest;
 import java.util.UUID;
+import com.google.common.net.UrlEscapers;
 import javax.annotation.Nonnull;
 import com.google.common.base.Preconditions;
 import com.spectralogic.ds3client.utils.SeekableByteChannelInputStream;
@@ -62,7 +63,7 @@ public PutMultiPartUploadPartRequest(final String bucketName, final String objec
         this.stream = new SeekableByteChannelInputStream(channel);
     }
 
-
+    
     public PutMultiPartUploadPartRequest(final String bucketName, final String objectName, @Nonnull final SeekableByteChannel channel, final int partNumber, final long size, final String uploadId) {
         Preconditions.checkNotNull(channel, "Channel may not be null.");
         this.bucketName = bucketName;

ds3-sdk/src/main/java/com/spectralogic/ds3client/commands/parsers/DeleteBucketChangesNotificationRegistrationSpectraS3ResponseParser.java

@@ -0,0 +1,44 @@
+/*
+ * ******************************************************************************
+ *   Copyright 2014-2019 Spectra Logic Corporation. All Rights Reserved.
+ *   Licensed under the Apache License, Version 2.0 (the "License"). You may not use
+ *   this file except in compliance with the License. A copy of the License is located at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *   or in the "license" file accompanying this file.
+ *   This file 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.
+ * ****************************************************************************
+ */
+
+// This code is auto-generated, do not modify
+package com.spectralogic.ds3client.commands.parsers;
+
+import com.spectralogic.ds3client.commands.parsers.interfaces.AbstractResponseParser;
+import com.spectralogic.ds3client.commands.parsers.utils.ResponseParserUtils;
+import com.spectralogic.ds3client.commands.spectrads3.DeleteBucketChangesNotificationRegistrationSpectraS3Response;
+import com.spectralogic.ds3client.networking.WebResponse;
+import java.io.IOException;
+
+public class DeleteBucketChangesNotificationRegistrationSpectraS3ResponseParser extends AbstractResponseParser<DeleteBucketChangesNotificationRegistrationSpectraS3Response> {
+    private final int[] expectedStatusCodes = new int[]{204};
+
+    @Override
+    public DeleteBucketChangesNotificationRegistrationSpectraS3Response parseXmlResponse(final WebResponse response) throws IOException {
+        final int statusCode = response.getStatusCode();
+        if (ResponseParserUtils.validateStatusCode(statusCode, expectedStatusCodes)) {
+            switch (statusCode) {
+            case 204:
+                //There is no payload, return an empty response handler
+                return new DeleteBucketChangesNotificationRegistrationSpectraS3Response(this.getChecksum(), this.getChecksumType());
+
+            default:
+                assert false: "validateStatusCode should have made it impossible to reach this line";
+            }
+        }
+
+        throw ResponseParserUtils.createFailedRequest(response, expectedStatusCodes);
+    }
+}

ds3-sdk/src/main/java/com/spectralogic/ds3client/commands/parsers/GetBucketChangesNotificationRegistrationSpectraS3ResponseParser.java

@@ -0,0 +1,49 @@
+/*
+ * ******************************************************************************
+ *   Copyright 2014-2019 Spectra Logic Corporation. All Rights Reserved.
+ *   Licensed under the Apache License, Version 2.0 (the "License"). You may not use
+ *   this file except in compliance with the License. A copy of the License is located at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *   or in the "license" file accompanying this file.
+ *   This file 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.
+ * ****************************************************************************
+ */
+
+// This code is auto-generated, do not modify
+package com.spectralogic.ds3client.commands.parsers;
+
+import com.spectralogic.ds3client.commands.parsers.interfaces.AbstractResponseParser;
+import com.spectralogic.ds3client.commands.parsers.utils.ResponseParserUtils;
+import com.spectralogic.ds3client.commands.spectrads3.GetBucketChangesNotificationRegistrationSpectraS3Response;
+import com.spectralogic.ds3client.models.BucketChangesNotificationRegistration;
+import com.spectralogic.ds3client.networking.WebResponse;
+import com.spectralogic.ds3client.serializer.XmlOutput;
+import java.io.IOException;
+import java.io.InputStream;
+
+public class GetBucketChangesNotificationRegistrationSpectraS3ResponseParser extends AbstractResponseParser<GetBucketChangesNotificationRegistrationSpectraS3Response> {
+    private final int[] expectedStatusCodes = new int[]{200};
+
+    @Override
+    public GetBucketChangesNotificationRegistrationSpectraS3Response parseXmlResponse(final WebResponse response) throws IOException {
+        final int statusCode = response.getStatusCode();
+        if (ResponseParserUtils.validateStatusCode(statusCode, expectedStatusCodes)) {
+            switch (statusCode) {
+            case 200:
+                try (final InputStream inputStream = response.getResponseStream()) {
+                    final BucketChangesNotificationRegistration result = XmlOutput.fromXml(inputStream, BucketChangesNotificationRegistration.class);
+                    return new GetBucketChangesNotificationRegistrationSpectraS3Response(result, this.getChecksum(), this.getChecksumType());
+                }
+
+            default:
+                assert false: "validateStatusCode should have made it impossible to reach this line";
+            }
+        }
+
+        throw ResponseParserUtils.createFailedRequest(response, expectedStatusCodes);
+    }
+}

ds3-sdk/src/main/java/com/spectralogic/ds3client/commands/parsers/GetBucketChangesNotificationRegistrationsSpectraS3ResponseParser.java

@@ -0,0 +1,51 @@
+/*
+ * ******************************************************************************
+ *   Copyright 2014-2019 Spectra Logic Corporation. All Rights Reserved.
+ *   Licensed under the Apache License, Version 2.0 (the "License"). You may not use
+ *   this file except in compliance with the License. A copy of the License is located at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *   or in the "license" file accompanying this file.
+ *   This file 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.
+ * ****************************************************************************
+ */
+
+// This code is auto-generated, do not modify
+package com.spectralogic.ds3client.commands.parsers;
+
+import com.spectralogic.ds3client.commands.parsers.interfaces.AbstractResponseParser;
+import com.spectralogic.ds3client.commands.parsers.utils.ResponseParserUtils;
+import com.spectralogic.ds3client.commands.spectrads3.GetBucketChangesNotificationRegistrationsSpectraS3Response;
+import com.spectralogic.ds3client.models.BucketChangesNotificationRegistrationList;
+import com.spectralogic.ds3client.networking.WebResponse;
+import com.spectralogic.ds3client.serializer.XmlOutput;
+import java.io.IOException;
+import java.io.InputStream;
+
+public class GetBucketChangesNotificationRegistrationsSpectraS3ResponseParser extends AbstractResponseParser<GetBucketChangesNotificationRegistrationsSpectraS3Response> {
+    private final int[] expectedStatusCodes = new int[]{200};
+
+    @Override
+    public GetBucketChangesNotificationRegistrationsSpectraS3Response parseXmlResponse(final WebResponse response) throws IOException {
+        final int statusCode = response.getStatusCode();
+        final Integer pagingTruncated = parseIntHeader("page-truncated");
+        final Integer pagingTotalResultCount = parseIntHeader("total-result-count");
+        if (ResponseParserUtils.validateStatusCode(statusCode, expectedStatusCodes)) {
+            switch (statusCode) {
+            case 200:
+                try (final InputStream inputStream = response.getResponseStream()) {
+                    final BucketChangesNotificationRegistrationList result = XmlOutput.fromXml(inputStream, BucketChangesNotificationRegistrationList.class);
+                    return new GetBucketChangesNotificationRegistrationsSpectraS3Response(result, pagingTotalResultCount, pagingTruncated, this.getChecksum(), this.getChecksumType());
+                }
+
+            default:
+                assert false: "validateStatusCode should have made it impossible to reach this line";
+            }
+        }
+
+        throw ResponseParserUtils.createFailedRequest(response, expectedStatusCodes);
+    }
+}