behzadalizadeh/Caspian.WorkflowFramework
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Upgrade package Mongologger to San.MongoLogger version 1.0.0-preview.3

Browse Source
This commit is contained in:
behzadalizadeh
2025-08-17 17:56:51 +03:30
parent d58167d24a
commit fa019e6126
8 changed files with 90 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Caspian.WorkflowFramework.Package/Services/WorkflowService.cs
+34 -13
View File
@@ -9,7 +9,7 @@ using Elsa.Workflows.Runtime.Messages;
using Elsa.Workflows.Models;
using Elsa.Common.Models;
using Caspian.WorkflowFramework.Utility;
using MongoLogger;
using San.MongoLogger;
using System.Diagnostics;
namespace Caspian.WorkflowFramework.Services
@@ -44,9 +44,10 @@ namespace Caspian.WorkflowFramework.Services
/// <inheritdoc />
public async Task<WorkflowResponse<WorkflowModel>> CreateAndExecuteAsync(CreateAndExecuteWorkflowModel input)
{
var sw = Stopwatch.StartNew();
try
{
_logger.Log("Start of CreateAndExecuteAsync", JsonConvert.SerializeObject(input));
_logger.Log("Start of CreateAndExecuteAsync", input);
WorkflowResponse<WorkflowModel> response;
@@ -68,7 +69,9 @@ namespace Caspian.WorkflowFramework.Services
Data = null
};
_logger.Log("End of CreateAndExecuteAsync", WFInstanceId: response.Data?.InstanceId, JsonConvert.SerializeObject(response));
sw.Stop();
_logger.Log("End of CreateAndExecuteAsync", WFInstanceId: response.Data?.InstanceId, response, sw.ElapsedMilliseconds);
return response;
}
@@ -100,7 +103,9 @@ namespace Caspian.WorkflowFramework.Services
Data = workflowModel
};
_logger.Log("End of CreateAndExecuteAsync", WFInstanceId: response.Data?.InstanceId, JsonConvert.SerializeObject(response));
sw.Stop();
_logger.Log("End of CreateAndExecuteAsync", WFInstanceId: response.Data?.InstanceId, response, sw.ElapsedMilliseconds);
return response;
}
@@ -113,7 +118,9 @@ namespace Caspian.WorkflowFramework.Services
Data = null
};
_logger.Log("Exception occurs in CreateAndExecuteAsync", WFInstanceId: response.Data?.InstanceId, JsonConvert.SerializeObject(response), ex);
sw.Stop();
_logger.Log("Exception occurs in CreateAndExecuteAsync", WFInstanceId: response.Data?.InstanceId, response, sw.ElapsedMilliseconds, ex);
return response;
}
@@ -124,9 +131,10 @@ namespace Caspian.WorkflowFramework.Services
/// <inheritdoc />
public async Task<WorkflowResponse<WorkflowModel>> PublishEventAsync(PublishEventModel input)
{
var sw = Stopwatch.StartNew();
try
{
_logger.Log("Start of PublishEventAsync", WFInstanceId: input.WorkflowInstanceId, JsonConvert.SerializeObject(input));
_logger.Log("Start of PublishEventAsync", WFInstanceId: input.WorkflowInstanceId, input);
WorkflowResponse<WorkflowModel> response;
@@ -142,7 +150,9 @@ namespace Caspian.WorkflowFramework.Services
Data = null
};
_logger.Log("End of PublishEventAsync", WFInstanceId: input.WorkflowInstanceId, JsonConvert.SerializeObject(response));
sw.Stop();
_logger.Log("End of PublishEventAsync", WFInstanceId: input.WorkflowInstanceId, response, sw.ElapsedMilliseconds);
return response;
}
@@ -165,7 +175,9 @@ namespace Caspian.WorkflowFramework.Services
Data = workflowModel
};
_logger.Log("End of PublishEventAsync", WFInstanceId: input.WorkflowInstanceId, JsonConvert.SerializeObject(response));
sw.Stop();
_logger.Log("End of PublishEventAsync", WFInstanceId: input.WorkflowInstanceId, response, sw.ElapsedMilliseconds);
return response;
}
@@ -178,7 +190,9 @@ namespace Caspian.WorkflowFramework.Services
Data = null
};
_logger.Log("Exception occurs in PublishEventAsync", WFInstanceId: input.WorkflowInstanceId, JsonConvert.SerializeObject(response), ex);
sw.Stop();
_logger.Log("Exception occurs in PublishEventAsync", WFInstanceId: input.WorkflowInstanceId, response, sw.ElapsedMilliseconds, ex);
return response;
}
@@ -189,9 +203,10 @@ namespace Caspian.WorkflowFramework.Services
/// <inheritdoc />
public async Task<WorkflowResponse<WorkflowModel>> InquiryStateAsync(InquiryStateModel input)
{
var sw = Stopwatch.StartNew();
try
{
_logger.Log("Start of InquiryStateAsync", WFInstanceId: input.WorkflowInstanceId, JsonConvert.SerializeObject(input));
_logger.Log("Start of InquiryStateAsync", WFInstanceId: input.WorkflowInstanceId, input);
WorkflowResponse<WorkflowModel> response;
@@ -207,7 +222,9 @@ namespace Caspian.WorkflowFramework.Services
Data = null
};
_logger.Log("End of InquiryStateAsync", WFInstanceId: input.WorkflowInstanceId, JsonConvert.SerializeObject(response));
sw.Stop();
_logger.Log("End of InquiryStateAsync", WFInstanceId: input.WorkflowInstanceId, response, sw.ElapsedMilliseconds);
return response;
}
@@ -228,7 +245,9 @@ namespace Caspian.WorkflowFramework.Services
Data = workflowModel
};
_logger.Log("End of InquiryStateAsync", WFInstanceId: input.WorkflowInstanceId, JsonConvert.SerializeObject(response));
sw.Stop();
_logger.Log("End of InquiryStateAsync", WFInstanceId: input.WorkflowInstanceId, response, sw.ElapsedMilliseconds);
return response;
}
@@ -241,7 +260,9 @@ namespace Caspian.WorkflowFramework.Services
Data = null
};
_logger.Log("Exception occurs in InquiryStateAsync", WFInstanceId: input.WorkflowInstanceId, JsonConvert.SerializeObject(response), ex);
sw.Stop();
_logger.Log("Exception occurs in InquiryStateAsync", WFInstanceId: input.WorkflowInstanceId, response, sw.ElapsedMilliseconds, ex);
return response;
}