Hubot Github PR script with Slack thread support

github-pr-slack-threads-bot.js

"use strict";

const url = require("url");
const querystring = require("querystring");

module.exports = function (robot) {
    robot.router.post("/hubot/gh-pull-requests", function (req, res) {
        let query = querystring.parse(url.parse(req.url).query)
        let room = query.room || "botvy-test";

        try {
            let payload = req.body;
            let message = handlePullRequest(payload);

            if (message) {
                let brainKey = getBrainKey(payload);

                let parentTs = robot.brain.get(brainKey);
                if (robot.brain.get(brainKey)) {
                    message.thread_ts = parentTs;
                }

                if (message) {
                    robot.messageRoom(room, message)[0].then(data => {
                        if (!parentTs) {
                            robot.brain.set(brainKey, data.ts);
                        }
                    });
                }
            }
        } catch (error) {
            robot.messageRoom("botvy-test", "Whoa, I got an error: " + error)
            console.log("github pull request notifier error: " + error + ". Request: " + req.body)
        }

        res.end("");
    });
};

function getBrainKey(data) {
    if (data.pull_request) {
        return "github-" + data.pull_request.html_url;
    }

    if (data.issue) {
        return "github-" + data.issue.html_url;
    }
}

function handlePullRequest(data) {
    // Open
    if (data.action === "opened" && data.pull_request) {
        let number = data.pull_request.number;
        let url = data.pull_request.html_url;
        let title = data.pull_request.title;

        return {
            attachments: [
                {
                    "fallback": `PR #${number}: ${title} - ${url}`,
                    "title": `PR #${number}: ${title}`,
                    "title_link": url,
                    "author_name": data.pull_request.user.login,
                    "author_link": data.pull_request.user.url,
                    "author_icon": data.pull_request.user.avatar_url,
                    "text": data.pull_request.body,
                    "color": "#7CD197"
                }
            ]
        };
    }

    // Comment
    if (data.action === "created" && data.comment && data.issue) {
        let number = data.issue.number;
        let url = data.comment.html_url;

        return {
            attachments: [
                {
                    "fallback": `PR #${number}: ${data.comment.user.login}: data.comment.body`,
                    "title_link": url,
                    "author_name": data.comment.user.login,
                    "author_link": data.comment.user.url,
                    "author_icon": data.comment.user.avatar_url,
                    "text": data.comment.body
                }
            ]
        };
    }

    // Close, Merge, Reopen
    if (data.pull_request && ["closed", "reopened"].indexOf(data.action) > -1) {
        let number = data.pull_request.number;
        let url = data.pull_request.html_url;

        let action = data.action;
        if (action === "closed" && data.pull_request.merged) {
            action = "merged";
        }

         return {
            attachments: [
                {
                    "fallback": `PR #${number}: ${action}`,
                    "title": `${action.toUpperCase()}`,
                    "title_link": url,
                    "author_name": data.sender.login,
                    "author_link": data.sender.url,
                    "author_icon": data.sender.avatar_url,
                    "color": "#d011dd"
                }
            ]
        };
    }

    //console.log(data);
}