<gh_stars>0
import json
import unittest

from alerta.app import alarm_model, create_app, db, plugins
from alerta.plugins import PluginBase


class Isa182TestCase(unittest.TestCase):

    def setUp(self):

        test_config = {
            'TESTING': True,
            'ALARM_MODEL': 'ISA_18_2',
            'AUTH_REQUIRED': False,
            'PLUGINS': ['remote_ip'],
            'ALERT_TIMEOUT': 120,
            'HISTORY_LIMIT': 5
        }
        self.app = create_app(test_config, environment='development')
        self.client = self.app.test_client()

        self.fault_alarm = {
            'severity': 'Critical',
            'origin': 'LIC_101',
            'value': 'ERROR',
            'resource': 'LIC_101',
            'event': 'FAILED_ALM',
            'group': 'PROCESS',
            'text': 'Shutdown/Interlocked',
            'type': 'FAULT',
            'environment': 'Production',
            'service': ['REACTORS'],
            'correlate': ['FAILED_ALM', 'HI_HI_ALM', 'HI_ALM', 'LO_ALM', 'LO_LO_ALM', 'ADVISE_ALM', 'RST_ALM']
        }

        self.critical_alarm = {
            'severity': 'Critical',
            'origin': 'PID1',
            'value': '19',
            'resource': 'LIC_101',
            'event': 'HI_HI_ALM',
            'group': 'PROCESS',
            'text': 'High High Alarm Limit 15',
            'type': 'ALARM',
            'environment': 'Production',
            'service': ['REACTORS'],
            'correlate': ['FAILED_ALM', 'HI_HI_ALM', 'HI_ALM', 'LO_ALM', 'LO_LO_ALM', 'ADVISE_ALM', 'RST_ALM']
        }

        self.high_alarm = {
            'severity': 'High',
            'origin': 'PID1',
            'value': '13',
            'resource': 'LIC_101',
            'event': 'HI_ALM',
            'group': 'PROCESS',
            'text': 'High Alarm Limit 10',
            'type': 'ALARM',
            'environment': 'Production',
            'service': ['REACTORS'],
            'correlate': ['FAILED_ALM', 'HI_HI_ALM', 'HI_ALM', 'LO_ALM', 'LO_LO_ALM', 'ADVISE_ALM', 'RST_ALM']
        }

        self.medium_alarm = {
            'severity': 'Medium',
            'origin': 'PID1',
            'value': '6',
            'resource': 'LIC_101',
            'event': 'LO_ALM',
            'group': 'PROCESS',
            'text': 'Low Alarm Limit 5',
            'type': 'ALARM',
            'environment': 'Production',
            'service': ['REACTORS'],
            'correlate': ['FAILED_ALM', 'HI_HI_ALM', 'HI_ALM', 'LO_ALM', 'LO_LO_ALM', 'ADVISE_ALM', 'RST_ALM']
        }

        self.low_alarm = {
            'severity': 'Low',
            'origin': 'PID1',
            'value': '1',
            'resource': 'LIC_101',
            'event': 'LO_LO_ALM',
            'group': 'PROCESS',
            'text': 'Low Low Alarm Limit 0',
            'type': 'ALARM',
            'environment': 'Production',
            'service': ['REACTORS'],
            'correlate': ['FAILED_ALM', 'HI_HI_ALM', 'HI_ALM', 'LO_ALM', 'LO_LO_ALM', 'ADVISE_ALM', 'RST_ALM']
        }

        self.advisory_alarm = {
            'severity': 'Advisory',
            'origin': 'PID1',
            'value': '1',
            'resource': 'LIC_101',
            'event': 'ADVISE_ALM',
            'group': 'PROCESS',
            'text': 'Low Low Alarm Limit 0',
            'type': 'ALARM',
            'environment': 'Production',
            'service': ['REACTORS'],
            'correlate': ['FAILED_ALM', 'HI_HI_ALM', 'HI_ALM', 'LO_ALM', 'LO_LO_ALM', 'ADVISE_ALM', 'RST_ALM']
        }

        self.ok_alarm = {
            'severity': 'OK',
            'origin': 'PID1',
            'value': '0',
            'resource': 'LIC_101',
            'event': 'RST_ALM',
            'group': 'PROCESS',
            'text': 'OK Alarm Limit 0',
            'type': 'ALARM',
            'environment': 'Production',
            'service': ['REACTORS'],
            'correlate': ['FAILED_ALM', 'HI_HI_ALM', 'HI_ALM', 'LO_ALM', 'LO_LO_ALM', 'ADVISE_ALM', 'RST_ALM']
        }

    def tearDown(self):
        plugins.plugins.clear()
        db.destroy()

    def test_ack_active_alarm(self):

        # Create OK alarm
        response = self.client.post('/alert', data=json.dumps(self.ok_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))

        alert_id = data['id']

        # Alarm Occurs, Normal (A) -> Unack (B)
        response = self.client.post('/alert', data=json.dumps(self.high_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'HI_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'High')
        self.assertEqual(data['alert']['status'], 'UNACK')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '13')
        self.assertEqual(data['alert']['text'], 'High Alarm Limit 10')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], alarm_model.DEFAULT_PREVIOUS_SEVERITY)
        self.assertEqual(data['alert']['trendIndication'], 'moreSevere')

        # Operator Ack, Unack (B) -> Ack (C)
        data = {
            'action': 'ack',
            'text': 'operator ack'
        }
        response = self.client.put('/alert/' + alert_id + '/action',
                                   data=json.dumps(data), content_type='application/json')
        self.assertEqual(response.status_code, 200)
        response = self.client.get('/alert/' + alert_id)
        self.assertEqual(response.status_code, 200)
        data = json.loads(response.data.decode('utf-8'))
        self.assertEqual(data['alert']['severity'], 'High')
        self.assertEqual(data['alert']['status'], 'ACKED')

        # Re-Alarm, Ack (C) -> Unack (B)
        response = self.client.post('/alert', data=json.dumps(self.critical_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'HI_HI_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'Critical')
        self.assertEqual(data['alert']['status'], 'UNACK')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '19')
        self.assertEqual(data['alert']['text'], 'High High Alarm Limit 15')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], 'High')
        self.assertEqual(data['alert']['trendIndication'], 'moreSevere')

        # Operator Ack (again), Unack (B) -> Ack (C)
        data = {
            'action': 'ack',
            'text': 'operator ack'
        }
        response = self.client.put('/alert/' + alert_id + '/action',
                                   data=json.dumps(data), content_type='application/json')
        self.assertEqual(response.status_code, 200)
        response = self.client.get('/alert/' + alert_id)
        self.assertEqual(response.status_code, 200)
        data = json.loads(response.data.decode('utf-8'))
        self.assertEqual(data['alert']['severity'], 'Critical')
        self.assertEqual(data['alert']['status'], 'ACKED')

        # Process RTN Alarm Clears, Ack (C) -> Normal (A)
        response = self.client.post('/alert', data=json.dumps(self.ok_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'RST_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'OK')
        self.assertEqual(data['alert']['status'], 'NORM')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '0')
        self.assertEqual(data['alert']['text'], 'OK Alarm Limit 0')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], 'Critical')
        self.assertEqual(data['alert']['trendIndication'], 'lessSevere')

    def test_rtn_before_ack(self):

        # Create OK alarm
        response = self.client.post('/alert', data=json.dumps(self.ok_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))

        alert_id = data['id']

        # Alarm Occurs, Normal (A) -> Unack (B)
        response = self.client.post('/alert', data=json.dumps(self.high_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'HI_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'High')
        self.assertEqual(data['alert']['status'], 'UNACK')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '13')
        self.assertEqual(data['alert']['text'], 'High Alarm Limit 10')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], alarm_model.DEFAULT_PREVIOUS_SEVERITY)
        self.assertEqual(data['alert']['trendIndication'], 'moreSevere')

        # Process RTN and Alarm Clears, Unack (B) -> RTN Unack (D)
        response = self.client.post('/alert', data=json.dumps(self.ok_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'RST_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'OK')
        self.assertEqual(data['alert']['status'], 'RTNUN')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '0')
        self.assertEqual(data['alert']['text'], 'OK Alarm Limit 0')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], 'High')
        self.assertEqual(data['alert']['trendIndication'], 'lessSevere')

        # Resend, Duplicate=1
        response = self.client.post('/alert', data=json.dumps(self.medium_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'LO_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'Medium')
        self.assertEqual(data['alert']['status'], 'UNACK')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '6')
        self.assertEqual(data['alert']['text'], 'Low Alarm Limit 5')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], 'OK')
        self.assertEqual(data['alert']['trendIndication'], 'moreSevere')

        # Resend, Duplicate=1
        response = self.client.post('/alert', data=json.dumps(self.medium_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'LO_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'Medium')
        self.assertEqual(data['alert']['status'], 'UNACK')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '6')
        self.assertEqual(data['alert']['text'], 'Low Alarm Limit 5')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 1)
        self.assertEqual(data['alert']['repeat'], True)
        self.assertEqual(data['alert']['previousSeverity'], 'OK')
        self.assertEqual(data['alert']['trendIndication'], 'moreSevere')

        # Process RTN and Alarm Clears, Unack (B) -> RTN Unack (D)
        response = self.client.post('/alert', data=json.dumps(self.ok_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'RST_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'OK')
        self.assertEqual(data['alert']['status'], 'RTNUN')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '0')
        self.assertEqual(data['alert']['text'], 'OK Alarm Limit 0')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], 'Medium')
        self.assertEqual(data['alert']['trendIndication'], 'lessSevere')

        # Operator Ack, RTN Unack (D) -> Normal (A)
        data = {
            'action': 'ack',
            'text': 'operator ack'
        }
        response = self.client.put('/alert/' + alert_id + '/action',
                                   data=json.dumps(data), content_type='application/json')
        self.assertEqual(response.status_code, 200)
        response = self.client.get('/alert/' + alert_id)
        self.assertEqual(response.status_code, 200)
        data = json.loads(response.data.decode('utf-8'))
        self.assertEqual(data['alert']['severity'], 'OK')
        self.assertEqual(data['alert']['status'], 'NORM')

    def test_operator_shelve(self):

        # Create OK alarm
        response = self.client.post('/alert', data=json.dumps(self.ok_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))

        alert_id = data['id']

        # Alarm Occurs, Normal (A) -> Unack (B)
        response = self.client.post('/alert', data=json.dumps(self.high_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'HI_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'High')
        self.assertEqual(data['alert']['status'], 'UNACK')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '13')
        self.assertEqual(data['alert']['text'], 'High Alarm Limit 10')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], alarm_model.DEFAULT_PREVIOUS_SEVERITY)
        self.assertEqual(data['alert']['trendIndication'], 'moreSevere')

        # Operator Ack (again), Unack (B) -> Ack (C)
        data = {
            'action': 'ack',
            'text': 'operator ack'
        }
        response = self.client.put('/alert/' + alert_id + '/action',
                                   data=json.dumps(data), content_type='application/json')
        self.assertEqual(response.status_code, 200)
        response = self.client.get('/alert/' + alert_id)
        self.assertEqual(response.status_code, 200)
        data = json.loads(response.data.decode('utf-8'))
        self.assertEqual(data['alert']['severity'], 'High')
        self.assertEqual(data['alert']['status'], 'ACKED')

        # Operator Shelve, Any (*) -> Shelve (E)
        data = {
            'action': 'shelve',
            'text': 'operator shelved'
        }
        response = self.client.put('/alert/' + alert_id + '/action',
                                   data=json.dumps(data), content_type='application/json')
        self.assertEqual(response.status_code, 200)
        response = self.client.get('/alert/' + alert_id)
        self.assertEqual(response.status_code, 200)
        data = json.loads(response.data.decode('utf-8'))
        self.assertEqual(data['alert']['severity'], 'High')
        self.assertEqual(data['alert']['status'], 'SHLVD')

        # Operator Unshelve, Shelve (E) -> Unack (B)
        data = {
            'action': 'unshelve',
            'text': 'operator unshelved'
        }
        response = self.client.put('/alert/' + alert_id + '/action',
                                   data=json.dumps(data), content_type='application/json')
        self.assertEqual(response.status_code, 200)
        response = self.client.get('/alert/' + alert_id)
        self.assertEqual(response.status_code, 200)
        data = json.loads(response.data.decode('utf-8'))
        self.assertEqual(data['alert']['severity'], 'High')
        self.assertEqual(data['alert']['status'], 'UNACK')

        # Operator Shelve, Any (*) -> Shelve (E)
        data = {
            'action': 'shelve',
            'text': 'operator shelved'
        }
        response = self.client.put('/alert/' + alert_id + '/action',
                                   data=json.dumps(data), content_type='application/json')
        self.assertEqual(response.status_code, 200)
        response = self.client.get('/alert/' + alert_id)
        self.assertEqual(response.status_code, 200)
        data = json.loads(response.data.decode('utf-8'))
        self.assertEqual(data['alert']['severity'], 'High')
        self.assertEqual(data['alert']['status'], 'SHLVD')

        # Process RTN and Alarm Clears, Unack (B) -> RTN Unack (D)
        response = self.client.post('/alert', data=json.dumps(self.ok_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'RST_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'OK')
        self.assertEqual(data['alert']['status'], 'SHLVD')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '0')
        self.assertEqual(data['alert']['text'], 'OK Alarm Limit 0')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], 'High')
        self.assertEqual(data['alert']['trendIndication'], 'lessSevere')

        # Operator Unshelve, Shelve (E) -> Normal (A)
        data = {
            'action': 'unshelve',
            'text': 'operator unshelved'
        }
        response = self.client.put('/alert/' + alert_id + '/action',
                                   data=json.dumps(data), content_type='application/json')
        self.assertEqual(response.status_code, 200)
        response = self.client.get('/alert/' + alert_id)
        self.assertEqual(response.status_code, 200)
        data = json.loads(response.data.decode('utf-8'))
        self.assertEqual(data['alert']['severity'], 'OK')
        self.assertEqual(data['alert']['status'], 'NORM')

    def test_out_of_service(self):

        plugins.plugins['blackout'] = NotificationBlackout()

        # Create OK alarm
        response = self.client.post('/alert', data=json.dumps(self.ok_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))

        alert_id = data['id']

        # Alarm Occurs, Normal (A) -> Unack (B)
        response = self.client.post('/alert', data=json.dumps(self.high_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'HI_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'High')
        self.assertEqual(data['alert']['status'], 'UNACK')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '13')
        self.assertEqual(data['alert']['text'], 'High Alarm Limit 10')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], alarm_model.DEFAULT_PREVIOUS_SEVERITY)
        self.assertEqual(data['alert']['trendIndication'], 'moreSevere')

        # Operator Ack (again), Unack (B) -> Ack (C)
        data = {
            'action': 'ack',
            'text': 'operator ack'
        }
        response = self.client.put('/alert/' + alert_id + '/action',
                                   data=json.dumps(data), content_type='application/json')
        self.assertEqual(response.status_code, 200)
        response = self.client.get('/alert/' + alert_id)
        self.assertEqual(response.status_code, 200)
        data = json.loads(response.data.decode('utf-8'))
        self.assertEqual(data['alert']['severity'], 'High')
        self.assertEqual(data['alert']['status'], 'ACKED')

        # Create a blackout
        plugins.plugins['blackout'] = NotificationBlackout()

        blackout = {
            'environment': 'Production',
            'service': ['REACTORS']
        }
        response = self.client.post('/blackout', data=json.dumps(blackout), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))

        blackout_id = data['id']

        # Blackout, Ack (C) -> Out-of-service (G)
        response = self.client.post('/alert', data=json.dumps(self.high_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'HI_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'High')
        self.assertEqual(data['alert']['status'], 'OOSRV')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '13')
        self.assertEqual(data['alert']['text'], 'High Alarm Limit 10')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 1)
        self.assertEqual(data['alert']['repeat'], True)
        self.assertEqual(data['alert']['previousSeverity'], alarm_model.DEFAULT_PREVIOUS_SEVERITY)
        self.assertEqual(data['alert']['trendIndication'], 'moreSevere')

        # Resend Alarm
        response = self.client.post('/alert', data=json.dumps(self.low_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'LO_LO_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'Low')
        self.assertEqual(data['alert']['status'], 'OOSRV')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '1')
        self.assertEqual(data['alert']['text'], 'Low Low Alarm Limit 0')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], 'High')
        self.assertEqual(data['alert']['trendIndication'], 'lessSevere')

        # Remove blackout
        response = self.client.delete('/blackout/' + blackout_id, content_type='application/json')
        self.assertEqual(response.status_code, 200)
        response = self.client.get('/alert/' + alert_id)
        self.assertEqual(response.status_code, 200)
        data = json.loads(response.data.decode('utf-8'))
        self.assertEqual(data['alert']['severity'], 'Low')
        self.assertEqual(data['alert']['status'], 'OOSRV')

        # Resend Alarm, Out-of-service (E) -> Unack (B)
        response = self.client.post('/alert', data=json.dumps(self.low_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'LO_LO_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'Low')
        self.assertEqual(data['alert']['status'], 'UNACK')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '1')
        self.assertEqual(data['alert']['text'], 'Low Low Alarm Limit 0')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 1)
        self.assertEqual(data['alert']['repeat'], True)
        self.assertEqual(data['alert']['previousSeverity'], 'High')
        self.assertEqual(data['alert']['trendIndication'], 'lessSevere')

        # Create a blackout
        plugins.plugins['blackout'] = NotificationBlackout()

        blackout = {
            'environment': 'Production',
            'service': ['REACTORS'],
            'resource': 'LIC_101'
        }
        response = self.client.post('/blackout', data=json.dumps(blackout), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))

        blackout_id = data['id']

        # Blackout, Ack (C) -> Out-of-service (G)
        response = self.client.post('/alert', data=json.dumps(self.high_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'HI_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'High')
        self.assertEqual(data['alert']['status'], 'OOSRV')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '13')
        self.assertEqual(data['alert']['text'], 'High Alarm Limit 10')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], 'Low')
        self.assertEqual(data['alert']['trendIndication'], 'moreSevere')

        # Resend Alarm
        response = self.client.post('/alert', data=json.dumps(self.ok_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'RST_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'OK')
        self.assertEqual(data['alert']['status'], 'OOSRV')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '0')
        self.assertEqual(data['alert']['text'], 'OK Alarm Limit 0')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], 'High')
        self.assertEqual(data['alert']['trendIndication'], 'lessSevere')

        # Remove blackout
        response = self.client.delete('/blackout/' + blackout_id, content_type='application/json')
        self.assertEqual(response.status_code, 200)
        response = self.client.get('/alert/' + alert_id)
        self.assertEqual(response.status_code, 200)
        data = json.loads(response.data.decode('utf-8'))
        self.assertEqual(data['alert']['severity'], 'OK')
        self.assertEqual(data['alert']['status'], 'OOSRV')

        # Resend Alarm, Out-of-service (E) -> Unack (B)
        response = self.client.post('/alert', data=json.dumps(self.ok_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'RST_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'OK')
        self.assertEqual(data['alert']['status'], 'NORM')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '0')
        self.assertEqual(data['alert']['text'], 'OK Alarm Limit 0')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 1)
        self.assertEqual(data['alert']['repeat'], True)
        self.assertEqual(data['alert']['previousSeverity'], 'High')
        self.assertEqual(data['alert']['trendIndication'], 'lessSevere')


