/*
* Copyright Amazon.com, Inc. or its affiliates. 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://aws.amazon.com/apache2.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.
*/
using System.IO;
using System.Xml;
using System.Text;
using Amazon.S3.Util;
using Amazon.Runtime;
using Amazon.Runtime.Internal;
using Amazon.Runtime.Internal.Transform;
using System.Globalization;
using Amazon.Util;
using Amazon.Runtime.Internal.Util;
#pragma warning disable 1591
namespace Amazon.S3.Model.Internal.MarshallTransformations
{
///
/// Put Object Acl Request Marshaller
///
public class PutACLRequestMarshaller : IMarshaller ,IMarshaller
{
public IRequest Marshall(Amazon.Runtime.AmazonWebServiceRequest input)
{
return this.Marshall((PutACLRequest)input);
}
public IRequest Marshall(PutACLRequest putObjectAclRequest)
{
IRequest request = new DefaultRequest(putObjectAclRequest, "AmazonS3");
request.HttpMethod = "PUT";
if (putObjectAclRequest.IsSetCannedACL())
request.Headers.Add(HeaderKeys.XAmzAclHeader, S3Transforms.ToStringValue(putObjectAclRequest.CannedACL));
if (putObjectAclRequest.IsSetExpectedBucketOwner())
request.Headers.Add(S3Constants.AmzHeaderExpectedBucketOwner, S3Transforms.ToStringValue(putObjectAclRequest.ExpectedBucketOwner));
if (putObjectAclRequest.IsSetChecksumAlgorithm())
request.Headers.Add(S3Constants.AmzHeaderSdkChecksumAlgorithm, S3Transforms.ToStringValue(putObjectAclRequest.ChecksumAlgorithm));
if (string.IsNullOrEmpty(putObjectAclRequest.BucketName))
throw new System.ArgumentException("BucketName is a required property and must be set before making this call.", "PutACLRequest.BucketName");
//Not checking if Key is null or empty because PutAcl allows to put an ACL for both a Bucket or an Object. TODO: deprecate PutAcl and create two separate operations
// if we are putting the acl onto the bucket, the keyname component will collapse to empty string
request.ResourcePath = string.Format(CultureInfo.InvariantCulture, "/{0}",
S3Transforms.ToStringValue(putObjectAclRequest.Key));
request.AddSubResource("acl");
if (putObjectAclRequest.IsSetVersionId())
request.AddSubResource("versionId", S3Transforms.ToStringValue(putObjectAclRequest.VersionId));
var stringWriter = new XMLEncodedStringWriter(System.Globalization.CultureInfo.InvariantCulture);
using (
var xmlWriter = XmlWriter.Create(stringWriter,
new XmlWriterSettings()
{
Encoding = Encoding.UTF8,
OmitXmlDeclaration = true,
NewLineHandling = NewLineHandling.Entitize
}))
{
var accessControlPolicyAccessControlPolicy = putObjectAclRequest.AccessControlList;
if (accessControlPolicyAccessControlPolicy != null)
{
xmlWriter.WriteStartElement("AccessControlPolicy", S3Constants.S3RequestXmlNamespace);
var accessControlPolicyAccessControlPolicygrantsList = accessControlPolicyAccessControlPolicy.Grants;
if (accessControlPolicyAccessControlPolicygrantsList != null &&
accessControlPolicyAccessControlPolicygrantsList.Count > 0)
{
accessControlPolicyAccessControlPolicy.Marshall("AccessControlList", xmlWriter);
var ownerOwner = accessControlPolicyAccessControlPolicy.Owner;
if (ownerOwner != null)
{
xmlWriter.WriteStartElement("Owner");
if (ownerOwner.IsSetDisplayName())
{
xmlWriter.WriteElementString("DisplayName",
S3Transforms.ToXmlStringValue(ownerOwner.DisplayName));
}
if (ownerOwner.IsSetId())
{
xmlWriter.WriteElementString("ID", S3Transforms.ToXmlStringValue(ownerOwner.Id));
}
xmlWriter.WriteEndElement();
}
}
xmlWriter.WriteEndElement();
}
}
try
{
var content = stringWriter.ToString();
request.Content = Encoding.UTF8.GetBytes(content);
request.Headers[HeaderKeys.ContentTypeHeader] = "application/xml";
ChecksumUtils.SetRequestChecksum(request, putObjectAclRequest.ChecksumAlgorithm);
}
catch (EncoderFallbackException e)
{
throw new AmazonServiceException("Unable to marshall request to XML", e);
}
return request;
}
private static PutACLRequestMarshaller _instance;
public static PutACLRequestMarshaller Instance
{
get
{
if (_instance == null)
{
_instance = new PutACLRequestMarshaller();
}
return _instance;
}
}
}
}