hanzoai/jube-fork
2
0
Fork 0
mirror of https://github.com/hanzoai/jube-fork.git synced 2026-10-30 18:33:33 +00:00
Code Issues Packages Projects Releases Wiki Activity
Files
118-cache-use-reduction-features
jube-fork/Jube.Service/Authentication/SandboxRegistration.cs
T
richard-churchman 811c938462 Improved Case Automation POST body conext and other minor issues: 
* Pushed Case Workflow Display HTML rendering logic down into a controller for improved security and consistent tokenisation of the Jube token format against context. Included a migration to update the default demo entry to use proper tokenisation. Updated the repository to support fetching CaseWorkflowDisplay with appropriate security.
* Implemented improved tokenisation of the EntityAnalysisModelInstanceEntryPayload model via a common extension method on EntityAnalysisModelInstanceEntryPayload, used consistently across the system for serialisation and storage.
* Included a migration to update the tokenisation format for full CaseWorkflowDisplay support.
* Fixed an issue where CaseWorkflowFilter was incorrectly filtering on CaseWorkflowStatus.Guid instead of CaseWorkflowStatus.Name, causing the GUID to be returned rather than the display name on the template/demo model. (The remainder was fixed in GitHub issue #6.) Included a migration with a corrective SQL statement.
* Fixed an issue where tokens were not being stored alongside CaseWorkflowFilter definition configuration. It now behaves identically to CaseSearch. Note: migrating missing tokens is not feasible as it requires JS-side parsing via JQueryBuilder.
* Reduced the size of the CaseWorkflowForm invocation to include only the required fields given the new POST body context being rendered server side. Improved API serialisation by using a dictionary for form payload keys and values.
* Consolidated JSON serialisation settings into DI and updated usages throughout.
* Updated EntityAnalysisModelInstanceEntryPayload write serialisers to handle deserialisation, which is required to support tokenisation of new Case Automation POST bodies.
* Created an extension method on the EntityAnalysisModelInstanceEntryPayload to centralise tokenisation of strings across Activation and Case Automation on a consistent basis. Simplified Case Notification and Case HTTP dispatch by removing tokenisation logic from those classes.
* Removed a redundant field from the CaseWorkflowFormEntry POCO (database left unchanged for now).
* Fixed a bug in Case session SQL rebuilding where the rebuild date was not being correctly checked for null or default value, which caused a failure in the last migration.
* Made minor modifications to the Create Case process and method signature to skip serialisation when the payload object required for tokenisation is already available on the thread (e.g. during synchronous reprocessing).
* Updated Case Workflow Macro processing to fetch the archive payload for the case from the database, improving security of that invocation endpoint.
* Removed what appeared to be a duplicate EntityAnalysisModelInstanceEntryPayload model introduced during refactoring.
* Fixed a but in Case Worfkflow Display Role assigment owing to volatile Guid in its update.
2026-02-22 13:08:42 +02:00

2888 lines
127 KiB
C#
Raw Permalink Blame History

namespace Jube.Service.Authentication
{
using Data.Context;
using Data.Poco;
using Data.Repository;
using Data.Security;
using Dto.Authentication;
using Exceptions.Authentication;
public class SandboxRegistration(DbContext dbContext)
{
public async Task<SandboxRegistrationResponseDto> RegisterAsync(
SandboxRegistrationRequestDto sandboxRegistrationRequestDto,
string passwordHashingKey, CancellationToken token = default)
{
if (sandboxRegistrationRequestDto.UserName == null)
{
throw new ArgumentException("Missing User Name.");
}
if (sandboxRegistrationRequestDto.Password == null)
{
throw new ArgumentException("Missing Password.");
}
await ValidateUserDoesNotExistAndRaiseExceptionIfExistsAsync(sandboxRegistrationRequestDto.UserName, token);
var tenantRegistry = await CreateTenantRegistryAsync(sandboxRegistrationRequestDto.UserName, token);
var roleRegistry = await CreateRoleRegistryAsync(sandboxRegistrationRequestDto.UserName, tenantRegistry, token);
await AllocateAllPermissionSpecificationsToRoleRegistryAsync(sandboxRegistrationRequestDto.UserName, roleRegistry, token);
var userRegistry = await CreateUserRegistryAsync(sandboxRegistrationRequestDto.UserName,
sandboxRegistrationRequestDto.Password, passwordHashingKey, roleRegistry, token);
await AssignToUserRegistryToTenantRegistryAsync(sandboxRegistrationRequestDto.UserName, tenantRegistry, token);
var entityAnalysisModel = await InsertEntityAnalysisModelAsync(userRegistry.Name, token);
await InsertEntityAnalysisModelRequestXPathsAsync(entityAnalysisModel.Id, userRegistry.Name, token);
await InsertEntityAnalysisModelInlineScriptAsync(entityAnalysisModel.Id, 1, userRegistry.Name, token);
await InsertEntityAnalysisModelAbstractionCalculationAsync(entityAnalysisModel.Id, userRegistry.Name, token);
await InsertEntityAnalysisModelAbstractionRuleAsync(entityAnalysisModel.Id, userRegistry.Name, token);
var entityAnalysisModelDictionaryId =
InsertEntityAnalysisModelDictionary(entityAnalysisModel.Guid, userRegistry.Name);
await InsertEntityAnalysisModelDictionaryKvpAsync(entityAnalysisModelDictionaryId, userRegistry.Name, token);
await InsertEntityAnalysisModelGatewayRuleAsync(entityAnalysisModel.Id, userRegistry.Name, token);
await InsertEntityAnalysisModelHttpAdaptationAsync(entityAnalysisModel.Id, userRegistry.Name, token);
await InsertEntityAnalysisModelInlineFunctionAsync(entityAnalysisModel.Id, userRegistry.Name, token);
var entityAnalysisModelListId = await InsertEntityAnalysisModelListAsync(entityAnalysisModel.Guid, userRegistry.Name, token);
await InsertEntityAnalysisModelListValueAsync(entityAnalysisModelListId, userRegistry.Name, token);
await InsertEntityAnalysisModelSanctionAsync(entityAnalysisModel.Id, userRegistry.Name, token);
await InsertEntityAnalysisModelTagAsync(entityAnalysisModel.Id, userRegistry.Name, token);
var entityEntityAnalysisModelTtlCounterId =
await InsertEntityAnalysisModelTtlCounterAsync(entityAnalysisModel.Id, userRegistry.Name, token);
var insertVisualisationRegistryExampleVisualisationId =
await InsertVisualisationRegistryExampleVisualisationAsync(userRegistry.Name, token);
var insertVisualisationRegistryExampleEmbeddedVisualisation =
await InsertVisualisationRegistryExampleEmbeddedVisualisationAsync(userRegistry.Name, token);
await InsertVisualisationRegistryParameterEmbeddedVisualisationAsync(
insertVisualisationRegistryExampleEmbeddedVisualisation.Id, userRegistry.Name, token);
await InsertVisualisationRegistryParameterExampleEmbeddedVisualisationAsync(
insertVisualisationRegistryExampleVisualisationId, userRegistry.Name, token);
await InsertVisualisationRegistryDatasourceExampleEmbeddedVisualisationAsync(
insertVisualisationRegistryExampleEmbeddedVisualisation.Id, userRegistry.Name).ConfigureAwait(false);
await InsertVisualisationRegistryDatasourceExampleVisualisationAsync(
insertVisualisationRegistryExampleVisualisationId, userRegistry.Name).ConfigureAwait(false);
var caseWorkflow = await InsertCaseWorkflowAsync(entityAnalysisModel.Id,
insertVisualisationRegistryExampleEmbeddedVisualisation.Guid, userRegistry.Name, token);
await InsertCaseWorkflowActionAsync(caseWorkflow.Id, userRegistry.Name, token);
await InsertCaseWorkflowDisplayAsync(caseWorkflow.Id, userRegistry.Name, token);
await InsertCaseWorkflowFilterAsync(caseWorkflow.Id, userRegistry.Name, token);
await InsertCaseWorkflowFormAsync(caseWorkflow.Id, userRegistry.Name, token);
await InsertCaseWorkflowMacroAsync(caseWorkflow.Id, userRegistry.Name, token);
await InsertCaseWorkflowXPathAsync(caseWorkflow.Id, userRegistry.Name, token);
var caseWorkflowStatusId = await InsertCaseWorkflowStatusAsync(caseWorkflow.Id, userRegistry.Name, token);
await InsertEntityAnalysisModelActivationRuleAsync(entityAnalysisModel,
caseWorkflow.Guid, caseWorkflowStatusId, entityEntityAnalysisModelTtlCounterId,
userRegistry.Name, token);
await InsertEntityAnalysisModelSynchronisationScheduleAsync(userRegistry.Name, token);
return new SandboxRegistrationResponseDto
{
TenantRegistryId = tenantRegistry.Id,
RoleRegistryId = roleRegistry.Id,
UserRegistryId = userRegistry.Id
};
}
private async Task<Guid> InsertCaseWorkflowStatusAsync(int caseWorkflowId, string userName, CancellationToken token = default)
{
var caseWorkflowStatusRepository = new CaseWorkflowStatusRepository(dbContext, userName);
var returnCaseWorkflowStatusId = (await caseWorkflowStatusRepository.InsertAsync(new CaseWorkflowStatus
{
CaseWorkflowId = caseWorkflowId,
Name = "First Line Review",
Active = 1,
Priority = 5,
ForeColor = "#260080",
BackColor = "#abc8f7",
Guid = Guid.NewGuid()
}, token)).Guid;
await caseWorkflowStatusRepository.InsertAsync(new CaseWorkflowStatus
{
CaseWorkflowId = caseWorkflowId,
Name = "Supervisor Review",
Active = 1,
Priority = 4,
ForeColor = "#260080",
BackColor = "#fafcb1",
Guid = Guid.NewGuid()
}, token);
await caseWorkflowStatusRepository.InsertAsync(new CaseWorkflowStatus
{
CaseWorkflowId = caseWorkflowId,
Name = "Restricted",
Active = 1,
Priority = 3,
ForeColor = "#260080",
BackColor = "#fce9c5",
Guid = Guid.NewGuid()
}, token);
await caseWorkflowStatusRepository.InsertAsync(new CaseWorkflowStatus
{
CaseWorkflowId = caseWorkflowId,
Name = "Fraudulent",
Active = 1,
Priority = 4,
ForeColor = "#260080",
BackColor = "#facaf4",
Guid = Guid.NewGuid()
}, token);
await caseWorkflowStatusRepository.InsertAsync(new CaseWorkflowStatus
{
CaseWorkflowId = caseWorkflowId,
Name = "Reported",
Active = 1,
Priority = 1,
ForeColor = "#260080",
BackColor = "#f77781",
Guid = Guid.NewGuid()
}, token);
return returnCaseWorkflowStatusId;
}
private async Task InsertCaseWorkflowActionAsync(int caseWorkflowId, string userName, CancellationToken token = default)
{
var caseWorkflowActionRepository = new CaseWorkflowActionRepository(dbContext, userName);
await caseWorkflowActionRepository.InsertAsync(new CaseWorkflowAction
{
Name = "Call Customer",
CaseWorkflowId = caseWorkflowId,
Active = 1
}, token);
await caseWorkflowActionRepository.InsertAsync(new CaseWorkflowAction
{
Name = "Email Customer",
CaseWorkflowId = caseWorkflowId,
Active = 1
}, token);
await caseWorkflowActionRepository.InsertAsync(new CaseWorkflowAction
{
Name = "Escalation",
CaseWorkflowId = caseWorkflowId,
Active = 1
}, token);
await caseWorkflowActionRepository.InsertAsync(new CaseWorkflowAction
{
Name = "General Action",
CaseWorkflowId = caseWorkflowId,
Active = 1
}, token);
}
private async Task InsertCaseWorkflowXPathAsync(int caseWorkflowId, string userName, CancellationToken token = default)
{
var caseWorkflowXPathRepository = new CaseWorkflowXPathRepository(dbContext, userName);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "AccountId",
XPath = "payload.AccountId",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "TxnDateTime",
XPath = "payload.TxnDateTime",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "Currency",
XPath = "payload.Currency",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "ResponseCode",
XPath = "payload.ResponseCode",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff",
RegularExpression = "[^0]+",
ForeRowColorScope = 1,
BackRowColorScope = 0
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "CurrencyAmount",
XPath = "payload.CurrencyAmount",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "SettlementAmount",
XPath = "payload.SettlementAmount",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "AccountCurrency",
XPath = "payload.AccountCurrency",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "ChannelId",
XPath = "payload.ChannelId",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "AppVersionCode",
XPath = "payload.AppVersionCode",
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "ServiceCode",
XPath = "payload.ServiceCode",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "System",
XPath = "payload.System",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "Brand",
XPath = "payload.Brand",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "Model",
XPath = "payload.Model",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "AccountLongitude",
XPath = "payload.AccountLongitude",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "AccountLatitude",
XPath = "payload.AccountLatitude",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "OS",
XPath = "payload.OS",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "Resolution",
XPath = "payload.Resolution",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "DebuggerAttached",
XPath = "payload.DebuggerAttached",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "SimulatorAttached",
XPath = "payload.SimulatorAttached",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "Jailbreak",
XPath = "payload.Jailbreak",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "MAC",
XPath = "payload.MAC",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "ToAccountId",
XPath = "payload.ToAccountId",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "ToAccountExternalRef",
XPath = "payload.ToAccountExternalRef",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "TwoFATypeId",
XPath = "payload.TwoFATypeId",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "TwoFAResponseId",
XPath = "payload.TwoFAResponseId",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "Storage",
XPath = "payload.Storage",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "TransactionExternalResponseId",
XPath = "payload.TransactionExternalResponseId",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "FingerprintHash",
XPath = "payload.FingerprintHash",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "BusinessModel",
XPath = "payload.BusinessModel",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "AmountEUR",
XPath = "payload.AmountEUR",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "AmountUSD",
XPath = "payload.AmountUSD",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "AmountUSDRate",
XPath = "payload.AmountUSDRate",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "AmountGBP",
XPath = "payload.AmountGBP",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "AmountGBPRate",
XPath = "payload.AmountGBPRate",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "Is3D",
XPath = "payload.Is3D",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "OriginalAmount",
XPath = "payload.OriginalAmount",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "OriginalCurrency",
XPath = "payload.OriginalCurrency",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "Email",
XPath = "payload.Email",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "CreditCardHash",
XPath = "payload.CreditCardHash",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "AcquirerBankName",
XPath = "payload.AcquirerBankName",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "ActionDate",
XPath = "payload.ActionDate",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "APMAccountId",
XPath = "payload.APMAccountId",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "BankId",
XPath = "payload.BankId",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "BillingAddress",
XPath = "payload.BillingAddress",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "BillingCity",
XPath = "payload.BillingCity",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "BillingCountry",
XPath = "payload.BillingCountry",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "BillingFirstName",
XPath = "payload.BillingFirstName",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "BillingLastName",
XPath = "payload.BillingLastName",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "BillingPhone",
XPath = "payload.BillingPhone",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "BillingState",
XPath = "payload.BillingState",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "BillingZip",
XPath = "payload.BillingZip",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "IsAPM",
XPath = "payload.IsAPM",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "IsCascaded",
XPath = "payload.IsCascaded",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "IsCredited",
XPath = "payload.IsCredited",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "IsCurrencyConverted",
XPath = "payload.IsCurrencyConverted",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "IsModification",
XPath = "payload.IsModification",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "IsRebill",
XPath = "payload.IsRebill",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "TransactionTypeId",
XPath = "payload.TransactionTypeId",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "TransactionResultId",
XPath = "payload.TransactionResultId",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "IP",
Drill = 1,
XPath = "payload.IP",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "AmountEURRate",
XPath = "payload.AmountEURRate",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "DeviceId",
Drill = 1,
XPath = "payload.DeviceId",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "IsModified",
XPath = "payload.IsModified",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "OrderId",
XPath = "payload.OrderId",
Active = 1,
BoldLineFormatForeColor = "#000000",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
await caseWorkflowXPathRepository.InsertAsync(new CaseWorkflowXPath
{
CaseWorkflowId = caseWorkflowId,
Name = "TxnId",
XPath = "payload.TxnId",
Active = 1,
BoldLineMatched = 1,
BoldLineFormatForeColor = "#032cfc",
BoldLineFormatBackColor = "#ffffff",
ConditionalFormatForeColor = "#000000",
ConditionalFormatBackColor = "#ffffff"
}, token);
}
private Task<CaseWorkflow> InsertCaseWorkflowAsync(int entityAnalysisModelId, Guid visualisationRegistryGuid, string userName, CancellationToken token = default)
{
var caseWorkflowRepository = new CaseWorkflowRepository(dbContext, userName);
return caseWorkflowRepository.InsertAsync(new CaseWorkflow
{
Name = "Detailed Account Financial Transactions Cases",
Active = 1,
EntityAnalysisModelId = entityAnalysisModelId,
EnableVisualisation = 1,
VisualisationRegistryGuid = visualisationRegistryGuid
}, token);
}
private Task InsertCaseWorkflowMacroAsync(int caseWorkflowId, string userName, CancellationToken token = default)
{
var caseWorkflowMacroRepository = new CaseWorkflowMacroRepository(dbContext, userName);
return caseWorkflowMacroRepository.InsertAsync(new CaseWorkflowMacro
{
CaseWorkflowId = caseWorkflowId,
Name = "ExampleMacro",
Active = 1,
Javascript = "alert('Example Macro Javascript Eval.');",
ImageLocation = "calculator.png"
}, token);
}
private Task InsertCaseWorkflowFormAsync(int caseWorkflowId, string userName, CancellationToken token = default)
{
var caseWorkflowForm = new CaseWorkflowFormRepository(dbContext, userName);
return caseWorkflowForm.InsertAsync(new CaseWorkflowForm
{
CaseWorkflowId = caseWorkflowId,
Name = "ExampleForm",
Active = 1,
Html = "<p>This form will support most unstyled elements available to HTML forms.</p>" +
Environment.NewLine +
"<p>Injection of Javascript to support validation and additional styling " +
"is not supported at this time.</p>" + Environment.NewLine +
"<p>The submit button is added during rendering. " +
"The submit button will query the name and value attributes and create the " +
"payload for processing.</p>" + Environment.NewLine +
"Example Textbox Element: " + Environment.NewLine +
"<br/>" + Environment.NewLine +
"<input id='ExampleTextboxElement'/>"
}, token);
}
private Task InsertCaseWorkflowFilterAsync(int caseWorkflowId, string userName, CancellationToken token = default)
{
var caseWorkflowFilterRepository = new CaseWorkflowFilterRepository(dbContext, userName);
return caseWorkflowFilterRepository.InsertAsync(new CaseWorkflowFilter
{
CaseWorkflowId = caseWorkflowId,
Name = "OpenCasesNotLockedByCreatedDate",
FilterSql = "\"Case\".\"ClosedStatusId\" = @1 AND \"Case\".\"Locked\" = @2",
FilterJson = "{\"rules\": [{\"id\": \"ClosedStatusId\", \"type\": \"integer\", \"field\": " +
"\"\\\"Case\\\".\\\"ClosedStatusId\\\"\", \"input\": \"select\", " +
"\"value\": 0, \"operator\": \"equal\"}, {\"id\": \"Locked\", " +
"\"type\": \"integer\", \"field\": \"\\\"Case\\\".\\\"Locked\\\"\", " +
"\"input\": \"radio\", \"value\": 0, \"operator\": \"equal\"}], " +
"\"valid\": true, \"condition\": \"AND\"}",
SelectJson = "{\"rules\": [{\"id\": \"CaseKey\", \"type\": \"string\", \"field\": \"\\\"CaseKey\\\"\", " +
"\"input\": \"radio\", \"value\": \"ASC\", \"operator\": \"order\"}, " +
"{\"id\": \"CaseKeyValue\", \"type\": \"string\", " +
"\"field\": \"\\\"CaseKeyValue\\\"\", " +
"\"input\": \"radio\", \"value\": \"ASC\", " +
"\"operator\": \"order\"}, {\"id\": \"CaseWorkflowStatusGuid\", " +
"\"type\": \"string\", \"field\": \"\\\"CaseWorkflowStatus\\\".\\\"Id\\\"\", " +
"\"input\": \"radio\", \"value\": \"ASC\", \"operator\": \"order\"}, " +
"{\"id\": \"Payload.CurrencyAmount\", " +
"\"type\": \"string\", \"field\": \"(\\\"Json\\\"-> 'payload' -> 'CurrencyAmount')::double precision\", " +
"\"input\": \"radio\", \"value\": \"ASC\", \"operator\": \"order\"}, " +
"{\"id\": \"Payload.BusinessModel\", \"type\": \"string\", " +
"\"field\": \"(\\\"Json\\\"-> 'payload' -> 'BusinessModel')\", " +
"\"input\": \"radio\", \"value\": \"ASC\", \"operator\": \"order\"}, " +
"{\"id\": \"Payload.IP\", \"type\": \"string\", " +
"\"field\": \"(\\\"Json\\\"-> 'payload' -> 'IP')\", " +
"\"input\": \"radio\", \"value\": \"ASC\", \"operator\": \"order\"}, " +
"{\"id\": \"Payload.Email\", \"type\": \"string\", " +
"\"field\": \"(\\\"Json\\\"-> 'payload' -> 'Email')\", " +
"\"input\": \"radio\", \"value\": \"ASC\", \"operator\": \"order\"}, " +
"{\"id\": \"Payload.BusinessModel\", \"type\": \"string\", " +
"\"field\": \"(\\\"Json\\\"-> 'payload' -> 'BusinessModel')\", " +
"\"input\": \"radio\", \"value\": \"ASC\", \"operator\": \"order\"}, " +
"{\"id\": \"Payload.BillingAddress\", \"type\": \"string\", " +
"\"field\": \"(\\\"Json\\\"-> 'payload' -> 'BillingAddress')\", " +
"\"input\": \"radio\", \"value\": \"ASC\", \"operator\": \"order\"}, " +
"{\"id\": \"Payload.BillingCountry\", \"type\": \"string\", \"field\": " +
"\"(\\\"Json\\\"-> 'payload' -> 'BillingCountry')\", \"input\": \"radio\", " +
"\"value\": \"ASC\", \"operator\": \"order\"}, {\"id\": \"CreatedDate\", " +
"\"type\": \"string\", \"field\": \"\\\"Case\\\".\\\"CreatedDate\\\"\", " +
"\"input\": \"radio\", \"value\": \"DESC\", \"operator\": \"order\"}], " +
"\"valid\": true, \"condition\": \"AND\"}",
FilterTokens = "[0,0]",
Active = 1
}, token);
}
private Task InsertCaseWorkflowDisplayAsync(int caseWorkflowId, string userName, CancellationToken token = default)
{
var caseWorkflowDisplayRepository = new CaseWorkflowDisplayRepository(dbContext, userName);
return caseWorkflowDisplayRepository.InsertAsync(new CaseWorkflowDisplay
{
CaseWorkflowId = caseWorkflowId,
Name = "ExampleDisplayCurrencyAmount",
Active = 1,
Html = "This is an example Cases Workflow Display:" + Environment.NewLine +
"The transaction amount is:" + Environment.NewLine +
"<br/>" + Environment.NewLine +
"<br/>" + Environment.NewLine +
"<div style='font-size:30px'>[@Payload.AccountId@]</div>" + Environment.NewLine +
"<br/>" + Environment.NewLine +
"The tokens are taken from the Cases Workflows XPath and can be laid out in HTML."
}, token);
}
private Task InsertVisualisationRegistryParameterEmbeddedVisualisationAsync(int visualisationRegistryId,
string userName, CancellationToken token = default)
{
var visualisationRegistryParameterRepository =
new VisualisationRegistryParameterRepository(dbContext, userName);
return visualisationRegistryParameterRepository.InsertAsync(new VisualisationRegistryParameter
{
VisualisationRegistryId = visualisationRegistryId,
Name = "AccountId",
Active = 1,
DataTypeId = 1,
Required = 1,
DefaultValue = "Test1",
Guid = Guid.NewGuid()
}, token);
}
private async Task InsertVisualisationRegistryParameterExampleEmbeddedVisualisationAsync(int visualisationRegistryId,
string userName, CancellationToken token = default)
{
var visualisationRegistryParameterRepository =
new VisualisationRegistryParameterRepository(dbContext, userName);
await visualisationRegistryParameterRepository.InsertAsync(new VisualisationRegistryParameter
{
VisualisationRegistryId = visualisationRegistryId,
Name = "Percentage Contribution Greater Than",
Active = 1,
DataTypeId = 3,
Required = 1,
DefaultValue = "0",
Guid = Guid.NewGuid()
}, token);
await visualisationRegistryParameterRepository.InsertAsync(new VisualisationRegistryParameter
{
VisualisationRegistryId = visualisationRegistryId,
Name = "Frequency Greater Than",
Active = 1,
DataTypeId = 2,
Required = 1,
DefaultValue = "0"
}, token);
}
private async Task InsertVisualisationRegistryDatasourceExampleVisualisationAsync(int visualisationRegistryId,
string userName)
{
var visualisationRegistryDatasourceRepository =
new VisualisationRegistryDatasourceRepository(dbContext, userName);
await visualisationRegistryDatasourceRepository.InsertWithValidationAsync(new VisualisationRegistryDatasource
{
VisualisationRegistryId = visualisationRegistryId,
Name = "ExamplePie",
Active = 1,
VisualisationTypeId = 1,
Command = "select " + Environment.NewLine +
"\"ActivationRuleName\"," + Environment.NewLine +
"\"Frequency\"," + Environment.NewLine +
"\"PercentageContribution\" " + Environment.NewLine +
"from \"ExampleCaseVolumeEntry\" " + Environment.NewLine +
"where \"Frequency\" > @Frequency_Greater_Than " + Environment.NewLine +
"and \"PercentageContribution\" > @Percentage_Contribution_Greater_Than " +
Environment.NewLine +
"order by \"Frequency\" desc",
Priority = 1,
IncludeGrid = 0,
IncludeDisplay = 1,
ColumnSpan = 3,
RowSpan = 2,
VisualisationText = "({" + Environment.NewLine +
" legend: {" + Environment.NewLine +
" position: \"bottom\"" + Environment.NewLine +
" }," + Environment.NewLine +
" series: [{" + Environment.NewLine +
" type: \"pie\"," + Environment.NewLine +
" field: \"Frequency\"," + Environment.NewLine +
" categoryField: \"ActivationRuleName\"" + Environment.NewLine +
" }]," + Environment.NewLine +
" seriesColors: [\"#03a9f4\", \"#ff9800\", \"#fad84a\", \"#4caf50\"]," +
Environment.NewLine +
" tooltip: {" + Environment.NewLine +
" visible: true," + Environment.NewLine +
" template: \"${ category } - ${ value }%\"" + Environment.NewLine +
" }" + Environment.NewLine +
"})" + Environment.NewLine,
Guid = Guid.NewGuid()
}).ConfigureAwait(false);
await visualisationRegistryDatasourceRepository.InsertWithValidationAsync(new VisualisationRegistryDatasource
{
VisualisationRegistryId = visualisationRegistryId,
Name = "ExampleBar",
Active = 1,
VisualisationTypeId = 1,
Command = "select " + Environment.NewLine +
"\"ActivationRuleName\"," + Environment.NewLine +
"\"Frequency\"," + Environment.NewLine +
"\"PercentageContribution\" " + Environment.NewLine +
"from \"ExampleCaseVolumeEntry\" " + Environment.NewLine +
"where \"Frequency\" > @Frequency_Greater_Than " + Environment.NewLine +
"and \"PercentageContribution\" > @Percentage_Contribution_Greater_Than " +
Environment.NewLine +
"order by \"Frequency\" desc",
Priority = 2,
IncludeGrid = 0,
IncludeDisplay = 1,
ColumnSpan = 3,
RowSpan = 2,
VisualisationText = "({" + Environment.NewLine +
" legend: {" + Environment.NewLine +
" visible: false" + Environment.NewLine +
" }," + Environment.NewLine +
" seriesDefaults: {" + Environment.NewLine +
" type: \"bar\"" + Environment.NewLine +
" }," + Environment.NewLine +
" series: [" + Environment.NewLine +
" {" + Environment.NewLine +
" field: \"Frequency\"," + Environment.NewLine +
" categoryField: \"ActivationRuleName\"," + Environment.NewLine +
" name: \"Frequency\"" + Environment.NewLine +
" }]," + Environment.NewLine +
" valueAxis: {" + Environment.NewLine +
" max: 140000," + Environment.NewLine +
" line: {" + Environment.NewLine +
" visible: false" + Environment.NewLine +
" }," + Environment.NewLine +
" minorGridLines: {" + Environment.NewLine +
" visible: true" + Environment.NewLine +
" }," + Environment.NewLine +
" labels: {" + Environment.NewLine +
" rotation: \"auto\"" + Environment.NewLine +
" }" + Environment.NewLine +
" }," + Environment.NewLine +
" tooltip: {" + Environment.NewLine +
" visible: true," + Environment.NewLine +
" template: \"#= series.name #: #= value #\"" + Environment.NewLine +
" }" + Environment.NewLine +
"})" + Environment.NewLine,
Guid = Guid.NewGuid()
}).ConfigureAwait(false);
}
private async Task InsertVisualisationRegistryDatasourceExampleEmbeddedVisualisationAsync(int visualisationRegistryId,
string userName)
{
var visualisationRegistryDatasourceRepository =
new VisualisationRegistryDatasourceRepository(dbContext, userName);
await visualisationRegistryDatasourceRepository.InsertWithValidationAsync(new VisualisationRegistryDatasource
{
VisualisationRegistryId = visualisationRegistryId,
Name = "ExamplePie",
Active = 1,
VisualisationTypeId = 1,
Command = "select " + Environment.NewLine +
"\"MCC\"," + Environment.NewLine +
"\"Frequency\"," + Environment.NewLine +
"\"Sum\" " + Environment.NewLine +
"from \"ExampleCustomerCaseManagement\" " + Environment.NewLine +
"where \"AccountId\" = @AccountId " + Environment.NewLine +
"order by \"Frequency\" desc",
Priority = 1,
IncludeGrid = 0,
IncludeDisplay = 1,
ColumnSpan = 3,
RowSpan = 2,
VisualisationText = "({" + Environment.NewLine +
" legend: {" + Environment.NewLine +
" position: \"bottom\"" + Environment.NewLine +
" }," + Environment.NewLine +
" series: [{" + Environment.NewLine +
" type: \"pie\"," + Environment.NewLine +
" field: \"Frequency\"," + Environment.NewLine +
" categoryField: \"MCC\"" + Environment.NewLine +
" }]," + Environment.NewLine +
" seriesColors: [\"#03a9f4\", \"#ff9800\", \"#fad84a\", \"#4caf50\"]," +
Environment.NewLine +
" tooltip: {" + Environment.NewLine +
" visible: true," + Environment.NewLine +
" template: \"${ category } - ${ value }%\"" + Environment.NewLine +
" }" + Environment.NewLine +
"})" + Environment.NewLine,
Guid = Guid.NewGuid()
}).ConfigureAwait(false);
await visualisationRegistryDatasourceRepository.InsertWithValidationAsync(new VisualisationRegistryDatasource
{
VisualisationRegistryId = visualisationRegistryId,
Name = "ExampleBar",
Active = 1,
VisualisationTypeId = 1,
Command = "select " + Environment.NewLine +
"\"MCC\"," + Environment.NewLine +
"\"Frequency\"," + Environment.NewLine +
"\"Sum\" " + Environment.NewLine +
"from \"ExampleCustomerCaseManagement\" " + Environment.NewLine +
"where \"AccountId\" = @AccountId " + Environment.NewLine +
"order by \"Frequency\" desc",
Priority = 2,
IncludeGrid = 0,
IncludeDisplay = 1,
ColumnSpan = 3,
RowSpan = 2,
VisualisationText = "({" + Environment.NewLine +
" legend: {" + Environment.NewLine +
" visible: false" + Environment.NewLine +
" }," + Environment.NewLine +
" seriesDefaults: {" + Environment.NewLine +
" type: \"bar\"" + Environment.NewLine +
" }," + Environment.NewLine +
" series: [" + Environment.NewLine +
" {" + Environment.NewLine +
" field: \"Sum\"," + Environment.NewLine +
" categoryField: \"MCC\"," + Environment.NewLine +
" name: \"Sum\"" + Environment.NewLine +
" }]," + Environment.NewLine +
" valueAxis: {" + Environment.NewLine +
" max: 140000," + Environment.NewLine +
" line: {" + Environment.NewLine +
" visible: false" + Environment.NewLine +
" }," + Environment.NewLine +
" minorGridLines: {" + Environment.NewLine +
" visible: true" + Environment.NewLine +
" }," + Environment.NewLine +
" labels: {" + Environment.NewLine +
" rotation: \"auto\"" + Environment.NewLine +
" }" + Environment.NewLine +
" }," + Environment.NewLine +
" tooltip: {" + Environment.NewLine +
" visible: true," + Environment.NewLine +
" template: \"#= series.name #: #= value #\"" + Environment.NewLine +
" }" + Environment.NewLine +
"})" + Environment.NewLine,
Guid = Guid.NewGuid()
}).ConfigureAwait(false);
}
private async Task<int> InsertVisualisationRegistryExampleVisualisationAsync(string userName, CancellationToken token = default)
{
var visualisationRegistryRepository = new VisualisationRegistryRepository(dbContext, userName);
return (await visualisationRegistryRepository.InsertAsync(new VisualisationRegistry
{
Name = "ExampleVisualisation",
Active = 1,
ShowInDirectory = 1,
TenantRegistryId = 1,
Columns = 6,
ColumnWidth = 300,
RowHeight = 300,
Guid = Guid.NewGuid()
}, token)).Id;
}
private Task<VisualisationRegistry> InsertVisualisationRegistryExampleEmbeddedVisualisationAsync(string userName, CancellationToken token = default)
{
var visualisationRegistryRepository = new VisualisationRegistryRepository(dbContext, userName);
return visualisationRegistryRepository.InsertAsync(new VisualisationRegistry
{
Name = "ExampleEmbeddedVisualisation",
Active = 1,
ShowInDirectory = 0,
TenantRegistryId = 1,
Columns = 6,
ColumnWidth = 300,
RowHeight = 300,
Guid = Guid.NewGuid()
}, token);
}
private Task InsertEntityAnalysisModelInlineScriptAsync(int entityAnalysisModelId, int entityAnalysisInlineScriptId,
string userName, CancellationToken token = default)
{
var entityAnalysisModelInlineScriptRepository =
new EntityAnalysisModelInlineScriptRepository(dbContext, userName);
return entityAnalysisModelInlineScriptRepository.InsertAsync(new EntityAnalysisModelInlineScript
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "Issue OTP",
Active = 1,
EntityAnalysisInlineScriptId = entityAnalysisInlineScriptId,
Guid = Guid.NewGuid()
}, token);
}
private Task InsertEntityAnalysisModelTagAsync(int entityAnalysisModelId, string userName, CancellationToken token = default)
{
var entityAnalysisModelTagRepository = new EntityAnalysisModelTagRepository(dbContext, userName);
return entityAnalysisModelTagRepository.InsertAsync(new EntityAnalysisModelTag
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "Fraud",
Active = 1,
Guid = Guid.NewGuid()
}, token);
}
private Task InsertEntityAnalysisModelSynchronisationScheduleAsync(string userName, CancellationToken token = default)
{
var entityAnalysisModelSynchronisationScheduleRepository =
new EntityAnalysisModelSynchronisationScheduleRepository(dbContext, userName);
return entityAnalysisModelSynchronisationScheduleRepository.InsertAsync(new EntityAnalysisModelSynchronisationSchedule(), token);
}
private Task InsertEntityAnalysisModelSanctionAsync(int entityAnalysisModelId, string userName, CancellationToken token = default)
{
var entityAnalysisModelSanctionRepository = new EntityAnalysisModelSanctionRepository(dbContext, userName);
return entityAnalysisModelSanctionRepository.InsertAsync(new EntityAnalysisModelSanction
{
Name = "FuzzyMatchDistance2JoinedName",
EntityAnalysisModelId = entityAnalysisModelId,
MultipartStringDataName = "JoinedName",
Distance = 2,
Active = 1,
ResponsePayload = 1,
CacheValue = 1,
CacheInterval = 'h',
Guid = Guid.NewGuid()
}, token);
}
private Task InsertEntityAnalysisModelListValueAsync(int entityAnalysisModelListId, string userName, CancellationToken token = default)
{
var entityAnalysisModelListValueRepository = new EntityAnalysisModelListValueRepository(dbContext, userName);
return entityAnalysisModelListValueRepository.InsertAsync(new EntityAnalysisModelListValue
{
EntityAnalysisModelListId = entityAnalysisModelListId,
ListValue = "123.456.789.123",
Guid = Guid.NewGuid()
}, token);
}
private Task InsertEntityAnalysisModelHttpAdaptationAsync(int entityAnalysisModelId, string userName, CancellationToken token = default)
{
var entityAnalysisModelHttpAdaptationRepository =
new EntityAnalysisModelHttpAdaptationRepository(dbContext, userName);
return entityAnalysisModelHttpAdaptationRepository.InsertAsync(new EntityAnalysisModelHttpAdaptation
{
EntityAnalysisModelId = entityAnalysisModelId,
Active = 0,
Name = "ExampleFraudScoreLocalEndpoint",
ResponsePayload = 1,
HttpEndpoint = "/api/invoke/ExampleFraudScoreLocalEndpoint",
Guid = Guid.NewGuid()
}, token);
}
private async Task<Guid> InsertEntityAnalysisModelTtlCounterAsync(int entityAnalysisModelId, string userName, CancellationToken token = default)
{
var entityAnalysisModelTtlCounterRepository = new EntityAnalysisModelTtlCounterRepository(dbContext, userName);
return (await entityAnalysisModelTtlCounterRepository.InsertAsync(new EntityAnalysisModelTtlCounter
{
Name = "TtlCounterAll",
EntityAnalysisModelId = entityAnalysisModelId,
Active = 1,
TtlCounterInterval = "h",
TtlCounterValue = 1,
ResponsePayload = 1,
TtlCounterDataName = "AccountId",
OnlineAggregation = 0,
EnableLiveForever = 0,
Guid = Guid.NewGuid()
}, token)).Guid;
}
private async Task<int> InsertEntityAnalysisModelListAsync(Guid entityAnalysisModelGuid, string userName, CancellationToken token = default)
{
var entityAnalysisModelListRepository = new EntityAnalysisModelListRepository(dbContext, userName);
return (await entityAnalysisModelListRepository.InsertAsync(new EntityAnalysisModelList
{
EntityAnalysisModelGuid = entityAnalysisModelGuid,
Name = "IPDenyList",
Active = 1,
Guid = Guid.NewGuid()
}, token)).Id;
}
private Task InsertEntityAnalysisModelInlineFunctionAsync(int entityAnalysisModelId, string userName, CancellationToken token = default)
{
var entityAnalysisModelInlineFunctionRepository =
new EntityAnalysisModelInlineFunctionRepository(dbContext, userName);
return entityAnalysisModelInlineFunctionRepository.InsertAsync(new EntityAnalysisModelInlineFunction
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "JoinedName",
FunctionScript = "Return Payload.BillingFirstName & \" \" & Payload.BillingLastName",
ReturnDataTypeId = 1,
Active = 1,
ResponsePayload = 1,
Guid = Guid.NewGuid()
}, token);
}
private Task InsertEntityAnalysisModelGatewayRuleAsync(int entityAnalysisModelId, string userName, CancellationToken token = default)
{
var entityAnalysisModelGatewayRuleRepository =
new EntityAnalysisModelGatewayRuleRepository(dbContext, userName);
var builderRuleScript = "If (Payload.CurrencyAmount > 0) Then " + Environment.NewLine +
" Return True " + Environment.NewLine +
"End If";
var json = "{\"not\": false, \"rules\": [{\"id\": \"Payload.CurrencyAmount\", \"type\": \"double\", " +
"\"field\": \"Payload.CurrencyAmount\", \"input\": \"number\", \"value\": 0, \"operator\": " +
"\"greater\"}], \"valid\": true, \"condition\": \"AND\"}";
return entityAnalysisModelGatewayRuleRepository.InsertAsync(new EntityAnalysisModelGatewayRule
{
EntityAnalysisModelId = entityAnalysisModelId,
Priority = 0,
BuilderRuleScript = builderRuleScript,
Json = json,
Name = "CurrencyAmountAllGreaterThan0.",
MaxResponseElevation = 10,
CoderRuleScript = "Return = True",
RuleScriptTypeId = 1,
GatewaySample = 1,
Active = 1,
Guid = Guid.NewGuid()
}, token);
}
private int InsertEntityAnalysisModelDictionary(Guid entityAnalysisModelGuid, string userName)
{
var entityAnalysisModelDictionaryRepository = new EntityAnalysisModelDictionaryRepository(dbContext, userName);
return entityAnalysisModelDictionaryRepository.InsertAsync(new EntityAnalysisModelDictionary
{
EntityAnalysisModelGuid = entityAnalysisModelGuid,
Name = "VolumeThresholdByAccountId",
Active = 1,
ResponsePayload = 1,
DataName = "AccountId",
Guid = Guid.NewGuid()
}).Id;
}
private Task InsertEntityAnalysisModelDictionaryKvpAsync(int entityAnalysisModelDictionaryId, string userName, CancellationToken token = default)
{
var entityAnalysisModelDictionaryKvpRepository =
new EntityAnalysisModelDictionaryKvpRepository(dbContext, userName);
return entityAnalysisModelDictionaryKvpRepository.InsertAsync(new EntityAnalysisModelDictionaryKvp
{
EntityAnalysisModelDictionaryId = entityAnalysisModelDictionaryId,
KvpKey = "Test1",
KvpValue = 1000,
Guid = Guid.NewGuid()
}, token);
}
private async Task InsertEntityAnalysisModelAbstractionRuleAsync(int entityAnalysisModelId, string userName, CancellationToken token = default)
{
var entityAnalysisModelAbstractionRuleRepository =
new EntityAnalysisModelAbstractionRuleRepository(dbContext, userName);
var builderRuleScriptApproved = "If (Payload.ResponseCode = \"0\") Then " + Environment.NewLine +
" Return True " + Environment.NewLine +
"End If";
var jsonApproved =
"{\"not\": false, \"rules\": [{\"id\": \"Payload.ResponseCode\", \"type\": \"string\", " +
"\"field\": \"Payload.ResponseCode\", \"input\": \"text\", \"value\": \"0\", " +
"\"operator\": \"equal\"}], \"valid\": true, \"condition\": \"AND\"}";
await entityAnalysisModelAbstractionRuleRepository.InsertAsync(new EntityAnalysisModelAbstractionRule
{
EntityAnalysisModelId = entityAnalysisModelId,
BuilderRuleScript = builderRuleScriptApproved,
CoderRuleScript = "Return True",
RuleScriptTypeId = 1,
Name = "ResponseCodeEqual0Volume",
Search = 1,
SearchFunctionTypeId = 3,
SearchFunctionKey = "CurrencyAmount",
SearchInterval = "h",
SearchValue = 1,
SearchKey = "AccountId",
Active = 1,
ResponsePayload = 1,
Json = jsonApproved,
Guid = Guid.NewGuid()
}, token);
var builderRuleScriptDeclined = "If (NOT ( Payload.ResponseCode = \"0\" )) Then " + Environment.NewLine +
" Return True" + Environment.NewLine +
"End If";
var jsonDeclined = "{\"not\": true, \"rules\": [{\"id\": \"Payload.ResponseCode\", \"type\": \"string\", " +
"\"field\": \"Payload.ResponseCode\", \"input\": \"text\", \"value\": \"0\", " +
"\"operator\": \"equal\"}], \"valid\": true, \"condition\": \"AND\"}";
await entityAnalysisModelAbstractionRuleRepository.InsertAsync(new EntityAnalysisModelAbstractionRule
{
EntityAnalysisModelId = entityAnalysisModelId,
BuilderRuleScript = builderRuleScriptDeclined,
CoderRuleScript = "Return True",
RuleScriptTypeId = 1,
Name = "NotResponseCodeEqual0Volume",
Search = 1,
SearchFunctionTypeId = 3,
SearchFunctionKey = "CurrencyAmount",
SearchInterval = "h",
SearchValue = 1,
SearchKey = "AccountId",
Active = 1,
ResponsePayload = 1,
Json = jsonDeclined,
Guid = Guid.NewGuid()
}, token);
}
private Task InsertEntityAnalysisModelAbstractionCalculationAsync(int entityAnalysisModelId, string userName, CancellationToken token = default)
{
var entityAnalysisModelAbstractionCalculationRepository =
new EntityAnalysisModelAbstractionCalculationRepository(dbContext, userName);
var functionScript = "Return Abstraction.NotResponseCodeEqual0Volume / " + Environment.NewLine +
" (Abstraction.NotResponseCodeEqual0Volume _ " + Environment.NewLine +
"+ Abstraction.ResponseCodeEqual0Volume) _ " + Environment.NewLine;
return entityAnalysisModelAbstractionCalculationRepository.InsertAsync(new EntityAnalysisModelAbstractionCalculation
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "ResponseCodeVolumeRatio",
Active = 1,
AbstractionCalculationTypeId = 5,
ResponsePayload = 1,
FunctionScript = functionScript,
Guid = Guid.NewGuid()
}, token);
}
private async Task InsertEntityAnalysisModelActivationRuleAsync(EntityAnalysisModel entityAnalysisModel,
Guid caseWorkflowGuid,
Guid caseWorkflowStatusGuid, Guid entityAnalysisModelTtlCounterGuid,
string userName, CancellationToken token = default)
{
var entityAnalysisModelActivationRuleRepository =
new EntityAnalysisModelActivationRuleRepository(dbContext, userName);
await entityAnalysisModelActivationRuleRepository.InsertAsync(new EntityAnalysisModelActivationRule
{
EntityAnalysisModelId = entityAnalysisModel.Id,
Name = "IncrementTtlCounterAll",
BuilderRuleScript = "Return False",
CoderRuleScript = "Return True",
RuleScriptTypeId = 2,
ResponseElevation = 0,
EnableCaseWorkflow = 0,
CaseKey = "",
Active = 1,
EnableTtlCounter = 1,
EntityAnalysisModelTtlCounterGuid = entityAnalysisModelTtlCounterGuid,
EntityAnalysisModelGuidTtlCounter = entityAnalysisModel.Guid,
ResponsePayload = 0,
EnableNotification = 0,
EnableResponseElevation = 0,
ResponseElevationKey = "",
EnableBypass = 0,
Visible = 0,
EnableReprocessing = 0,
EnableSuppression = 0,
ActivationSample = 1,
ReviewStatusId = 4,
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelActivationRuleRepository.InsertAsync(new EntityAnalysisModelActivationRule
{
EntityAnalysisModelId = entityAnalysisModel.Id,
Name = "ThresholdTtlCounterAll",
BuilderRuleScript = "If (TTLCounter.TtlCounterAll > 5) Then " + Environment.NewLine +
" Return True" + Environment.NewLine +
"End If",
CoderRuleScript = "Return False",
RuleScriptTypeId = 1,
Json = "{\"not\": false, \"rules\": [{\"id\": \"TTLCounter.TtlCounterAll\", " +
"\"type\": \"double\", \"field\": \"TTLCounter.TtlCounterAll\", " +
"\"input\": \"number\", \"value\": 5, \"operator\": \"greater\"}], " +
"\"valid\": true, \"condition\": \"AND\"}",
ResponseElevation = 1,
Active = 1,
EnableCaseWorkflow = 1,
CaseWorkflowGuid = caseWorkflowGuid,
CaseKey = "AccountId",
EnableTtlCounter = 0,
EntityAnalysisModelTtlCounterGuid = entityAnalysisModelTtlCounterGuid,
EntityAnalysisModelGuidTtlCounter = entityAnalysisModel.Guid,
ResponsePayload = 1,
EnableNotification = 0,
EnableResponseElevation = 1,
ResponseElevationKey = "AccountId",
EnableBypass = 0,
Visible = 1,
EnableReprocessing = 1,
EnableSuppression = 1,
ActivationSample = 1,
ReviewStatusId = 4,
ResponseElevationContent = "Declined for \"ThresholdTtlCounterAll\"",
ResponseElevationForeColor = "#fb0707",
ResponseElevationBackColor = "#f5f2cb",
SendToActivationWatcher = 1,
CaseWorkflowStatusGuid = caseWorkflowStatusGuid,
ResponseElevationRedirect = "https://www.jube.io",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelActivationRuleRepository.InsertAsync(new EntityAnalysisModelActivationRule
{
EntityAnalysisModelId = entityAnalysisModel.Id,
Name = "ThresholdSanctionsDistance",
BuilderRuleScript = "If (Sanction.FuzzyMatchDistance2JoinedName < 1) Then " + Environment.NewLine +
" Return True" + Environment.NewLine +
"End If",
CoderRuleScript = "Return False",
RuleScriptTypeId = 1,
Json = "{\"not\": false, \"rules\": [{\"id\": \"Sanction.FuzzyMatchDistance2JoinedName\", " +
"\"type\": \"double\", \"field\": \"sanction.FuzzyMatchDistance2JoinedName\", " +
"\"input\": \"number\", \"value\": 1, \"operator\": \"less\"}], " +
"\"valid\": true, \"condition\": \"AND\"}",
ResponseElevation = 2,
EnableCaseWorkflow = 1,
CaseWorkflowGuid = caseWorkflowGuid,
CaseKey = "AccountId",
EnableTtlCounter = 0,
EntityAnalysisModelTtlCounterGuid = entityAnalysisModelTtlCounterGuid,
EntityAnalysisModelGuidTtlCounter = entityAnalysisModel.Guid,
ResponsePayload = 1,
EnableNotification = 0,
EnableResponseElevation = 1,
ResponseElevationKey = "AccountId",
EnableBypass = 0,
Visible = 1,
EnableReprocessing = 1,
EnableSuppression = 1,
ActivationSample = 1,
Active = 1,
ReviewStatusId = 4,
ResponseElevationContent = "Declined for \"ThresholdSanctionsDistance\"",
ResponseElevationForeColor = "#fb0707",
ResponseElevationBackColor = "#f5f2cb",
SendToActivationWatcher = 1,
CaseWorkflowStatusGuid = caseWorkflowStatusGuid,
ResponseElevationRedirect = "https://www.jube.io",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelActivationRuleRepository.InsertAsync(new EntityAnalysisModelActivationRule
{
EntityAnalysisModelId = entityAnalysisModel.Id,
Name = "AllIPDenyList",
BuilderRuleScript = "If (( List.IPDenyList.contains(Payload.IP))) Then" + Environment.NewLine +
" Return True" + Environment.NewLine +
"End If",
CoderRuleScript = "Return False",
RuleScriptTypeId = 1,
Json = "{\"rules\": [{\"id\": \"List.IPDenyList\", \"type\": \"string\", \"field\": " +
"\"List.IPDenyList\", \"input\": \"select\", \"value\": \"Payload.IP\", \"operator\": \"has\"}], " +
"\"valid\": true, \"condition\": \"AND\"}",
ResponseElevation = 2,
EnableCaseWorkflow = 1,
CaseWorkflowGuid = caseWorkflowGuid,
CaseKey = "AccountId",
Active = 1,
EnableTtlCounter = 0,
EntityAnalysisModelTtlCounterGuid = entityAnalysisModelTtlCounterGuid,
EntityAnalysisModelGuidTtlCounter = entityAnalysisModel.Guid,
ResponsePayload = 1,
EnableNotification = 0,
EnableResponseElevation = 1,
ResponseElevationKey = "AccountId",
EnableBypass = 0,
Visible = 1,
EnableReprocessing = 1,
EnableSuppression = 1,
ActivationSample = 1,
ReviewStatusId = 4,
ResponseElevationContent = "Declined for \"AllIPDenyList\"",
ResponseElevationForeColor = "#fb0707",
ResponseElevationBackColor = "#f5f2cb",
SendToActivationWatcher = 1,
CaseWorkflowStatusGuid = caseWorkflowStatusGuid,
ResponseElevationRedirect = "https://www.jube.io",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelActivationRuleRepository.InsertAsync(new EntityAnalysisModelActivationRule
{
EntityAnalysisModelId = entityAnalysisModel.Id,
Name = "VolumeThresholdByAccountId",
BuilderRuleScript = "Return False",
CoderRuleScript =
"If (Abstraction.ResponseCodeEqual0Volume > Dictionary.VolumeThresholdByAccountId) Then" +
Environment.NewLine +
" Return True" + Environment.NewLine +
"End If",
RuleScriptTypeId = 2,
ResponseElevation = 2,
EnableCaseWorkflow = 1,
CaseWorkflowGuid = caseWorkflowGuid,
CaseKey = "AccountId",
EnableTtlCounter = 0,
EntityAnalysisModelTtlCounterGuid = entityAnalysisModelTtlCounterGuid,
EntityAnalysisModelGuidTtlCounter = entityAnalysisModel.Guid,
ResponsePayload = 1,
EnableNotification = 0,
EnableResponseElevation = 1,
ResponseElevationKey = "AccountId",
EnableBypass = 0,
Visible = 1,
EnableReprocessing = 1,
EnableSuppression = 1,
ActivationSample = 1,
Active = 1,
ReviewStatusId = 4,
ResponseElevationContent = "Declined for \"VolumeThresholdByAccountId\"",
ResponseElevationForeColor = "#fb0707",
ResponseElevationBackColor = "#f5f2cb",
SendToActivationWatcher = 1,
CaseWorkflowStatusGuid = caseWorkflowStatusGuid,
ResponseElevationRedirect = "https://www.jube.io",
Guid = Guid.NewGuid()
}, token);
}
private async Task InsertEntityAnalysisModelRequestXPathsAsync(int entityAnalysisModelId, string userName, CancellationToken token = default)
{
var entityAnalysisModelRequestXPathRepository =
new EntityAnalysisModelRequestXPathRepository(dbContext, userName);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "AccountId",
XPath = "$.AccountId",
DataTypeId = 1,
EnableSuppression = 1,
ResponsePayload = 1,
SearchKey = 1,
SearchKeyFetchLimit = 100,
SearchKeyCacheInterval = "h",
SearchKeyCacheTtlValue = 1,
SearchKeyTtlIntervalValue = 1,
SearchKeyTtlInterval = "h",
Active = 1,
DefaultValue = "Test1",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "TxnDateTime",
XPath = "$.TxnDateTime",
DataTypeId = 4,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "2022-08-19T21:41:37.247",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "Currency",
XPath = "$.Currency",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "826",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "ResponseCode",
XPath = "$.ResponseCode",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "1",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "CurrencyAmount",
XPath = "$.CurrencyAmount",
DataTypeId = 3,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "123.45",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "SettlementAmount",
XPath = "$.SettlementAmount",
DataTypeId = 3,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "123.45",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "AccountCurrency",
XPath = "$.AccountCurrency",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "566",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "ChannelId",
XPath = "$.ChannelId",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "1",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "AppVersionCode",
XPath = "$.AppVersionCode",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "12.34",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "ServiceCode",
XPath = "$.ServiceCode",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "DID",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "System",
XPath = "$.System",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "Android",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "Brand",
XPath = "$.Brand",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "ZTE",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "Model",
XPath = "$.Model",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "Barby",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "AccountLongitude",
XPath = "$.AccountLongitude",
DataTypeId = 6,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "36.1408",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "AccountLatitude",
XPath = "$.AccountLatitude",
DataTypeId = 7,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "5.3536",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "OS",
XPath = "$.OS",
DataTypeId = 7,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "Lollypop",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "Resolution",
XPath = "$.Resolution",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "720*1280",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "DebuggerAttached",
XPath = "$.DebuggerAttached",
DataTypeId = 5,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "true",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "SimulatorAttached",
XPath = "$.SimulatorAttached",
DataTypeId = 5,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "true",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "Jailbreak",
XPath = "$.Jailbreak",
DataTypeId = 5,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "false",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "MAC",
XPath = "$.MAC",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "94:23:44f:2:d3",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "ToAccountId",
XPath = "$.ToAccountId",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "Test2",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "ToAccountExternalRef",
XPath = "$.ToAccountExternalRef",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "ChurchmanR",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "TwoFATypeId",
XPath = "$.TwoFATypeId",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "SMS",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "TwoFAResponseId",
XPath = "$.TwoFAResponseId",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "1",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "Storage",
XPath = "$.Storage",
DataTypeId = 5,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "true",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "TransactionExternalResponseId",
XPath = "$.TransactionExternalResponseId",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "0",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "FingerprintHash",
XPath = "$.FingerprintHash",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "jhjkhjkhsjh2hjhjkhj2k",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "BusinessModel",
XPath = "$.BusinessModel",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "Travel",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "AmountEUR",
XPath = "$.AmountEUR",
DataTypeId = 3,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "100.00",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "AmountUSD",
XPath = "$.AmountUSD",
DataTypeId = 3,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "113.05",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "AmountUSDRate",
XPath = "$.AmountUSDRate",
DataTypeId = 3,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "1.1305502954",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "AmountGBP",
XPath = "$.AmountGBP",
DataTypeId = 3,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "86.5866",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "AmountGBPRate",
XPath = "$.AmountGBPRate",
DataTypeId = 3,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "0.8658658602",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "Is3D",
XPath = "$.Is3D",
DataTypeId = 5,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "true",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "OriginalAmount",
XPath = "$.OriginalAmount",
DataTypeId = 3,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "100",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "OriginalCurrency",
XPath = "$.OriginalCurrency",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "EUR",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "Email",
XPath = "$.Email",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "[email protected]",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "CreditCardHash",
XPath = "$.CreditCardHash",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "1FDA39A3EE5E6B4HKAJAA890AFD80709",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "AcquirerBankName",
XPath = "$.AcquirerBankName",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "Caixa",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "ActionDate",
XPath = "$.ActionDate",
DataTypeId = 4,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "2022-08-19T21:41:37.247",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "APMAccountId",
XPath = "$.APMAccountId",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "Skrill123456789",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "BankId",
XPath = "$.BankId",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "57",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "BillingAddress",
XPath = "$.BillingAddress",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "Address Line 1",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "BillingCity",
XPath = "$.BillingCity",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "Address Line 2",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "BillingCountry",
XPath = "$.BillingCountry",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "DE",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "BillingFirstName",
XPath = "$.BillingFirstName",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "Richard",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "BillingLastName",
XPath = "$.BillingLastName",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "Churchman",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "BillingPhone",
XPath = "$.BillingPhone",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "1234567890",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "BillingState",
XPath = "$.BillingState",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "DE",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "BillingZip",
XPath = "$.BillingZip",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "123456",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "IsAPM",
XPath = "$.IsAPM",
DataTypeId = 5,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "true",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "IsCascaded",
XPath = "$.IsCascaded",
DataTypeId = 5,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "false",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "IsCredited",
XPath = "$.IsCredited",
DataTypeId = 5,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "false",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "IsCurrencyConverted",
XPath = "$.IsCurrencyConverted",
DataTypeId = 5,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "true",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "IsModification",
XPath = "$.IsModification",
DataTypeId = 5,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "false",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "IsRebill",
XPath = "$.IsRebill",
DataTypeId = 5,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "true",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "TransactionTypeId",
XPath = "$.TransactionTypeId",
DataTypeId = 5,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "1000",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "TransactionResultId",
XPath = "$.TransactionResultId",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "2000",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "IP",
XPath = "$.IP",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "123.456.789.200",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "AmountEURRate",
XPath = "$.AmountEURRate",
DataTypeId = 3,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "1",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "DeviceId",
XPath = "$.DeviceId",
DataTypeId = 1,
EnableSuppression = 1,
ResponsePayload = 1,
SearchKey = 1,
SearchKeyFetchLimit = 100,
SearchKeyCacheInterval = "h",
SearchKeyTtlIntervalValue = 1,
Active = 1,
DefaultValue = "OlaRoseGoldPhone6",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "IsModified",
XPath = "$.IsModified",
DataTypeId = 5,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "false",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "OrderId",
XPath = "$.OrderId",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "10607324128",
Guid = Guid.NewGuid()
}, token);
await entityAnalysisModelRequestXPathRepository.InsertAsync(new EntityAnalysisModelRequestXpath
{
EntityAnalysisModelId = entityAnalysisModelId,
Name = "TxnId",
XPath = "$.TxnId",
DataTypeId = 1,
EnableSuppression = 0,
ResponsePayload = 1,
SearchKey = 0,
Active = 1,
DefaultValue = "0987654321",
Guid = Guid.NewGuid()
}, token);
}
private Task<EntityAnalysisModel> InsertEntityAnalysisModelAsync(string userName, CancellationToken token = default)
{
var entityAnalysisModelRepository = new EntityAnalysisModelRepository(dbContext, userName);
return entityAnalysisModelRepository.InsertAsync(new EntityAnalysisModel
{
Name = "Detailed Account Financial Transactions",
Guid = Guid.NewGuid(),
EntryXPath = "$.TxnId",
EntryName = "TxnId",
ReferenceDateXPath = "$.TxnDateTime",
ReferenceDatePayloadLocationTypeId = 1,
Active = 1,
ReferenceDateName = "TxnDateTime",
CacheFetchLimit = 100,
CacheTtlInterval = 'd',
CacheTtlIntervalValue = 100,
EnableCache = 1,
EnableRdbmsArchive = 1,
EnableTtlCounter = 1,
EnableSanctionCache = 1,
EnableActivationArchive = 1,
EnableActivationWatcher = 1,
MaxActivationWatcherValue = 1,
MaxActivationWatcherInterval = 'h',
MaxActivationWatcherThreshold = 100,
EnableResponseElevationLimit = 0,
MaxResponseElevation = 10,
ActivationWatcherSample = 1
}, token);
}
private Task AssignToUserRegistryToTenantRegistryAsync(string userName, TenantRegistry tenantRegistry, CancellationToken token = default)
{
var userInTenantRepository = new UserInTenantRepository(dbContext, "Administrator");
return userInTenantRepository.UpdateAsync(userName, tenantRegistry.Id, token);
}
private async Task AllocateAllPermissionSpecificationsToRoleRegistryAsync(string userName, RoleRegistry roleRegistry, CancellationToken token = default)
{
var permissionSpecificationRepository = new PermissionSpecificationRepository(dbContext);
var permissionSpecifications = await permissionSpecificationRepository.GetAsync(token);
var roleRegistryPermissionRepository = new RoleRegistryPermissionRepository(dbContext, userName);
foreach (var roleRegistryPermission in permissionSpecifications.ToList().Select(permissionSpecification =>
new RoleRegistryPermission
{
RoleRegistryId = roleRegistry.Id,
Active = 1,
PermissionSpecificationId = permissionSpecification.Id
}))
{
await roleRegistryPermissionRepository.InsertAsync(roleRegistryPermission, token);
}
}
private async Task<UserRegistry> CreateUserRegistryAsync(string userName, string password, string passwordHashingKey,
RoleRegistry roleRegistry, CancellationToken token = default)
{
var userRegistry = new UserRegistry
{
Name = userName,
Email = userName,
Active = 1,
RoleRegistryId = roleRegistry.Id
};
var userRegistryRepository = new UserRegistryRepository(dbContext, roleRegistry);
await userRegistryRepository.InsertAsync(userRegistry, token);
await userRegistryRepository.SetPasswordAsync(userRegistry.Id,
HashPassword.GenerateHash(password, passwordHashingKey), DateTime.Now.AddDays(90), token);
return userRegistry;
}
private async Task<RoleRegistry> CreateRoleRegistryAsync(string userName, TenantRegistry tenantRegistry, CancellationToken token = default)
{
var roleRegistry = new RoleRegistry
{
TenantRegistryId = tenantRegistry.Id,
Name = userName,
Active = 1
};
var roleRegistryRepository = new RoleRegistryRepository(dbContext, tenantRegistry);
roleRegistry = await roleRegistryRepository.InsertAsync(roleRegistry, token);
return roleRegistry;
}
private async Task<TenantRegistry> CreateTenantRegistryAsync(string userName, CancellationToken token = default)
{
var tenantRegistryRepository = new TenantRegistryRepository(dbContext, "Administrator");
var tenantRegistry = new TenantRegistry
{
Active = 1,
Name = userName,
Landlord = 0
};
tenantRegistry = await tenantRegistryRepository.InsertAsync(tenantRegistry, token);
return tenantRegistry;
}
private async Task ValidateUserDoesNotExistAndRaiseExceptionIfExistsAsync(string userName, CancellationToken token = default)
{
var userRegistryRepositoryExisting = new UserRegistryRepository(dbContext);
var userRegistryExisting = await userRegistryRepositoryExisting.GetByUserNameAsync(userName, token);
if (userRegistryExisting != null)
{
throw new ConflictException();
}
}
}
}
Reference in New Issue View Git Blame Copy Permalink