# -*- encoding: utf-8 -*-
#
# Copyright © 2012 New Dream Network, LLC (DreamHost)
#
# Author: Doug Hellmann <doug.hellmann@dreamhost.com>
#
# 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.
"""Tests for ceilometer/agent/manager.py
"""

import datetime

import mock
from oslo.config import cfg
from stevedore import extension

from ceilometer import nova_client
from ceilometer.compute import manager
from ceilometer import counter
from ceilometer.tests import base


@mock.patch('ceilometer.pipeline.setup_pipeline', mock.MagicMock())
def test_load_plugins():
    mgr = manager.AgentManager()
    assert list(mgr.pollster_manager), 'Failed to load any plugins'
    return


class TestRunTasks(base.TestCase):

    class Pollster:
        counters = []
        test_data = counter.Counter(
            name='test',
            type=counter.TYPE_CUMULATIVE,
            unit='',
            volume=1,
            user_id='test',
            project_id='test',
            resource_id='test_run_tasks',
            timestamp=datetime.datetime.utcnow().isoformat(),
            resource_metadata={'name': 'Pollster'},
        )

        def get_counters(self, manager, instance):
            self.counters.append((manager, instance))
            return [self.test_data]

    @mock.patch('ceilometer.pipeline.setup_pipeline', mock.MagicMock())
    def setUp(self):
        super(TestRunTasks, self).setUp()
        self.mgr = manager.AgentManager()
        self.mgr.pollster_manager = extension.ExtensionManager(
            'fake',
            invoke_on_load=False,
        )
        self.mgr.pollster_manager.extensions = [
            extension.Extension('test',
                                None,
                                None,
                                self.Pollster(), ),
        ]

        # Set up a fake instance value to be returned by
        # instance_get_all_by_host() so when the manager gets the list
        # of instances to poll we can control the results.
        self.instance = {'name': 'faux',
                         'OS-EXT-STS:vm_state': 'active'}
        stillborn_instance = {'name': 'stillborn',
                              'OS-EXT-STS:vm_state': 'error'}
        self.stubs.Set(nova_client.Client, 'instance_get_all_by_host',
                       lambda *x: [self.instance, stillborn_instance])
        self.mox.ReplayAll()
        # Invoke the periodic tasks to call the pollsters.
        self.mgr.periodic_tasks(None)

    def tearDown(self):
        self.Pollster.counters = []
        super(TestRunTasks, self).tearDown()

    def test_message(self):
        self.assertEqual(len(self.Pollster.counters), 2)
        self.assertTrue(self.Pollster.counters[0][1] is self.instance)

    def test_notifications(self):
        self.assertTrue(self.mgr.pipeline_manager.publisher.called)
        args, _ = self.mgr.pipeline_manager.publisher.call_args
        self.assertEqual(args[1], cfg.CONF.counter_source)

@@ -1755,16 +1755,205 @@
 _data%5D%0A%0A
+    def _fake_instance(self, name, state):%0A        instance = mock.MagicMock()%0A        instance.name = name%0A        setattr(instance, 'OS-EXT-STS:vm_state', state)%0A        return instance%0A%0A
     @moc
@@ -2016,16 +2016,16 @@
 Mock())%0A
-
     def 
@@ -2692,72 +2692,35 @@
 e = 
-%7B'name': 'faux',%0A                         'OS-EXT-STS:vm_state':
+self._fake_instance('faux',
  'ac
@@ -2724,17 +2724,17 @@
 'active'
-%7D
+)
 %0A       
@@ -2759,90 +2759,48 @@
 e = 
-%7B'name': 'stillborn',%0A                              'OS-EXT-STS:vm_state':
+self._fake_instance('stillborn',
  'error'
 %7D%0A  
@@ -2795,17 +2795,17 @@
  'error'
-%7D
+)
 %0A       
@@ -3254,17 +3254,17 @@
 nters), 
-2
+1
 )%0A      

Fix a bug in compute manager test case