class NotificationBlackout(PluginBase):

    def pre_receive(self, alert, **kwargs):
        if alert.is_blackout():
            alert.status = 'OOSRV'
        return alert

    def post_receive(self, alert, **kwargs):
        return alert

    def status_change(self, alert, status, text, **kwargs):
        return

import json
import unittest

from alerta.app import alarm_model, create_app, db, plugins
from alerta.plugins import PluginBase


class Isa182TestCase(unittest.TestCase):

    def setUp(self):

        test_config = {
            'TESTING': True,
            'ALARM_MODEL': 'ISA_18_2',
            'AUTH_REQUIRED': False,
            'PLUGINS': ['remote_ip'],
            'ALERT_TIMEOUT': 120,
            'HISTORY_LIMIT': 5
        }
        self.app = create_app(test_config, environment='development')
        self.client = self.app.test_client()

        self.fault_alarm = {
            'severity': 'Critical',
            'origin': 'LIC_101',
            'value': 'ERROR',
            'resource': 'LIC_101',
            'event': 'FAILED_ALM',
            'group': 'PROCESS',
            'text': 'Shutdown/Interlocked',
            'type': 'FAULT',
            'environment': 'Production',
            'service': ['REACTORS'],
            'correlate': ['FAILED_ALM', 'HI_HI_ALM', 'HI_ALM', 'LO_ALM', 'LO_LO_ALM', 'ADVISE_ALM', 'RST_ALM']
        }

        self.critical_alarm = {
            'severity': 'Critical',
            'origin': 'PID1',
            'value': '19',
            'resource': 'LIC_101',
            'event': 'HI_HI_ALM',
            'group': 'PROCESS',
            'text': 'High High Alarm Limit 15',
            'type': 'ALARM',
            'environment': 'Production',
            'service': ['REACTORS'],
            'correlate': ['FAILED_ALM', 'HI_HI_ALM', 'HI_ALM', 'LO_ALM', 'LO_LO_ALM', 'ADVISE_ALM', 'RST_ALM']
        }

        self.high_alarm = {
            'severity': 'High',
            'origin': 'PID1',
            'value': '13',
            'resource': 'LIC_101',
            'event': 'HI_ALM',
            'group': 'PROCESS',
            'text': 'High Alarm Limit 10',
            'type': 'ALARM',
            'environment': 'Production',
            'service': ['REACTORS'],
            'correlate': ['FAILED_ALM', 'HI_HI_ALM', 'HI_ALM', 'LO_ALM', 'LO_LO_ALM', 'ADVISE_ALM', 'RST_ALM']
        }

        self.medium_alarm = {
            'severity': 'Medium',
            'origin': 'PID1',
            'value': '6',
            'resource': 'LIC_101',
            'event': 'LO_ALM',
            'group': 'PROCESS',
            'text': 'Low Alarm Limit 5',
            'type': 'ALARM',
            'environment': 'Production',
            'service': ['REACTORS'],
            'correlate': ['FAILED_ALM', 'HI_HI_ALM', 'HI_ALM', 'LO_ALM', 'LO_LO_ALM', 'ADVISE_ALM', 'RST_ALM']
        }

        self.low_alarm = {
            'severity': 'Low',
            'origin': 'PID1',
            'value': '1',
            'resource': 'LIC_101',
            'event': 'LO_LO_ALM',
            'group': 'PROCESS',
            'text': 'Low Low Alarm Limit 0',
            'type': 'ALARM',
            'environment': 'Production',
            'service': ['REACTORS'],
            'correlate': ['FAILED_ALM', 'HI_HI_ALM', 'HI_ALM', 'LO_ALM', 'LO_LO_ALM', 'ADVISE_ALM', 'RST_ALM']
        }

        self.advisory_alarm = {
            'severity': 'Advisory',
            'origin': 'PID1',
            'value': '1',
            'resource': 'LIC_101',
            'event': 'ADVISE_ALM',
            'group': 'PROCESS',
            'text': 'Low Low Alarm Limit 0',
            'type': 'ALARM',
            'environment': 'Production',
            'service': ['REACTORS'],
            'correlate': ['FAILED_ALM', 'HI_HI_ALM', 'HI_ALM', 'LO_ALM', 'LO_LO_ALM', 'ADVISE_ALM', 'RST_ALM']
        }

        self.ok_alarm = {
            'severity': 'OK',
            'origin': 'PID1',
            'value': '0',
            'resource': 'LIC_101',
            'event': 'RST_ALM',
            'group': 'PROCESS',
            'text': 'OK Alarm Limit 0',
            'type': 'ALARM',
            'environment': 'Production',
            'service': ['REACTORS'],
            'correlate': ['FAILED_ALM', 'HI_HI_ALM', 'HI_ALM', 'LO_ALM', 'LO_LO_ALM', 'ADVISE_ALM', 'RST_ALM']
        }

    def tearDown(self):
        plugins.plugins.clear()
        db.destroy()

    def test_ack_active_alarm(self):

        # Create OK alarm
        response = self.client.post('/alert', data=json.dumps(self.ok_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))

        alert_id = data['id']

        # Alarm Occurs, Normal (A) -> Unack (B)
        response = self.client.post('/alert', data=json.dumps(self.high_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'HI_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'High')
        self.assertEqual(data['alert']['status'], 'UNACK')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '13')
        self.assertEqual(data['alert']['text'], 'High Alarm Limit 10')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], alarm_model.DEFAULT_PREVIOUS_SEVERITY)
        self.assertEqual(data['alert']['trendIndication'], 'moreSevere')

        # Operator Ack, Unack (B) -> Ack (C)
        data = {
            'action': 'ack',
            'text': 'operator ack'
        }
        response = self.client.put('/alert/' + alert_id + '/action',
                                   data=json.dumps(data), content_type='application/json')
        self.assertEqual(response.status_code, 200)
        response = self.client.get('/alert/' + alert_id)
        self.assertEqual(response.status_code, 200)
        data = json.loads(response.data.decode('utf-8'))
        self.assertEqual(data['alert']['severity'], 'High')
        self.assertEqual(data['alert']['status'], 'ACKED')

        # Re-Alarm, Ack (C) -> Unack (B)
        response = self.client.post('/alert', data=json.dumps(self.critical_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'HI_HI_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'Critical')
        self.assertEqual(data['alert']['status'], 'UNACK')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '19')
        self.assertEqual(data['alert']['text'], 'High High Alarm Limit 15')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], 'High')
        self.assertEqual(data['alert']['trendIndication'], 'moreSevere')

        # Operator Ack (again), Unack (B) -> Ack (C)
        data = {
            'action': 'ack',
            'text': 'operator ack'
        }
        response = self.client.put('/alert/' + alert_id + '/action',
                                   data=json.dumps(data), content_type='application/json')
        self.assertEqual(response.status_code, 200)
        response = self.client.get('/alert/' + alert_id)
        self.assertEqual(response.status_code, 200)
        data = json.loads(response.data.decode('utf-8'))
        self.assertEqual(data['alert']['severity'], 'Critical')
        self.assertEqual(data['alert']['status'], 'ACKED')

        # Process RTN Alarm Clears, Ack (C) -> Normal (A)
        response = self.client.post('/alert', data=json.dumps(self.ok_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'RST_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'OK')
        self.assertEqual(data['alert']['status'], 'NORM')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '0')
        self.assertEqual(data['alert']['text'], 'OK Alarm Limit 0')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], 'Critical')
        self.assertEqual(data['alert']['trendIndication'], 'lessSevere')

    def test_rtn_before_ack(self):

        # Create OK alarm
        response = self.client.post('/alert', data=json.dumps(self.ok_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))

        alert_id = data['id']

        # Alarm Occurs, Normal (A) -> Unack (B)
        response = self.client.post('/alert', data=json.dumps(self.high_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'HI_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'High')
        self.assertEqual(data['alert']['status'], 'UNACK')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '13')
        self.assertEqual(data['alert']['text'], 'High Alarm Limit 10')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], alarm_model.DEFAULT_PREVIOUS_SEVERITY)
        self.assertEqual(data['alert']['trendIndication'], 'moreSevere')

        # Process RTN and Alarm Clears, Unack (B) -> RTN Unack (D)
        response = self.client.post('/alert', data=json.dumps(self.ok_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'RST_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'OK')
        self.assertEqual(data['alert']['status'], 'RTNUN')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '0')
        self.assertEqual(data['alert']['text'], 'OK Alarm Limit 0')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], 'High')
        self.assertEqual(data['alert']['trendIndication'], 'lessSevere')

        # Resend, Duplicate=1
        response = self.client.post('/alert', data=json.dumps(self.medium_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'LO_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'Medium')
        self.assertEqual(data['alert']['status'], 'UNACK')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '6')
        self.assertEqual(data['alert']['text'], 'Low Alarm Limit 5')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], 'OK')
        self.assertEqual(data['alert']['trendIndication'], 'moreSevere')

        # Resend, Duplicate=1
        response = self.client.post('/alert', data=json.dumps(self.medium_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'LO_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'Medium')
        self.assertEqual(data['alert']['status'], 'UNACK')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '6')
        self.assertEqual(data['alert']['text'], 'Low Alarm Limit 5')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 1)
        self.assertEqual(data['alert']['repeat'], True)
        self.assertEqual(data['alert']['previousSeverity'], 'OK')
        self.assertEqual(data['alert']['trendIndication'], 'moreSevere')

        # Process RTN and Alarm Clears, Unack (B) -> RTN Unack (D)
        response = self.client.post('/alert', data=json.dumps(self.ok_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'RST_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'OK')
        self.assertEqual(data['alert']['status'], 'RTNUN')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '0')
        self.assertEqual(data['alert']['text'], 'OK Alarm Limit 0')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], 'Medium')
        self.assertEqual(data['alert']['trendIndication'], 'lessSevere')

        # Operator Ack, RTN Unack (D) -> Normal (A)
        data = {
            'action': 'ack',
            'text': 'operator ack'
        }
        response = self.client.put('/alert/' + alert_id + '/action',
                                   data=json.dumps(data), content_type='application/json')
        self.assertEqual(response.status_code, 200)
        response = self.client.get('/alert/' + alert_id)
        self.assertEqual(response.status_code, 200)
        data = json.loads(response.data.decode('utf-8'))
        self.assertEqual(data['alert']['severity'], 'OK')
        self.assertEqual(data['alert']['status'], 'NORM')

    def test_operator_shelve(self):

        # Create OK alarm
        response = self.client.post('/alert', data=json.dumps(self.ok_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))

        alert_id = data['id']

        # Alarm Occurs, Normal (A) -> Unack (B)
        response = self.client.post('/alert', data=json.dumps(self.high_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'HI_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'High')
        self.assertEqual(data['alert']['status'], 'UNACK')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '13')
        self.assertEqual(data['alert']['text'], 'High Alarm Limit 10')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], alarm_model.DEFAULT_PREVIOUS_SEVERITY)
        self.assertEqual(data['alert']['trendIndication'], 'moreSevere')

        # Operator Ack (again), Unack (B) -> Ack (C)
        data = {
            'action': 'ack',
            'text': 'operator ack'
        }
        response = self.client.put('/alert/' + alert_id + '/action',
                                   data=json.dumps(data), content_type='application/json')
        self.assertEqual(response.status_code, 200)
        response = self.client.get('/alert/' + alert_id)
        self.assertEqual(response.status_code, 200)
        data = json.loads(response.data.decode('utf-8'))
        self.assertEqual(data['alert']['severity'], 'High')
        self.assertEqual(data['alert']['status'], 'ACKED')

        # Operator Shelve, Any (*) -> Shelve (E)
        data = {
            'action': 'shelve',
            'text': 'operator shelved'
        }
        response = self.client.put('/alert/' + alert_id + '/action',
                                   data=json.dumps(data), content_type='application/json')
        self.assertEqual(response.status_code, 200)
        response = self.client.get('/alert/' + alert_id)
        self.assertEqual(response.status_code, 200)
        data = json.loads(response.data.decode('utf-8'))
        self.assertEqual(data['alert']['severity'], 'High')
        self.assertEqual(data['alert']['status'], 'SHLVD')

        # Operator Unshelve, Shelve (E) -> Unack (B)
        data = {
            'action': 'unshelve',
            'text': 'operator unshelved'
        }
        response = self.client.put('/alert/' + alert_id + '/action',
                                   data=json.dumps(data), content_type='application/json')
        self.assertEqual(response.status_code, 200)
        response = self.client.get('/alert/' + alert_id)
        self.assertEqual(response.status_code, 200)
        data = json.loads(response.data.decode('utf-8'))
        self.assertEqual(data['alert']['severity'], 'High')
        self.assertEqual(data['alert']['status'], 'UNACK')

        # Operator Shelve, Any (*) -> Shelve (E)
        data = {
            'action': 'shelve',
            'text': 'operator shelved'
        }
        response = self.client.put('/alert/' + alert_id + '/action',
                                   data=json.dumps(data), content_type='application/json')
        self.assertEqual(response.status_code, 200)
        response = self.client.get('/alert/' + alert_id)
        self.assertEqual(response.status_code, 200)
        data = json.loads(response.data.decode('utf-8'))
        self.assertEqual(data['alert']['severity'], 'High')
        self.assertEqual(data['alert']['status'], 'SHLVD')

        # Process RTN and Alarm Clears, Unack (B) -> RTN Unack (D)
        response = self.client.post('/alert', data=json.dumps(self.ok_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'RST_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'OK')
        self.assertEqual(data['alert']['status'], 'SHLVD')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '0')
        self.assertEqual(data['alert']['text'], 'OK Alarm Limit 0')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], 'High')
        self.assertEqual(data['alert']['trendIndication'], 'lessSevere')

        # Operator Unshelve, Shelve (E) -> Normal (A)
        data = {
            'action': 'unshelve',
            'text': 'operator unshelved'
        }
        response = self.client.put('/alert/' + alert_id + '/action',
                                   data=json.dumps(data), content_type='application/json')
        self.assertEqual(response.status_code, 200)
        response = self.client.get('/alert/' + alert_id)
        self.assertEqual(response.status_code, 200)
        data = json.loads(response.data.decode('utf-8'))
        self.assertEqual(data['alert']['severity'], 'OK')
        self.assertEqual(data['alert']['status'], 'NORM')

    def test_out_of_service(self):

        plugins.plugins['blackout'] = NotificationBlackout()

        # Create OK alarm
        response = self.client.post('/alert', data=json.dumps(self.ok_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))

        alert_id = data['id']

        # Alarm Occurs, Normal (A) -> Unack (B)
        response = self.client.post('/alert', data=json.dumps(self.high_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'HI_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'High')
        self.assertEqual(data['alert']['status'], 'UNACK')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '13')
        self.assertEqual(data['alert']['text'], 'High Alarm Limit 10')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], alarm_model.DEFAULT_PREVIOUS_SEVERITY)
        self.assertEqual(data['alert']['trendIndication'], 'moreSevere')

        # Operator Ack (again), Unack (B) -> Ack (C)
        data = {
            'action': 'ack',
            'text': 'operator ack'
        }
        response = self.client.put('/alert/' + alert_id + '/action',
                                   data=json.dumps(data), content_type='application/json')
        self.assertEqual(response.status_code, 200)
        response = self.client.get('/alert/' + alert_id)
        self.assertEqual(response.status_code, 200)
        data = json.loads(response.data.decode('utf-8'))
        self.assertEqual(data['alert']['severity'], 'High')
        self.assertEqual(data['alert']['status'], 'ACKED')

        # Create a blackout
        plugins.plugins['blackout'] = NotificationBlackout()

        blackout = {
            'environment': 'Production',
            'service': ['REACTORS']
        }
        response = self.client.post('/blackout', data=json.dumps(blackout), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))

        blackout_id = data['id']

        # Blackout, Ack (C) -> Out-of-service (G)
        response = self.client.post('/alert', data=json.dumps(self.high_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'HI_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'High')
        self.assertEqual(data['alert']['status'], 'OOSRV')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '13')
        self.assertEqual(data['alert']['text'], 'High Alarm Limit 10')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 1)
        self.assertEqual(data['alert']['repeat'], True)
        self.assertEqual(data['alert']['previousSeverity'], alarm_model.DEFAULT_PREVIOUS_SEVERITY)
        self.assertEqual(data['alert']['trendIndication'], 'moreSevere')

        # Resend Alarm
        response = self.client.post('/alert', data=json.dumps(self.low_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'LO_LO_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'Low')
        self.assertEqual(data['alert']['status'], 'OOSRV')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '1')
        self.assertEqual(data['alert']['text'], 'Low Low Alarm Limit 0')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], 'High')
        self.assertEqual(data['alert']['trendIndication'], 'lessSevere')

        # Remove blackout
        response = self.client.delete('/blackout/' + blackout_id, content_type='application/json')
        self.assertEqual(response.status_code, 200)
        response = self.client.get('/alert/' + alert_id)
        self.assertEqual(response.status_code, 200)
        data = json.loads(response.data.decode('utf-8'))
        self.assertEqual(data['alert']['severity'], 'Low')
        self.assertEqual(data['alert']['status'], 'OOSRV')

        # Resend Alarm, Out-of-service (E) -> Unack (B)
        response = self.client.post('/alert', data=json.dumps(self.low_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'LO_LO_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'Low')
        self.assertEqual(data['alert']['status'], 'UNACK')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '1')
        self.assertEqual(data['alert']['text'], 'Low Low Alarm Limit 0')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 1)
        self.assertEqual(data['alert']['repeat'], True)
        self.assertEqual(data['alert']['previousSeverity'], 'High')
        self.assertEqual(data['alert']['trendIndication'], 'lessSevere')

        # Create a blackout
        plugins.plugins['blackout'] = NotificationBlackout()

        blackout = {
            'environment': 'Production',
            'service': ['REACTORS'],
            'resource': 'LIC_101'
        }
        response = self.client.post('/blackout', data=json.dumps(blackout), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))

        blackout_id = data['id']

        # Blackout, Ack (C) -> Out-of-service (G)
        response = self.client.post('/alert', data=json.dumps(self.high_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'HI_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'High')
        self.assertEqual(data['alert']['status'], 'OOSRV')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '13')
        self.assertEqual(data['alert']['text'], 'High Alarm Limit 10')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], 'Low')
        self.assertEqual(data['alert']['trendIndication'], 'moreSevere')

        # Resend Alarm
        response = self.client.post('/alert', data=json.dumps(self.ok_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'RST_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'OK')
        self.assertEqual(data['alert']['status'], 'OOSRV')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '0')
        self.assertEqual(data['alert']['text'], 'OK Alarm Limit 0')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 0)
        self.assertEqual(data['alert']['repeat'], False)
        self.assertEqual(data['alert']['previousSeverity'], 'High')
        self.assertEqual(data['alert']['trendIndication'], 'lessSevere')

        # Remove blackout
        response = self.client.delete('/blackout/' + blackout_id, content_type='application/json')
        self.assertEqual(response.status_code, 200)
        response = self.client.get('/alert/' + alert_id)
        self.assertEqual(response.status_code, 200)
        data = json.loads(response.data.decode('utf-8'))
        self.assertEqual(data['alert']['severity'], 'OK')
        self.assertEqual(data['alert']['status'], 'OOSRV')

        # Resend Alarm, Out-of-service (E) -> Unack (B)
        response = self.client.post('/alert', data=json.dumps(self.ok_alarm), content_type='application/json')
        self.assertEqual(response.status_code, 201)
        data = json.loads(response.data.decode('utf-8'))
        self.assertIn(alert_id, data['alert']['id'])
        self.assertEqual(data['alert']['resource'], 'LIC_101')
        self.assertEqual(data['alert']['event'], 'RST_ALM')
        self.assertEqual(data['alert']['environment'], 'Production')
        self.assertEqual(data['alert']['severity'], 'OK')
        self.assertEqual(data['alert']['status'], 'NORM')
        self.assertEqual(data['alert']['service'], ['REACTORS'])
        self.assertEqual(data['alert']['group'], 'PROCESS')
        self.assertEqual(data['alert']['value'], '0')
        self.assertEqual(data['alert']['text'], 'OK Alarm Limit 0')
        self.assertEqual(data['alert']['tags'], [])
        self.assertEqual(data['alert']['attributes'], {'ip': '127.0.0.1'})
        self.assertEqual(data['alert']['origin'], 'PID1')
        self.assertEqual(data['alert']['type'], 'ALARM')
        self.assertEqual(data['alert']['duplicateCount'], 1)
        self.assertEqual(data['alert']['repeat'], True)
        self.assertEqual(data['alert']['previousSeverity'], 'High')
        self.assertEqual(data['alert']['trendIndication'], 'lessSevere')


