jrojas
541 lines
19 KiB
C#
541 lines
19 KiB
C#
using adas_core.Application.Repositories.Interfaces;
|
|
using adas_core.Application.Services;
|
|
using adas_core.Application.Services.Interfaces;
|
|
using adas_core.Domain.Enums;
|
|
using adas_core.Domain.Models;
|
|
using adas_core.Domain.Models.AppSettings;
|
|
using adas_core.Domain.Models.MongoModels;
|
|
using Microsoft.AspNetCore.Http;
|
|
using Microsoft.Extensions.Logging;
|
|
using Microsoft.Extensions.Options;
|
|
using MongoDB.Bson;
|
|
using Moq;
|
|
using Options = Microsoft.Extensions.Options.Options;
|
|
|
|
namespace adas_core.Test.Services;
|
|
|
|
[TestFixture]
|
|
public class DiagnosisServiceTest
|
|
{
|
|
[SetUp]
|
|
public void Setup()
|
|
{
|
|
_patientServiceMock = new Mock<IPatientService>();
|
|
_patientServiceLazy = new Lazy<IPatientService>(() => _patientServiceMock.Object);
|
|
|
|
//var sectionServiceMock = new Mock<ISectionService>();
|
|
//sectionServiceLazy = new Lazy<ISectionService>(() => sectionServiceMock.Object);
|
|
|
|
_diagnosisRepositoryMock = new Mock<IDiagnosisRepository>();
|
|
_diagnosisArchiveRepositoryMock = new Mock<IDiagnosisArchiveRepository>();
|
|
_clientMessageServiceMock = new Mock<IClientMessageService>();
|
|
_subscribersServiceMock = new Mock<ISubscribersService>();
|
|
_unitServiceMock = new Mock<IUnitService>();
|
|
_httpContextAccessor = new Mock<IHttpContextAccessor>();
|
|
_auditService = new Mock<ILocalAuditService>();
|
|
_calculatedObservationsServiceMock = new Mock<ICalculatedObservationsService>();
|
|
_calculatedObservationsServiceLazy =
|
|
new Lazy<ICalculatedObservationsService>(() => _calculatedObservationsServiceMock.Object);
|
|
_calculatedObservationsServiceMock.Setup(x => x.Map(It.IsAny<PatientDiagnosis>()))
|
|
.ReturnsAsync((PatientDiagnosis? value) => value);
|
|
_optionsApiSettings = Options.Create(_apiSettings);
|
|
_logger = new Mock<ILogger<DiagnosisService>>();
|
|
_diagnosisService = new DiagnosisService(
|
|
_patientServiceLazy,
|
|
//sectionServiceLazy,
|
|
_optionsApiSettings,
|
|
_diagnosisRepositoryMock.Object,
|
|
_diagnosisArchiveRepositoryMock.Object,
|
|
_logger.Object,
|
|
_clientMessageServiceMock.Object,
|
|
_subscribersServiceMock.Object,
|
|
_calculatedObservationsServiceLazy,
|
|
_httpContextAccessor.Object,
|
|
_auditService.Object,
|
|
_unitServiceMock.Object
|
|
);
|
|
|
|
|
|
// Create a mock of the singleton class subscribers
|
|
var mockSingleton = new Mock<ICalculatedObservationsService>();
|
|
|
|
// Set up the mock object to return a specific value when a method is called
|
|
mockSingleton.Setup(x => x.Map(It.IsAny<PatientDiagnosis>())).ReturnsAsync((PatientDiagnosis? value) => value);
|
|
}
|
|
|
|
private DiagnosisService _diagnosisService;
|
|
|
|
private Lazy<IPatientService> _patientServiceLazy;
|
|
|
|
private Mock<IPatientService> _patientServiceMock;
|
|
private Mock<IDiagnosisRepository> _diagnosisRepositoryMock;
|
|
private Mock<IDiagnosisArchiveRepository> _diagnosisArchiveRepositoryMock;
|
|
|
|
private Mock<IClientMessageService> _clientMessageServiceMock;
|
|
private Mock<ISubscribersService> _subscribersServiceMock;
|
|
private Mock<IUnitService> _unitServiceMock;
|
|
private Lazy<ICalculatedObservationsService> _calculatedObservationsServiceLazy;
|
|
private Mock<ICalculatedObservationsService> _calculatedObservationsServiceMock;
|
|
private Mock<IHttpContextAccessor> _httpContextAccessor = new();
|
|
private Mock<ILocalAuditService> _auditService = new();
|
|
|
|
private readonly ApiSettings _apiSettings = new()
|
|
{
|
|
DiagnosisSystem = "Snomed-CT",
|
|
DiagnosisCode = { "55607006" }
|
|
};
|
|
|
|
private IOptions<ApiSettings> _optionsApiSettings;
|
|
|
|
|
|
private Mock<ILogger<DiagnosisService>> _logger;
|
|
|
|
private static readonly DateTime Now = DateTime.Now;
|
|
private static readonly ObjectId PatientId = ObjectId.GenerateNewId();
|
|
|
|
// [Test]
|
|
// public void SaveRequest_patientNumber_and_pointOfCare_null_Return_not_insert()
|
|
// {
|
|
// var apiRequest = new ApiRequest();
|
|
//
|
|
// Assert.ThrowsAsync<Exception>(async () => await _diagnosisService.SaveRequest(apiRequest, null));
|
|
// }
|
|
|
|
// [Test]
|
|
// public void SaveRequest_Not_ORU_R01_Return_not_insert()
|
|
// {
|
|
// var patientObs = new Person
|
|
// {
|
|
// FirstName = "Miguel",
|
|
// LastName = "Villanueva",
|
|
// Ids = new Dictionary<string, string> { { "MR", "437537" } }
|
|
// };
|
|
//
|
|
// var patient = new Patient
|
|
// {
|
|
// Id = ObjectId.GenerateNewId(),
|
|
// UnitString = "UCI5C",
|
|
// Bed = "Box4",
|
|
// PatientNumber = "437537",
|
|
// Person = patientObs
|
|
//
|
|
// };
|
|
//
|
|
// var apiRequest = new ApiRequest
|
|
// {
|
|
// Location = new PatientLocation("UCI5C", "Box4"),
|
|
// Patient = patientObs,
|
|
// PatientNumber = "437537",
|
|
// Type = "ORU_R11",
|
|
// PatientId = PatientId.ToString(),
|
|
// MessageTime = Now
|
|
// };
|
|
//
|
|
// _patientServiceMock.Setup(cm => cm.FindPatientByApiRequest(apiRequest)).ReturnsAsync(patient);
|
|
//
|
|
// Assert.ThrowsAsync<Exception>(async () => await _diagnosisService.SaveRequest(apiRequest, null));
|
|
// }
|
|
|
|
|
|
[Test]
|
|
public async Task SaveRequest_Not_FindPatient_Return_not_insert()
|
|
{
|
|
var apiRequest = new ApiRequest
|
|
{
|
|
Location = new PatientLocation("UCI5C", "Box4"),
|
|
PatientNumber = "437537",
|
|
Type = "ORU_R01",
|
|
PatientId = PatientId.ToString(),
|
|
MessageTime = Now
|
|
};
|
|
|
|
_patientServiceMock.Setup(cm => cm.FindPatientByApiRequest(apiRequest)).ReturnsAsync((Patient?)null);
|
|
|
|
await _diagnosisService.SaveRequest(apiRequest, null);
|
|
|
|
_diagnosisRepositoryMock.Verify(d => d.InsertOneAsync(It.IsAny<PatientDiagnosis>()), Times.Never);
|
|
}
|
|
|
|
[Test]
|
|
public async Task SaveRequest_Not_Observations_Return_not_insert()
|
|
{
|
|
var patientObs = new Person
|
|
{
|
|
FirstName = "Miguel",
|
|
LastName = "Villanueva",
|
|
Ids = new Dictionary<string, string> { { "MR", "437537" } }
|
|
};
|
|
|
|
var patient = new Patient
|
|
{
|
|
Id = ObjectId.GenerateNewId(),
|
|
UnitString = "UCI5C",
|
|
Bed = "Box4",
|
|
PatientNumber = "437537",
|
|
Person = patientObs
|
|
};
|
|
|
|
var apiRequest = new ApiRequest
|
|
{
|
|
Location = new PatientLocation("UCI5C", "Box4"),
|
|
ObservationData = new ObservationData
|
|
{
|
|
Code = "302147001",
|
|
CodingSystem = "SNM",
|
|
Value = "Aire; Contacto; Preventivo",
|
|
Text = "Aislamiento",
|
|
Time = Now
|
|
},
|
|
Patient = patientObs,
|
|
PatientNumber = "437537",
|
|
Type = "ORU_R01",
|
|
PatientId = PatientId.ToString(),
|
|
MessageTime = Now
|
|
};
|
|
|
|
|
|
_patientServiceMock.Setup(cm => cm.FindPatientByApiRequest(apiRequest)).ReturnsAsync(patient);
|
|
|
|
await _diagnosisService.SaveRequest(apiRequest, null);
|
|
|
|
_diagnosisRepositoryMock.Verify(d => d.InsertOneAsync(It.IsAny<PatientDiagnosis>()), Times.Never);
|
|
}
|
|
|
|
[Test]
|
|
public async Task SaveRequest_Not_DiagnosisCodeSettings_Return_not_insert()
|
|
{
|
|
var patientObs = new Person
|
|
{
|
|
FirstName = "Miguel",
|
|
LastName = "Villanueva",
|
|
Ids = new Dictionary<string, string> { { "MR", "437537" } }
|
|
};
|
|
|
|
var patient = new Patient
|
|
{
|
|
Id = ObjectId.GenerateNewId(),
|
|
UnitString = "UCI5C",
|
|
Bed = "Box4",
|
|
PatientNumber = "437537",
|
|
Person = patientObs
|
|
};
|
|
|
|
var apiRequest = new ApiRequest
|
|
{
|
|
Location = new PatientLocation("UCI5C", "Box4"),
|
|
ObservationData = new ObservationData
|
|
{
|
|
Code = "302147001",
|
|
CodingSystem = "SNM",
|
|
Value = "Aire; Contacto; Preventivo",
|
|
Text = "Aislamiento",
|
|
Time = Now
|
|
},
|
|
Observations =
|
|
[
|
|
new PatientObservation
|
|
{
|
|
Code = "263490005",
|
|
CodingSystem = "SNM",
|
|
Name = "Estado",
|
|
Status = StatusEnum.Type.Ok,
|
|
Time = Now,
|
|
Value = "Sin alergias conocidas"
|
|
},
|
|
|
|
new PatientObservation
|
|
{
|
|
Code = "300916003",
|
|
CodingSystem = "SNM",
|
|
Name = "¿Alergia al látex?",
|
|
Status = StatusEnum.Type.Ok,
|
|
Time = Now,
|
|
Value = "No"
|
|
}
|
|
],
|
|
Patient = patientObs,
|
|
PatientNumber = "437537",
|
|
Type = "ORU_R01",
|
|
PatientId = PatientId.ToString(),
|
|
MessageTime = Now
|
|
};
|
|
|
|
Options.Create(new ApiSettings());
|
|
|
|
var diagnosisService = new DiagnosisService(
|
|
_patientServiceLazy,
|
|
//sectionServiceLazy,
|
|
_optionsApiSettings,
|
|
_diagnosisRepositoryMock.Object,
|
|
_diagnosisArchiveRepositoryMock.Object,
|
|
_logger.Object,
|
|
_clientMessageServiceMock.Object,
|
|
_subscribersServiceMock.Object,
|
|
_calculatedObservationsServiceLazy,
|
|
_httpContextAccessor.Object,
|
|
_auditService.Object,
|
|
_unitServiceMock.Object);
|
|
|
|
_patientServiceMock.Setup(cm => cm.FindPatientByApiRequest(apiRequest)).ReturnsAsync(patient);
|
|
|
|
await diagnosisService.SaveRequest(apiRequest, null);
|
|
|
|
_diagnosisRepositoryMock.Verify(d => d.InsertOneAsync(It.IsAny<PatientDiagnosis>()), Times.Never);
|
|
}
|
|
|
|
|
|
// [Test]
|
|
// public async Task SaveRequest_DiagnosisCodeSettings_Return_insert()
|
|
// {
|
|
// var patientObs = new Person
|
|
// {
|
|
// FirstName = "Miguel",
|
|
// LastName = "Villanueva",
|
|
// Ids = new Dictionary<string, string> { { "MR", "437537" } }
|
|
// };
|
|
//
|
|
// var patient = new Patient
|
|
// {
|
|
// Id = ObjectId.GenerateNewId(),
|
|
// UnitString = "UCI5C",
|
|
// Bed = "Box4",
|
|
// PatientNumber = "437537",
|
|
// Person = patientObs
|
|
// };
|
|
//
|
|
// var apiRequest = new ApiRequest
|
|
// {
|
|
// Location = new PatientLocation("UCI5C", "Box4"),
|
|
// ObservationData= new ObservationData
|
|
// {
|
|
// Code = "55607006",
|
|
// CodingSystem = "SNM",
|
|
// Value = "Diagnosis",
|
|
// Time = Now
|
|
//
|
|
// },
|
|
// Observations = new List<PatientObservation>
|
|
// {
|
|
// new()
|
|
// {
|
|
// Code = "272099008",
|
|
// CodingSystem = "SNM",
|
|
// Name = "description",
|
|
// Status = ObservationStatus.Ok,
|
|
// Time = Now,
|
|
// Value = "Daño axonal difuso"
|
|
// },
|
|
// new()
|
|
// {
|
|
// Code = "1000000013",
|
|
// CodingSystem = "SNM",
|
|
// Name = "label",
|
|
// Status = ObservationStatus.Ok,
|
|
// Time = Now,
|
|
// Value = "Daño axonal difuso"
|
|
// },
|
|
// new()
|
|
// {
|
|
// Code = "1000000014",
|
|
// CodingSystem = "SNM",
|
|
// Name = "code",
|
|
// Status = ObservationStatus.Ok,
|
|
// Time = Now,
|
|
// Value = "262693007"
|
|
// },
|
|
// new()
|
|
// {
|
|
// Code = "394731006",
|
|
// CodingSystem = "SNM",
|
|
// Name = "state",
|
|
// Status = ObservationStatus.Ok,
|
|
// Time = Now,
|
|
// Value = "state"
|
|
// },
|
|
// new()
|
|
// {
|
|
// Code = "272125009",
|
|
// CodingSystem = "SNM",
|
|
// Name = "category",
|
|
// Status = ObservationStatus.Ok,
|
|
// Time = Now,
|
|
// Value = "category"
|
|
// },
|
|
// new()
|
|
// {
|
|
// Code = "398201009",
|
|
// CodingSystem = "SNM",
|
|
// Name = "starTime",
|
|
// Status = ObservationStatus.Ok,
|
|
// Time = Now,
|
|
// Value = Now.AddHours(1)
|
|
// },
|
|
// new()
|
|
// {
|
|
// Code = "397898000",
|
|
// CodingSystem = "SNM",
|
|
// Name = "endTime",
|
|
// Status = ObservationStatus.Ok,
|
|
// Time = Now,
|
|
// Value = Now.AddHours(2)
|
|
// }
|
|
//
|
|
// },
|
|
// Patient = patientObs,
|
|
// PatientNumber = "437537",
|
|
// Type = "ORU_R01",
|
|
// PatientId = PatientId.ToString(),
|
|
// MessageTime = Now
|
|
// };
|
|
//
|
|
// _diagnosisService = new DiagnosisService(
|
|
// _patientServiceLazy,
|
|
// //sectionServiceLazy,
|
|
// _optionsApiSettings,
|
|
// _diagnosisRepositoryMock.Object,
|
|
// _diagnosisArchiveRepositoryMock.Object,
|
|
// _logger.Object,
|
|
// _clientMessageServiceMock.Object,
|
|
// _subscribersServiceMock.Object,
|
|
// _calculatedObservationsServiceLazy,
|
|
// _unitServiceMock.Object);
|
|
//
|
|
// _patientServiceMock.Setup(cm => cm.FindPatientByApiRequest(apiRequest)).ReturnsAsync(patient);
|
|
//
|
|
// await _diagnosisService.SaveRequest(apiRequest, null);
|
|
//
|
|
// _diagnosisRepositoryMock.Verify(d => d.InsertOneAsync(It.IsAny<PatientDiagnosis>()), Times.Once);
|
|
// _diagnosisRepositoryMock.Verify(d => d.UpdateOneAsync(It.IsAny<ObjectId>(),It.IsAny<PatientDiagnosis>()), Times.Never);
|
|
// }
|
|
|
|
// [Test]
|
|
// public async Task SaveRequest_DiagnosisCodeSettings_Return_Update()
|
|
// {
|
|
// var patientObs = new Person
|
|
// {
|
|
// FirstName = "Miguel",
|
|
// LastName = "Villanueva",
|
|
// Ids = new Dictionary<string, string> { { "MR", "437537" } }
|
|
// };
|
|
//
|
|
// var patient = new Patient
|
|
// {
|
|
// Id = ObjectId.GenerateNewId(),
|
|
// UnitString = "UCI5C",
|
|
// Bed = "Box4",
|
|
// PatientNumber = "437537",
|
|
// Person = patientObs
|
|
// };
|
|
//
|
|
// var apiRequest = new ApiRequest
|
|
// {
|
|
// Location = new PatientLocation("UCI5C", "Box4"),
|
|
// ObservationData= new ObservationData
|
|
// {
|
|
// Code = "55607006",
|
|
// CodingSystem = "SNM",
|
|
// Value = "Diagnosis",
|
|
// Time = Now
|
|
//
|
|
// },
|
|
// Observations = new List<PatientObservation>
|
|
// {
|
|
// new()
|
|
// {
|
|
// Code = "272099008",
|
|
// CodingSystem = "SNM",
|
|
// Name = "description",
|
|
// Status = ObservationStatus.Ok,
|
|
// Time = Now,
|
|
// Value = "Daño axonal difuso"
|
|
// },
|
|
// new()
|
|
// {
|
|
// Code = "1000000013",
|
|
// CodingSystem = "SNM",
|
|
// Name = "label",
|
|
// Status = ObservationStatus.Ok,
|
|
// Time = Now,
|
|
// Value = "Daño axonal difuso"
|
|
// },
|
|
// new()
|
|
// {
|
|
// Code = "1000000014",
|
|
// CodingSystem = "SNM",
|
|
// Name = "code",
|
|
// Status = ObservationStatus.Ok,
|
|
// Time = Now,
|
|
// Value = "262693007"
|
|
// },
|
|
// new()
|
|
// {
|
|
// Code = "394731006",
|
|
// CodingSystem = "SNM",
|
|
// Name = "state",
|
|
// Status = ObservationStatus.Ok,
|
|
// Time = Now,
|
|
// Value = "state"
|
|
// },
|
|
// new()
|
|
// {
|
|
// Code = "272125009",
|
|
// CodingSystem = "SNM",
|
|
// Name = "category",
|
|
// Status = ObservationStatus.Ok,
|
|
// Time = Now,
|
|
// Value = "category"
|
|
// },
|
|
// new()
|
|
// {
|
|
// Code = "398201009",
|
|
// CodingSystem = "SNM",
|
|
// Name = "starTime",
|
|
// Status = ObservationStatus.Ok,
|
|
// Time = Now,
|
|
// Value = Now.AddHours(1)
|
|
// },
|
|
// new()
|
|
// {
|
|
// Code = "397898000",
|
|
// CodingSystem = "SNM",
|
|
// Name = "endTime",
|
|
// Status = ObservationStatus.Ok,
|
|
// Time = Now,
|
|
// Value = Now.AddHours(2)
|
|
// }
|
|
//
|
|
// },
|
|
// Patient = patientObs,
|
|
// PatientNumber = "437537",
|
|
// Type = "ORU_R01",
|
|
// PatientId = patient.Id.ToString(),
|
|
// MessageTime = Now
|
|
// };
|
|
//
|
|
// var patientDiagnosis = new PatientDiagnosis
|
|
// {
|
|
// Id = ObjectId.GenerateNewId(),
|
|
// Time = Now
|
|
// };
|
|
//
|
|
// _diagnosisService = new DiagnosisService(
|
|
// _patientServiceLazy,
|
|
// //sectionServiceLazy,
|
|
// _optionsApiSettings,
|
|
// _diagnosisRepositoryMock.Object,
|
|
// _diagnosisArchiveRepositoryMock.Object,
|
|
// _logger.Object,
|
|
// _clientMessageServiceMock.Object,
|
|
// _subscribersServiceMock.Object,
|
|
// _calculatedObservationsServiceLazy,
|
|
// _unitServiceMock.Object);
|
|
//
|
|
// _patientServiceMock.Setup(cm => cm.FindPatientByApiRequest(apiRequest)).ReturnsAsync(patient);
|
|
// _diagnosisRepositoryMock.Setup(d => d.FindByPatientIdAndCode(patient.Id, "262693007", "Snomed-CT")).ReturnsAsync(patientDiagnosis);
|
|
//
|
|
// await _diagnosisService.SaveRequest(apiRequest, null);
|
|
//
|
|
// //_diagnosisRepositoryMock.Verify(d => d.InsertOneAsync(It.IsAny<PatientDiagnosis>()), Times.Never);
|
|
// _diagnosisRepositoryMock.Verify(d => d.UpdateOneAsync(It.IsAny<ObjectId>(), It.IsAny<PatientDiagnosis>()), Times.Once);
|
|
// }
|
|
} |