Handle exception thrown from plug-in engine

Signed-off-by: Victor Chang <[email protected]>

Author: mocsharp

src/InformaticsGateway/Logging/Log.500.ExportService.cs

@@ -129,5 +129,8 @@ public static partial class Log
 
         [LoggerMessage(EventId = 535, Level = LogLevel.Warning, Message = "Exceeded maximum number of worker in {serviceName}: {count}.")]
         public static partial void ExceededMaxmimumNumberOfWorkers(this ILogger logger, string serviceName, ulong count);
+
+        [LoggerMessage(EventId = 536, Level = LogLevel.Error, Message = "Error executing data plug-ins.")]
+        public static partial void ErrorExecutingDataPlugIns(this ILogger logger, Exception ex);
     }
 }

src/InformaticsGateway/Services/Export/ExportServiceBase.cs

@@ -275,10 +275,20 @@ private IEnumerable<ExportRequestDataMessage> DownloadPayloadActionCallback(Expo
 
         private async Task<ExportRequestDataMessage> ExecuteOutputDataEngineCallback(ExportRequestDataMessage exportDataRequest, CancellationToken token)
         {
-            var outputDataEngine = _scope.ServiceProvider.GetService<IOutputDataPlugInEngine>() ?? throw new ServiceNotFoundException(nameof(IOutputDataPlugInEngine));
+            try
+            {
+                var outputDataEngine = _scope.ServiceProvider.GetService<IOutputDataPlugInEngine>() ?? throw new ServiceNotFoundException(nameof(IOutputDataPlugInEngine));
 
-            outputDataEngine.Configure(exportDataRequest.PlugInAssemblies);
-            return await outputDataEngine.ExecutePlugInsAsync(exportDataRequest).ConfigureAwait(false);
+                outputDataEngine.Configure(exportDataRequest.PlugInAssemblies);
+                return await outputDataEngine.ExecutePlugInsAsync(exportDataRequest).ConfigureAwait(false);
+            }
+            catch (Exception ex)
+            {
+                var errorMessage = $"Error executing data plug-ins: {ex}";
+                _logger.ErrorExecutingDataPlugIns(ex);
+                exportDataRequest.SetFailed(FileExportStatus.ServiceError, errorMessage);
+                return exportDataRequest;
+            }
         }
 
         private void ReportingActionBlock(ExportRequestDataMessage exportRequestData)