class NotificationBlackout(PluginBase):

    def pre_receive(self, alert, **kwargs):
        if alert.is_blackout():
            alert.status = 'OOSRV'
        return alert

    def post_receive(self, alert, **kwargs):
        return alert

    def status_change(self, alert, status, text, **kwargs):
        return
# Create OK alarm # Alarm Occurs, Normal (A) -> Unack (B) # Operator Ack, Unack (B) -> Ack (C) # Re-Alarm, Ack (C) -> Unack (B) # Operator Ack (again), Unack (B) -> Ack (C) # Process RTN Alarm Clears, Ack (C) -> Normal (A) # Create OK alarm # Alarm Occurs, Normal (A) -> Unack (B) # Process RTN and Alarm Clears, Unack (B) -> RTN Unack (D) # Resend, Duplicate=1 # Resend, Duplicate=1 # Process RTN and Alarm Clears, Unack (B) -> RTN Unack (D) # Operator Ack, RTN Unack (D) -> Normal (A) # Create OK alarm # Alarm Occurs, Normal (A) -> Unack (B) # Operator Ack (again), Unack (B) -> Ack (C) # Operator Shelve, Any (*) -> Shelve (E) # Operator Unshelve, Shelve (E) -> Unack (B) # Operator Shelve, Any (*) -> Shelve (E) # Process RTN and Alarm Clears, Unack (B) -> RTN Unack (D) # Operator Unshelve, Shelve (E) -> Normal (A) # Create OK alarm # Alarm Occurs, Normal (A) -> Unack (B) # Operator Ack (again), Unack (B) -> Ack (C) # Create a blackout # Blackout, Ack (C) -> Out-of-service (G) # Resend Alarm # Remove blackout # Resend Alarm, Out-of-service (E) -> Unack (B) # Create a blackout # Blackout, Ack (C) -> Out-of-service (G) # Resend Alarm # Remove blackout # Resend Alarm, Out-of-service (E) -> Unack (B)