Implement Cbor response and structure unmarshallers generators

Author: muhammad-othman

extensions/src/AWSSDK.Extensions.CborProtocol/Internal/Transform/CborErrorResponseUnmarshaller.cs

@@ -0,0 +1,58 @@
+/*
+ * 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 Amazon.Runtime;
+using Amazon.Runtime.Internal;
+using Amazon.Runtime.Internal.Transform;
+using Amazon.Runtime.Internal.Util;
+using Amazon.Util;
+using System;
+using System.Collections.Generic;
+using System.Formats.Cbor;
+using System.IO;
+
+namespace AWSSDK.Extensions.CborProtocol.Internal.Transform
+{
+    /// <summary>
+    /// Class for unmarshalling CBOR service responses.
+    /// </summary>
+    public class CborErrorResponseUnmarshaller : ICborUnmarshaller<ErrorResponse, CborUnmarshallerContext>
+    {
+        /// <summary>
+        /// Build an ErrorResponse from Cbor 
+        /// </summary>
+        /// <param name="context">The Cbor parsing context. 
+        /// Usually an <c>Amazon.Runtime.Internal.CborUnmarshallerContext</c>.</param>
+        /// <returns>An <c>ErrorResponse</c> object.</returns>
+        public ErrorResponse Unmarshall(CborUnmarshallerContext context)
+        {
+            // Placeholder until CBOR exception implementation.
+            return null;
+        }
+
+        private static CborErrorResponseUnmarshaller instance;
+
+        /// <summary>
+        /// Return an instance of CborErrorResponseUnmarshaller.
+        /// </summary>
+        /// <returns></returns>
+        public static CborErrorResponseUnmarshaller GetInstance()
+        {
+            if (instance == null)
+                instance = new CborErrorResponseUnmarshaller();
+
+            return instance;
+        }
+    }
+}

extensions/src/AWSSDK.Extensions.CborProtocol/Internal/Transform/CborMarshallerContext.cs

@@ -0,0 +1,38 @@
+/*
+ * 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 Amazon.Runtime;
+using Amazon.Runtime.Internal;
+using Amazon.Runtime.Internal.Transform;
+using Amazon.Runtime.Internal.Util;
+using Amazon.Util;
+using System;
+using System.Collections.Generic;
+using System.Formats.Cbor;
+using System.IO;
+
+namespace AWSSDK.Extensions.CborProtocol.Internal.Transform
+{
+    public class CborMarshallerContext : MarshallerContext
+    {
+        public CborWriter Writer { get; private set; }
+
+        public CborMarshallerContext(IRequest request, CborWriter writer)
+            : base(request)
+        {
+            Writer = writer;
+        }
+    }
+}

extensions/src/AWSSDK.Extensions.CborProtocol/Internal/Transform/CborResponseUnmarshaller.cs

@@ -0,0 +1,75 @@
+/*
+ * 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 Amazon.Runtime;
+using Amazon.Runtime.Internal;
+using Amazon.Runtime.Internal.Transform;
+using Amazon.Runtime.Internal.Util;
+using Amazon.Util;
+using System;
+using System.Collections.Generic;
+using System.Formats.Cbor;
+using System.IO;
+using System.Net;
+
+namespace AWSSDK.Extensions.CborProtocol.Internal.Transform
+{
+    public abstract class CborResponseUnmarshaller : ResponseUnmarshaller
+    {
+        public override AmazonWebServiceResponse Unmarshall(UnmarshallerContext input)
+        {
+            CborUnmarshallerContext context = input as CborUnmarshallerContext;
+            if (context == null)
+                throw new InvalidOperationException("Unsupported UnmarshallerContext");
+
+            string requestId = context.ResponseData.GetHeaderValue(HeaderKeys.RequestIdHeader);
+            try
+            {
+                var response = Unmarshall(context);
+                response.ResponseMetadata = new ResponseMetadata();
+                response.ResponseMetadata.RequestId = requestId;
+                return response;
+            }
+            catch (Exception e)
+            {
+                throw new AmazonUnmarshallingException(requestId, context.CurrentPath, e, context.ResponseData.StatusCode);
+            }
+        }
+
+        public override AmazonServiceException UnmarshallException(UnmarshallerContext input, Exception innerException, HttpStatusCode statusCode)
+        {
+            CborUnmarshallerContext context = input as CborUnmarshallerContext;
+            if (context == null)
+                throw new InvalidOperationException("Unsupported UnmarshallerContext");
+            var responseException = UnmarshallException(context, innerException, statusCode);
+            responseException.RequestId = context.ResponseData.GetHeaderValue(HeaderKeys.RequestIdHeader);
+            return responseException;
+        }
+
+        public abstract AmazonWebServiceResponse Unmarshall(CborUnmarshallerContext input);
+
+        public abstract AmazonServiceException UnmarshallException(CborUnmarshallerContext input, Exception innerException, HttpStatusCode statusCode);
+
+        protected override UnmarshallerContext ConstructUnmarshallerContext(Stream responseStream, bool maintainResponseBody, IWebResponseData response, bool isException)
+        {
+            return new CborUnmarshallerContext(responseStream, maintainResponseBody, response, isException, null);
+        }
+
+        protected override UnmarshallerContext ConstructUnmarshallerContext(Stream responseStream, bool maintainResponseBody, IWebResponseData response, bool isException, IRequestContext requestContext)
+        {
+            return new CborUnmarshallerContext(responseStream, maintainResponseBody, response, isException, requestContext);
+        }
+    }
+}