hanzo/jube-fork
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Resiliency, Database Security, Bug Fixes and Observability:

Browse Source 
* Implemented a wrapper library for Redis and Postgres clients using Polly retry to enhance durability during failover. Removed all direct client references across projects, replacing them with the new resilient libraries. Bulk changes were largely confined to the database context constructor, given the application's broad use of the Repository pattern and LINQ2DB.
* Implemented a WAL log in Redis that stores JSON payloads pending commit to the Archive table as part of an asynchronous process. The WAL entry is removed once the commit completes. During graceful drain on SIGTERM, this provides an observability and recovery mechanism for transactions lost due to host failure or fatal termination.
* Implemented a read-only reporting connection for all case management query functions and other backend functions with significant read overhead or security implications, enabling targeting of read replicas under read-only database users. Dynamic query functions have been handled carefully to ensure parameterised variables are always used.
* Implemented a `MigrationConnectionString` environment variable to support a dedicated migration user, allowing the application and reporting to run under minimal permissions while still supporting the online upgrade process used in Jube Herd (Docker Swarm).
* Added evaluation counters to Gateway and Activation Rule Counters, and ensured they are displayed in the Gateway Rules, Activation Rules, and Activation Rules pages — an important missing observability feature for gradual rule rollout assessment prior to taking decline or case creation steps. Also introduced model total response time counters throughout the invocation pipeline and updated the administration page accordingly. Made all response times throughout the system record in microseconds for consistency.
* Updated `CookieOptions` to include the `Secure` flag having been flagged on CodeQL.
* Fixed major bugs in fan-out queries across all Case Management entities caused by the recently released permissions functionality, where entities were duplicated when more than one user was present.
* Fixed a long-standing issue with performance counter increments to use `Interlocked`, or custom locks in the case of date-based counters.
* Fixed a bug in preservation import introduced during the `CacheIndexId` functionality, which failed due to a nested transaction. The import now bypasses `CacheIndexId` rekeying and reads it directly from the `.jemp` file, which was itself the correct original behaviour.
* Fixed Payload Responses not being included in the response payload when response payload was selected in Request XPath.
* Fixed the Report Table switch in Request XPath having no effect and not writing to the `ArchiveKeys` table.
* Fixed the inability to edit Case Workflows in the user interface because of a minor JS typo in the key name.
* Refactored notification dispatch to use async methods for all database calls.
* Refactored the Postgres Query class to make better use of `using`/dispose patterns, moved connection creation to the constructor, and ensured consistent disposal. Extended the use of `using` dispose throughout all LINQ2DB queries outside the Repository pattern.
* Some refactoring to use byte arrays rather than `MemoryStream` in serialisation of JSON Archive and response payloads. Eliminated duplication in Archive payload creation for case creation, given the payload now also exists in the WAL, and is created during invocation (not asynchronously as was the case).
* Updated the composite index for `AddArchiveKeyTableIndex` in Baseline to use covering indexes ONLY, avoiding Postgres page lookups (noting this table exists solely as an access path to the Archive table via predication and join on `EntityAnalysisModelInstanceEntryGuid`). IMPORTANT NOTE: No migration provided for existing data. Any such index will need to be rebuilt manually to obtain this benefit.
* Updated the completions controller and query to order fields by name ascending, with new repository methods to apply ordering server-side.
* Updated the date format for Created Dates in the user interface to a more verbose and readable format, consistent with the rest of the system.
* Removed legacy billing aggregation counter for response elevation, which is no longer a relevant concept. Renamed remaining billing-related counter fields for clarity.
* Updated Dockerfile for the new resilience projects.
* Fixed typo in TTL Counter Resolution page where hours was duplicated instead of minutes.
* Implemented RedisBackplane environment variable to support SignalR with Redis in clustered environments.
* Fixed loss of password, password expiry, and password created date during User Administration updates; added empty password check in authentication controller to raise an exception treated as user not found; fixed inability to change password on expiry; fixed password expiry date evaluation bug; moved increment password failure to capture all code paths.
* Updated ExhaustiveSearchInstanceTrialInstanceVariable repository to use logical deletes instead of physical deletes, which are unsupported by the database user; updated MockArchive loading to occur only once since the data is static.
* Updated default Log4NetLogLevel environment variable to WARN and updated documentation accordingly.
* Fixed missing reference for Archive Keys during payload creation, as while they were being populated, the reference to it was missing, so they did not get stored.
This commit is contained in:
richard-churchman
2026-03-08 18:31:03 +02:00
parent 9b35fc38ae
commit 62f33221b6
287 changed files with 2857 additions and 1557 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Jube.App/Code/MigrationExtension.cs
-45
View File
@@ -1,45 +0,0 @@
/* Copyright (C) 2022-present Jube Holdings Limited.
*
* This file is part of Jube™ software.
*
* Jube™ is free software: you can redistribute it and/or modify it under the terms of the GNU Affero General Public License
* as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.
* Jube™ is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty
* of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License for more details.
* You should have received a copy of the GNU Affero General Public License along with Jube™. If not,
* see <https://www.gnu.org/licenses/>.
*/
namespace Jube.App.Code
{
using System;
using DynamicEnvironment;
using FluentMigrator.Runner;
using Microsoft.AspNetCore.Builder;
using Microsoft.Extensions.DependencyInjection;
public static class MigrationExtension
{
public static IApplicationBuilder Migrate(this IApplicationBuilder app)
{
using var scope = app.ApplicationServices.CreateScope();
var dynamicEnvironment = scope.ServiceProvider.GetService<DynamicEnvironment>();
if (dynamicEnvironment == null || !dynamicEnvironment.AppSettings("EnableMigration").Equals("True", StringComparison.OrdinalIgnoreCase))
{
return app;
}
var runners = scope.ServiceProvider.GetServices<IMigrationRunner>();
foreach (var runner in runners)
{
runner.ListMigrations();
runner.MigrateUp();
}
return app;
}
}
}
Jube.App/Code/PermissionValidation.cs
+5 -4
View File
@@ -16,16 +16,17 @@ namespace Jube.App.Code
using System.Linq;
using Data.Context;
using Data.Security;
using log4net;
public class PermissionValidation
{
private readonly PermissionValidationDto permissionValidationDto;
public PermissionValidation(DbContext dbContext, string userName)
public PermissionValidation(DbContext dbContext, string userName, ILog log)
{
var permissionValidation = new Data.Security.PermissionValidation();
permissionValidationDto = permissionValidation
.GetPermissionsAsync(dbContext, userName)
.GetPermissionsAsync(dbContext, userName, log)
.ConfigureAwait(false)
.GetAwaiter()
#pragma warning disable VSTHRD002
@@ -33,12 +34,12 @@ namespace Jube.App.Code
#pragma warning restore VSTHRD002
}
public PermissionValidation(string connectionString, string userName)
public PermissionValidation(string connectionString, string userName, ILog log)
{
var permissionValidation = new Data.Security.PermissionValidation();
permissionValidationDto = permissionValidation
.GetPermissionsAsync(connectionString, userName)
.GetPermissionsAsync(connectionString, userName, log)
.ConfigureAwait(false)
.GetAwaiter()
#pragma warning disable VSTHRD002
Jube.App/Code/WatcherDispatch/Relay.cs
+1 -6
View File
@@ -20,7 +20,6 @@ namespace Jube.App.Code.WatcherDispatch
using Data.Context;
using Data.Repository;
using DynamicEnvironment;
using LinqToDB.Configuration;
using log4net;
using Microsoft.AspNetCore.SignalR;
using Newtonsoft.Json;
@@ -265,11 +264,7 @@ namespace Jube.App.Code.WatcherDispatch
$"Data Connection DbContext: Is about to attempt construction of database context with {dynamicEnvironment.AppSettings("ConnectionString")}.");
}
var builder = new LinqToDbConnectionOptionsBuilder();
builder.UsePostgreSQL(dynamicEnvironment.AppSettings("ConnectionString"));
var connection = builder.Build<DbContext>();
var dbContext = new DbContext(connection);
var dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
if (log.IsInfoEnabled)
{
Jube.App/Controllers/Authentication/AuthenticationController.cs
+3 -4
View File
@@ -21,6 +21,7 @@ namespace Jube.App.Controllers.Authentication
using Code;
using Data.Context;
using DynamicEnvironment;
using log4net;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
@@ -41,12 +42,10 @@ namespace Jube.App.Controllers.Authentication
private readonly Authentication service;
public AuthenticationController(DynamicEnvironment dynamicEnvironment,
IHttpContextAccessor contextAccessor)
IHttpContextAccessor contextAccessor, ILog log)
{
this.dynamicEnvironment = dynamicEnvironment;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(
this.dynamicEnvironment.AppSettings("ConnectionString"));
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(this.dynamicEnvironment.AppSettings("ConnectionString"), log);
this.contextAccessor = contextAccessor;
service = new Authentication(dbContext);
}
Jube.App/Controllers/Authentication/SandboxRegistrationController.cs
+6 -5
View File
@@ -21,6 +21,7 @@ namespace Jube.App.Controllers.Authentication
using Code;
using Data.Context;
using DynamicEnvironment;
using log4net;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
@@ -36,14 +37,14 @@ namespace Jube.App.Controllers.Authentication
{
private readonly DbContext dbContext;
private readonly DynamicEnvironment dynamicEnvironment;
private readonly ILog log;
private readonly SandboxRegistration service;
public SandboxRegistrationController(DynamicEnvironment dynamicEnvironment)
public SandboxRegistrationController(DynamicEnvironment dynamicEnvironment, ILog log)
{
this.dynamicEnvironment = dynamicEnvironment;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(
this.dynamicEnvironment.AppSettings("ConnectionString"));
this.log = log;
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(this.dynamicEnvironment.AppSettings("ConnectionString"), log);
service = new SandboxRegistration(dbContext);
}
@@ -78,7 +79,7 @@ namespace Jube.App.Controllers.Authentication
try
{
var sandboxRegistrationResponseDto =
await service.RegisterAsync(model, dynamicEnvironment.AppSettings("PasswordHashingKey"), token).ConfigureAwait(false);
await service.RegisterAsync(model, dynamicEnvironment.AppSettings("PasswordHashingKey"), log, token).ConfigureAwait(false);
SetAuthenticationCookie(model);
Jube.App/Controllers/Helper/CaseWorkflowDisplayExecutionController.cs
+4 -5
View File
@@ -23,6 +23,7 @@ namespace Jube.App.Controllers.Helper
using Engine.EntityAnalysisModelInvoke.Models.Payload.EntityAnalysisModelInstanceEntryPayload;
using Engine.EntityAnalysisModelInvoke.Models.Payload.EntityAnalysisModelInstanceEntryPayload.Extensions;
using Engine.Helpers;
using log4net;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
@@ -43,21 +44,19 @@ namespace Jube.App.Controllers.Helper
public CaseWorkflowDisplayExecutionController(
DynamicEnvironment dynamicEnvironment, IHttpContextAccessor httpContextAccessor,
JsonSerializationHelper jsonSerializationHelper)
JsonSerializationHelper jsonSerializationHelper, ILog log)
{
if (httpContextAccessor.HttpContext?.User.Identity != null)
{
userName = httpContextAccessor.HttpContext.User.Identity.Name;
}
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
repositoryCase = new CaseRepository(dbContext, userName);
repositoryCaseWorkflowDisplay = new CaseWorkflowDisplayRepository(dbContext, userName);
repositoryCaseWorkflowStatus = new CaseWorkflowStatusRepository(dbContext, userName);
permissionValidation = new PermissionValidation(dbContext, userName);
permissionValidation = new PermissionValidation(dbContext, userName, log);
this.jsonSerializationHelper = jsonSerializationHelper;
}
Jube.App/Controllers/Helper/CaseWorkflowMacroExecutionController.cs
+2 -6
View File
@@ -55,17 +55,13 @@ namespace Jube.App.Controllers.Helper
userName = httpContextAccessor.HttpContext.User.Identity.Name;
}
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
this.log = log;
this.dynamicEnvironment = dynamicEnvironment;
repositoryCase = new CaseRepository(dbContext, userName);
repositoryCaseWorkflowMacro = new CaseWorkflowMacroRepository(dbContext, userName);
repositoryCaseWorkflowStatus = new CaseWorkflowStatusRepository(dbContext, userName);
permissionValidation = new PermissionValidation(dbContext, userName);
permissionValidation = new PermissionValidation(dbContext, userName, log);
this.jsonSerializationHelper = jsonSerializationHelper;
}
Jube.App/Controllers/Helper/CompletionsController.cs
+2 -3
View File
@@ -49,9 +49,8 @@ namespace Jube.App.Controllers.Helper
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
}
protected override void Dispose(bool disposing)
Jube.App/Controllers/Helper/EntityAnalysisModelDictionaryCsvFileUploadController.cs
+2 -3
View File
@@ -52,9 +52,8 @@ namespace Jube.App.Controllers.Helper
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
entityAnalysisModelDictionaryKvpRepository =
new EntityAnalysisModelDictionaryKvpRepository(dbContext, userName);
Jube.App/Controllers/Helper/EntityAnalysisModelListCsvFileUploadController.cs
+2 -3
View File
@@ -52,9 +52,8 @@ namespace Jube.App.Controllers.Helper
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
entityAnalysisModelListValueRepository = new EntityAnalysisModelListValueRepository(dbContext, userName);
entityAnalysisModelListValueCsvFileUploadRepository =
Jube.App/Controllers/Helper/IconsController.cs
+2 -3
View File
@@ -50,9 +50,8 @@ namespace Jube.App.Controllers.Helper
this.log = log;
env = webHostEnvironment;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
}
protected override void Dispose(bool disposing)
Jube.App/Controllers/Helper/ParserController.cs
+5 -5
View File
@@ -56,8 +56,8 @@ namespace Jube.App.Controllers.Helper
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
}
protected override void Dispose(bool disposing)
@@ -119,7 +119,7 @@ namespace Jube.App.Controllers.Helper
List<string> entityAnalysisModelsHttpAdaptations = null;
List<string> entityAnalysisModelsExhaustiveAdaptations = null;
List<string> entityAnalysisModelsActivationRules = null;
if (parseRuleRequestDto.RuleParseType > 4)
{
entityAnalysisModelAbstractionCalculations
@@ -266,7 +266,7 @@ namespace Jube.App.Controllers.Helper
{
continue;
}
var entityAnalysisInlineScript = await entityAnalysisInlineScriptRepository.GetByIdAsync(entityAnalysisModelInlineScript.EntityAnalysisInlineScriptId.Value, token);
foreach (var publicProperty in SyntaxTreeHelpers.GetPublicProperties(entityAnalysisInlineScript.Code, entityAnalysisInlineScript.LanguageId == 2))
{
@@ -319,7 +319,7 @@ namespace Jube.App.Controllers.Helper
return entityAnalysisModelLists.Select(s => s.Name).ToList();
}
private async Task<List<string>> EntityAnalysisModelActivationRulesAsync(int entityAnalysisModelId, CancellationToken token = default)
{
var entityAnalysisModelActivationRuleRepository =
Jube.App/Controllers/Helper/RegisterSignalrConnectionController.cs
+4 -4
View File
@@ -20,6 +20,7 @@ namespace Jube.App.Controllers.Helper
using Code.signalr;
using Data.Context;
using DynamicEnvironment;
using log4net;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
@@ -37,16 +38,15 @@ namespace Jube.App.Controllers.Helper
private readonly IHubContext<WatcherHub> watcherHub;
public RegisterSignalrConnectionController(IHubContext<WatcherHub> watcherHub,
IHttpContextAccessor httpContextAccessor, DynamicEnvironment dynamicEnvironment)
IHttpContextAccessor httpContextAccessor, DynamicEnvironment dynamicEnvironment, ILog log)
{
if (httpContextAccessor.HttpContext?.User.Identity != null)
{
userName = httpContextAccessor.HttpContext.User.Identity.Name;
}
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
tenantRegistryId = dbContext.UserInTenant.Where(w => w.User == userName)
.Select(s => s.TenantRegistryId).FirstOrDefault();
Jube.App/Controllers/Helper/TreeChildrenController.cs
+3 -5
View File
@@ -48,10 +48,8 @@ namespace Jube.App.Controllers.Helper
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
}
protected override void Dispose(bool disposing)
@@ -540,7 +538,7 @@ namespace Jube.App.Controllers.Helper
return StatusCode(500);
}
}
[HttpGet]
[Route("TTLCounter")]
public async Task<ActionResult<List<EntityAnalysisModelTreeChildDto>>> GetEntityAnalysisModelTtlCountersAsync(int id, CancellationToken token = default)
Jube.App/Controllers/Invoke/InvokeController.cs
+12 -12
View File
@@ -54,7 +54,7 @@ namespace Jube.App.Controllers.Invoke
this.dynamicEnvironment = dynamicEnvironment;
if (this.engine != null)
{
this.engine.Context.Counters.HttpCounterAllRequests += 1;
Interlocked.Increment(ref this.engine.Context.Counters.HttpCounterAllRequests);
}
}
@@ -70,7 +70,7 @@ namespace Jube.App.Controllers.Invoke
return await Task.FromResult<ActionResult>(Forbid()).ConfigureAwait(false);
}
engine.Context.Counters.HttpCounterCallback += 1;
Interlocked.Increment(ref engine.Context.Counters.HttpCounterCallback);
var tcs = engine.Context.Services.CacheService.CacheCallbackPublishSubscribe.Callbacks.GetOrAdd(guid, _ => new TaskCompletionSource<Callback>(TaskCreationOptions.RunContinuationsAsynchronously));
var callback = await tcs.Task.WaitAsync(TimeSpan.FromSeconds(timeout ?? 30000), token);
@@ -90,7 +90,7 @@ namespace Jube.App.Controllers.Invoke
{
log.Error($"Callback Fetch: Has seen an error as {ex}. Returning 500.");
engine.Context.Counters.HttpCounterCallback += 1;
Interlocked.Increment(ref engine.Context.Counters.HttpCounterCallback);
return await Task.FromResult<ActionResult>(StatusCode(500)).ConfigureAwait(false);
}
}
@@ -112,7 +112,7 @@ namespace Jube.App.Controllers.Invoke
return Task.FromResult<ActionResult<List<SanctionEntryDto>>>(StatusCode(503));
}
engine.Context.Counters.HttpCounterSanction += 1;
Interlocked.Increment(ref engine.Context.Counters.HttpCounterSanction);
if (log.IsInfoEnabled)
{
@@ -139,7 +139,7 @@ namespace Jube.App.Controllers.Invoke
{
log.Error($"Sanction Fetch: Has seen an error as {ex}. Returning 500.");
engine.Context.Counters.HttpCounterAllError += 1;
Interlocked.Increment(ref engine.Context.Counters.HttpCounterAllError);
return Task.FromResult<ActionResult<List<SanctionEntryDto>>>(StatusCode(500));
}
}
@@ -168,7 +168,7 @@ namespace Jube.App.Controllers.Invoke
$" name {model.Name} and value {model.Value}.");
}
engine.Context.Counters.HttpCounterTag += 1;
Interlocked.Increment(ref engine.Context.Counters.HttpCounterTag);
var entityAnalysisModelGuid = Guid.Parse(model.EntityAnalysisModelGuid);
foreach (var (_, value) in
@@ -246,7 +246,7 @@ namespace Jube.App.Controllers.Invoke
return StatusCode(503);
}
engine.Context.Counters.HttpCounterModel += 1;
Interlocked.Increment(ref engine.Context.Counters.HttpCounterModel);
var ms = new MemoryStream();
await Request.Body.CopyToAsync(ms).ConfigureAwait(false);
@@ -260,7 +260,7 @@ namespace Jube.App.Controllers.Invoke
{
async = Request.RouteValues["async"].AsString()
.Equals("Async", StringComparison.OrdinalIgnoreCase);
engine.Context.Counters.HttpCounterModelAsync += 1;
Interlocked.Increment(ref engine.Context.Counters.HttpCounterModelAsync);
}
EntityAnalysisModel entityAnalysisModel = null;
@@ -297,10 +297,10 @@ namespace Jube.App.Controllers.Invoke
ms, Int32.Parse(dynamicEnvironment.AppSettings("MaxInvokeControllerRequestBytes")),
async).ConfigureAwait(false);
var bytes = context.EntityAnalysisModelInstanceEntryPayload.ResponseJson.Length > 0 ? context.EntityAnalysisModelInstanceEntryPayload.ResponseJson : context.EntityAnalysisModelInstanceEntryPayload.ArchiveJson;
Response.ContentType = "application/json";
Response.ContentLength = context.JsonResult.Length;
return Ok(context.JsonResult);
Response.ContentLength = bytes.Length;
await Response.Body.WriteAsync(bytes);
}
catch (ExceededBytesException)
{
@@ -376,7 +376,7 @@ namespace Jube.App.Controllers.Invoke
return StatusCode(503);
}
engine.Context.Counters.HttpCounterExhaustive += 1;
Interlocked.Increment(ref engine.Context.Counters.HttpCounterExhaustive);
var ms = new MemoryStream();
await Request.Body.CopyToAsync(ms).ConfigureAwait(false);
Jube.App/Controllers/Preservation/Preservation.cs
+2 -5
View File
@@ -39,11 +39,8 @@ namespace Jube.App.Controllers.Preservation
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
this.log = log;
this.dynamicEnvironment = dynamicEnvironment;
}
Jube.App/Controllers/Query/GetByVisualisationRegistryDatasourceCommandExecutionQueryController.cs
+5 -9
View File
@@ -52,15 +52,11 @@ namespace Jube.App.Controllers.Query
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
if (dynamicEnvironment.AppSettings("ReportConnectionString") != null)
{
query = new GetByVisualisationRegistryDatasourceCommandExecutionQuery(dbContext,
dynamicEnvironment.AppSettings("ReportConnectionString"), userName);
}
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
query = dynamicEnvironment.AppSettings("ReportConnectionString") != null ?
new GetByVisualisationRegistryDatasourceCommandExecutionQuery(dbContext, userName, log, dynamicEnvironment.AppSettings("ReportConnectionString"))
: new GetByVisualisationRegistryDatasourceCommandExecutionQuery(dbContext, userName, log, dynamicEnvironment.AppSettings("ConnectionString"));
}
protected override void Dispose(bool disposing)
Jube.App/Controllers/Query/GetCaseByCaseKeyValueQueryController.cs
+2 -3
View File
@@ -47,9 +47,8 @@ namespace Jube.App.Controllers.Query
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
query = new GetCaseByCaseKeyValueQuery(dbContext, userName);
}
Jube.App/Controllers/Query/GetCaseByIdQueryController.cs
+2 -5
View File
@@ -50,12 +50,9 @@ namespace Jube.App.Controllers.Query
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
query = new GetCaseByIdQuery(dbContext, userName);
repository = new CaseEventRepository(dbContext, userName);
}
Jube.App/Controllers/Query/GetCaseBySessionCaseSearchCompileQueryController.cs
+3 -5
View File
@@ -52,11 +52,9 @@ namespace Jube.App.Controllers.Query
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
query = new GetCaseBySessionCaseSearchCompileQuery(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
query = new GetCaseBySessionCaseSearchCompileQuery(dbContext, userName, log, dynamicEnvironment.AppSettings("ReportConnectionString") ?? dbContext.ConnectionString);
caseEventRepository = new CaseEventRepository(dbContext, userName);
caseRepository = new CaseRepository(dbContext, userName);
}
Jube.App/Controllers/Query/GetCaseEventByCaseKeyValueQueryController.cs
+2 -3
View File
@@ -46,9 +46,8 @@ namespace Jube.App.Controllers.Query
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
query = new GetCaseEventByCaseKeyValueQuery(dbContext, userName);
}
Jube.App/Controllers/Query/GetCaseJournalQueryController.cs
+3 -6
View File
@@ -45,12 +45,9 @@ namespace Jube.App.Controllers.Query
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
query = new GetCaseJournalQuery(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
query = new GetCaseJournalQuery(dbContext, userName, log, dynamicEnvironment.AppSettings("ReportConnectionString") ?? dbContext.ConnectionString);
}
protected override void Dispose(bool disposing)
Jube.App/Controllers/Query/GetCaseNoteByCaseKeyValueQueryController.cs
+2 -5
View File
@@ -45,11 +45,8 @@ namespace Jube.App.Controllers.Query
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
query = new GetCaseNoteByCaseKeyValueQuery(dbContext, userName);
}
Jube.App/Controllers/Query/GetCaseWorkflowFormEntryByCaseKeyValueQueryController.cs
+2 -5
View File
@@ -45,11 +45,8 @@ namespace Jube.App.Controllers.Query
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
query = new GetCaseWorkflowFormEntryByCaseKeyValueQuery(dbContext, userName);
}
Jube.App/Controllers/Query/GetEntityAnalysisInlineScriptSearchKeysQueryController.cs
+2 -5
View File
@@ -46,11 +46,8 @@ namespace Jube.App.Controllers.Query
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
query = new GetEntityAnalysisInlineScriptSearchKeysQuery(dbContext, userName);
}
Jube.App/Controllers/Query/GetEntityAnalysisModelActivationsRuleSuppressionQueryController.cs
+2 -4
View File
@@ -46,10 +46,8 @@ namespace Jube.App.Controllers.Query
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
query = new GetEntityAnalysisModelActivationRuleSuppressionQuery(dbContext, userName);
}
Jube.App/Controllers/Query/GetEntityAnalysisModelSuppressionQueryController.cs
+3 -6
View File
@@ -43,14 +43,11 @@ namespace Jube.App.Controllers.Query
if (httpContextAccessor.HttpContext?.User.Identity != null)
{
userName = httpContextAccessor.HttpContext.User.Identity.Name;
this.log = log;
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
query = new GetEntityAnalysisModelSuppressionQuery(dbContext, userName);
}
Jube.App/Controllers/Query/GetEntityAnalysisModelSynchronisationNodeStatusEntriesController.cs
+2 -3
View File
@@ -47,9 +47,8 @@ namespace Jube.App.Controllers.Query
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
query = new GetEntityAnalysisModelSynchronisationNodeStatusEntriesQuery(dbContext, userName);
}
Jube.App/Controllers/Query/GetEntityAnalysisPotentialMultiPartStringNamesController.cs
+2 -5
View File
@@ -46,11 +46,8 @@ namespace Jube.App.Controllers.Query
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
query = new GetEntityAnalysisPotentialMultiPartStringNamesQuery(dbContext, userName);
}
Jube.App/Controllers/Query/GetExhaustiveSearchInstancePromotedTrialInstanceConfusionQueryController.cs
+2 -5
View File
@@ -45,11 +45,8 @@ namespace Jube.App.Controllers.Query
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
query = new GetExhaustiveSearchInstancePromotedTrialInstanceConfusionQuery(dbContext, userName);
}
Jube.App/Controllers/Query/GetExhaustiveSearchInstancePromotedTrialInstanceErrorHistogramQueryController.cs
+2 -5
View File
@@ -46,11 +46,8 @@ namespace Jube.App.Controllers.Query
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
query = new GetExhaustiveSearchInstancePromotedTrialInstanceErrorHistogramQuery(dbContext, userName);
}
Jube.App/Controllers/Query/GetExhaustiveSearchInstancePromotedTrialInstanceLearningCurveController.cs
+2 -5
View File
@@ -46,11 +46,8 @@ namespace Jube.App.Controllers.Query
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
query = new GetExhaustiveSearchInstancePromotedTrialInstanceLearningCurveQuery(dbContext, userName);
}
Jube.App/Controllers/Query/GetExhaustiveSearchInstancePromotedTrialInstancePredictedActualQueryController.cs
+2 -5
View File
@@ -46,11 +46,8 @@ namespace Jube.App.Controllers.Query
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
query = new GetExhaustiveSearchInstancePromotedTrialInstancePredictedActualQuery(dbContext, userName);
}
Jube.App/Controllers/Query/GetExhaustiveSearchInstancePromotedTrialInstanceQueryController.cs
+2 -5
View File
@@ -46,11 +46,8 @@ namespace Jube.App.Controllers.Query
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
query = new GetExhaustiveSearchInstancePromotedTrialInstanceQuery(dbContext, userName);
}
Jube.App/Controllers/Query/GetExhaustiveSearchInstancePromotedTrialInstanceRocQueryController.cs
+2 -5
View File
@@ -46,11 +46,8 @@ namespace Jube.App.Controllers.Query
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
query = new GetExhaustiveSearchInstancePromotedTrialInstanceRocQuery(dbContext, userName);
}
Jube.App/Controllers/Query/GetExhaustiveSearchInstancePromotedTrialInstanceVariablePrescriptionController.cs
+2 -5
View File
@@ -46,11 +46,8 @@ namespace Jube.App.Controllers.Query
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
query = new GetExhaustiveSearchInstancePromotedTrialInstanceVariablePrescriptionQuery(dbContext);
}
Jube.App/Controllers/Query/GetExhaustiveSearchInstanceTrialInstanceVariableQueryController.cs
+2 -5
View File
@@ -46,11 +46,8 @@ namespace Jube.App.Controllers.Query
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
query = new GetExhaustiveSearchInstancePromotedTrialInstanceVariableQuery(dbContext, userName);
}
Jube.App/Controllers/Query/GetExhaustiveSearchInstanceTrialInstanceVariableVarianceQueryController.cs
+2 -5
View File
@@ -46,11 +46,8 @@ namespace Jube.App.Controllers.Query
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
query = new GetExhaustiveSearchInstanceVariableVarianceQuery(dbContext, userName);
}
Jube.App/Controllers/Query/GetExhaustiveSearchInstanceVariableQueryController.cs
+2 -5
View File
@@ -46,11 +46,8 @@ namespace Jube.App.Controllers.Query
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
query = new GetExhaustiveSearchInstanceVariableQuery(dbContext, userName);
}
Jube.App/Controllers/Repository/ActivationWatcherController.cs
+3 -6
View File
@@ -52,14 +52,11 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
repository = new ActivationWatcherRepository(dbContext, userName);
this.watcherHub = watcherHub;
this.contractResolver = contractResolver;
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
repository = new ActivationWatcherRepository(dbContext, userName);
}
protected override void Dispose(bool disposing)
Jube.App/Controllers/Repository/CaseController.cs
+2 -5
View File
@@ -66,11 +66,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/CaseFileController.cs
+2 -4
View File
@@ -51,10 +51,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/CaseNoteController.cs
+2 -4
View File
@@ -65,10 +65,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/CaseWorkflowActionController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/CaseWorkflowActionRoleController.cs
+2 -4
View File
@@ -54,10 +54,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/CaseWorkflowController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/CaseWorkflowDisplayController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/CaseWorkflowDisplayRoleController.cs
+2 -4
View File
@@ -53,10 +53,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/CaseWorkflowFilterController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/CaseWorkflowFilterRoleController.cs
+2 -4
View File
@@ -53,10 +53,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/CaseWorkflowFormController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/CaseWorkflowFormEntryController.cs
+2 -4
View File
@@ -65,10 +65,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/CaseWorkflowFormEntryValueController.cs
+2 -4
View File
@@ -50,10 +50,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/CaseWorkflowFormRoleController.cs
+2 -4
View File
@@ -53,10 +53,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/CaseWorkflowMacroController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/CaseWorkflowMacroRoleController.cs
+2 -4
View File
@@ -53,10 +53,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/CaseWorkflowPriorityController.cs
+2 -4
View File
@@ -44,10 +44,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
}
protected override void Dispose(bool disposing)
Jube.App/Controllers/Repository/CaseWorkflowRoleController.cs
+2 -4
View File
@@ -53,10 +53,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/CaseWorkflowStatusController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/CaseWorkflowStatusRoleController.cs
+2 -4
View File
@@ -53,10 +53,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/CaseWorkflowXPathController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/CaseWorkflowXPathRoleController.cs
+2 -4
View File
@@ -53,10 +53,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/EntityAnalysisAsynchronousQueueBalanceController.cs
+2 -4
View File
@@ -50,10 +50,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/EntityAnalysisInlineScriptController.cs
+2 -4
View File
@@ -50,10 +50,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/EntityAnalysisModelAbstractionCalculationController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/EntityAnalysisModelAbstractionRuleController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/EntityAnalysisModelActivationRuleController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/EntityAnalysisModelActivationRuleSuppressionController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/EntityAnalysisModelAdaptationController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/EntityAnalysisModelAsynchronousQueueBalanceController.cs
+2 -4
View File
@@ -48,10 +48,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/EntityAnalysisModelController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/EntityAnalysisModelDictionaryController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/EntityAnalysisModelDictionaryKvpController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/EntityAnalysisModelGatewayRuleController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/EntityAnalysisModelInlineFunctionController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/EntityAnalysisModelInlineScriptController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/EntityAnalysisModelListController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/EntityAnalysisModelListValueController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/EntityAnalysisModelProcessingCounterController.cs
+2 -4
View File
@@ -48,10 +48,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/EntityAnalysisModelReprocessingRuleController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/EntityAnalysisModelReprocessingRuleInstanceController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/EntityAnalysisModelRequestXPathController.cs
+3 -5
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
@@ -238,7 +236,7 @@ namespace Jube.App.Controllers.Repository
var results = await validator.ValidateAsync(model, token);
if (results.IsValid)
{
return Ok(await repository.InsertAsync(mapper.Map<EntityAnalysisModelRequestXpath>(model), token));
return Ok(await repository.InsertIncrementCacheIndexIdAsync(mapper.Map<EntityAnalysisModelRequestXpath>(model), token));
}
return BadRequest(results);
Jube.App/Controllers/Repository/EntityAnalysisModelSanctionController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/EntityAnalysisModelSuppressionController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/EntityAnalysisModelSynchronisationScheduleController.cs
+2 -4
View File
@@ -54,10 +54,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/EntityAnalysisModelTagController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/EntityAnalysisModelTtlCounterController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/ExhaustiveSearchInstanceController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/ExhaustiveSearchInstancePromotedTrialInstanceController.cs
+2 -4
View File
@@ -47,10 +47,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
repository = new ExhaustiveSearchInstancePromotedTrialInstanceRepository(dbContext, userName);
}
Jube.App/Controllers/Repository/HttpProcessingCounterController.cs
+2 -4
View File
@@ -50,10 +50,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/PermissionSpecificationController.cs
+2 -4
View File
@@ -50,10 +50,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/RoleRegistryController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/RoleRegistryPermissionController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/TenantRegistryController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/UserInTenantController.cs
+2 -4
View File
@@ -52,10 +52,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/UserRegistryController.cs
+2 -4
View File
@@ -58,10 +58,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/VisualisationRegistryController.cs
+2 -4
View File
@@ -55,10 +55,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/VisualisationRegistryDatasourceController.cs
+4 -7
View File
@@ -56,10 +56,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
@@ -198,7 +196,7 @@ namespace Jube.App.Controllers.Repository
}
var visualisationRegistryDatasource =
await repository.InsertWithValidationAsync(mapper.Map<VisualisationRegistryDatasource>(model), token);
await repository.InsertWithValidationAsync(mapper.Map<VisualisationRegistryDatasource>(model), log, token);
return Ok(visualisationRegistryDatasource);
@@ -241,8 +239,7 @@ namespace Jube.App.Controllers.Repository
var results = await validator.ValidateAsync(model, token);
if (results.IsValid)
{
return Ok(
await repository.UpdateWithValidationAsync(mapper.Map<VisualisationRegistryDatasource>(model), token));
return Ok(await repository.UpdateWithValidationAsync(mapper.Map<VisualisationRegistryDatasource>(model), log, token));
}
return BadRequest(results);
Jube.App/Controllers/Repository/VisualisationRegistryDatasourceRoleController.cs
+2 -4
View File
@@ -53,10 +53,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
var config = new MapperConfiguration(cfg =>
{
Jube.App/Controllers/Repository/VisualisationRegistryDatasourceSeriesController.cs
+2 -4
View File
@@ -50,10 +50,8 @@ namespace Jube.App.Controllers.Repository
}
this.log = log;
dbContext =
DataConnectionDbContext.GetDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"));
permissionValidation = new PermissionValidation(dbContext, userName);
dbContext = DataConnectionDbContext.GetResilientDbContextDataConnection(dynamicEnvironment.AppSettings("ConnectionString"), log);
permissionValidation = new PermissionValidation(dbContext, userName, log);
repository = new VisualisationRegistryDatasourceSeriesRepository(dbContext, userName);
var config = new MapperConfiguration(cfg =>

Some files were not shown because too many files have changed in this diff Show More