# -*- encoding: utf-8 -*-
# Copyright (c) 2017 Servionica
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#    http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
# implied.
# See the License for the specific language governing permissions and
# limitations under the License.

import datetime

import freezegun
import mock
import oslo_messaging as om

from watcher.common import rpc
from watcher import notifications
from watcher.objects import service as w_service
from watcher.tests.db import base
from watcher.tests.objects import utils


@freezegun.freeze_time('2016-10-18T09:52:05.219414')
class TestActionPlanNotification(base.DbTestCase):

    def setUp(self):
        super(TestActionPlanNotification, self).setUp()
        p_get_notifier = mock.patch.object(rpc, 'get_notifier')
        m_get_notifier = p_get_notifier.start()
        self.addCleanup(p_get_notifier.stop)
        self.m_notifier = mock.Mock(spec=om.Notifier)

        def fake_get_notifier(publisher_id):
            self.m_notifier.publisher_id = publisher_id
            return self.m_notifier

        m_get_notifier.side_effect = fake_get_notifier

    def test_service_failed(self):
        service = utils.get_test_service(mock.Mock(),
                                         created_at=datetime.datetime.utcnow())
        state = w_service.ServiceStatus.FAILED
        notifications.service.send_service_update(mock.MagicMock(),
                                                  service,
                                                  state,
                                                  host='node0')
        notification = self.m_notifier.warning.call_args[1]
        payload = notification['payload']
        self.assertEqual("infra-optim:node0", self.m_notifier.publisher_id)
        self.assertDictEqual({
            'watcher_object.data': {
                'last_seen_up': '2016-09-22T08:32:06Z',
                'name': 'watcher-service',
                'sevice_host': 'controller',
                'status_update': {
                    'watcher_object.data': {
                        'old_state': 'ACTIVE',
                        'state': 'FAILED'
                    },
                    'watcher_object.name': 'ServiceStatusUpdatePayload',
                    'watcher_object.namespace': 'watcher',
                    'watcher_object.version': '1.0'
                }
            },
            'watcher_object.name': 'ServiceUpdatePayload',
            'watcher_object.namespace': 'watcher',
            'watcher_object.version': '1.0'
        },
            payload
        )

[((30, 1, 30, 52), 'freezegun.freeze_time', 'freezegun.freeze_time', ({(30, 23, 30, 51): '"""2016-10-18T09:52:05.219414"""'}, {}), "('2016-10-18T09:52:05.219414')", False, 'import freezegun\n'), ((35, 25, 35, 63), 'mock.patch.object', 'mock.patch.object', ({(35, 43, 35, 46): 'rpc', (35, 48, 35, 62): '"""get_notifier"""'}, {}), "(rpc, 'get_notifier')", False, 'import mock\n'), ((38, 26, 38, 53), 'mock.Mock', 'mock.Mock', (), '', False, 'import mock\n'), ((47, 41, 47, 52), 'mock.Mock', 'mock.Mock', ({}, {}), '()', False, 'import mock\n'), ((50, 50, 50, 66), 'mock.MagicMock', 'mock.MagicMock', ({}, {}), '()', False, 'import mock\n'), ((48, 52, 48, 78), 'datetime.datetime.utcnow', 'datetime.datetime.utcnow', ({}, {}), '()', False, 'import datetime\n')]