Using the Yammer long polling API (https://developer.yammer.com/api/realtime.html)

yammer-comment-poll.js

var https = require('https');

// https://www.yammer.com/api/v1/messages.json
var options = {
    host: 'www.yammer.com',
    path: '/api/v1/messages.json?access_token=YOUR-OAUTH2-TOKEN',
    headers: { "Authorization": "Bearer YOUR-OAUTH2-TOKEN" }
}

var globalRequestId = 1;

var request = https.request(options, function(response) {
    console.log("*** Retrieving meta real-time information ***");
    data = "";
    response.on("data", function(chunk) {
    	if(response.statusCode == 200) {
    		if(chunk.toString().trim() != "") {
            	//var data = JSON.parse(chunk);
            	data += chunk;
        	}	
        }
    	else {
    		console.log("No data was processed because of status code " + response.statusCode);
    	}
    });

    response.on("end", function() {
        console.log("*** Performing handshake ***");
        // process the response from yammer
        var responseObj = JSON.parse(data);
        // look for the meta structure
        rtURI = responseObj.meta.realtime.uri;
        rtChannelId = responseObj.meta.realtime.channel_id;
        rtAuthToken = responseObj.meta.realtime.authentication_token;

        console.log("Real time URI = " + rtURI);
        console.log("Channel Id = " + rtChannelId);
        console.log("Authorizationt token = " + rtAuthToken);

        console.log("Connecting to real time API at " + rtURI + " with token " + rtAuthToken);

        // build the json data to be POSTed
        var handshakeRequestData = [];
        handshakeRequestData[0] = {
            "ext": { "token": rtAuthToken },
            "version": "1.0",
            "minimumVersion": "0.9",
            "channel": "/meta/handshake",
            "supportedConnectionTypes":["long-polling"],
            "id": globalRequestId
        }
        
        globalRequestId = globalRequestId + 1;

        var rtURIParts = require('url').parse(rtURI);
        var handshakeRequestOptions = {
            host: rtURIParts.host,
            path: rtURIParts.pathname,
            method: "POST",
            headers: {
                "Content-Type": "application/json"
            }
        }
        // and POST it
        var handshakeRequest = https.request(handshakeRequestOptions, function(res) {
            console.log('Handshake request response code: ' + res.statusCode);
            res.on('data', function (chunk) {

                console.log("*** Performing subscription ***");

                var data = JSON.parse(chunk);

                // extract the client id
                var clientId = data[0].clientId;
                console.log("We will use client id = " + clientId);

                // and subscribe
                var subscribeOptions = { 
                    host: rtURIParts.host, 
                    path: rtURIParts.pathname, 
                    method: "POST",
                    headers: { "Content-Type": "application/json" }
                };
                var subscribeData = [];
                subscribeData[0] = {
                    "channel": "/meta/subscribe",
                    "subscription": "/feeds/" + rtChannelId + "/primary",
                    "id": globalRequestId,
                    "clientId": clientId
                };
                globalRequestId = globalRequestId + 1;
                subscribeData[1] = {
                    "channel": "/meta/subscribe",
                    "subscription": "/feeds/" + rtChannelId + "/secondary",
                    "id": globalRequestId,
                    "clientId": clientId
                };               

                console.log("Subscription request data = " + JSON.stringify(subscribeData));
                
                var subscribeRequest = https.request(subscribeOptions, function(res) {
                    tmpData = ""; 
                    console.log("Subscription request response code: " + res.statusCode);
                    res.on("data", function(chunk) {
                        tmpData += chunk;
                    });
                    res.on("end", function() {
                        // handle the subscription response
                        var subscriptionResponse = JSON.parse(tmpData);
                        console.log("Subscription response: " + tmpData);

                        var doConnection = function() {
                            console.log("*** Performing connection ***");
                            var connectionOptions = {
                                host: rtURIParts.host, 
                                path: rtURIParts.pathname, 
                                method: "POST",
                                headers: { "Content-Type": "application/json" }                            
                            };
                            var connectionData = [];
                            connectionData[0] = {
                                "channel": "/meta/connect",
                                "connectionType": "long-polling",
                                "id": globalRequestId,
                                "clientId": clientId
                            };
                            globalRequestId = globalRequestId + 1;
                            var connectionRequest = https.request(connectionOptions, function(res) {
                                console.log("Waiting for data...");
                                data = "";
                                res.on("data", function(chunk) {
                                    data += chunk;
                                });

                                res.on("end", function() {
                                    console.log("The response was = " + data);
                                    var connectionResponse = JSON.parse(data);
                                    if(connectionResponse[0].advice) {
                                        // there was no message data, so we should wait
                                        console.log("No data received; waiting 10 seconds");                                        
                                    }
                                    else {
                                        // there was post data
                                        console.log("There were new messages!");
                                    }

                                    setTimeout(doConnection, 10*1000)
                                });
                            });
                            connectionRequest.write(JSON.stringify(connectionData));
                            connectionRequest.end();                            
                        }

                        // call ourselves
                        doConnection();
                    });
                });
                subscribeRequest.write(JSON.stringify(subscribeData));
                subscribeRequest.end();                
            });
        });

        handshakeRequest.on("error", function(e) {
            console.log("There was an error with the handshake request: " + e.message);
        });

        console.log(JSON.stringify(handshakeRequestData));

        handshakeRequest.write(JSON.stringify(handshakeRequestData));
        handshakeRequest.end();

    });
});
request.end();