node_helper.js

/*
This code was originally written by JC21 https://github.com/jc21/MMM-IFTTT and modified by P J Tewkesbury
*/

'use strict';

const _ = require('lodash');
const NodeHelper = require('node_helper');
const bodyParser = require('body-parser');
const moment = require('moment');
const Mustache = require('mustache');
var url = require('url');
const { findLastKey } = require('lodash');

module.exports = NodeHelper.create({
    /**
     * node_helper start method
     */
    start: function () {
        this.log('Starting node_helper');

        // Create endpoint for Webhook notifications
        this.expressApp.use(bodyParser.json());
        this.expressApp.use(bodyParser.urlencoded({ extended: true }));

        //https://docs.microsoft.com/en-us/azure/devops/service-hooks/events?view=azure-devops#work-item
        this.expressApp.post('/webhook', (req, res) => {

            // Process request.
            this.log('Incoming webhook notification : ' + JSON.stringify(req.body), true);
            this.log(JSON.stringify(this.config));

            // Get query string from request
            var url_parts = url.parse(req.url, true);
            var query = url_parts.query;

            // Get templateName from Query String
            var templateName = "";
            if (query) {
                if (query.templateName) {
                    templateName = query.templateName;
                }
            }
            console.log("Template List : ", this.config.templates);

            // Find TemplateName in MagicMirror Config
            var t = this.config.templates.find(function (e) {
                return (templateName.toLocaleLowerCase() == e.templateName.toLocaleLowerCase());
            });

            console.log("Template Found  : ", t);

            // If we have template then render and display
            if (t) {
                var template = t.template;
                try {
                    var output = Mustache.render(t.template, req.body);

                    var firstLineOnly = false;
                    if (t.onlyShowFirstLine === true)
                        firstLineOnly = true;
                    if (firstLineOnly == true)
                        output = this.FirstLineOnly(output);

                    var title = "WebHook";
                    if (t.title != undefined)
                        title = Mustache.render(t.title, req.body);

                    if (t.sound === undefined && this.config.sound !== undefined)
                        t.sound = this.config.sound;
                    if (t.displaySeconds === undefined && this.config.displaySeconds !== undefined)
                        t.displaySeconds = this.config.displaySeconds;
                    if (t.fadeSpeed === undefined && this.config.fadeSpeed !== undefined)
                        t.fadeSpeed = this.config.fadeSpeed;
                    if (t.size === undefined && this.config.size !== undefined)
                        t.size = this.config.size;

                    var msg = {
                        message: output,
                        sound: t.sound,
                        displaySeconds: t.displaySeconds,
                        fadeSpeed: t.fadeSpeed,
                        size: t.size,
                        title: title,
                    }

                    this.log('Incoming webhook notification ' + JSON.stringify(msg));
                    this.sendSocketNotification('WEBHOOKALERTS_NOTIFICATION', msg);

                    // return OK to caller
                    res.status(200)
                        .send({
                            status: 200
                        });
                }
                catch (err) {
                    // Return errors to caller
                    let final_error = new Error(err);
                    res.status(400)
                        .send({
                            status: 400,
                            error: err.message
                        });
                }
            }
            else {
                this.log('Incoming webhook notification Failed - Template not specifed or found in config');
                // Return error to caller
                res.status(400)
                    .send({
                        status: 400,
                        error: "templateName not specified in query string or specified templateName in query string not defined in MagicMirror config"
                    });
            }
        });
    },

    /**
     *
     * @param {String} notification
     * @param {*}      payload
     */
    socketNotificationReceived: function (notification, payload) {
        this.log("Socket Notification recevied : " + notification);
        if (notification === 'START') {
            // Load config into this module
            this.config = payload;
            this.log("Config at start " + this.config);
        }
    },

    /**
     * Outputs log messages
     *
     * @param {String}  message
     * @param {Boolean} [debug_only]
     */
    log: function (message) {
        console.log('[' + moment().format('YYYY-MM-DD HH:mm:ss') + '] [MMM-WebHookAlert] ' + message);
    }
    , FirstLineOnly: function (text) {
        return text.split('/r/n')[0];
    }
});