Commit d163069725baec41205a54cac6e2d7aef5dca6f9
1 parent
ee9a82c732
Exists in
master
SENT logger
Showing 1 changed file with 10 additions and 4 deletions Side-by-side Diff
lib/smstools-handler/sent.js
... | ... | @@ -4,23 +4,25 @@ const logger = require('komodo-sdk/logger'); |
4 | 4 | const config = require('komodo-sdk/config'); |
5 | 5 | const messagingClient = require('komodo-center-messaging-client-lib'); |
6 | 6 | const transport = require('../transport'); |
7 | +const mailparser = require('../mailparser-wrapper'); | |
7 | 8 | |
8 | 9 | messagingClient.setTransport(transport); |
9 | 10 | |
10 | -const mailparser = require('../mailparser-wrapper'); | |
11 | +const eventType = 'SENT'; | |
12 | + | |
11 | 13 | |
12 | 14 | module.exports = async (msgFilename) => { |
13 | 15 | const msg = await fs.promises.readFile(msgFilename); |
14 | 16 | |
15 | 17 | if (!msg) { |
16 | - logger.warn('Can not read message file', { msgFile: msgFilename }); | |
18 | + logger.warn('Can not read message file', { eventType, msgFile: msgFilename }); | |
17 | 19 | return; |
18 | 20 | } |
19 | 21 | |
20 | 22 | const parsedMsg = await mailparser(msg); |
21 | 23 | |
22 | 24 | if (!parsedMsg || !parsedMsg.headers) { |
23 | - logger.warn('Invalid message'); | |
25 | + logger.warn('Invalid message', { eventType, msgFile: msgFilename }); | |
24 | 26 | return; |
25 | 27 | } |
26 | 28 | |
... | ... | @@ -29,7 +31,11 @@ module.exports = async (msgFilename) => { |
29 | 31 | const { text } = parsedMsg; |
30 | 32 | |
31 | 33 | logger.info('Message parsed', { |
32 | - from: to, imsi, text, | |
34 | + eventType, | |
35 | + msgFile: msgFilename, | |
36 | + to, | |
37 | + imsi, | |
38 | + text, | |
33 | 39 | }); |
34 | 40 | |
35 | 41 | if (!to || !imsi || !text) { |