<filename>src/core/tests/test_environment.py<gh_stars>100-1000
# Copyright (c) 2016-present, Facebook, Inc.
# All rights reserved.
#
# This source code is licensed under the BSD-style license found in the
# LICENSE file in the root directory of this source tree. An additional grant
# of patent rights can be found in the PATENTS file in the same directory.

from __future__ import absolute_import
from __future__ import division
from __future__ import print_function
from __future__ import unicode_literals
import unittest
import core.task as task
import core.environment as environment


class SerializerMock(object):
    pass


class SingleTaskScheduler():
    def __init__(self, task):
        self.task = task

    def get_next_task(self):
        return self.task

    def reward(self, reward):
        pass


class TestEnvironment(unittest.TestCase):

    def testRegistering(self):
        class TestTask(task.Task):
            def __init__(self, *args, **kwargs):
                super(TestTask, self).__init__(*args, **kwargs)
                self.handled = False

            @task.on_start()
            def start_handler(self, event):
                self.handled = True
        tt = TestTask(max_time=10)
        env = environment.Environment(SerializerMock(), SingleTaskScheduler(tt))
        tt.start(env)
        env._register_task_triggers(tt)
        # Start should be handled
        self.assertTrue(env.raise_event(task.Start()))
        # The start handler should have been executed
        self.assertTrue(tt.handled)
        env._deregister_task_triggers(tt)
        # Start should not be handled anymore
        self.assertFalse(env.raise_event(task.Start()))

    def testDynRegistering(self):
        class TestTask(task.Task):
            def __init__(self, *args, **kwargs):
                super(TestTask, self).__init__(*args, **kwargs)
                self.start_handled = False
                self.end_handled = False

            @task.on_start()
            def start_handler(self, event):
                try:
                    self.add_handler(task.on_ended()(
                        self.end_handler.im_func))
                except AttributeError: # Python 3
                    self.add_handler(task.on_ended()(
                        self.end_handler.__func__))
                self.start_handled = True

            def end_handler(self, event):
                self.end_handled = True

        tt = TestTask(max_time=10)
        env = environment.Environment(SerializerMock(), SingleTaskScheduler(tt))
        tt.start(env)
        env._register_task_triggers(tt)
        # End cannot be handled
        self.assertFalse(env.raise_event(task.Ended()))
        self.assertFalse(tt.end_handled)
        # Start should be handled
        self.assertTrue(env.raise_event(task.Start()))
        # The start handler should have been executed
        self.assertTrue(tt.start_handled)
        # Now the End should be handled
        self.assertTrue(env.raise_event(task.Ended()))
        # The end handler should have been executed
        self.assertTrue(tt.end_handled)
        env._deregister_task_triggers(tt)
        # Start should not be handled anymore
        self.assertFalse(env.raise_event(task.Start()))
        tt.end_handled = False
        # End should not be handled anymore
        self.assertFalse(env.raise_event(task.Ended()))
        self.assertFalse(tt.end_handled)
        # Register them again! mwahaha (evil laugh) -- lol
        env._register_task_triggers(tt)
        # End should not be handled anymore
        self.assertFalse(env.raise_event(task.Ended()))
        self.assertFalse(tt.end_handled)
        # Deregister them again! mwahahahaha (more evil laugh)
        env._deregister_task_triggers(tt)
        self.assertFalse(env.raise_event(task.Ended()))
        self.assertFalse(tt.end_handled)

<filename>src/core/tests/test_environment.py<gh_stars>100-1000
# Copyright (c) 2016-present, Facebook, Inc.
# All rights reserved.
#
# This source code is licensed under the BSD-style license found in the
# LICENSE file in the root directory of this source tree. An additional grant
# of patent rights can be found in the PATENTS file in the same directory.

from __future__ import absolute_import
from __future__ import division
from __future__ import print_function
from __future__ import unicode_literals
import unittest
import core.task as task
import core.environment as environment


class SerializerMock(object):
    pass


class SingleTaskScheduler():
    def __init__(self, task):
        self.task = task

    def get_next_task(self):
        return self.task

    def reward(self, reward):
        pass


class TestEnvironment(unittest.TestCase):

    def testRegistering(self):
        class TestTask(task.Task):
            def __init__(self, *args, **kwargs):
                super(TestTask, self).__init__(*args, **kwargs)
                self.handled = False

            @task.on_start()
            def start_handler(self, event):
                self.handled = True
        tt = TestTask(max_time=10)
        env = environment.Environment(SerializerMock(), SingleTaskScheduler(tt))
        tt.start(env)
        env._register_task_triggers(tt)
        # Start should be handled
        self.assertTrue(env.raise_event(task.Start()))
        # The start handler should have been executed
        self.assertTrue(tt.handled)
        env._deregister_task_triggers(tt)
        # Start should not be handled anymore
        self.assertFalse(env.raise_event(task.Start()))

    def testDynRegistering(self):
        class TestTask(task.Task):
            def __init__(self, *args, **kwargs):
                super(TestTask, self).__init__(*args, **kwargs)
                self.start_handled = False
                self.end_handled = False

            @task.on_start()
            def start_handler(self, event):
                try:
                    self.add_handler(task.on_ended()(
                        self.end_handler.im_func))
                except AttributeError: # Python 3
                    self.add_handler(task.on_ended()(
                        self.end_handler.__func__))
                self.start_handled = True

            def end_handler(self, event):
                self.end_handled = True

        tt = TestTask(max_time=10)
        env = environment.Environment(SerializerMock(), SingleTaskScheduler(tt))
        tt.start(env)
        env._register_task_triggers(tt)
        # End cannot be handled
        self.assertFalse(env.raise_event(task.Ended()))
        self.assertFalse(tt.end_handled)
        # Start should be handled
        self.assertTrue(env.raise_event(task.Start()))
        # The start handler should have been executed
        self.assertTrue(tt.start_handled)
        # Now the End should be handled
        self.assertTrue(env.raise_event(task.Ended()))
        # The end handler should have been executed
        self.assertTrue(tt.end_handled)
        env._deregister_task_triggers(tt)
        # Start should not be handled anymore
        self.assertFalse(env.raise_event(task.Start()))
        tt.end_handled = False
        # End should not be handled anymore
        self.assertFalse(env.raise_event(task.Ended()))
        self.assertFalse(tt.end_handled)
        # Register them again! mwahaha (evil laugh) -- lol
        env._register_task_triggers(tt)
        # End should not be handled anymore
        self.assertFalse(env.raise_event(task.Ended()))
        self.assertFalse(tt.end_handled)
        # Deregister them again! mwahahahaha (more evil laugh)
        env._deregister_task_triggers(tt)
        self.assertFalse(env.raise_event(task.Ended()))
        self.assertFalse(tt.end_handled)

# Copyright (c) 2016-present, Facebook, Inc. # All rights reserved. # # This source code is licensed under the BSD-style license found in the # LICENSE file in the root directory of this source tree. An additional grant # of patent rights can be found in the PATENTS file in the same directory. # Start should be handled # The start handler should have been executed # Start should not be handled anymore # Python 3 # End cannot be handled # Start should be handled # The start handler should have been executed # Now the End should be handled # The end handler should have been executed # Start should not be handled anymore # End should not be handled anymore # Register them again! mwahaha (evil laugh) -- lol # End should not be handled anymore # Deregister them again! mwahahahaha (more evil laugh)