1 |
|
2 |
|
3 |
|
4 |
|
5 |
|
6 |
|
7 |
|
8 |
|
9 |
|
10 |
|
11 |
|
12 |
|
13 |
|
14 |
|
15 |
|
16 |
|
17 |
|
18 |
|
19 |
|
20 |
|
21 | 'use strict';
|
22 |
|
23 | var test = require('tape');
|
24 |
|
25 | var KafkaLogger = require('./lib/kafka-logger.js');
|
26 |
|
27 | test('can .error("message", new Error())', function (assert) {
|
28 | var logger = KafkaLogger(function (err, msg) {
|
29 | assert.ifError(err, 'no unexpected server error');
|
30 | var obj = msg.messages[0].payload;
|
31 |
|
32 | assert.notEqual(obj.msg.indexOf('hello'), -1);
|
33 | assert.notEqual(
|
34 | obj.fields.stack.indexOf('Error: lulz'), -1);
|
35 | assert.equal(obj.fields.message, 'lulz');
|
36 |
|
37 | logger.destroy();
|
38 | assert.end();
|
39 | });
|
40 |
|
41 | logger.error('hello', new Error('lulz'));
|
42 | });
|
43 |
|
44 | test('can error("message", { error: Error() })', function (assert) {
|
45 | var logger = KafkaLogger(function (err, msg) {
|
46 | assert.ifError(err, 'no unexpected server error');
|
47 | var obj = msg.messages[0].payload;
|
48 |
|
49 | assert.notEqual(obj.msg.indexOf('some message'), -1);
|
50 | assert.notEqual(
|
51 | obj.fields.error.stack.indexOf('Error: some error'), -1);
|
52 | assert.equal(obj.fields.error.message, 'some error');
|
53 | assert.equal(obj.fields.other, 'key');
|
54 |
|
55 | logger.destroy();
|
56 | assert.end();
|
57 | });
|
58 |
|
59 | logger.error('some message', {
|
60 | error: new Error('some error'),
|
61 | other: 'key'
|
62 | });
|
63 | });
|
64 |
|
65 | test('can error(msg, { someKey: Error() })', function (assert) {
|
66 | var logger = KafkaLogger(function (err, msg) {
|
67 | assert.ifError(err, 'no unexpected server error');
|
68 | var obj = msg.messages[0].payload;
|
69 |
|
70 | assert.notEqual(obj.msg.indexOf('some message'), -1);
|
71 | assert.notEqual(
|
72 | obj.fields.someKey.stack.indexOf('Error: some error'), -1);
|
73 | assert.equal(obj.fields.someKey.message, 'some error');
|
74 | assert.equal(obj.fields.other, 'key');
|
75 |
|
76 | logger.destroy();
|
77 | assert.end();
|
78 | });
|
79 |
|
80 | logger.error('some message', {
|
81 | someKey: new Error('some error'),
|
82 | other: 'key'
|
83 | });
|
84 | });
|