Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -19,10 +19,10 @@
* Common classes required for S3 rest API's.
*/
@javax.xml.bind.annotation.XmlSchema(
namespace = "http://s3.amazonaws"
+ ".com/doc/2006-03-01/", elementFormDefault =
namespace = S3Consts.S3_XML_NAMESPACE, elementFormDefault =
javax.xml.bind.annotation.XmlNsForm.QUALIFIED,
xmlns = {
@javax.xml.bind.annotation.XmlNs(namespaceURI = "http://s3.amazonaws"
+ ".com/doc/2006-03-01/", prefix = "")})
@javax.xml.bind.annotation.XmlNs(namespaceURI = S3Consts.S3_XML_NAMESPACE, prefix = "")})
package org.apache.hadoop.ozone.s3.commontypes;

import org.apache.hadoop.ozone.s3.util.S3Consts;
Original file line number Diff line number Diff line change
Expand Up @@ -24,13 +24,14 @@
import javax.xml.bind.annotation.XmlElement;
import javax.xml.bind.annotation.XmlRootElement;
import org.apache.hadoop.ozone.OzoneConsts;
import org.apache.hadoop.ozone.s3.util.S3Consts;

/**
* Request for Complete Multipart Upload request.
*/
@XmlAccessorType(XmlAccessType.FIELD)
@XmlRootElement(name = "CompleteMultipartUpload", namespace =
"http://s3.amazonaws.com/doc/2006-03-01/")
S3Consts.S3_XML_NAMESPACE)
public class CompleteMultipartUploadRequest {

@XmlElement(name = "Part")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,14 +22,15 @@
import javax.xml.bind.annotation.XmlElement;
import javax.xml.bind.annotation.XmlRootElement;
import org.apache.hadoop.ozone.OzoneConsts;
import org.apache.hadoop.ozone.s3.util.S3Consts;

/**
* Complete Multipart Upload request response.
*/

@XmlAccessorType(XmlAccessType.FIELD)
@XmlRootElement(name = "CompleteMultipartUploadResult", namespace =
"http://s3.amazonaws.com/doc/2006-03-01/")
S3Consts.S3_XML_NAMESPACE)
public class CompleteMultipartUploadResponse {

@XmlElement(name = "Location")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,13 +25,14 @@
import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter;
import org.apache.hadoop.ozone.OzoneConsts;
import org.apache.hadoop.ozone.s3.commontypes.IsoDateAdapter;
import org.apache.hadoop.ozone.s3.util.S3Consts;

/**
* Copy object Response.
*/
@XmlAccessorType(XmlAccessType.FIELD)
@XmlRootElement(name = "CopyObjectResult",
namespace = "http://s3.amazonaws.com/doc/2006-03-01/")
namespace = S3Consts.S3_XML_NAMESPACE)
public class CopyObjectResponse {

@XmlJavaTypeAdapter(IsoDateAdapter.class)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,13 +25,14 @@
import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter;
import org.apache.hadoop.ozone.OzoneConsts;
import org.apache.hadoop.ozone.s3.commontypes.IsoDateAdapter;
import org.apache.hadoop.ozone.s3.util.S3Consts;

/**
* Copy object Response.
*/
@XmlAccessorType(XmlAccessType.FIELD)
@XmlRootElement(name = "CopyPartResult",
namespace = "http://s3.amazonaws.com/doc/2006-03-01/")
namespace = S3Consts.S3_XML_NAMESPACE)
public class CopyPartResult {

@XmlJavaTypeAdapter(IsoDateAdapter.class)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,13 +26,14 @@
import javax.xml.bind.annotation.XmlElementWrapper;
import javax.xml.bind.annotation.XmlRootElement;
import org.apache.hadoop.ozone.s3.commontypes.BucketMetadata;
import org.apache.hadoop.ozone.s3.util.S3Consts;

/**
* Response from the ListBucket RPC Call.
*/
@XmlAccessorType(XmlAccessType.FIELD)
@XmlRootElement(name = "ListAllMyBucketsResult",
namespace = "http://s3.amazonaws.com/doc/2006-03-01/")
namespace = S3Consts.S3_XML_NAMESPACE)
public class ListBucketResponse {
@XmlElementWrapper(name = "Buckets")
@XmlElement(name = "Bucket")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,14 +26,15 @@
import javax.xml.bind.annotation.XmlRootElement;
import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter;
import org.apache.hadoop.ozone.s3.commontypes.IsoDateAdapter;
import org.apache.hadoop.ozone.s3.util.S3Consts;
import org.apache.hadoop.ozone.s3.util.S3StorageType;

/**
* AWS compatible REST response for list multipart upload.
*/
@XmlAccessorType(XmlAccessType.FIELD)
@XmlRootElement(name = "ListMultipartUploadsResult", namespace =
"http://s3.amazonaws.com/doc/2006-03-01/")
S3Consts.S3_XML_NAMESPACE)
public class ListMultipartUploadsResult {

@XmlElement(name = "Bucket")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,13 +28,13 @@
import org.apache.hadoop.ozone.s3.commontypes.EncodingTypeObject;
import org.apache.hadoop.ozone.s3.commontypes.KeyMetadata;
import org.apache.hadoop.ozone.s3.commontypes.ObjectKeyNameAdapter;
import org.apache.hadoop.ozone.s3.util.S3Consts;

/**
* Response from the ListObject RPC Call.
*/
@XmlAccessorType(XmlAccessType.FIELD)
@XmlRootElement(name = "ListBucketResult", namespace = "http://s3.amazonaws"
+ ".com/doc/2006-03-01/")
@XmlRootElement(name = "ListBucketResult", namespace = S3Consts.S3_XML_NAMESPACE)
public class ListObjectResponse {

@XmlElement(name = "Name")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,13 +27,13 @@
import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter;
import org.apache.hadoop.ozone.OzoneConsts;
import org.apache.hadoop.ozone.s3.commontypes.IsoDateAdapter;
import org.apache.hadoop.ozone.s3.util.S3Consts;

/**
* Request for list parts of a multipart upload request.
*/
@XmlAccessorType(XmlAccessType.FIELD)
@XmlRootElement(name = "ListPartsResult", namespace = "http://s3.amazonaws"
+ ".com/doc/2006-03-01/")
@XmlRootElement(name = "ListPartsResult", namespace = S3Consts.S3_XML_NAMESPACE)
public class ListPartsResponse {

@XmlElement(name = "Bucket")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,14 +23,14 @@
import javax.xml.bind.annotation.XmlAccessorType;
import javax.xml.bind.annotation.XmlElement;
import javax.xml.bind.annotation.XmlRootElement;
import org.apache.hadoop.ozone.s3.util.S3Consts;

/**
* Request for multi object delete request.
*/

@XmlAccessorType(XmlAccessType.FIELD)
@XmlRootElement(name = "Delete", namespace = "http://s3.amazonaws"
+ ".com/doc/2006-03-01/")
@XmlRootElement(name = "Delete", namespace = S3Consts.S3_XML_NAMESPACE)
public class MultiDeleteRequest {

@XmlElement(name = "Quiet")
Expand Down Expand Up @@ -60,8 +60,7 @@ public void setObjects(
* JAXB entity for child element.
*/
@XmlAccessorType(XmlAccessType.FIELD)
@XmlRootElement(name = "Object", namespace = "http://s3.amazonaws"
+ ".com/doc/2006-03-01/")
@XmlRootElement(name = "Object", namespace = S3Consts.S3_XML_NAMESPACE)
public static class DeleteObject {

@XmlElement(name = "Key")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,13 +23,13 @@
import javax.xml.bind.annotation.XmlAccessorType;
import javax.xml.bind.annotation.XmlElement;
import javax.xml.bind.annotation.XmlRootElement;
import org.apache.hadoop.ozone.s3.util.S3Consts;

/**
* Response for multi object delete request.
*/
@XmlAccessorType(XmlAccessType.FIELD)
@XmlRootElement(name = "DeleteResult", namespace = "http://s3.amazonaws"
+ ".com/doc/2006-03-01/")
@XmlRootElement(name = "DeleteResult", namespace = S3Consts.S3_XML_NAMESPACE)
public class MultiDeleteResponse {

@XmlElement(name = "Deleted")
Expand Down Expand Up @@ -68,8 +68,7 @@ public void setErrors(
* JAXB entity for child element.
*/
@XmlAccessorType(XmlAccessType.FIELD)
@XmlRootElement(name = "Deleted", namespace = "http://s3.amazonaws"
+ ".com/doc/2006-03-01/")
@XmlRootElement(name = "Deleted", namespace = S3Consts.S3_XML_NAMESPACE)
public static class DeletedObject {

@XmlElement(name = "Key")
Expand Down Expand Up @@ -105,8 +104,7 @@ public void setVersionId(String versionId) {
* JAXB entity for child element.
*/
@XmlAccessorType(XmlAccessType.FIELD)
@XmlRootElement(name = "Error", namespace = "http://s3.amazonaws"
+ ".com/doc/2006-03-01/")
@XmlRootElement(name = "Error", namespace = S3Consts.S3_XML_NAMESPACE)
public static class Error {

@XmlElement(name = "Key")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,13 +21,14 @@
import javax.xml.bind.annotation.XmlAccessorType;
import javax.xml.bind.annotation.XmlElement;
import javax.xml.bind.annotation.XmlRootElement;
import org.apache.hadoop.ozone.s3.util.S3Consts;

/**
* Response for Initiate Multipart Upload request.
*/
@XmlAccessorType(XmlAccessType.FIELD)
@XmlRootElement(name = "InitiateMultipartUploadResult",
namespace = "http://s3.amazonaws.com/doc/2006-03-01/")
namespace = S3Consts.S3_XML_NAMESPACE)
public class MultipartUploadInitiateResponse {

@XmlElement(name = "Bucket")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,13 +25,14 @@
import javax.xml.bind.annotation.XmlAttribute;
import javax.xml.bind.annotation.XmlElement;
import javax.xml.bind.annotation.XmlRootElement;
import org.apache.hadoop.ozone.s3.util.S3Consts;

/**
* Bucket ACL.
*/
@XmlAccessorType(XmlAccessType.FIELD)
@XmlRootElement(name = "AccessControlPolicy",
namespace = "http://s3.amazonaws.com/doc/2006-03-01/")
namespace = S3Consts.S3_XML_NAMESPACE)
public class S3BucketAcl {

@XmlElement(name = "Owner")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,13 +25,14 @@
import javax.xml.bind.annotation.XmlAccessorType;
import javax.xml.bind.annotation.XmlElement;
import javax.xml.bind.annotation.XmlRootElement;
import org.apache.hadoop.ozone.s3.util.S3Consts;

/**
* S3 tagging.
*/
@XmlAccessorType(XmlAccessType.FIELD)
@XmlRootElement(name = "Tagging",
namespace = "http://s3.amazonaws.com/doc/2006-03-01/")
namespace = S3Consts.S3_XML_NAMESPACE)
public class S3Tagging {

@XmlElement(name = "TagSet")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,11 +19,11 @@
* Rest endpoint implementation for the s3 gateway.
*/
@javax.xml.bind.annotation.XmlSchema(
namespace = "http://s3.amazonaws"
+ ".com/doc/2006-03-01/", elementFormDefault =
namespace = S3Consts.S3_XML_NAMESPACE, elementFormDefault =
javax.xml.bind.annotation.XmlNsForm.QUALIFIED,
xmlns = {
@javax.xml.bind.annotation.XmlNs(namespaceURI = "http://s3.amazonaws"
+ ".com/doc/2006-03-01/", prefix = "")})
@javax.xml.bind.annotation.XmlNs(namespaceURI = S3Consts.S3_XML_NAMESPACE, prefix = "")})

package org.apache.hadoop.ozone.s3.endpoint;

import org.apache.hadoop.ozone.s3.util.S3Consts;
Original file line number Diff line number Diff line change
Expand Up @@ -71,8 +71,7 @@ private S3Consts() {
//Error code 416 is Range Not Satisfiable
public static final int RANGE_NOT_SATISFIABLE = 416;

public static final String S3_XML_NAMESPACE = "http://s3.amazonaws" +
".com/doc/2006-03-01/";
public static final String S3_XML_NAMESPACE = "http://s3.amazonaws.com/doc/2006-03-01/";

// Constants related to custom metadata
public static final String CUSTOM_METADATA_HEADER_PREFIX = "x-amz-meta-";
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,6 +27,7 @@
import java.util.List;
import java.util.UUID;
import java.util.concurrent.CompletableFuture;
import org.apache.hadoop.ozone.s3.util.S3Consts;
import org.junit.jupiter.api.Test;

/**
Expand All @@ -41,8 +42,7 @@ public void fromStreamWithNamespace() throws IOException {
//GIVEN
ByteArrayInputStream inputBody =
new ByteArrayInputStream(
("<CompleteMultipartUpload xmlns=\"http://s3.amazonaws" +
".com/doc/2006-03-01/\">" +
("<CompleteMultipartUpload xmlns=\"" + S3Consts.S3_XML_NAMESPACE + "\">" +
"<Part><ETag>" + part1 + "</ETag><PartNumber>1" +
"</PartNumber></Part><Part><ETag>" + part2 +
"</ETag><PartNumber>2</PartNumber></Part>" +
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@

import java.io.ByteArrayInputStream;
import java.io.IOException;
import org.apache.hadoop.ozone.s3.util.S3Consts;
import org.junit.jupiter.api.Test;

/**
Expand All @@ -34,8 +35,7 @@ public void fromStreamWithNamespace() throws IOException {
//GIVEN
ByteArrayInputStream inputBody =
new ByteArrayInputStream(
("<Delete xmlns=\"http://s3.amazonaws"
+ ".com/doc/2006-03-01/\"><Object>key1</Object><Object>key2"
("<Delete xmlns=\"" + S3Consts.S3_XML_NAMESPACE + "\"><Object>key1</Object><Object>key2"
+ "</Object><Object>key3"
+ "</Object></Delete>")
.getBytes(UTF_8));
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -49,6 +49,7 @@
import org.apache.hadoop.ozone.om.exceptions.OMException;
import org.apache.hadoop.ozone.om.exceptions.OMException.ResultCodes;
import org.apache.hadoop.ozone.s3.exception.OS3Exception;
import org.apache.hadoop.ozone.s3.util.S3Consts;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;

Expand Down Expand Up @@ -196,7 +197,7 @@ private InputStream emptyBody() {

private InputStream invalidXmlStructure() {
String xml =
"<Tagging xmlns=\"http://s3.amazonaws.com/doc/2006-03-01/\">" +
"<Tagging xmlns=\"" + S3Consts.S3_XML_NAMESPACE + "\">" +
" <TagSet>" +
" </Ta" +
"Tagging>";
Expand All @@ -206,7 +207,7 @@ private InputStream invalidXmlStructure() {

private InputStream twoTags() {
String xml =
"<Tagging xmlns=\"http://s3.amazonaws.com/doc/2006-03-01/\">" +
"<Tagging xmlns=\"" + S3Consts.S3_XML_NAMESPACE + "\">" +
" <TagSet>" +
" <Tag>" +
" <Key>tag1</Key>" +
Expand All @@ -224,14 +225,14 @@ private InputStream twoTags() {

private InputStream noTagSet() {
String xml =
"<Tagging xmlns=\"http://s3.amazonaws.com/doc/2006-03-01/\">" +
"<Tagging xmlns=\"" + S3Consts.S3_XML_NAMESPACE + "\">" +
"</Tagging>";
return new ByteArrayInputStream(xml.getBytes(UTF_8));
}

private InputStream emptyTags() {
String xml =
"<Tagging xmlns=\"http://s3.amazonaws.com/doc/2006-03-01/\">" +
"<Tagging xmlns=\"" + S3Consts.S3_XML_NAMESPACE + "\">" +
" <TagSet>" +
" </TagSet>" +
"</Tagging>";
Expand All @@ -241,7 +242,7 @@ private InputStream emptyTags() {

public InputStream tagKeyNotSpecified() {
String xml =
"<Tagging xmlns=\"http://s3.amazonaws.com/doc/2006-03-01/\">" +
"<Tagging xmlns=\"" + S3Consts.S3_XML_NAMESPACE + "\">" +
" <TagSet>" +
" <Tag>" +
" <Value>val1</Value>" +
Expand All @@ -254,7 +255,7 @@ public InputStream tagKeyNotSpecified() {

public InputStream tagValueNotSpecified() {
String xml =
"<Tagging xmlns=\"http://s3.amazonaws.com/doc/2006-03-01/\">" +
"<Tagging xmlns=\"" + S3Consts.S3_XML_NAMESPACE + "\">" +
" <TagSet>" +
" <Tag>" +
" <Key>tag1</Key>" +
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -53,6 +53,7 @@
import org.apache.hadoop.ozone.om.helpers.ErrorInfo;
import org.apache.hadoop.ozone.s3.exception.OS3Exception;
import org.apache.hadoop.ozone.s3.metrics.S3GatewayMetrics;
import org.apache.hadoop.ozone.s3.util.S3Consts;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;

Expand Down Expand Up @@ -318,7 +319,7 @@ public void testObjectTagging() throws Exception {
.setClient(client)
.build();
String xml =
"<Tagging xmlns=\"http://s3.amazonaws.com/doc/2006-03-01/\">" +
"<Tagging xmlns=\"" + S3Consts.S3_XML_NAMESPACE + "\">" +
" <TagSet>" +
" <Tag>" +
" <Key>tag1</Key>" +
Expand Down
Loading