@(Watch messages that include any of the following strings)
+
+
+
@(Tag people if message includes something)
+
+
+
`;
+
+exports.readme = `# Slack Filter`;
+
+exports.install = function(instance) {
+ var running = false;
+ instance["savedSlackMessages"] = [];
+ var timer = null;
+
+ instance.on('data', function(response) {
+ if (!running) return;
+ let value = response.data;
+ if (typeof value !== 'object') return;
+
+ let can = false
+ var k = Object.keys(value);
+ var interested = JSON.parse(instance.options.types);
+ var msg_incl = JSON.parse(instance.options.message_includes);
+ var tags = JSON.parse(instance.options.tag_on_include);
+
+ if (k.length <= 0) return;
+ if (value[k[0]].length <= 0) return;
+ if (!Object.prototype.hasOwnProperty.call(value[k[0]][0], 'values')) return;
+ if (!Object.prototype.hasOwnProperty.call(value[k[0]][0]['values'], '_event')) return;
+ if (!Object.prototype.hasOwnProperty.call(value[k[0]][0]['values']['_event'], 'type')) return;
+ if (!Object.prototype.hasOwnProperty.call(value[k[0]][0]['values']['_event'], 'source')) return;
+ if (!Object.prototype.hasOwnProperty.call(value[k[0]][0]['values']['_event']['source'], 'func')) return;
+ if (!Object.prototype.hasOwnProperty.call(value[k[0]][0]['values']['_event'], 'message')) return;
+ if (!Object.prototype.hasOwnProperty.call(value[k[0]][0]['values']['_event'], 'message_data')) return;
+
+ let icon = ':totaljs:';
+ let type = value[k[0]][0]['values']['_event']['type'];
+ let source = value[k[0]][0]['values']['_event']['source']['func'];
+ let message = value[k[0]][0]['values']['_event']['message'];
+ let message_data = value[k[0]][0]['values']['_event']['message_data'];
+ let tag = '';
+
+ switch(type){
+ case 'debug':
+ icon = ':beetle:';
+ break;
+ case 'info':
+ icon = ':speech_balloon:';
+ break;
+ case 'notice':
+ icon = ':speech_balloon:';
+ break;
+ case 'warning':
+ icon = ':exclamation:';
+ break;
+ case 'alert':
+ icon = ':warning:';
+ break;
+ case 'error':
+ icon = ':no_entry:';
+ break;
+ case 'emergency':
+ icon = ':fire:';
+ break;
+ case 'critical':
+ icon = ':fire:';
+ break;
+ }
+
+ // Check if this message includes one of the strings we are watching for
+ for (const msg of msg_incl){
+ if (message.includes(msg)){
+ if (msg == 'is responding again') icon = ':large_green_circle:';
+ can = true;
+ break;
+ }
+ }
+ // Check if message is one of the types we are watching for
+ if (interested.includes(type)){
+ can = true;
+ }
+
+ if (!can) return;
+
+
+ // Check for each person tags based on what the message includes
+ for (const person of tags){
+ for (const msg of person.includes){
+ if (message.includes(msg)){
+ tag += '<@'+person.user_id+'> ';
+ break; // Break out from this person checks as they are already tagged now
+ }
+ }
+ }
+ // Now that all people are tagged add new line symbol
+ if (tag != '') tag += '\n';
+
+ let send_data = tag+instance.options.name+' '+type.toUpperCase()+'\n*Source*: '+source+'\n*Message*: '+message;
+ if (message_data) {
+ send_data += '\nData: '+message_data;
+ }
+
+ let ignore_msg = false
+ if (message.includes('Configuration of dimming profile to node no')){
+ for (let i = 0; i < FLOW["savedSlackMessages"].length; i++){
+ if (FLOW["savedSlackMessages"][i].message == message){
+ ignore_msg = true;
+ break;
+ }
+ }
+ if (!ignore_msg){
+ FLOW["savedSlackMessages"].push({message, 'dateandtime': Date.now()});
+ if (timer === null){
+ timer = setTimeout(checkSavedMessages, 60*60000);
+ }
+ }
+ }
+
+ if (!ignore_msg){
+ instance.send2({'msg':send_data,'bot_name':instance.options.name+' '+type.toUpperCase(),'bot_icon':icon,'channel':instance.options.slack_channel});
+ }
+ });
+
+ function checkSavedMessages(){
+ var d = Date.now();
+ d = d - 86400000; // older then 24hr
+ var a = [];
+ //Remove msgs older then 24hr
+ for (let i = 0; i < FLOW["savedSlackMessages"].length; i++){
+ if (FLOW["savedSlackMessages"][i].dateandtime > d){
+ a.push(FLOW["savedSlackMessages"][i]);
+ }
+ }
+ FLOW["savedSlackMessages"] = a;
+
+ if (FLOW["savedSlackMessages"].length > 0) {
+ timer = setTimeout(checkSavedMessages, 60*60000);
+ } else {
+ timer = null;
+ }
+ }
+
+ instance.reconfigure = function() {
+ try {
+ if (!FLOW["savedSlackMessages"]){
+ FLOW["savedSlackMessages"] = [];
+ }
+
+ if (instance.options.name) {
+ instance.status('Running');
+ running = true;
+ } else {
+ instance.status('Please enter name', 'red');
+ running = false;
+ }
+ } catch (e) {
+ instance.error('Citysys connector: ' + e.message);
+ }
+ };
+
+ instance.on('options', instance.reconfigure);
+ instance.reconfigure();
+};
\ No newline at end of file