mrpastewart/platform
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Test: adding checkpoint for passing test

Browse source
This commit is contained in:
Patrick Stewart 2024-10-05 23:46:09 -07:00
parent 42596c1026
commit c01e96ddc9
1 changed files with 47 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

65
core/queue/test/queue_test.dart
View file

@ -40,12 +40,15 @@ void main() {
// Setup for EventBus mock
when(eventBus.fire(any)).thenAnswer((_) => Future<void>.value());
// // Setup for MQClient mock
// when(mq.sendMessage(
// message: any,
// exchangeName: any,
// routingKey: any,
// )).thenAnswer((_) => Future<void>.value());
// Setup for MQClient mock
when(mq.sendMessage(
message: anyNamed('message'),
exchangeName: anyNamed('exchangeName'),
routingKey: anyNamed('routingKey'),
)).thenAnswer((_) {
print("Debug: Mock sendMessage called");
// Notice we're not returning anything here
});
});
test('pushOn calls push with correct arguments', () async {
@ -81,6 +84,7 @@ void main() {
test('enqueueUsing publishes message and fires events', () async {
when(container.has<TransactionManager>()).thenReturn(false);
print("Debug: Before enqueueUsing");
await queue.enqueueUsing(
'test_job',
'test_payload',
@ -88,19 +92,41 @@ void main() {
null,
(payload, queue, delay) async => 'job_id',
);
print("Debug: After enqueueUsing");
// Verify that events were fired
// Verify all method calls in order
verifyInOrder([
eventBus.fire(argThat(isA<JobQueueingEvent>())),
eventBus.fire(argThat(isA<JobQueuedEvent>())),
mq.sendMessage(
message: anyNamed('message'),
exchangeName: anyNamed('exchangeName'),
routingKey: anyNamed('routingKey'),
),
]);
// Print captured arguments for sendMessage
final sendMessageCall = verify(mq.sendMessage(
message: captureAnyNamed('message'),
exchangeName: captureAnyNamed('exchangeName'),
routingKey: captureAnyNamed('routingKey'),
));
if (sendMessageCall.captured.isNotEmpty) {
print("sendMessage was called with:");
print("message: ${sendMessageCall.captured[0]}");
print("exchangeName: ${sendMessageCall.captured[1]}");
print("routingKey: ${sendMessageCall.captured[2]}");
} else {
print("sendMessage was not called");
}
// Additional verifications
verify(eventBus.fire(any)).called(2);
// More specific verification
verify(eventBus.fire(argThat(isA<JobQueueingEvent>()))).called(1);
verify(eventBus.fire(argThat(isA<JobQueuedEvent>()))).called(1);
// Verify that message was sent
verify(mq.sendMessage(
message: argThat(isA<Message>()),
exchangeName: '',
routingKey: 'test_queue',
message: anyNamed('message'),
exchangeName: anyNamed('exchangeName'),
routingKey: anyNamed('routingKey'),
)).called(1);
});
}
@ -148,10 +174,12 @@ class TestQueue extends Queue {
Duration? delay,
Future<dynamic> Function(String, String?, Duration?) callback,
) async {
await raiseJobQueueingEvent(queue, job, payload, delay);
eventBus.fire(JobQueueingEvent(connectionName, queue, job, payload, delay));
final result = await callback(payload, queue, delay);
await raiseJobQueuedEvent(queue, result, job, payload, delay);
eventBus.fire(
JobQueuedEvent(connectionName, queue, result, job, payload, delay));
print("Attempting to send message..."); // Debug print
mq.sendMessage(
message: Message(
id: 'test-id',
@ -162,6 +190,7 @@ class TestQueue extends Queue {
exchangeName: '',
routingKey: queue ?? 'default',
);
print("Message sent."); // Debug print
return result;
}