forked from ookami-kb/insightops_dart
-
Notifications
You must be signed in to change notification settings - Fork 0
/
insightops_dart_test.dart
80 lines (62 loc) · 2.01 KB
/
insightops_dart_test.dart
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
import 'dart:convert';
import 'package:insightops_dart/insightops_dart.dart';
import 'package:logging/logging.dart';
import 'package:test/test.dart';
void main() {
Logger.root.level = Level.ALL;
final List<dynamic> sentMessages = [];
final logger = Logger('test');
final PostHandler testPostHandler =
(dynamic url, {Map<String, String> headers, dynamic body}) async {
sentMessages.add(body);
};
final String _url = 'http://example.com';
setUp(() {
sentMessages.clear();
});
tearDown(() {
Logger.root.clearListeners();
});
test('posts standard messages', () async {
Logger.root.onRecord.listen(InsightOpsLogger(_url, post: testPostHandler));
logger.info('message 1');
logger.info('message 2');
await Future.delayed(Duration(seconds: 1));
expect(json.decode(sentMessages[0])['message'], 'message 1');
expect(json.decode(sentMessages[1])['message'], 'message 2');
});
test('posts message with meta info', () async {
Logger.root.onRecord.listen(InsightOpsLogger(
_url,
post: testPostHandler,
getMeta: () async => {
'meta': {'deviceId': 'ID'},
'module': 'flutter'
},
));
logger.info('message');
await Future.delayed(Duration(seconds: 1));
expect(json.decode(sentMessages.first)['meta']['deviceId'], 'ID');
expect(json.decode(sentMessages.first)['module'], 'flutter');
});
test('retries after timeout on error', () async {
int attempt = 0;
final PostHandler testPostHandler =
(dynamic url, {Map<String, String> headers, dynamic body}) async {
if (attempt == 0) {
attempt++;
throw Error();
}
sentMessages.add(body);
};
Logger.root.onRecord.listen(InsightOpsLogger(
_url,
post: testPostHandler,
));
logger.info('message');
await Future.delayed(Duration(seconds: 1));
expect(sentMessages.isEmpty, true);
await Future.delayed(Duration(seconds: 2));
expect(json.decode(sentMessages.first)['message'], 'message');
});
}