Added BackgroundJobStore_Tests

pull/1810/head
Halil İbrahim Kalkan 6 years ago
parent 08f299b6f4
commit d834687f7c

@ -48,7 +48,13 @@ namespace Volo.Abp.BackgroundJobs
/// </summary>
public virtual BackgroundJobPriority Priority { get; set; }
public BackgroundJobRecord()
private BackgroundJobRecord()
{
}
public BackgroundJobRecord(Guid id)
: base(id)
{
}

@ -8,9 +8,11 @@ namespace Volo.Abp.BackgroundJobs
public BackgroundJobsDomainAutoMapperProfile()
{
CreateMap<BackgroundJobInfo, BackgroundJobRecord>()
.ConstructUsing(x => new BackgroundJobRecord(x.Id))
.Ignore(record => record.ConcurrencyStamp)
.Ignore(record => record.ExtraProperties)
.ReverseMap();
.Ignore(record => record.ExtraProperties);
CreateMap<BackgroundJobRecord, BackgroundJobInfo>();
}
}
}

@ -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<IBackgroundJobStore>();
}
[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);
}
}
}

@ -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,

Loading…
Cancel
Save