logviewer/static/js/jquery.kismet.messagebus.js

   1 // Display the messagebus message system from Kismet
   2 //
   3 // dragorn@kismetwireless.net
   4 // MIT/GPL License (pick one); the web ui code is licensed more
   5 // freely than GPL to reflect the generally MIT-licensed nature
   6 // of the web/jquery environment
   7
   8 // Options:
   9 // use_color (bool) (true) - Colorize messages
  10 // scroll (bool) (true) - Make scrollable
  11 // max_messages (int) (30) - Maximum messages to show
  12 // old_time (int) (30) - How long before a message is considered 'old'
  13 // class_debug (string) (messagebus_debug) - Display class applied to debug msgs
  14 // class_info (string) (messagebus_info) - Display class applied to info msgs
  15 // class_error (string) (messagebus_error) - Display class applied to error msgs
  16 // class_alert (string) (messagebus_alert) - Display class applied to alert msgs
  17 // class_fatal (string) (messagebus_fatal) - Display class applied to fatal msgs
  18 // class_old (string) (messagebus_old) - Display class applied to old msgs
  19 //
  20
  21 (function ($) {
  22     var local_uri_prefix = "";
  23     if (typeof(KISMET_URI_PREFIX) !== 'undefined')
  24         local_uri_prefix = KISMET_URI_PREFIX;
  25
  26     // Message flags
  27     var MSGFLAG_NONE = 0;
  28     var MSGFLAG_DEBUG = 1;
  29     var MSGFLAG_INFO = 2;
  30     var MSGFLAG_ERROR = 4;
  31     var MSGFLAG_ALERT = 8;
  32     var MSGFLAG_FATAL = 16;
  33
  34     var base_options = {
  35         use_color: true,
  36         scroll: true,
  37         max_messages: 30,
  38         class_debug: "messagebus_debug",
  39         class_info: "messagebus_info",
  40         class_error: "messagebus_error",
  41         class_alert: "messagebus_alert",
  42         class_fatal: "messagebus_fatal",
  43         class_old: "messagebus_old",
  44     };
  45
  46     var merge_messages = function(state, messages) {
  47         var divs = $('div.messagebus_message', state['element']);
  48
  49         $.merge(messages, state['message_list']);
  50
  51         state['message_list'] = messages.slice(0, state['options'].max_messages);
  52
  53         for (var x = 0; x < state['message_list'].length; x++) {
  54             var d = divs.eq(x);
  55
  56             // Compute trimmed date
  57             var ds = (new Date(state['message_list'][x]['kismet.messagebus.message_time'] * 1000).toString()).substring(4, 25);
  58
  59             /*
  60             var pse = $('<p>').text(ds);
  61             var ce = $('<span>').html(kismet.sanitizeHTML(kismet.censorMAC(state['message_list'][x]['kismet.messagebus.message_string'])));
  62
  63             d.empty();
  64             d.append(pse);
  65             d.append(ce);
  66             */
  67
  68             d.html(`<p>${ds}</p> ${kismet.censorMAC(state['message_list'][x]['kismet.messagebus.message_string'])}`);
  69
  70             // Remove all flagged clases
  71             d.removeClass("messagebus_debug");
  72             d.removeClass("messagebus_info");
  73             d.removeClass("messagebus_error");
  74             d.removeClass("messagebus_alert");
  75             d.removeClass("messagebus_fatal");
  76
  77             var f = state['message_list'][x]['kismet.messagebus.message_flags'];
  78
  79             if (f & MSGFLAG_FATAL) {
  80                 d.addClass("messagebus_fatal");
  81             } else if (f & MSGFLAG_ALERT) {
  82                 d.addClass("messagebus_alert");
  83             } else if (f & MSGFLAG_ERROR) {
  84                 d.addClass("messagebus_error");
  85             } else if (f & MSGFLAG_INFO) {
  86                 d.addClass("messagebus_info");
  87             } else if (f & MSGFLAG_DEBUG) {
  88                 d.addClass("messagebus_debug");
  89             }
  90         }
  91     }
  92
  93     var messagebus_refresh = function(state) {
  94         $.get(local_uri_prefix + "messagebus/last-time/" +
  95             state['last_msg_time'] + "/messages.json")
  96             .done(function(data) {
  97                 data['kismet.messagebus.list'].reverse();
  98
  99                 merge_messages(state, kismet.sanitizeObject(data['kismet.messagebus.list']));
 100             })
 101     }
 102
 103     $.fn.messagebus = function(inopt) {
 104         var state = {
 105             element: $(this),
 106             options: base_options,
 107             last_msg_time: 0,
 108             message_list: [],
 109             timerid: -1,
 110         };
 111
 112         state['element'].empty();
 113
 114         state['element'].addClass('messagebus');
 115
 116         state['options'] = $.extend(base_options, inopt);
 117
 118         // Fill the div with placeholders for as many messages as we need
 119         var ndiv = $('div.messagebus_message', state['element']).length;
 120
 121         if (ndiv < state['options'].max_messages) {
 122             for (var x = ndiv; x < state['options'].max_messages; x++) {
 123                 var d = $('<div>', { class: "messagebus_message" });
 124                 state['element'].append(d);
 125             }
 126         } else if (ndiv > state['options'].max_messages) {
 127             var nremoved = 0;
 128             $('div.messagebus_message', state['element']).each(function() {
 129                 if (ndiv - nremoved <= state['options'].max_messages) {
 130                     return;
 131                 }
 132
 133                 $(this).remove();
 134                 nremoved++;
 135             });
 136         }
 137
 138         messagebus_refresh(state);
 139
 140         kismet_ui_base.SubscribeEventbus("MESSAGE", [], function(data) {
 141             data = kismet.sanitizeObject(data);
 142             merge_messages(state, [data]);
 143         });
 144
 145     };
 146
 147 }(jQuery));