Pushes Data from a Firebase DB ref to Slack

logExceptionToSlack.js

'use strict';

const functions = require('firebase-functions');
const admin = require('firebase-admin');
const IncomingWebhook = require('@slack/client').IncomingWebhook;
const url = 'https://hooks.slack.com/services/${SLACK_API}';
const functions = require('firebase-functions');

/**
 * Pushes from firebase ref /exception to slack chanel
 */
exports.pushExceptionToSlack = functions.database.ref('/exception/{exceptionId}').onWrite(event => {
    if (event.data.exists()) {
        let webhook = new IncomingWebhook(url);
        let message =
            `ERROR - ${event.timestamp} - ${event.params.exceptionId} 
              \n ${event.resource} 
              \n ${JSON.stringify(event.data.val())}`;

        webhook.send(message, function (err, res) {
            if (err) {
                console.log('Error:', err);
            } else {
                console.log('Message sent: ', res);
                event.data.ref.remove(); // delete ref after being successfully posted to slack
            }
        });
    }
});