Messages counter

Adhidarma Hadiwinoto
1 parent 99f1f3d97a
Showing 2 changed files with 27 additions and 0 deletions Side-by-side Diff
lib/counters.js
lib/modem.js
@@ -0,0 +1,24 @@
+'use strict';
+
+const countersSdk = require('komodo-sdk/counters');
+
+function increment(name, modemInfo) {
+    if (!name || !modemInfo.imsi) return;
+
+    countersSdk.increment(`IMSI_${modemInfo.IMSI}_${name}`);
+}
+
+function get(name, modemInfo) {
+    return new Promise(async (resolve) => {
+        if (!name || !modemInfo.imsi) {
+            resolve(0);
+            return;
+        }
+
+        const value = await countersSdk.get(`IMSI_${modemInfo.IMSI}_${name}`);
+        resolve(Number(value));
+    });
+}
+
+exports.get = get;
+exports.increment = increment;
@@ -21,6 +21,7 @@ const dbCops = require(&#39;./db-cops&#39;);
 const reportSender = require('./report-sender');
 // const msisdn = require('./msisdn');
 const registerModem = require('./register-modem');
+const counters = require('./counters');
  
 const modemInfo = {
     device: config.modem.device,
@@ -145,6 +146,7 @@ parserReadLine.on(&#39;data&#39;, (data) =&gt; {
                 registerModem(modemInfo);
             }
         } else if (data.indexOf('+CMTI: ') === 0) {
+            counters.increment('MESSAGE_RECEIVED', modemInfo);
             onIncomingSMS(data);
         } else if (data.indexOf('+COPS: ') === 0) {
             onCOPS(data);
@@ -288,6 +290,7 @@ async function sendSMS(destination, msg) {
     await mutex.setLockWaitForCommand();
  
     logger.info('Sending message', { destination, msg });
+    counters.increment('MESSAGE_SENT', modemInfo);
  
     const correctedDestination = `+${destination}`.replace(/^0/, '62').replace(/^\++/, '+');
...	...	@@ -0,0 +1,24 @@
	1	+'use strict';
	2	+
	3	+const countersSdk = require('komodo-sdk/counters');
	4	+
	5	+function increment(name, modemInfo) {
	6	+ if (!name \|\| !modemInfo.imsi) return;
	7	+
	8	+ countersSdk.increment(`IMSI_${modemInfo.IMSI}_${name}`);
	9	+}
	10	+
	11	+function get(name, modemInfo) {
	12	+ return new Promise(async (resolve) => {
	13	+ if (!name \|\| !modemInfo.imsi) {
	14	+ resolve(0);
	15	+ return;
	16	+ }
	17	+
	18	+ const value = await countersSdk.get(`IMSI_${modemInfo.IMSI}_${name}`);
	19	+ resolve(Number(value));
	20	+ });
	21	+}
	22	+
	23	+exports.get = get;
	24	+exports.increment = increment;
...	...	@@ -21,6 +21,7 @@ const dbCops = require('./db-cops');
21	21	const reportSender = require('./report-sender');
22	22	// const msisdn = require('./msisdn');
23	23	const registerModem = require('./register-modem');
	24	+const counters = require('./counters');
24	25
25	26	const modemInfo = {
26	27	device: config.modem.device,
...	...	@@ -145,6 +146,7 @@ parserReadLine.on('data', (data) => {
145	146	registerModem(modemInfo);
146	147	}
147	148	} else if (data.indexOf('+CMTI: ') === 0) {
	149	+ counters.increment('MESSAGE_RECEIVED', modemInfo);
148	150	onIncomingSMS(data);
149	151	} else if (data.indexOf('+COPS: ') === 0) {
150	152	onCOPS(data);
...	...	@@ -288,6 +290,7 @@ async function sendSMS(destination, msg) {
288	290	await mutex.setLockWaitForCommand();
289	291
290	292	logger.info('Sending message', { destination, msg });
	293	+ counters.increment('MESSAGE_SENT', modemInfo);
291	294
292	295	const correctedDestination = `+${destination}`.replace(/^0/, '62').replace(/^\++/, '+');
293	296