node_helper.js

const Log = require("logger")
const NodeHelper = require("node_helper")
const express = require("express")
const { exec } = require("node:child_process")

module.exports = NodeHelper.create({
	start: function () {
		this.expressApp.use(express.json())
		this.expressApp.use(express.urlencoded({ extended: true }))

		this.expressApp.post("/webhook", (req, res) => {
			Log.log("[NOTTRG] reqpost?", req.body)
			this.sendSocketNotification("WEBHOOK", req.body)
			res.status(200).send({ status: 200 })
		})
		this.expressApp.get("/webhook", (req, res) => {
			Log.log("[NOTTRG] reqget?", req.query)
			this.sendSocketNotification("WEBHOOK", req.query)
			res.status(200).send({ status: 200 })
		})
	},

	socketNotificationReceived: function (noti, payload) {
		if (noti === "EXEC") {
			exec(payload.exec, (error, stdout, stderr) => {
				if (error) {
					Log.error(`[NOTTRG] exec error: ${error}`)
				}
				else {
					Log.log(`[NOTTRG] stdout: ${stdout}`)
					Log.log(`[NOTTRG] stderr: ${stderr}`)
				}
				this.sendSocketNotification("EXEC_RESULT", {
					trigger: payload.trigger,
					fire: payload.fire,
					error: error,
					stdout: stdout,
					stderr: stderr
				})
			})
		}
	}
})