70 lines
2.0 KiB
C#
70 lines
2.0 KiB
C#
using System;
|
|
using System.Linq.Expressions;
|
|
using Hangfire;
|
|
using LeafWeb.Core.DAL;
|
|
using LeafWeb.Core.Entities;
|
|
using LeafWeb.Core.Remote;
|
|
using NLog;
|
|
using Polly;
|
|
|
|
namespace LeafWeb.Web.Services.PiscalQueue
|
|
{
|
|
public abstract class PiscalQueueBase : IDisposable
|
|
{
|
|
protected readonly DataService DataService;
|
|
protected readonly PiscalService PiscalService;
|
|
protected readonly Logger Logger;
|
|
private readonly Policy _retryPolicy;
|
|
|
|
protected PiscalQueueBase(DataService dataService, PiscalService piscalService)
|
|
{
|
|
DataService = dataService;
|
|
PiscalService = piscalService;
|
|
Logger = LogManager.GetLogger(GetType().Name);
|
|
|
|
_retryPolicy =
|
|
Policy
|
|
.Handle<TimeoutException>()
|
|
.Retry(3,
|
|
(exception, i) => Logger.Warn($"Retry {i} after exception: {exception.Message}"));
|
|
}
|
|
|
|
protected PiscalQueueBase() : this(new DataService(), new PiscalService()) { }
|
|
|
|
protected string FormatException(Exception ex, int leafInputId)
|
|
{
|
|
return
|
|
$"LeafInput: {leafInputId}{Environment.NewLine}" +
|
|
$"Class: {GetType().Name}{Environment.NewLine}" +
|
|
$"Exception: {ex.Message}{Environment.NewLine}" +
|
|
(ex.InnerException != null ? $"InnerException: {ex.InnerException}{Environment.NewLine}" : string.Empty)
|
|
+ $"StackTrace: {ex.StackTrace}";
|
|
}
|
|
|
|
protected void PiscalExceptionHandle(PiscalClientException ex, LeafInput leafInput)
|
|
{
|
|
var errorMessage = FormatException(ex, ex.LeafInputId);
|
|
Logger.Error(errorMessage);
|
|
BackgroundJobEnqueueRetry<EmailNotificationService>(
|
|
email => email.SendAdministratorMessage($"LeafWeb: PiscalQueue {GetType().Name} Exception", errorMessage));
|
|
|
|
// TODO send user email too
|
|
|
|
if (leafInput != null)
|
|
{
|
|
DataService.SetLeafInputStatus(leafInput, LeafInputStatusType.Exception, "Error occurred processing LeafInput",
|
|
ex.Message);
|
|
}
|
|
}
|
|
|
|
public void Dispose()
|
|
{
|
|
DataService.Dispose();
|
|
}
|
|
|
|
protected string BackgroundJobEnqueueRetry<T>(Expression<Action<T>> a)
|
|
{
|
|
return _retryPolicy.Execute(() => BackgroundJob.Enqueue(a));
|
|
}
|
|
}
|
|
} |