Splunkbot/irclog.js at master · coccyx/Splunkbot · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
var util = require('util');

/*
** Takes any integer and returns a string of at least length digits
** If the integer is less than length, it pads the left side with zeros
*/
function pad(number, length) {
    var str = number.toString();
    while (str.length < length) {
        str = '0' + str;
    }
    return str;
}

/*
** Takes any string and returns a string of at least length characters
** If the string is less than length, it pads the left side with spaces
*/
function strpad(str, length) {
    var strout = str;
    while (strout.length < length) {
        strout = ' ' + strout;
    }
    return strout;
}

/*
** Takes any date Javascript can parse and outputs Mon DD YYYY
*/
function makedate(datestr) {
    var monthtext = [ "Jan", "Feb", "Mar", "Apr", "May", "Jun", "Jul", "Aug", "Sep", "Oct", "Nov", "Dec" ]
      , dtm = new Date(datestr);
    return monthtext[dtm.getMonth()]+" "+pad(dtm.getDate(), 2)+" "+dtm.getFullYear();
}

/*
** Takes any date Javascript can parse and outputs HH:MM:SS
*/
function maketime(datestr) {
    var dtm = new Date(datestr);
    return pad(dtm.getHours(), 2)+':'+pad(dtm.getMinutes(), 2)+':'+pad(dtm.getSeconds(), 2);
}

/*
** Utility function for makeirclog that takes a row of splunksearch results and outputs an IRC Log format
*/

function makeircline(row, fields) {
    var dispatch = { };
    dispatch.join = function(result, fields) {
                            return util.format("%s -!- %s has joined %s\n", maketime(row[fields.indexOf('_time')]),
                                                row[fields.indexOf('nick')], row[fields.indexOf('channel')]);
                        };
    dispatch.part = function(result, fields) {
                            if (row[fields.indexOf('reason')] === 'undefined' ||
                                row[fields.indexOf('reason')] === 'null') {
                                return util.format("%s -!- %s has left %s\n", maketime(row[fields.indexOf('_time')]),
                                                    row[fields.indexOf('nick')], row[fields.indexOf('channel')]);
                            }
                        };
    dispatch.quit = function(result, fields) {
                            return util.format("%s -!- %s has quit IRC (%s)\n", maketime(row[fields.indexOf('_time')]),
                                                row[fields.indexOf('nick')], row[fields.indexOf('reason')]);
                        };
    dispatch.topic = function(result, fields) {
                            return util.format("%s -!- %s changed the topic of %s to: %s\n", maketime(row[fields.indexOf('_time')]),
                                                row[fields.indexOf('nick')], row[fields.indexOf('channel')],
                                                row[fields.indexOf('topic')]);
                        };
    dispatch.nick = function(result, fields) {
                            return util.format("%s -!- %s is now known as %s\n", maketime(row[fields.indexOf('_time')]),
                                                strpad(row[fields.indexOf('oldnick')],9), row[fields.indexOf('newnick')]);
                        };
    dispatch.message = function(result, fields) {
                            // Make sure we have a string
                            row[fields.indexOf('text')] = row[fields.indexOf('text')] === null ? "" : row[fields.indexOf('text')];

                            if (row[fields.indexOf('text')].substr(0, 10) === '\\x01ACTION') {
                                var metext = row[fields.indexOf('text')].substring(10, row[fields.indexOf('text')].length-4);
                                return util.format("%s * %s %s\n", maketime(row[fields.indexOf('_time')]),
                                                    strpad(row[fields.indexOf('nick')],9), metext);
                            } else if (row[fields.indexOf('text')].substr(0, 4) === '\\x01') {
                                return util.format("%s -%s- CTCP %s\n", maketime(row[fields.indexOf('_time')]),
                                                    strpad(row[fields.indexOf('nick')],9), row[fields.indexOf('text')].substr(4, row[fields.indexOf('text')].length-8));
                            } else {
                                return util.format("%s <%s> %s\n", maketime(row[fields.indexOf('_time')]),
                                                    strpad(row[fields.indexOf('nick')],9), row[fields.indexOf('text')]);
                            }
                        };
    dispatch.notice = function(result, fields) {
                            return util.format("%s -%s- %s\n", maketime(row[fields.indexOf('_time')]),
                                                strpad(row[fields.indexOf('nick')],9), row[fields.indexOf('text')]);
                        };
    if (typeof dispatch[row[fields.indexOf('action')]] === 'function') {
        return dispatch[row[fields.indexOf('action')]](row, fields);
    } else {
        return "";
    }
}


/*
** Takes search results object from splunksearch and outputs in an IRC Log format
*/

function makeirclog(results) {
    var retstr = ''
      , lastdate = '';
    if (results.rows.length > 0) {
        lastdate = makedate(results.rows[0][results.fields.indexOf('_time')]);
        for (var i=0; i < results.rows.length; i++) {
            var row = results.rows[i]
              , fields = results.fields
              , date = makedate(row[fields.indexOf('_time')]);
            if (date != lastdate) {
                retstr += 'Day changed to '+date+'\n';
            }
            retstr += makeircline(results.rows[i], results.fields);
            lastdate = date;
        }
    }
    return retstr;
}

exports.makedate = makedate;
exports.maketime = maketime;
exports.makeirclog = makeirclog;