in src/Services/S3/Custom/Model/Internal/MarshallTransformations/PutBucketReplicationRequestMarshaller.cs [39:246]
public IRequest Marshall(PutBucketReplicationRequest putBucketreplicationRequest)
{
IRequest request = new DefaultRequest(putBucketreplicationRequest, "AmazonS3");
request.HttpMethod = "PUT";
if (string.IsNullOrEmpty(putBucketreplicationRequest.BucketName))
throw new System.ArgumentException("BucketName is a required property and must be set before making this call.", "PutBucketReplicationRequest.BucketName");
request.MarshallerVersion = 2;
request.ResourcePath = string.Concat("/", S3Transforms.ToStringValue(putBucketreplicationRequest.BucketName));
request.AddSubResource("replication");
if (putBucketreplicationRequest.IsSetToken())
request.Headers.Add("x-amz-bucket-object-lock-token", putBucketreplicationRequest.Token);
var stringWriter = new StringWriter(System.Globalization.CultureInfo.InvariantCulture);
using (var xmlWriter = XmlWriter.Create(stringWriter, new XmlWriterSettings() { Encoding = Encoding.UTF8, OmitXmlDeclaration = true }))
{
var replicationConfiguration = putBucketreplicationRequest.Configuration;
if (replicationConfiguration != null)
{
xmlWriter.WriteStartElement("ReplicationConfiguration", "");
if (replicationConfiguration.Role != null)
{
xmlWriter.WriteElementString("Role", "", S3Transforms.ToXmlStringValue(replicationConfiguration.Role));
}
if (replicationConfiguration.Rules != null)
{
foreach (var rule in replicationConfiguration.Rules)
{
xmlWriter.WriteStartElement("Rule");
if (rule.IsSetId())
{
xmlWriter.WriteElementString("ID", "", S3Transforms.ToXmlStringValue(rule.Id));
}
if (rule.IsSetPriority())
{
xmlWriter.WriteElementString("Priority", "", S3Transforms.ToXmlStringValue(rule.Priority));
}
if (rule.IsSetPrefix())
{
xmlWriter.WriteElementString("Prefix", "", S3Transforms.ToXmlStringValue(rule.Prefix));
}
if (rule.IsSetFilter())
{
xmlWriter.WriteStartElement("Filter", "");
if (rule.Filter.IsSetPrefix())
{
xmlWriter.WriteElementString("Prefix", "", S3Transforms.ToXmlStringValue(rule.Filter.Prefix));
}
if (rule.Filter.IsSetTag())
{
rule.Filter.Tag.Marshall("Tag", xmlWriter);
}
if (rule.Filter.IsSetAnd())
{
xmlWriter.WriteStartElement("And");
if (rule.Filter.And.IsSetPrefix())
{
xmlWriter.WriteElementString("Prefix", "", S3Transforms.ToXmlStringValue(rule.Filter.And.Prefix));
}
if (rule.Filter.And.IsSetTags())
{
foreach (var tag in rule.Filter.And.Tags)
{
tag.Marshall("Tag", xmlWriter);
}
}
xmlWriter.WriteEndElement();
}
xmlWriter.WriteEndElement();
}
if (rule.IsSetStatus())
{
xmlWriter.WriteElementString("Status", "", S3Transforms.ToXmlStringValue(rule.Status.ToString()));
}
if (rule.IsSetSourceSelectionCriteria())
{
xmlWriter.WriteStartElement("SourceSelectionCriteria");
if (rule.SourceSelectionCriteria.IsSetSseKmsEncryptedObjects())
{
xmlWriter.WriteStartElement("SseKmsEncryptedObjects");
if (rule.SourceSelectionCriteria.SseKmsEncryptedObjects.IsSetSseKmsEncryptedObjectsStatus())
{
xmlWriter.WriteElementString("Status", "", rule.SourceSelectionCriteria.SseKmsEncryptedObjects.SseKmsEncryptedObjectsStatus);
}
xmlWriter.WriteEndElement();
}
xmlWriter.WriteEndElement();
}
if (rule.IsSetExistingObjectReplication())
{
xmlWriter.WriteStartElement("ExistingObjectReplication");
if (rule.ExistingObjectReplication.IsSetExistingObjectReplicationStatus())
{
xmlWriter.WriteElementString("Status", "", rule.ExistingObjectReplication.Status);
}
xmlWriter.WriteEndElement();
}
if (rule.IsSetDeleteMarkerReplication())
{
xmlWriter.WriteStartElement("DeleteMarkerReplication");
if (rule.DeleteMarkerReplication.IsSetStatus())
{
xmlWriter.WriteElementString("Status", "", rule.DeleteMarkerReplication.Status);
}
xmlWriter.WriteEndElement();
}
if (rule.IsSetDestination())
{
xmlWriter.WriteStartElement("Destination", "");
if (rule.Destination.IsSetBucketArn())
{
xmlWriter.WriteElementString("Bucket", "", rule.Destination.BucketArn);
}
if (rule.Destination.IsSetStorageClass())
{
xmlWriter.WriteElementString("StorageClass", "", rule.Destination.StorageClass);
}
if (rule.Destination.IsSetAccountId())
{
xmlWriter.WriteElementString("Account", "", S3Transforms.ToXmlStringValue(rule.Destination.AccountId));
}
if (rule.Destination.IsSetEncryptionConfiguration())
{
xmlWriter.WriteStartElement("EncryptionConfiguration");
if (rule.Destination.EncryptionConfiguration.isSetReplicaKmsKeyID())
{
xmlWriter.WriteElementString("ReplicaKmsKeyID", "", S3Transforms.ToXmlStringValue(rule.Destination.EncryptionConfiguration.ReplicaKmsKeyID));
}
xmlWriter.WriteEndElement();
}
if (rule.Destination.IsSetMetrics())
{
xmlWriter.WriteStartElement("Metrics");
if (rule.Destination.Metrics.IsSetStatus())
{
xmlWriter.WriteElementString("Status", "", S3Transforms.ToXmlStringValue(rule.Destination.Metrics.Status));
}
if (rule.Destination.Metrics.IsSetEventThreshold())
{
xmlWriter.WriteStartElement("EventThreshold");
if (rule.Destination.Metrics.EventThreshold.IsSetMinutes())
{
xmlWriter.WriteElementString("Minutes", "", S3Transforms.ToXmlStringValue(rule.Destination.Metrics.EventThreshold.Minutes));
}
xmlWriter.WriteEndElement();
}
xmlWriter.WriteEndElement();
}
if (rule.Destination.IsSetReplicationTime())
{
xmlWriter.WriteStartElement("ReplicationTime");
if (rule.Destination.ReplicationTime.IsSetStatus())
{
xmlWriter.WriteElementString("Status", "", S3Transforms.ToXmlStringValue(rule.Destination.ReplicationTime.Status));
}
if (rule.Destination.ReplicationTime.IsSetTime())
{
xmlWriter.WriteStartElement("Time");
if (rule.Destination.ReplicationTime.Time.IsSetMinutes())
{
xmlWriter.WriteElementString("Minutes", "", S3Transforms.ToXmlStringValue(rule.Destination.ReplicationTime.Time.Minutes));
}
xmlWriter.WriteEndElement();
}
xmlWriter.WriteEndElement();
}
if (rule.Destination.IsSetAccessControlTranslation())
{
xmlWriter.WriteStartElement("AccessControlTranslation");
if (rule.Destination.AccessControlTranslation.IsSetOwner())
{
xmlWriter.WriteElementString("Owner", "", S3Transforms.ToXmlStringValue(rule.Destination.AccessControlTranslation.Owner));
}
xmlWriter.WriteEndElement();
}
xmlWriter.WriteEndElement();
}
xmlWriter.WriteEndElement();
}
}
xmlWriter.WriteEndElement();
}
}
try
{
var content = stringWriter.ToString();
request.Content = Encoding.UTF8.GetBytes(content);
request.Headers[HeaderKeys.ContentTypeHeader] = "application/xml";
var checksum = AmazonS3Util.GenerateChecksumForContent(content, true);
request.Headers[HeaderKeys.ContentMD5Header] = checksum;
}
catch (EncoderFallbackException e)
{
throw new AmazonServiceException("Unable to marshall request to XML", e);
}
return request;
}