Fix report GET_REFERRAL_FEE_PREVIEW_REPORT when return null

Author: abuzuhri

Source/FikaAmazonAPI/ReportGeneration/ReportManager.cs

@@ -2,6 +2,7 @@
 using FikaAmazonAPI.Utils;
 using System;
 using System.Collections.Generic;
+using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
 using static FikaAmazonAPI.Utils.Constants;
@@ -379,7 +380,23 @@ public async Task<List<ReferralFeeReportRow>> GetReferralFeeReportDataAsync(Date
         }
         private async Task<string> GetReferralFeeReportDataAsync(AmazonConnection amazonConnection, DateTime fromDate, DateTime toDate)
         {
-            return await amazonConnection.Reports.CreateReportAndDownloadFileAsync(ReportTypes.GET_REFERRAL_FEE_PREVIEW_REPORT, fromDate, toDate);
+            var reportPath = await amazonConnection.Reports.CreateReportAndDownloadFileAsync(ReportTypes.GET_REFERRAL_FEE_PREVIEW_REPORT, fromDate, toDate);
+            if (reportPath == null)
+            {
+                var getOldReports = amazonConnection.Reports.GetReports(new Parameter.Report.ParameterReportList()
+                {
+                    reportTypes = new ReportTypes[] { ReportTypes.GET_REFERRAL_FEE_PREVIEW_REPORT },
+                    processingStatuses = new List<ProcessingStatuses> { ProcessingStatuses.DONE }
+                });
+
+                if (getOldReports != null && getOldReports.Count > 0)
+                {
+                    var reportId = getOldReports.FirstOrDefault().ReportId;
+                    return await amazonConnection.Reports.GetReportFileByReportIdAsync(reportId, false);
+
+                }
+            }
+            return reportPath;
         }
         #endregion
     }

Source/FikaAmazonAPI/Services/ReportService.cs

@@ -20,9 +20,9 @@ public ReportService(AmazonCredential amazonCredential) : base(amazonCredential)
         {
         }
         #region GetReport
-        public List<Report> GetReports(ParameterReportList parameterReportList) =>
+        public IList<Report> GetReports(ParameterReportList parameterReportList) =>
             Task.Run(() => GetReportsAsync(parameterReportList)).ConfigureAwait(false).GetAwaiter().GetResult();
-        public async Task<List<Report>> GetReportsAsync(ParameterReportList parameterReportList, CancellationToken cancellationToken = default)
+        public async Task<IList<Report>> GetReportsAsync(ParameterReportList parameterReportList, CancellationToken cancellationToken = default)
         {
             if (parameterReportList.marketplaceIds == null || parameterReportList.marketplaceIds.Count == 0)
             {
@@ -94,10 +94,10 @@ public GetReportsResponseV00 GetReportsByNextToken(ParameterReportList parameter
             Task.Run(() => GetReportsByNextTokenAsync(parameterReportList)).ConfigureAwait(false).GetAwaiter().GetResult();
         public async Task<GetReportsResponseV00> GetReportsByNextTokenAsync(ParameterReportList parameterReportList, CancellationToken cancellationToken = default)
         {
-	    List<KeyValuePair<string, string>> parameters = null;
-	    if(string.IsNullOrEmpty(parameterReportList.nextToken))
+            List<KeyValuePair<string, string>> parameters = null;
+            if (string.IsNullOrEmpty(parameterReportList.nextToken))
                 parameters = parameterReportList.getParameters();
-	    else
+            else
             {
                 var parameterReportListNew = new ParameterReportList();
                 parameterReportListNew.nextToken = parameterReportList.nextToken;
@@ -215,38 +215,44 @@ private async Task<string> GetFileAsync(ReportDocument reportDocument, Cancellat
 
             string tempFilePath = Path.Combine(Path.GetTempPath() + fileName);
 
-            try {
-                if (isEncryptedFile) {
+            try
+            {
+                if (isEncryptedFile)
+                {
                     //Later will check
                     byte[] rawData = client.DownloadData(reportDocument.Url);
                     byte[] key = Convert.FromBase64String(reportDocument.EncryptionDetails.Key);
                     byte[] iv = Convert.FromBase64String(reportDocument.EncryptionDetails.InitializationVector);
                     var reportData = FileTransform.DecryptString(key, iv, rawData);
                     File.WriteAllText(tempFilePath, reportData);
                 }
-                else {
+                else
+                {
                     var stream = await client.OpenReadTaskAsync(new Uri(reportDocument.Url));
-                    using (Stream s = File.Create(tempFilePath)) {
+                    using (Stream s = File.Create(tempFilePath))
+                    {
                         stream?.CopyTo(s);
                     }
                 }
 
                 cancellationToken.ThrowIfCancellationRequested();
 
-				if (isCompressionFile) {
+                if (isCompressionFile)
+                {
                     var compressionFile = tempFilePath;
                     tempFilePath = FileTransform.Decompress(tempFilePath);
                     File.Delete(compressionFile);
                 }
 
-				cancellationToken.ThrowIfCancellationRequested();
+                cancellationToken.ThrowIfCancellationRequested();
 
-				return tempFilePath;
+                return tempFilePath;
             }
-            catch(OperationCanceledException){
-				File.Delete(tempFilePath);
+            catch (OperationCanceledException)
+            {
+                File.Delete(tempFilePath);
                 throw;
-			}
+            }
         }
 
         public async Task SaveStreamToFileAsync(string fileFullPath, Stream stream, CancellationToken cancellationToken = default)
@@ -309,6 +315,12 @@ public async Task<string> CreateReportAndDownloadFileAsync(ReportTypes reportTyp
                 parameters.dataEndTime = dataEndTime;
 
             var reportId = await CreateReportAsync(parameters, cancellationToken);
+            return await GetReportFileByReportIdAsync(reportId, isRestrictedReport, millisecondsDelay, cancellationToken);
+
+        }
+
+        public async Task<string> GetReportFileByReportIdAsync(string reportId, bool isRestrictedReport, int millisecondsDelay = 500, CancellationToken cancellationToken = default)
+        {
             var filePath = string.Empty;
             string ReportDocumentId = string.Empty;