Read file

Adhidarma Hadiwinoto
1 parent 4dce19e6b0
Showing 1 changed file with 9 additions and 2 deletions Side-by-side Diff
lib/smstools-handler/received.js
-// const winston = require('winston');
+const fs = require('fs');
 const logger = require('komodo-sdk/logger');
  
 const config = require('komodo-sdk/config');
@@ -7,7 +7,14 @@ const messagingClient = require(&#39;komodo-center-messaging-client-lib&#39;);
 const mailparser = require('../mailparser-wrapper');
  
  
-module.exports = async (msg) => {
+module.exports = async (msgFilename) => {
+    const msg = await fs.promises.readFile(msgFilename);
+
+    if (!msg) {
+        logger.warn('Can not read message file', { msgFile: msgFilename });
+        return;
+    }
+
     const parsedMsg = await mailparser(msg);
  
     if (!parsedMsg || !parsedMsg.headers) {
1		-// const winston = require('winston');
	1	+const fs = require('fs');
2	2	const logger = require('komodo-sdk/logger');
3	3
4	4	const config = require('komodo-sdk/config');
...	...	@@ -7,7 +7,14 @@ const messagingClient = require('komodo-center-messaging-client-lib');
7	7	const mailparser = require('../mailparser-wrapper');
8	8
9	9
10		-module.exports = async (msg) => {
	10	+module.exports = async (msgFilename) => {
	11	+ const msg = await fs.promises.readFile(msgFilename);
	12	+
	13	+ if (!msg) {
	14	+ logger.warn('Can not read message file', { msgFile: msgFilename });
	15	+ return;
	16	+ }
	17	+
11	18	const parsedMsg = await mailparser(msg);
12	19
13	20	if (!parsedMsg \|\| !parsedMsg.headers) {