From d834687f7cb69ed49979a9eab928eea47fb7edaa Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Halil=20=C4=B0brahim=20Kalkan?= Date: Fri, 20 Sep 2019 20:13:23 +0300 Subject: [PATCH] Added BackgroundJobStore_Tests --- .../Abp/BackgroundJobs/BackgroundJobRecord.cs | 8 +++- .../BackgroundJobsDomainAutoMapperProfile.cs | 6 ++- .../BackgroundJobStore_Tests.cs | 38 +++++++++++++++++++ .../BackgroundJobsTestDataBuilder.cs | 9 ++--- 4 files changed, 52 insertions(+), 9 deletions(-) create mode 100644 modules/background-jobs/test/Volo.Abp.BackgroundJobs.Domain.Tests/Volo/Abp/BackgroundJobs/BackgroundJobStore_Tests.cs diff --git a/modules/background-jobs/src/Volo.Abp.BackgroundJobs.Domain/Volo/Abp/BackgroundJobs/BackgroundJobRecord.cs b/modules/background-jobs/src/Volo.Abp.BackgroundJobs.Domain/Volo/Abp/BackgroundJobs/BackgroundJobRecord.cs index c3684d9cfe..76106ea468 100644 --- a/modules/background-jobs/src/Volo.Abp.BackgroundJobs.Domain/Volo/Abp/BackgroundJobs/BackgroundJobRecord.cs +++ b/modules/background-jobs/src/Volo.Abp.BackgroundJobs.Domain/Volo/Abp/BackgroundJobs/BackgroundJobRecord.cs @@ -48,7 +48,13 @@ namespace Volo.Abp.BackgroundJobs /// public virtual BackgroundJobPriority Priority { get; set; } - public BackgroundJobRecord() + private BackgroundJobRecord() + { + + } + + public BackgroundJobRecord(Guid id) + : base(id) { } diff --git a/modules/background-jobs/src/Volo.Abp.BackgroundJobs.Domain/Volo/Abp/BackgroundJobs/BackgroundJobsDomainAutoMapperProfile.cs b/modules/background-jobs/src/Volo.Abp.BackgroundJobs.Domain/Volo/Abp/BackgroundJobs/BackgroundJobsDomainAutoMapperProfile.cs index a20a01392b..ebf98bbe70 100644 --- a/modules/background-jobs/src/Volo.Abp.BackgroundJobs.Domain/Volo/Abp/BackgroundJobs/BackgroundJobsDomainAutoMapperProfile.cs +++ b/modules/background-jobs/src/Volo.Abp.BackgroundJobs.Domain/Volo/Abp/BackgroundJobs/BackgroundJobsDomainAutoMapperProfile.cs @@ -8,9 +8,11 @@ namespace Volo.Abp.BackgroundJobs public BackgroundJobsDomainAutoMapperProfile() { CreateMap() + .ConstructUsing(x => new BackgroundJobRecord(x.Id)) .Ignore(record => record.ConcurrencyStamp) - .Ignore(record => record.ExtraProperties) - .ReverseMap(); + .Ignore(record => record.ExtraProperties); + + CreateMap(); } } } diff --git a/modules/background-jobs/test/Volo.Abp.BackgroundJobs.Domain.Tests/Volo/Abp/BackgroundJobs/BackgroundJobStore_Tests.cs b/modules/background-jobs/test/Volo.Abp.BackgroundJobs.Domain.Tests/Volo/Abp/BackgroundJobs/BackgroundJobStore_Tests.cs new file mode 100644 index 0000000000..caa9a3c445 --- /dev/null +++ b/modules/background-jobs/test/Volo.Abp.BackgroundJobs.Domain.Tests/Volo/Abp/BackgroundJobs/BackgroundJobStore_Tests.cs @@ -0,0 +1,38 @@ +using System; +using System.Threading.Tasks; +using Shouldly; +using Xunit; + +namespace Volo.Abp.BackgroundJobs +{ + public class BackgroundJobStore_Tests : BackgroundJobsDomainTestBase + { + private readonly IBackgroundJobStore _backgroundJobStore; + + public BackgroundJobStore_Tests() + { + _backgroundJobStore = GetRequiredService(); + } + + [Fact] + public async Task InsertAsync() + { + var jobInfo = new BackgroundJobInfo + { + Id = Guid.NewGuid(), + JobArgs = "args1", + JobName = "name1" + }; + + await _backgroundJobStore.InsertAsync( + jobInfo + ); + + var jobInfo2 = await _backgroundJobStore.FindAsync(jobInfo.Id); + jobInfo2.ShouldNotBeNull(); + jobInfo2.Id.ShouldBe(jobInfo.Id); + jobInfo2.JobArgs.ShouldBe(jobInfo.JobArgs); + jobInfo2.JobName.ShouldBe(jobInfo.JobName); + } + } +} diff --git a/modules/background-jobs/test/Volo.Abp.BackgroundJobs.TestBase/Volo/Abp/BackgroundJobs/BackgroundJobsTestDataBuilder.cs b/modules/background-jobs/test/Volo.Abp.BackgroundJobs.TestBase/Volo/Abp/BackgroundJobs/BackgroundJobsTestDataBuilder.cs index 347db003a2..dd74854a9c 100644 --- a/modules/background-jobs/test/Volo.Abp.BackgroundJobs.TestBase/Volo/Abp/BackgroundJobs/BackgroundJobsTestDataBuilder.cs +++ b/modules/background-jobs/test/Volo.Abp.BackgroundJobs.TestBase/Volo/Abp/BackgroundJobs/BackgroundJobsTestDataBuilder.cs @@ -23,9 +23,8 @@ namespace Volo.Abp.BackgroundJobs public void Build() { _backgroundJobRepository.Insert( - new BackgroundJobRecord + new BackgroundJobRecord(_testData.JobId1) { - Id = _testData.JobId1, JobName = "TestJobName", JobArgs = "{ value: 1 }", NextTryTime = _clock.Now.Subtract(TimeSpan.FromMinutes(1)), @@ -38,9 +37,8 @@ namespace Volo.Abp.BackgroundJobs ); _backgroundJobRepository.Insert( - new BackgroundJobRecord + new BackgroundJobRecord(_testData.JobId2) { - Id = _testData.JobId2, JobName = "TestJobName", JobArgs = "{ value: 2 }", NextTryTime = _clock.Now.AddMinutes(42), @@ -53,9 +51,8 @@ namespace Volo.Abp.BackgroundJobs ); _backgroundJobRepository.Insert( - new BackgroundJobRecord + new BackgroundJobRecord(_testData.JobId3) { - Id = _testData.JobId3, JobName = "TestJobName", JobArgs = "{ value: 3 }", NextTryTime = _clock.Now,