DX | 19-01-2026 | Release

CHANGELOG.md

@@ -1,4 +1,10 @@
 # Changelog
+
+## [v0.6.0](https://github.com/contentstack/contentstack-management-dotnet/tree/v0.6.0)
+ - Enhancement
+   - Refactor retry policy implementation to improve exception handling  and retry logic across various scenarios
+   - Improved error messages
+
 ## [v0.5.0](https://github.com/contentstack/contentstack-management-dotnet/tree/v0.5.0)
  - Feat
    - **Variant Group Management**: Added comprehensive support for variant group operations

Contentstack.Management.ASPNETCore/LICENSE.txt

@@ -1,6 +1,6 @@
 MIT License
 
-Copyright © 2012-2025 Contentstack. All Rights Reserved
+Copyright © 2012-2026 Contentstack. All Rights Reserved
 
 Permission is hereby granted, free of charge, to any person obtaining a copy
 of this software and associated documentation files (the "Software"), to deal

Contentstack.Management.ASPNETCore/contentstack.management.aspnetcore.csproj

@@ -5,7 +5,7 @@
     <PackageId>contentstack.management.aspnetcore</PackageId>
     <PackageVersion>$(Version)</PackageVersion>
     <Authors>Contentstack</Authors>
-    <Copyright>Copyright © 2012-2025 Contentstack. All Rights Reserved</Copyright>
+    <Copyright>Copyright © 2012-2026 Contentstack. All Rights Reserved</Copyright>
     <Owners>Contentstack </Owners>
     <PackageProjectUrl>https://github.com/contentstack/contentstack-management-dotnet</PackageProjectUrl>
     <PackageReleaseNotes>Initial Release</PackageReleaseNotes>

Contentstack.Management.Core.Unit.Tests/Mokes/CustomJsonConverter.cs

