/* * 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; 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 Amazon.Util; using System.Globalization; using Amazon.Runtime.Internal.Util; #pragma warning disable 1591 namespace Amazon.S3.Model.Internal.MarshallTransformations { /// /// Request Marshaller for PutAnalyticsConfiguration operation /// public class PutBucketAnalyticsConfigurationRequestMarshaller : IMarshaller, IMarshaller { public IRequest Marshall(Amazon.Runtime.AmazonWebServiceRequest input) { return this.Marshall((PutBucketAnalyticsConfigurationRequest)input); } public IRequest Marshall(PutBucketAnalyticsConfigurationRequest putBucketAnalyticsConfigurationRequest) { IRequest request = new DefaultRequest(putBucketAnalyticsConfigurationRequest, "AmazonS3"); request.HttpMethod = "PUT"; if (putBucketAnalyticsConfigurationRequest.IsSetExpectedBucketOwner()) request.Headers.Add(S3Constants.AmzHeaderExpectedBucketOwner, S3Transforms.ToStringValue(putBucketAnalyticsConfigurationRequest.ExpectedBucketOwner)); if (string.IsNullOrEmpty(putBucketAnalyticsConfigurationRequest.BucketName)) throw new System.ArgumentException("BucketName is a required property and must be set before making this call.", "PutBucketAnalyticsConfigurationRequest.BucketName"); request.ResourcePath = "/"; request.AddSubResource("analytics"); if (putBucketAnalyticsConfigurationRequest.IsSetAnalyticsId()) { request.AddSubResource("id", S3Transforms.ToStringValue(putBucketAnalyticsConfigurationRequest.AnalyticsId)); } var stringWriter = new XMLEncodedStringWriter(System.Globalization.CultureInfo.InvariantCulture); using (var xmlWriter = XmlWriter.Create(stringWriter, new XmlWriterSettings() { Encoding = Encoding.UTF8, OmitXmlDeclaration = true, NewLineHandling = NewLineHandling.Entitize })) { if (putBucketAnalyticsConfigurationRequest.IsSetAnalyticsConfiguration()) { var analyticsConfiguration = putBucketAnalyticsConfigurationRequest.AnalyticsConfiguration; xmlWriter.WriteStartElement("AnalyticsConfiguration", S3Constants.S3RequestXmlNamespace); if (analyticsConfiguration.IsSetAnalyticsId()) { xmlWriter.WriteElementString("Id", analyticsConfiguration.AnalyticsId); } if (analyticsConfiguration.IsSetAnalyticsFilter()) { xmlWriter.WriteStartElement("Filter"); var predicate = analyticsConfiguration.AnalyticsFilter.AnalyticsFilterPredicate; predicate.Accept(new AnalyticsPredicateVisitor(xmlWriter)); xmlWriter.WriteEndElement(); } if (analyticsConfiguration.IsSetStorageClassAnalysis()) { if (analyticsConfiguration.IsSetStorageClassAnalysis()) { StorageClassAnalysis storageClassAnalysis = analyticsConfiguration.StorageClassAnalysis; xmlWriter.WriteStartElement("StorageClassAnalysis"); if (storageClassAnalysis.IsSetDataExport()) { xmlWriter.WriteStartElement("DataExport"); StorageClassAnalysisDataExport storageClassAnalysisDataExport = storageClassAnalysis.DataExport; if(storageClassAnalysisDataExport.IsSetOutputSchemaVersion()) { StorageClassAnalysisSchemaVersion storageClassAnalysisSchemaVersion = storageClassAnalysisDataExport.OutputSchemaVersion; if (storageClassAnalysisSchemaVersion != null) { xmlWriter.WriteElementString("OutputSchemaVersion", storageClassAnalysisSchemaVersion); } } if (storageClassAnalysisDataExport.IsSetDestination()) { xmlWriter.WriteStartElement("Destination"); AnalyticsExportDestination analyticsExportDestination = storageClassAnalysisDataExport.Destination; if (analyticsExportDestination.IsSetS3BucketDestination()) { xmlWriter.WriteStartElement("S3BucketDestination"); AnalyticsS3BucketDestination analyticsS3BucketDestination = analyticsExportDestination.S3BucketDestination; if (analyticsS3BucketDestination.IsSetFormat()) { xmlWriter.WriteElementString("Format", analyticsS3BucketDestination.Format); } if (analyticsS3BucketDestination.IsSetBucketAccountId()) { xmlWriter.WriteElementString("BucketAccountId", analyticsS3BucketDestination.BucketAccountId); } if (analyticsS3BucketDestination.IsSetBucketName()) { xmlWriter.WriteElementString("Bucket", analyticsS3BucketDestination.BucketName); } if (analyticsS3BucketDestination.IsSetPrefix()) { xmlWriter.WriteElementString("Prefix", analyticsS3BucketDestination.Prefix); } xmlWriter.WriteEndElement(); } 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 = AWSSDKUtils.GenerateChecksumForContent(content, true); request.Headers[HeaderKeys.ContentMD5Header] = checksum; } catch (EncoderFallbackException e) { throw new AmazonServiceException("Unable to marshall request to XML", e); } return request; } private static PutBucketAnalyticsConfigurationRequestMarshaller _instance; public static PutBucketAnalyticsConfigurationRequestMarshaller Instance { get { if (_instance == null) { _instance = new PutBucketAnalyticsConfigurationRequestMarshaller(); } return _instance; } } } }