Komodo / komodo-modem-sms

Download as
Browse Code ยป

Commit 8617a6cbf0549bd020ea6e12926a5ffbc5a5455d

Authored by Adhidarma Hadiwinoto
1 parent 7f00b5aeb7
Exists in master

logger.info

Showing 1 changed file with 1 additions and 1 deletions Inline Diff

1 const SerialPort = require('serialport'); 1 const SerialPort = require('serialport');
2 2
3 const config = require('komodo-sdk/config'); 3 const config = require('komodo-sdk/config');
4 const logger = require('komodo-sdk/logger'); 4 const logger = require('komodo-sdk/logger');
5 5
6 6
7 const ParserInterByteTimeout = require('@serialport/parser-inter-byte-timeout'); 7 const ParserInterByteTimeout = require('@serialport/parser-inter-byte-timeout');
8 8
9 const parsers = require('./lib/serialport-parsers'); 9 const parsers = require('./lib/serialport-parsers');
10 const modemCommands = require('./lib/modem-commands'); 10 const modemCommands = require('./lib/modem-commands');
11 11
12 const parserInterByteTimeout = new ParserInterByteTimeout({ interval: 1000 }); 12 const parserInterByteTimeout = new ParserInterByteTimeout({ interval: 1000 });
13 parserInterByteTimeout.on('data', (data) => { 13 parserInterByteTimeout.on('data', (data) => {
14 logger.verbose('INCOMING', { parser: 'parserInterByteTimeout', data: data.toString() }); 14 logger.verbose('INCOMING', { parser: 'parserInterByteTimeout', data: data.toString() });
15 }); 15 });
16 16
17 let port; 17 let port;
18 18
19 function sleep(ms) { 19 function sleep(ms) {
20 return new Promise((resolve) => { 20 return new Promise((resolve) => {
21 setTimeout(() => { 21 setTimeout(() => {
22 resolve(); 22 resolve();
23 }, ms || 0); 23 }, ms || 0);
24 }); 24 });
25 } 25 }
26 26
27 function writeToPort(data) { 27 function writeToPort(data) {
28 return new Promise((resolve) => { 28 return new Promise((resolve) => {
29 port.write(data, (err, bytesWritten) => { 29 port.write(data, (err, bytesWritten) => {
30 if (err) logger.warn(`ERROR: ${err.toString()}`); 30 if (err) logger.warn(`ERROR: ${err.toString()}`);
31 31
32 logger.verbose('OUTGOING', { bytesWritten, data: data.toString() }); 32 logger.verbose('OUTGOING', { bytesWritten, data: data.toString() });
33 resolve(bytesWritten); 33 resolve(bytesWritten);
34 }); 34 });
35 }); 35 });
36 } 36 }
37 37
38 async function writeToPortDelayed(data, ms) { 38 async function writeToPortDelayed(data, ms) {
39 await sleep(ms || 500); 39 await sleep(ms || 500);
40 const result = writeToPort(data); 40 const result = writeToPort(data);
41 return result; 41 return result;
42 } 42 }
43 43
44 port = new SerialPort(config.modem.device, { baudRate: 115200 }, async (err) => { 44 port = new SerialPort(config.modem.device, { baudRate: 115200 }, async (err) => {
45 if (err) { 45 if (err) {
46 logger.warn(`Error opening modem. ${err}. Terminating modem ${config.modem.device}.`); 46 logger.warn(`Error opening modem. ${err}. Terminating modem ${config.modem.device}.`);
47 process.exit(1); 47 process.exit(1);
48 } 48 }
49 49
50 await writeToPortDelayed('AT\r'); 50 await writeToPortDelayed('AT\r');
51 51
52 const commands = [ 52 const commands = [
53 'AT&FE0\r', 53 'AT&FE0\r',
54 'AT+CIMI\r', 54 'AT+CIMI\r',
55 'AT+CMGF=0\r', 55 'AT+CMGF=0\r',
56 'AT+CNMI=1,2,0,1,0\r', 56 'AT+CNMI=1,2,0,1,0\r',
57 ]; 57 ];
58 58
59 const commandsCount = commands.length; 59 const commandsCount = commands.length;
60 // eslint-disable-next-line no-plusplus 60 // eslint-disable-next-line no-plusplus
61 for (let i = 0; i < commandsCount; i++) { 61 for (let i = 0; i < commandsCount; i++) {
62 // eslint-disable-next-line no-await-in-loop 62 // eslint-disable-next-line no-await-in-loop
63 await writeToPortDelayed(commands[i], 2000); 63 await writeToPortDelayed(commands[i], 2000);
64 } 64 }
65 65
66 if (config && config.modem_tester && config.modem_tester.commands 66 if (config && config.modem_tester && config.modem_tester.commands
67 && config.modem_tester.commands.length) { 67 && config.modem_tester.commands.length) {
68 const additionalCommandsLength = config.modem_tester.commands.length; 68 const additionalCommandsLength = config.modem_tester.commands.length;
69 // eslint-disable-next-line no-plusplus 69 // eslint-disable-next-line no-plusplus
70 for (let i = 0; i < additionalCommandsLength; i++) { 70 for (let i = 0; i < additionalCommandsLength; i++) {
71 // eslint-disable-next-line no-await-in-loop 71 // eslint-disable-next-line no-await-in-loop
72 await writeToPortDelayed(config.modem_tester.commands[i], 2000); 72 await writeToPortDelayed(config.modem_tester.commands[i], 2000);
73 } 73 }
74 } 74 }
75 75
76 const imei = await modemCommands.queryIMEI(); 76 const imei = await modemCommands.queryIMEI();
77 logger.verbose(`**** IMEI: ${imei}`); 77 logger.info(`**** IMEI: ${imei}`);
78 await modemCommands.queryCOPS(); 78 await modemCommands.queryCOPS();
79 await modemCommands.querySignalQuality(); 79 await modemCommands.querySignalQuality();
80 80
81 setInterval(() => { 81 setInterval(() => {
82 modemCommands.querySignalQuality(); 82 modemCommands.querySignalQuality();
83 }, 30000); 83 }, 30000);
84 }); 84 });
85 85
86 parsers.setPort(port); 86 parsers.setPort(port);
87 modemCommands.setPort(port); 87 modemCommands.setPort(port);
88 88
89 if (config && config.modem_tester && config.modem_tester.parser === 'regex') { 89 if (config && config.modem_tester && config.modem_tester.parser === 'regex') {
90 logger.info('Using parserWaitForOkOrError'); 90 logger.info('Using parserWaitForOkOrError');
91 port.pipe(parsers.parserWaitForOkOrError); 91 port.pipe(parsers.parserWaitForOkOrError);
92 } else if (config && config.modem_tester && config.modem_tester.parser === 'interbyte') { 92 } else if (config && config.modem_tester && config.modem_tester.parser === 'interbyte') {
93 logger.info('Using parserInterByteTimeout'); 93 logger.info('Using parserInterByteTimeout');
94 port.pipe(parserInterByteTimeout); 94 port.pipe(parserInterByteTimeout);
95 } else { 95 } else {
96 logger.info('Using parserReadline'); 96 logger.info('Using parserReadline');
97 port.pipe(parsers.parserReadline); 97 port.pipe(parsers.parserReadline);
98 } 98 }
99 99