Add delete notification optional

Author: abuzuhri

Source/FikaAmazonAPI.SampleCode/Program.cs

@@ -28,18 +28,29 @@ static async Task Main(string[] args)
                 IsDebugMode = true
             });
 
+            //var feedTypes = new ParameterGetFeed { feedTypes = { FeedType.POST_PRODUCT_PRICING_DATA }, processingStatuses = ProcessingStatuses.IN_PROGRESS };
 
-            FeedsSample feedsSample = new FeedsSample(amazonConnection);
-            feedsSample.SubmitFeedPRICING(69.3F, "8809606851663");
+            //var feeds = amazonConnection.Feed.GetFeeds(feedTypes);
+
+
+            //FeedsSample feedsSample = new FeedsSample(amazonConnection);
+            //feedsSample.SubmitFeedPRICING(69.3F, "8809606851663");
 
             var feeds = amazonConnection.Feed.GetFeeds(new Parameter.Feed.ParameterGetFeed()
             {
-                processingStatuses = ProcessingStatuses.IN_QUEUE,
+                processingStatuses = ProcessingStatuses.IN_PROGRESS,//ProcessingStatuses.IN_QUEUE,
                 pageSize = 100,
                 feedTypes = new List<FeedType> { FeedType.POST_PRODUCT_PRICING_DATA },
                 marketplaceIds = new List<string> { MarketPlace.UnitedArabEmirates.ID }
             });
 
+            var feeds2 = amazonConnection.Feed.GetFeeds(new Parameter.Feed.ParameterGetFeed()
+            {
+                processingStatuses = ProcessingStatuses.IN_PROGRESS,//ProcessingStatuses.IN_PROGRESS,
+                pageSize = 100,
+                feedTypes = new List<FeedType> { FeedType.POST_INVENTORY_AVAILABILITY_DATA },
+                marketplaceIds = new List<string> { MarketPlace.UnitedArabEmirates.ID }
+            });
             foreach (var feed in feeds)
             {
                 Console.WriteLine("FeedId " + feed.FeedId);

Source/FikaAmazonAPI/Services/NotificationService.cs

@@ -113,10 +113,10 @@ public async Task<bool> DeleteSubscriptionByIdAsync(NotificationType notificatio
             return true;
         }
 
-        public void StartReceivingNotificationMessages(ParameterMessageReceiver param, IMessageReceiver messageReceiver) =>
-            Task.Run(() => StartReceivingNotificationMessagesAsync(param, messageReceiver)).ConfigureAwait(false).GetAwaiter().GetResult();
+        public void StartReceivingNotificationMessages(ParameterMessageReceiver param, IMessageReceiver messageReceiver, bool isDeleteNotificationAfterRead = true) =>
+            Task.Run(() => StartReceivingNotificationMessagesAsync(param, messageReceiver, isDeleteNotificationAfterRead)).ConfigureAwait(false).GetAwaiter().GetResult();
 
-        public async Task StartReceivingNotificationMessagesAsync(ParameterMessageReceiver param, IMessageReceiver messageReceiver, CancellationToken cancellationToken = default)
+        public async Task StartReceivingNotificationMessagesAsync(ParameterMessageReceiver param, IMessageReceiver messageReceiver, bool isDeleteNotificationAfterRead = true, CancellationToken cancellationToken = default)
         {
             var awsAccessKeyId = param.awsAccessKeyId;
             var awsSecretAccessKey = param.awsSecretAccessKey;
@@ -140,7 +140,7 @@ public async Task StartReceivingNotificationMessagesAsync(ParameterMessageReceiv
                         {
                             foreach (var msg in Messages)
                             {
-                                ProcessAnyOfferChangedMessage(msg, messageReceiver, amazonSQSClient, SQS_URL, cancellationToken).ConfigureAwait(false);
+                                ProcessAnyOfferChangedMessage(msg, messageReceiver, amazonSQSClient, SQS_URL, isDeleteNotificationAfterRead, cancellationToken).ConfigureAwait(false);
 
                             }
 
@@ -156,19 +156,23 @@ public async Task StartReceivingNotificationMessagesAsync(ParameterMessageReceiv
             }
         }
 
-        private async Task ProcessAnyOfferChangedMessage(Message msg, IMessageReceiver messageReceiver, AmazonSQSClient amazonSQSClient, string SQS_URL, CancellationToken cancellationToken = default)
+        private async Task ProcessAnyOfferChangedMessage(Message msg, IMessageReceiver messageReceiver, AmazonSQSClient amazonSQSClient, string SQS_URL, bool isDeleteNotificationAfterRead = true, CancellationToken cancellationToken = default)
         {
             try
             {
                 var data = DeserializeNotification(msg);
 
                 messageReceiver.NewMessageRevicedTriger(data);
-                await DeleteMessageFromQueueAsync(amazonSQSClient, SQS_URL, msg.ReceiptHandle, cancellationToken);
+
+                if (isDeleteNotificationAfterRead)
+                    await DeleteMessageFromQueueAsync(amazonSQSClient, SQS_URL, msg.ReceiptHandle, cancellationToken);
             }
             catch (Exception ex)
             {
                 messageReceiver.ErrorCatch(ex);
-                await DeleteMessageFromQueueAsync(amazonSQSClient, SQS_URL, msg.ReceiptHandle, cancellationToken);
+
+                if (isDeleteNotificationAfterRead)
+                    await DeleteMessageFromQueueAsync(amazonSQSClient, SQS_URL, msg.ReceiptHandle, cancellationToken);
             }
         }
         private async Task DeleteMessageFromQueueAsync(AmazonSQSClient sqsClient, string QueueUrl, string ReceiptHandle, CancellationToken cancellationToken = default)