82 lines
2.3 KiB
Dart
82 lines
2.3 KiB
Dart
import 'package:mocktail/mocktail.dart';
|
|
import 'package:stream_chat/src/client/retry_policy.dart';
|
|
import 'package:stream_chat/src/client/retry_queue.dart';
|
|
import 'package:stream_chat/stream_chat.dart';
|
|
import 'package:test/test.dart';
|
|
|
|
import '../mocks.dart';
|
|
|
|
void main() {
|
|
late final channel = MockRetryQueueChannel();
|
|
late final logger = MockLogger();
|
|
late RetryQueue retryQueue;
|
|
|
|
setUpAll(() {
|
|
final retryPolicy = RetryPolicy(
|
|
shouldRetry: (_, __, error) {
|
|
return error is StreamChatNetworkError && error.isRetriable;
|
|
},
|
|
);
|
|
when(() => channel.client.retryPolicy).thenReturn(retryPolicy);
|
|
|
|
when(() => channel.client.on(EventType.connectionRecovered)).thenAnswer(
|
|
(_) => Stream.value(Event(
|
|
type: EventType.connectionRecovered,
|
|
online: false,
|
|
)),
|
|
);
|
|
|
|
when(() => channel.on(any(), any(), any(), any())).thenAnswer(
|
|
(_) => Stream.value(
|
|
Event(type: EventType.any),
|
|
),
|
|
);
|
|
});
|
|
|
|
setUp(() {
|
|
retryQueue = RetryQueue(channel: channel, logger: logger);
|
|
});
|
|
|
|
tearDown(() {
|
|
retryQueue.dispose();
|
|
});
|
|
|
|
group('`.add`', () {
|
|
test('should return if message list is empty', () {
|
|
expect(() => retryQueue.add([]), returnsNormally);
|
|
verifyNever(() => logger.info(any()));
|
|
});
|
|
|
|
test('should throw if message state is not failed', () {
|
|
final message = Message(
|
|
id: 'test-message-id',
|
|
text: 'Sample message test',
|
|
state: MessageState.sent,
|
|
);
|
|
expect(() => retryQueue.add([message]), throwsA(isA<AssertionError>()));
|
|
});
|
|
|
|
test('should return if queue already contains the message', () {
|
|
final message = Message(
|
|
id: 'test-message-id',
|
|
text: 'Sample message test',
|
|
state: MessageState.sendingFailed,
|
|
);
|
|
retryQueue.add([message]);
|
|
expect(() => retryQueue.add([message]), returnsNormally);
|
|
// Called only for the first message
|
|
verify(() => logger.info('Adding 1 messages to the queue')).called(1);
|
|
});
|
|
|
|
test('`.add` should add failed request to the queue', () async {
|
|
final message = Message(
|
|
id: 'test-message-id',
|
|
text: 'Sample message test',
|
|
state: MessageState.sendingFailed,
|
|
);
|
|
retryQueue.add([message]);
|
|
expect(retryQueue.hasMessages, isTrue);
|
|
});
|
|
});
|
|
}
|