# Copyright (c) testtools developers. See LICENSE for details.

"""Tests for testtools._deferred."""

from testtools.matchers import (
    Equals,
    MatchesException,
    Raises,
)

from ._helpers import NeedsTwistedTestCase

try:
    from testtools.twistedsupport._deferred import DeferredNotFired
except ImportError:
    DeferredNotFired = None  # type: ignore[misc,assignment]

try:
    from testtools.twistedsupport._deferred import extract_result
except ImportError:
    extract_result = None  # type: ignore[assignment]

try:
    from twisted.internet import defer
except ImportError:
    defer = None  # type: ignore[assignment]

try:
    from twisted.python.failure import Failure
except ImportError:
    Failure = None  # type: ignore[misc,assignment]


class TestExtractResult(NeedsTwistedTestCase):
    """Tests for ``extract_result``."""

    def test_not_fired(self):
        # _spinner.extract_result raises _spinner.DeferredNotFired if it's
        # given a Deferred that has not fired.
        self.assertThat(
            lambda: extract_result(defer.Deferred()),
            Raises(MatchesException(DeferredNotFired)),
        )

    def test_success(self):
        # _spinner.extract_result returns the value of the Deferred if it has
        # fired successfully.
        marker = object()
        d = defer.succeed(marker)
        self.assertThat(extract_result(d), Equals(marker))

    def test_failure(self):
        # _spinner.extract_result raises the failure's exception if it's given
        # a Deferred that is failing.
        try:
            1 / 0
        except ZeroDivisionError:
            f = Failure()
        d = defer.fail(f)
        self.assertThat(
            lambda: extract_result(d), Raises(MatchesException(ZeroDivisionError))
        )


def test_suite():
    from unittest import TestLoader

    return TestLoader().loadTestsFromName(__name__)