#!/usr/bin/env python


from pytest import fixture, skip, PLATFORM


if PLATFORM == "win32":
    skip("Broken on Windows")


from circuits import Component, Event
from circuits.net.events import close
from circuits.node import Node, remote
from circuits.net.sockets import UDPServer


class App(Component):

    ready = False
    value = False
    disconnected = False

    def foo(self):
        return "Hello World!"

    def ready(self, *args):
        self.ready = True

    def disconnect(self, component):
        self.disconnected = True

    def remote_value_changed(self, value):
        self.value = True


@fixture()
def bind(request, manager, watcher):
    server = UDPServer(0).register(manager)
    assert watcher.wait("ready")

    host, port = server.host, server.port

    server.fire(close())
    assert watcher.wait("closed")

    server.unregister()
    assert watcher.wait("unregistered")

    return host, port


@fixture()
def app(request, manager, watcher, bind):
    app = App().register(manager)
    node = Node().register(app)
    watcher.wait("ready")

    child = (App() + Node(bind))
    child.start(process=True)

    node.add("child", *bind)
    watcher.wait("connected")

    def finalizer():
        child.stop()

    request.addfinalizer(finalizer)

    return app


def test_return_value(app, watcher):
    e = Event.create("foo")
    e.notify = True

    r = remote(e, "child")
    r.notify = True

    value = app.fire(r)
    assert watcher.wait("remote_value_changed")

    assert value.value == "Hello World!"