import unittest

from manticore.utils.event import Eventful

class A(Eventful):
    _published_events = set(['eventA'])
    def do_stuff(self):
        self._publish("eventA",1, 'a')

class B(Eventful):
    _published_events = set(['eventB'])
    def __init__(self, child, **kwargs):
        super(B, self).__init__(**kwargs)
        self.child = child
        self.forward_events_from(child)

    def do_stuff(self):
        self._publish("eventB", 2, 'b')


class C():
    def __init__(self):
        self.received = []
    def callback(self, *args):
        self.received.append(args)

class ManticoreDriver(unittest.TestCase):
    _multiprocess_can_split_ = True
    def setUp(self):
        self.state = {}

    def tearDown(self):
        pass

    def test_weak_references(self):
        a = A()
        self.assertSequenceEqual( map(len, (a._signals, a._forwards)), (0, 0) )

        b = B(a)
        self.assertSequenceEqual( map(len, (a._signals, a._forwards)), (0, 1) )
        self.assertSequenceEqual( map(len, (b._signals, b._forwards)), (0, 0) )

        c = C()
        b.subscribe('eventA', c.callback)

        self.assertSequenceEqual( map(len, (a._signals, a._forwards)), (0, 1) )
        self.assertSequenceEqual( map(len, (b._signals, b._forwards)), (1, 0) )

        b.subscribe('eventB', c.callback)

        self.assertSequenceEqual( map(len, (a._signals, a._forwards)), (0, 1) )
        self.assertSequenceEqual( map(len, (b._signals, b._forwards)), (2, 0) )


        del c

        self.assertSequenceEqual( map(len, (a._signals, a._forwards)), (0, 1) )
        self.assertSequenceEqual( map(len, (b._signals, b._forwards)), (0, 0) )

        del b

        self.assertSequenceEqual( map(len, (a._signals, a._forwards)), (0, 0) )

    def test_basic(self):
        a = A()
        b = B(a)
        c = C()

        b.subscribe('eventA', c.callback)
        b.subscribe('eventB', c.callback)

        a.do_stuff()
        self.assertSequenceEqual(c.received, [(1, 'a')])

        b.do_stuff()
        self.assertSequenceEqual(c.received, [(1, 'a'), (2, 'b')])