@@ -9,7 +9,7 @@ public class CustomJsonConverter : JsonConverter
     {
         public override bool CanConvert(Type objectType)
         {
-            throw new NotImplementedException();
+            return false; // Mock converter - not actually used for conversion
         }
 
         public override object ReadJson(JsonReader reader, Type objectType, object existingValue, JsonSerializer serializer)
@@ -28,7 +28,7 @@ public class CustomConverter : JsonConverter
     {
         public override bool CanConvert(Type objectType)
         {
-            throw new NotImplementedException();
+            return false; // Mock converter - not actually used for conversion
         }
 
         public override object ReadJson(JsonReader reader, Type objectType, object existingValue, JsonSerializer serializer)

Contentstack.Management.Core.Unit.Tests/Mokes/MockHttpHandlerWithRetries.cs

@@ -0,0 +1,150 @@
+using System;
+using System.Collections.Generic;
+using System.Net;
+using System.Net.Http;
+using Contentstack.Management.Core.Http;
+using Contentstack.Management.Core.Internal;
+using Contentstack.Management.Core.Runtime.Contexts;
+using Contentstack.Management.Core.Runtime.Pipeline;
+using Newtonsoft.Json;
+
+namespace Contentstack.Management.Core.Unit.Tests.Mokes
+{
+    /// <summary>
+    /// Mock HTTP handler that can simulate failures and successes for retry testing.
+    /// </summary>
+    public class MockHttpHandlerWithRetries : IPipelineHandler
+    {
+        private readonly Queue<Func<IExecutionContext, IResponse>> _responseQueue;
+        private readonly Queue<Exception> _exceptionQueue;
+        private int _callCount = 0;
+
+        public ILogManager LogManager { get; set; }
+        public IPipelineHandler InnerHandler { get; set; }
+        public int CallCount => _callCount;
+
+        public MockHttpHandlerWithRetries()
+        {
+            _responseQueue = new Queue<Func<IExecutionContext, IResponse>>();
+            _exceptionQueue = new Queue<Exception>();
+        }
+
+        /// <summary>
+        /// Adds a response that will be returned on the next call.
+        /// </summary>
+        public void AddResponse(HttpStatusCode statusCode, string body = null)
+        {
+            _responseQueue.Enqueue((context) =>
+            {
+                var response = new HttpResponseMessage(statusCode);
+                if (body != null)
+                {
+                    response.Content = new StringContent(body);
+                }
+                return new ContentstackResponse(response, JsonSerializer.Create(new JsonSerializerSettings()));
+            });
+        }
+
+        /// <summary>
+        /// Adds a successful response (200 OK).
+        /// </summary>
+        public void AddSuccessResponse(string body = "{\"success\": true}")
+        {
+            AddResponse(HttpStatusCode.OK, body);
+        }
+
+        /// <summary>
+        /// Adds an exception that will be thrown on the next call.
+        /// </summary>
+        public void AddException(Exception exception)
+        {
+            _exceptionQueue.Enqueue(exception);
+        }
+
+        /// <summary>
+        /// Adds multiple failures followed by a success.
+        /// </summary>
+        public void AddFailuresThenSuccess(int failureCount, Exception failureException, string successBody = "{\"success\": true}")
+        {
+            for (int i = 0; i < failureCount; i++)
+            {
+                AddException(failureException);
+            }
+            AddSuccessResponse(successBody);
+        }
+
+        /// <summary>
+        /// Adds multiple HTTP error responses followed by a success.
+        /// </summary>
+        public void AddHttpErrorsThenSuccess(int errorCount, HttpStatusCode errorStatusCode, string successBody = "{\"success\": true}")
+        {
+            for (int i = 0; i < errorCount; i++)
+            {
+                AddResponse(errorStatusCode);
+            }
+            AddSuccessResponse(successBody);
+        }
+
+        public async System.Threading.Tasks.Task<T> InvokeAsync<T>(
+            IExecutionContext executionContext,
+            bool addAcceptMediaHeader = false,
+            string apiVersion = null)
+        {
+            _callCount++;
+
+            // Check for exceptions first
+            if (_exceptionQueue.Count > 0)
+            {
+                var exception = _exceptionQueue.Dequeue();
+                throw exception;
+            }
+
+            // Check for responses
+            if (_responseQueue.Count > 0)
+            {
+                var responseFactory = _responseQueue.Dequeue();
+                var response = responseFactory(executionContext);
+                executionContext.ResponseContext.httpResponse = response;
+                return await System.Threading.Tasks.Task.FromResult<T>((T)response);
+            }
+
+            // Default: return success
+            var defaultResponse = new HttpResponseMessage(HttpStatusCode.OK);
+            defaultResponse.Content = new StringContent("{\"success\": true}");
+            var contentstackResponse = new ContentstackResponse(defaultResponse, JsonSerializer.Create(new JsonSerializerSettings()));
+            executionContext.ResponseContext.httpResponse = contentstackResponse;
+            return await System.Threading.Tasks.Task.FromResult<T>((T)(IResponse)contentstackResponse);
+        }
+
+        public void InvokeSync(
+            IExecutionContext executionContext,
+            bool addAcceptMediaHeader = false,
+            string apiVersion = null)
+        {
+            _callCount++;
+
+            // Check for exceptions first
+            if (_exceptionQueue.Count > 0)
+            {
+                var exception = _exceptionQueue.Dequeue();
+                throw exception;
+            }
+
+            // Check for responses
+            if (_responseQueue.Count > 0)
+            {
+                var responseFactory = _responseQueue.Dequeue();
+                var response = responseFactory(executionContext);
+                executionContext.ResponseContext.httpResponse = response;
+                return;
+            }
+
+            // Default: return success
+            var defaultResponse = new HttpResponseMessage(HttpStatusCode.OK);
+            defaultResponse.Content = new StringContent("{\"success\": true}");
+            var contentstackResponse = new ContentstackResponse(defaultResponse, JsonSerializer.Create(new JsonSerializerSettings()));
+            executionContext.ResponseContext.httpResponse = contentstackResponse;
+        }
+    }
+}
+

Contentstack.Management.Core.Unit.Tests/Mokes/MockNetworkErrorGenerator.cs

@@ -0,0 +1,55 @@
+using System;
+using System.Net;
+using System.Net.Http;
+using System.Net.Sockets;
+using System.Threading;
+using System.Threading.Tasks;
+using Contentstack.Management.Core.Exceptions;
+
+namespace Contentstack.Management.Core.Unit.Tests.Mokes
+{
+    /// <summary>
+    /// Utility to generate various network error exceptions for testing.
+    /// </summary>
+    public static class MockNetworkErrorGenerator
+    {
+        public static SocketException CreateSocketException(SocketError errorCode)
+        {
+            return new SocketException((int)errorCode);
+        }
+
+        public static HttpRequestException CreateHttpRequestExceptionWithSocketException(SocketError socketError)
+        {
+            var socketException = CreateSocketException(socketError);
+            return new HttpRequestException("Network error", socketException);
+        }
+
+        public static TaskCanceledException CreateTaskCanceledExceptionTimeout()
+        {
+            var cts = new CancellationTokenSource();
+            return new TaskCanceledException("Operation timed out", null, cts.Token);
+        }
+
+        public static TaskCanceledException CreateTaskCanceledExceptionUserCancellation()
+        {
+            var cts = new CancellationTokenSource();
+            cts.Cancel();
+            return new TaskCanceledException("User cancelled", null, cts.Token);
+        }
+
+        public static TimeoutException CreateTimeoutException()
+        {
+            return new TimeoutException("Operation timed out");
+        }
+
+        public static ContentstackErrorException CreateContentstackErrorException(HttpStatusCode statusCode)
+        {
+            return new ContentstackErrorException
+            {
+                StatusCode = statusCode,
+                Message = $"HTTP {statusCode} error"
+            };
+        }
+    }
+}
+

Contentstack.Management.Core.Unit.Tests/Mokes/MockRetryPolicy.cs

@@ -0,0 +1,49 @@
+using System;
+using Contentstack.Management.Core.Exceptions;
+using Contentstack.Management.Core.Runtime.Contexts;
+using Contentstack.Management.Core.Runtime.Pipeline.RetryHandler;
+
+namespace Contentstack.Management.Core.Unit.Tests.Mokes
+{
+    /// <summary>
+    /// Mock retry policy for testing RetryHandler in isolation.
+    /// </summary>
+    public class MockRetryPolicy : RetryPolicy
+    {
+        public bool ShouldRetryValue { get; set; } = true;
+        public bool CanRetryValue { get; set; } = true;
+        public bool RetryLimitExceededValue { get; set; } = false;
+        public TimeSpan WaitDelay { get; set; } = TimeSpan.FromMilliseconds(100);
+        public Exception LastException { get; private set; }
+        public int RetryCallCount { get; private set; }
+
+        public MockRetryPolicy()
+        {
+            RetryOnError = true;
+            RetryLimit = 5;
+        }
+
+        public override bool RetryForException(IExecutionContext executionContext, Exception exception)
+        {
+            LastException = exception;
+            RetryCallCount++;
+            return ShouldRetryValue;
+        }
+
+        public override bool CanRetry(IExecutionContext executionContext)
+        {
+            return CanRetryValue;
+        }
+
+        public override bool RetryLimitExceeded(IExecutionContext executionContext)
+        {
+            return RetryLimitExceededValue;
+        }
+
+        internal override void WaitBeforeRetry(IExecutionContext executionContext)
+        {
+            System.Threading.Tasks.Task.Delay(WaitDelay).Wait();
+        }
+    }
+}
+

Contentstack.Management.Core.Unit.Tests/Mokes/Response/429Response.txt

@@ -0,0 +1,9 @@
+HTTP/1.1 429 Too Many Requests
+content-type: application/json
+content-length: 45
+retry-after: 5
+date: Wed, 28 Apr 2021 11:11:34 GMT
+connection: Keep-Alive
+
+{"error_message": "Too many requests","error_code": 429}
+

Contentstack.Management.Core.Unit.Tests/Mokes/Response/500Response.txt

@@ -0,0 +1,8 @@
+HTTP/1.1 500 Internal Server Error
+content-type: application/json
+content-length: 45
+date: Wed, 28 Apr 2021 11:11:34 GMT
+connection: Keep-Alive
+
+{"error_message": "Internal server error","error_code": 500}
+

Contentstack.Management.Core.Unit.Tests/Mokes/Response/502Response.txt

@@ -0,0 +1,8 @@
+HTTP/1.1 502 Bad Gateway
+content-type: application/json
+content-length: 40
+date: Wed, 28 Apr 2021 11:11:34 GMT
+connection: Keep-Alive
+
+{"error_message": "Bad gateway","error_code": 502}
+

Contentstack.Management.Core.Unit.Tests/Mokes/Response/503Response.txt

@@ -0,0 +1,8 @@
+HTTP/1.1 503 Service Unavailable
+content-type: application/json
+content-length: 48
+date: Wed, 28 Apr 2021 11:11:34 GMT
+connection: Keep-Alive
+
+{"error_message": "Service unavailable","error_code": 503}
+

Contentstack.Management.Core.Unit.Tests/Mokes/Response/504Response.txt

@@ -0,0 +1,8 @@
+HTTP/1.1 504 Gateway Timeout
+content-type: application/json
+content-length: 45
+date: Wed, 28 Apr 2021 11:11:34 GMT
+connection: Keep-Alive
+
+{"error_message": "Gateway timeout","error_code": 504}
+