Commit 3b649ecc2b4bb5ef774a2e1ddb6d0aae1afbd0ae
1 parent
d163069725
Exists in
master
More log
Showing 1 changed file with 1 additions and 0 deletions Inline Diff
lib/smstools-handler/failed.js
1 | const fs = require('fs'); | 1 | const fs = require('fs'); |
2 | const logger = require('komodo-sdk/logger'); | 2 | const logger = require('komodo-sdk/logger'); |
3 | const mailparser = require('../mailparser-wrapper'); | 3 | const mailparser = require('../mailparser-wrapper'); |
4 | 4 | ||
5 | const eventType = 'FAILED'; | 5 | const eventType = 'FAILED'; |
6 | 6 | ||
7 | module.exports = async (msgFilename) => { | 7 | module.exports = async (msgFilename) => { |
8 | const msg = await fs.promises.readFile(msgFilename); | 8 | const msg = await fs.promises.readFile(msgFilename); |
9 | 9 | ||
10 | if (!msg) { | 10 | if (!msg) { |
11 | logger.warn('Sent failed detected but we can not read message file', { eventType, msgFile: msgFilename }); | 11 | logger.warn('Sent failed detected but we can not read message file', { eventType, msgFile: msgFilename }); |
12 | return; | 12 | return; |
13 | } | 13 | } |
14 | 14 | ||
15 | const parsedMsg = await mailparser(msg); | 15 | const parsedMsg = await mailparser(msg); |
16 | if (!parsedMsg || !parsedMsg.headers) { | 16 | if (!parsedMsg || !parsedMsg.headers) { |
17 | logger.warn('Sent failed detected and we can not parsed message file', { | 17 | logger.warn('Sent failed detected and we can not parsed message file', { |
18 | eventType, | 18 | eventType, |
19 | msgFile: msgFilename, | 19 | msgFile: msgFilename, |
20 | msgFileContent: (msg || '').toString(), | 20 | msgFileContent: (msg || '').toString(), |
21 | }); | 21 | }); |
22 | return; | 22 | return; |
23 | } | 23 | } |
24 | 24 | ||
25 | const to = parsedMsg.headers.get('to').text; | 25 | const to = parsedMsg.headers.get('to').text; |
26 | const modem = parsedMsg.headers.get('modem'); | 26 | const modem = parsedMsg.headers.get('modem'); |
27 | const imsi = parsedMsg.headers.get('imsi'); | 27 | const imsi = parsedMsg.headers.get('imsi'); |
28 | const imei = parsedMsg.headers.get('imei'); | 28 | const imei = parsedMsg.headers.get('imei'); |
29 | const failReason = parsedMsg.headers.get('fail_reason'); | 29 | const failReason = parsedMsg.headers.get('fail_reason'); |
30 | const failed = parsedMsg.headers.get('failed'); | 30 | const failed = parsedMsg.headers.get('failed'); |
31 | const { text } = parsedMsg; | 31 | const { text } = parsedMsg; |
32 | 32 | ||
33 | logger.verbose('Sent failed detected', { | 33 | logger.verbose('Sent failed detected', { |
34 | eventType, | 34 | eventType, |
35 | msgFile: msgFilename, | ||
35 | to, | 36 | to, |
36 | modem, | 37 | modem, |
37 | imsi, | 38 | imsi, |
38 | imei, | 39 | imei, |
39 | failReason, | 40 | failReason, |
40 | failed, | 41 | failed, |
41 | text, | 42 | text, |
42 | }); | 43 | }); |
43 | }; | 44 | }; |
44 | 45 |