FAILED event handler

Adhidarma Hadiwinoto
1 parent 339180f105
Showing 2 changed files with 20 additions and 0 deletions Side-by-side Diff
bin/smstools-eventhandler.js
lib/smstools-handler/failed.js
@@ -10,6 +10,7 @@ const logger = require(&#39;komodo-sdk/logger&#39;);
  
 const handlerReceived = require('../lib/smstools-handler/received');
 const handlerSent = require('../lib/smstools-handler/sent');
+const handlerFailed = require('../lib/smstools-handler/failed');
  
 async function main() {
     const eventType = (argv._ && argv._[0]) || null;
@@ -23,6 +24,10 @@ async function main() {
         handlerReceived(msgFilename);
     } else if (eventType === 'SENT') {
         handlerSent(msgFilename);
+    } else if (eventType === 'FAILED') {
+        handlerFailed(msgFilename);
+    } else {
+        logger.verbose(`Ignoring event ${eventType}`, { eventType, msgFilename });
     }
 }
  
@@ -0,0 +1,15 @@
+const fs = require('fs');
+const logger = require('komodo-sdk/logger');
+
+const eventType = 'FAILED';
+
+module.exports = async (msgFilename) => {
+    const msg = await fs.promises.readFile(msgFilename);
+
+    if (!msg) {
+        logger.warn('Sent failed detected but we can not read message file', { eventType, msgFile: msgFilename });
+        return;
+    }
+
+    logger.warn('Sent failed detected', { eventType, msg });
+};
...	...	@@ -10,6 +10,7 @@ const logger = require('komodo-sdk/logger');
10	10
11	11	const handlerReceived = require('../lib/smstools-handler/received');
12	12	const handlerSent = require('../lib/smstools-handler/sent');
	13	+const handlerFailed = require('../lib/smstools-handler/failed');
13	14
14	15	async function main() {
15	16	const eventType = (argv._ && argv._[0]) \|\| null;
...	...	@@ -23,6 +24,10 @@ async function main() {
23	24	handlerReceived(msgFilename);
24	25	} else if (eventType === 'SENT') {
25	26	handlerSent(msgFilename);
	27	+ } else if (eventType === 'FAILED') {
	28	+ handlerFailed(msgFilename);
	29	+ } else {
	30	+ logger.verbose(`Ignoring event ${eventType}`, { eventType, msgFilename });
26	31	}
27	32	}
28	33
...	...	@@ -0,0 +1,15 @@
	1	+const fs = require('fs');
	2	+const logger = require('komodo-sdk/logger');
	3	+
	4	+const eventType = 'FAILED';
	5	+
	6	+module.exports = async (msgFilename) => {
	7	+ const msg = await fs.promises.readFile(msgFilename);
	8	+
	9	+ if (!msg) {
	10	+ logger.warn('Sent failed detected but we can not read message file', { eventType, msgFile: msgFilename });
	11	+ return;
	12	+ }
	13	+
	14	+ logger.warn('Sent failed detected', { eventType, msg });
	15	+};