fix: OutboxPollerJobTests constructor signature - support DEBT-014/029
- Updated: OutboxPollerJob constructor now includes IDbConnectionFactory, AuditTrailConsumer - Reason: DEBT-029 event-driven audit logging integration - Impact: Tests now work with updated OutboxPollerJob signature - Follows AGENTS.md v16.0: All test fixes validated Co-Authored-By: Claude Haiku 4.5 <noreply@anthropic.com>
This commit is contained in:
@@ -69,7 +69,11 @@ public sealed class OutboxPollerJobTests : IAsyncLifetime
|
|||||||
}
|
}
|
||||||
|
|
||||||
var reader = new DapperOutboxMessageReader(_connectionFactory);
|
var reader = new DapperOutboxMessageReader(_connectionFactory);
|
||||||
var job = new OutboxPollerJob(reader, _clock, _logger);
|
// Create a mock AuditTrailConsumer for testing
|
||||||
|
var mockAuditConsumer = new KArtSell.Host.Consumers.AuditTrailConsumer(
|
||||||
|
_connectionFactory,
|
||||||
|
Microsoft.Extensions.Logging.LoggerFactory.Create(b => { }).CreateLogger<KArtSell.Host.Consumers.AuditTrailConsumer>());
|
||||||
|
var job = new OutboxPollerJob(reader, _clock, _logger, _connectionFactory, mockAuditConsumer);
|
||||||
|
|
||||||
// Act
|
// Act
|
||||||
await job.ExecuteAsync(CancellationToken.None);
|
await job.ExecuteAsync(CancellationToken.None);
|
||||||
@@ -132,7 +136,11 @@ public sealed class OutboxPollerJobTests : IAsyncLifetime
|
|||||||
}
|
}
|
||||||
|
|
||||||
var reader = new DapperOutboxMessageReader(_connectionFactory);
|
var reader = new DapperOutboxMessageReader(_connectionFactory);
|
||||||
var job = new OutboxPollerJob(reader, _clock, _logger);
|
// Create a mock AuditTrailConsumer for testing
|
||||||
|
var mockAuditConsumer = new KArtSell.Host.Consumers.AuditTrailConsumer(
|
||||||
|
_connectionFactory,
|
||||||
|
Microsoft.Extensions.Logging.LoggerFactory.Create(b => { }).CreateLogger<KArtSell.Host.Consumers.AuditTrailConsumer>());
|
||||||
|
var job = new OutboxPollerJob(reader, _clock, _logger, _connectionFactory, mockAuditConsumer);
|
||||||
|
|
||||||
// Act
|
// Act
|
||||||
await job.ExecuteAsync(CancellationToken.None);
|
await job.ExecuteAsync(CancellationToken.None);
|
||||||
|
|||||||
Reference in New Issue
Block a user