from __future__ import annotations

import inspect
import os
import re
import subprocess
import sys
import time
import unittest.case
from pathlib import Path
from textwrap import dedent

import django
import pytest
from django.db import connection
from django.test import SimpleTestCase, TestCase
from django.test.runner import DiscoverRunner


@pytest.mark.skip(reason="Run below via Django unittest subprocess.")
class ExampleTests(TestCase):
    def test_pass(self):
        self.assertEqual(1, 1)

    def test_error(self):
        raise ValueError("Woops")

    def test_failure(self):
        self.assertEqual(1, 2)

    def test_failure_django_assertion(self):
        self.assertURLEqual("/url/", "/test/")

    def test_failure_sql_query(self):
        with connection.cursor() as cursor:
            cursor.execute(
                "SELECT 1234, %s",
                (5678,),
            )
        self.assertTrue(False)

    def test_skip(self):
        self.skipTest("some reason")

    @unittest.expectedFailure
    def test_expected_failure(self):
        self.assertEqual(1, 2)

    @unittest.expectedFailure
    def test_unexpected_success(self):
        self.assertEqual(1, 1)

    def test_pass_output(self):
        print("This is some example output")
        print("This is some example output", file=sys.stderr)

    def test_failure_stdout(self):
        print("This is some example output")
        self.assertTrue(False)

    def test_failure_stdout_no_newline(self):
        print("This is some example output", end="")
        self.assertTrue(False)

    def test_failure_stderr(self):
        print("This is some example output", file=sys.stderr)
        self.assertTrue(False)

    def test_failure_stderr_no_newline(self):
        print("This is some example output", end="", file=sys.stderr)
        self.assertTrue(False)

    def test_slow(self):
        # Ensure over the 0.001s threshold
        time.sleep(0.002)

    def test_subtest(self):
        for i in range(0, 2):
            with self.subTest(i=i):
                self.assertEqual(i, i)

    def test_failure_subtest(self):
        for i in range(0, 2):
            with self.subTest(i=i):
                # 1 is not even.
                self.assertEqual(i % 2, 0)

    def test_skip_subtest(self):
        with self.subTest("success", a=1):
            pass
        with self.subTest("skip", b=2):
            self.skipTest("skip")

    def test_mixed_subtest(self):
        with self.subTest("success", a=1):
            pass
        with self.subTest("skip", b=2):
            self.skipTest("skip")
        with self.subTest("error", c=3):  # type: ignore [unreachable]
            self.fail("fail")
        with self.subTest("error", d=4):
            raise Exception("error")


@pytest.mark.skip(reason="Run below via Django unittest subprocess.")
class TearDownFailTests(TestCase):
    def tearDown(self):
        raise AssertionError("fail")

    def test_tearDownError_success(self):
        self.assertEqual(1, 1)

    def test_tearDownError_fail(self):
        self.assertEqual(1, 2)

    def test_tearDownError_error(self):
        raise ValueError("Woops")


@pytest.mark.skip(reason="Run below via Django unittest subprocess.")
class TearDownErrorTests(TestCase):
    def tearDown(self):
        raise Exception("error")

    def test_tearDownError_skip(self):
        self.skipTest("skip")


PYPROJECT_PATH = Path(__file__).resolve().parent.parent / "pyproject.toml"


class TestRunnerTests(SimpleTestCase):
    def test_test_runner_base_class(self):
        # RichTestRunner currently inherits from unittest.TextTestRunner, which
        # is what Django’s DiscoverRunner uses by default. This test ensures
        # that has not changed in a future Django version.
        assert DiscoverRunner.test_runner is unittest.TextTestRunner

    def run_test(
        self,
        *args: str,
        input: str | None = None,
        width: int = 80,
    ) -> subprocess.CompletedProcess[str]:
        return subprocess.run(
            [
                "python3",
                "-m",
                "django",
                "test",
                *args,
            ],
            input=input,
            capture_output=True,
            text=True,
            env={
                **os.environ,
                "DJANGO_SETTINGS_MODULE": "tests.settings",
                "COVERAGE_PROCESS_START": str(PYPROJECT_PATH),
                # Ensure rich uses colouring and consistent width
                "TERM": "",
                "COLUMNS": str(width),
            },
        )

    def test_does_not_exist(self):
        result = self.run_test("does_not_exist")
        assert result.returncode == 1
        lines = result.stderr.splitlines()
        if sys.version_info >= (3, 11):
            assert lines[:6] == [
                "E",
                "─" * 80,
                "ERROR: does_not_exist (unittest.loader._FailedTest.does_not_exist)",
                "─" * 80,
                "ImportError: Failed to import test module: does_not_exist",
                "Traceback (most recent call last):",
            ]
        else:
            assert lines[:6] == [
                "E",
                "─" * 80,
                "ERROR: does_not_exist (unittest.loader._FailedTest)",
                "─" * 80,
                "ImportError: Failed to import test module: does_not_exist",
                "Traceback (most recent call last):",
            ]

    def test_pass_quiet(self):
        result = self.run_test("-v", "0", f"{__name__}.ExampleTests.test_pass")
        assert result.returncode == 0
        assert result.stderr.splitlines()[:1] == [
            "━" * 80,
        ]

    def test_pass_normal(self):
        result = self.run_test(f"{__name__}.ExampleTests.test_pass")
        assert result.returncode == 0
        assert result.stderr.splitlines()[1:3] == [
            ".",
            "━" * 80,
        ]

    def test_pass_verbose(self):
        result = self.run_test("-v", "2", f"{__name__}.ExampleTests.test_pass")
        assert result.returncode == 0
        lines = result.stderr.splitlines()
        if sys.version_info >= (3, 11):
            assert lines[1:4] == [
                "test_pass (tests.test_test.ExampleTests.test_pass) ... ok",
                "",
                "━" * 80,
            ]
        else:
            assert lines[1:4] == [
                "test_pass (tests.test_test.ExampleTests) ... ok",
                "",
                "━" * 80,
            ]

    def test_error_quiet(self):
        result = self.run_test("-v", "0", f"{__name__}.ExampleTests.test_error")
        assert result.returncode == 1
        lines = result.stderr.splitlines()
        if sys.version_info >= (3, 11):
            assert lines[:2] == [
                "─" * 80,
                "ERROR: test_error (tests.test_test.ExampleTests.test_error)",
            ]
        else:
            assert lines[:2] == [
                "─" * 80,
                "ERROR: test_error (tests.test_test.ExampleTests)",
            ]
        assert "─ locals ─" in result.stderr

    def test_error_normal(self):
        result = self.run_test(f"{__name__}.ExampleTests.test_error")
        assert result.returncode == 1
        lines = result.stderr.splitlines()
        if sys.version_info >= (3, 11):
            assert lines[1:4] == [
                "E",
                "─" * 80,
                "ERROR: test_error (tests.test_test.ExampleTests.test_error)",
            ]
        else:
            assert lines[1:4] == [
                "E",
                "─" * 80,
                "ERROR: test_error (tests.test_test.ExampleTests)",
            ]
        assert "─ locals ─" in result.stderr

    def test_error_verbose(self):
        result = self.run_test("-v", "2", f"{__name__}.ExampleTests.test_error")
        assert result.returncode == 1
        lines = result.stderr.splitlines()
        if sys.version_info >= (3, 11):
            assert lines[1:5] == [
                "test_error (tests.test_test.ExampleTests.test_error) ... ERROR",
                "",
                "─" * 80,
                "ERROR: test_error (tests.test_test.ExampleTests.test_error)",
            ]
        else:
            assert lines[1:5] == [
                "test_error (tests.test_test.ExampleTests) ... ERROR",
                "",
                "─" * 80,
                "ERROR: test_error (tests.test_test.ExampleTests)",
            ]
        assert "─ locals ─" in result.stderr

    def test_failure_quiet(self):
        result = self.run_test("-v", "0", f"{__name__}.ExampleTests.test_failure")
        assert result.returncode == 1
        lines = result.stderr.splitlines()
        if sys.version_info >= (3, 11):
            assert lines[:2] == [
                "─" * 80,
                "FAIL: test_failure (tests.test_test.ExampleTests.test_failure)",
            ]
        else:
            assert lines[:2] == [
                "─" * 80,
                "FAIL: test_failure (tests.test_test.ExampleTests)",
            ]
        assert "─ locals ─" in result.stderr

    def test_failure_normal(self):
        result = self.run_test(f"{__name__}.ExampleTests.test_failure")
        assert result.returncode == 1
        lines = result.stderr.splitlines()
        if sys.version_info >= (3, 11):
            assert lines[1:4] == [
                "F",
                "─" * 80,
                "FAIL: test_failure (tests.test_test.ExampleTests.test_failure)",
            ]
        else:
            assert lines[1:4] == [
                "F",
                "─" * 80,
                "FAIL: test_failure (tests.test_test.ExampleTests)",
            ]
        assert "─ locals ─" in result.stderr

    def test_failure_verbose(self):
        result = self.run_test("-v", "2", f"{__name__}.ExampleTests.test_failure")
        assert result.returncode == 1
        lines = result.stderr.splitlines()
        if sys.version_info >= (3, 11):
            assert lines[1:5] == [
                "test_failure (tests.test_test.ExampleTests.test_failure) ... FAIL",
                "",
                "─" * 80,
                "FAIL: test_failure (tests.test_test.ExampleTests.test_failure)",
            ]
        else:
            assert lines[1:5] == [
                "test_failure (tests.test_test.ExampleTests) ... FAIL",
                "",
                "─" * 80,
                "FAIL: test_failure (tests.test_test.ExampleTests)",
            ]
        assert "─ locals ─" in result.stderr

    def test_failure_stack_frames(self):
        result = self.run_test(
            "-v", "2", f"{__name__}.ExampleTests.test_failure", width=1000
        )
        assert result.returncode == 1
        assert "unittest/case.py" not in result.stderr
        assert "in _baseAssertEqual" not in result.stderr

    def test_skip_quiet(self):
        result = self.run_test("-v", "0", f"{__name__}.ExampleTests.test_skip")
        assert result.returncode == 0
        assert result.stderr.splitlines()[:1] == [
            "━" * 80,
        ]

    def test_skip_normal(self):
        result = self.run_test(f"{__name__}.ExampleTests.test_skip")
        assert result.returncode == 0
        assert result.stderr.splitlines()[1:3] == [
            "s",
            "━" * 80,
        ]

    def test_skip_verbose(self):
        result = self.run_test("-v", "2", f"{__name__}.ExampleTests.test_skip")
        assert result.returncode == 0
        lines = result.stderr.splitlines()
        if sys.version_info >= (3, 11):
            assert lines[1:4] == [
                (
                    "test_skip (tests.test_test.ExampleTests.test_skip) ... "
                    + "skipped 'some reason'"
                ),
                "",
                "━" * 80,
            ]
        else:
            assert lines[1:4] == [
                "test_skip (tests.test_test.ExampleTests) ... skipped 'some reason'",
                "",
                "━" * 80,
            ]

    def test_expected_failure_quiet(self):
        result = self.run_test(
            "-v", "0", f"{__name__}.ExampleTests.test_expected_failure"
        )
        assert result.returncode == 0
        assert result.stderr.splitlines()[:1] == [
            "━" * 80,
        ]

    def test_expected_failure_normal(self):
        result = self.run_test(f"{__name__}.ExampleTests.test_expected_failure")
        assert result.returncode == 0
        assert result.stderr.splitlines()[1:3] == [
            "x",
            "━" * 80,
        ]

    def test_expected_failure_verbose(self):
        result = self.run_test(
            "-v", "2", f"{__name__}.ExampleTests.test_expected_failure"
        )
        assert result.returncode == 0
        lines = result.stderr.splitlines()
        if sys.version_info >= (3, 11):
            assert lines[1:4] == [
                (
                    "test_expected_failure (tests.test_test.ExampleTests."
                    + "test_expected_failure) ... expected failure"
                ),
                "",
                "━" * 80,
            ]
        else:
            assert lines[1:4] == [
                (
                    "test_expected_failure (tests.test_test.ExampleTests) ... "
                    + "expected failure"
                ),
                "",
                "━" * 80,
            ]

    def test_unexpected_success_quiet(self):
        result = self.run_test(
            "-v", "0", f"{__name__}.ExampleTests.test_unexpected_success"
        )
        assert result.returncode == 1
        lines = result.stderr.splitlines()
        if sys.version_info >= (3, 11):
            assert lines[:1] == ["═" * 80]
        else:
            assert lines[:1] == ["━" * 80]

    def test_unexpected_success_normal(self):
        result = self.run_test(f"{__name__}.ExampleTests.test_unexpected_success")

        assert result.returncode == 1
        lines = result.stderr.splitlines()
        if sys.version_info >= (3, 11):
            assert lines[1:3] == [
                "u",
                "═" * 80,
            ]
        else:
            assert lines[1:3] == [
                "u",
                "━" * 80,
            ]

    def test_unexpected_success_verbose(self):
        result = self.run_test(
            "-v", "2", f"{__name__}.ExampleTests.test_unexpected_success"
        )
        assert result.returncode == 1
        lines = result.stderr.splitlines()
        if sys.version_info >= (3, 11):
            assert lines[1:4] == [
                (
                    "test_unexpected_success (tests.test_test.ExampleTests."
                    + "test_unexpected_success) ... unexpected success"
                ),
                "",
                "═" * 80,
            ]
        else:
            assert lines[1:4] == [
                (
                    "test_unexpected_success (tests.test_test.ExampleTests) "
                    + "... unexpected success"
                ),
                "",
                "━" * 80,
            ]

    def test_debug_sql(self):
        result = self.run_test(
            "--debug-sql", f"{__name__}.ExampleTests.test_failure_sql_query"
        )

        assert result.returncode == 1
        lines = result.stderr.splitlines()
        assert "─ locals ─" in result.stderr
        assert lines[-10:-7] == [
            "AssertionError: False is not true",
            "",
            "─" * 80,
        ]
        # https://docs.djangoproject.com/en/4.0/releases/4.0/#logging
        sql_line_re = r"\(\d.\d\d\d\) SELECT 1234, 5678; args=\(5678,\); alias=default"
        assert re.match(sql_line_re, lines[-7])
        assert lines[-6:-4] == [
            "",
            "━" * 80,
        ]

    def test_pdb(self):
        result = self.run_test(
            "--pdb",
            f"{__name__}.ExampleTests.test_failure",
            input="p 2 * 2\n",
        )

        assert result.returncode == 1
        lines = result.stdout.splitlines()
        expected = [
            "Found 1 test(s).",
            "System check identified no issues (0 silenced).",
            "",
            "Opening PDB: AssertionError('1 != 2')",
        ]
        assert lines[: len(expected)] == expected

        assert lines[len(expected) + 1] == "-> self.assertEqual(1, 2)"

        assert lines[len(expected) + 2 : len(expected) + 4] == [
            "(Pdb) 4",
            "(Pdb) ",
        ]

    def test_failure_django_assertion(self):
        "Django and Unit test modules are hidden in tracebacks."
        result = self.run_test(f"{__name__}.ExampleTests.test_failure_django_assertion")
        assert result.returncode == 1
        assert "testPartExecutor" not in result.stderr
        assert "_callTestMethod" not in result.stderr
        assert 'self.assertURLEqual("/url/", "/test/")' in result.stderr
        assert 'self.assertURLEqual("/url/", "/test/")' in result.stderr
        assert result.stderr.count("─ locals ─") == 1

    def test_buffer_pass(self):
        result = self.run_test("--buffer", f"{__name__}.ExampleTests.test_pass_output")
        assert result.returncode == 0
        assert "This is some example output" not in result.stdout
        assert "This is some example output" not in result.stderr

    def test_buffer_stdout(self):
        result = self.run_test(
            "--buffer", f"{__name__}.ExampleTests.test_failure_stdout"
        )
        assert result.returncode == 1
        assert result.stderr.splitlines()[-10:-4] == [
            "AssertionError: False is not true",
            "",
            "Stdout:",
            "This is some example output",
            "",
            "━" * 80,
        ]

    def test_buffer_stdout_no_newline(self):
        result = self.run_test(
            "--buffer", f"{__name__}.ExampleTests.test_failure_stdout_no_newline"
        )
        assert result.returncode == 1
        assert result.stderr.splitlines()[-10:-4] == [
            "AssertionError: False is not true",
            "",
            "Stdout:",
            "This is some example output",
            "",
            "━" * 80,
        ]

    def test_buffer_stderr(self):
        result = self.run_test(
            "--buffer", f"{__name__}.ExampleTests.test_failure_stderr"
        )
        assert result.returncode == 1
        assert result.stderr.splitlines()[-10:-4] == [
            "AssertionError: False is not true",
            "",
            "Stderr:",
            "This is some example output",
            "",
            "━" * 80,
        ]

    def test_buffer_stderr_no_newline(self):
        result = self.run_test(
            "--buffer", f"{__name__}.ExampleTests.test_failure_stderr_no_newline"
        )
        assert result.returncode == 1
        assert result.stderr.splitlines()[-10:-4] == [
            "AssertionError: False is not true",
            "",
            "Stderr:",
            "This is some example output",
            "",
            "━" * 80,
        ]

    durations_test = pytest.mark.skipif(
        sys.version_info < (3, 12) or django.VERSION < (5, 0),
        reason="unittest --durations only on Python 3.12+ and Django 5.0+",
    )

    @durations_test
    def test_durations_upstream_source(self):
        # RichTestRunner completely replaces _printDurations(), so check the
        # overridden function for changes that may need copying in.
        source = dedent(
            inspect.getsource(
                unittest.TextTestRunner._printDurations,  # type: ignore[attr-defined]
            )
        )
        expected = dedent(
            """\
            def _printDurations(self, result):
                if not result.collectedDurations:
                    return
                ls = sorted(result.collectedDurations, key=lambda x: x[1],
                            reverse=True)
                if self.durations > 0:
                    ls = ls[:self.durations]
                self.stream.writeln("Slowest test durations")
                if hasattr(result, 'separator2'):
                    self.stream.writeln(result.separator2)
                hidden = False
                for test, elapsed in ls:
                    if self.verbosity < 2 and elapsed < 0.001:
                        hidden = True
                        continue
                    self.stream.writeln("%-10s %s" % ("%.3fs" % elapsed, test))
                if hidden:
                    self.stream.writeln("\\n(durations < 0.001s were hidden; "
                                        "use -v to show these durations)")
                else:
                    self.stream.writeln("")
            """
        )
        assert source == expected

    @durations_test
    def test_durations_none(self):
        result = self.run_test(
            "--durations",
            "10",
            f"{__name__}.ExampleTests.test_slow",
            "--tag",
            "nonexistent",
        )
        assert result.returncode == 0
        lines = result.stderr.splitlines()
        assert lines[0:2] == [
            "",
            "━" * 80,
        ]
        assert re.fullmatch(r"Ran 0 tests in \d\.\d\d\ds", lines[2])
        assert lines[3:] == [
            "",
            "NO TESTS RAN",
        ]

    @durations_test
    def test_durations_shown(self):
        result = self.run_test(
            "--durations", "10", f"{__name__}.ExampleTests.test_slow"
        )
        assert result.returncode == 0
        lines = result.stderr.splitlines()
        assert lines[2:6] == [
            "                     Slowest test durations                      ",
            "┏━━━━━━━━━━┳━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┓",
            "┃ Duration ┃ Test                                               ┃",
            "┡━━━━━━━━━━╇━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┩",
        ]
        assert re.fullmatch(
            re.escape("│   ")
            + r"\d.\d\d\ds "
            + re.escape("│ test_slow (tests.test_test.ExampleTests.test_slow) │"),
            lines[6],
        )
        assert lines[7:8] == [
            "└──────────┴────────────────────────────────────────────────────┘",
        ]

    @durations_test
    def test_durations_all(self):
        result = self.run_test("--durations", "0", f"{__name__}.ExampleTests.test_slow")
        assert result.returncode == 0
        lines = result.stderr.splitlines()
        assert lines[2:6] == [
            "                     Slowest test durations                      ",
            "┏━━━━━━━━━━┳━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┓",
            "┃ Duration ┃ Test                                               ┃",
            "┡━━━━━━━━━━╇━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┩",
        ]
        assert re.fullmatch(
            re.escape("│   ")
            + r"\d.\d\d\ds "
            + re.escape("│ test_slow (tests.test_test.ExampleTests.test_slow) │"),
            lines[6],
        )
        assert lines[7:8] == [
            "└──────────┴────────────────────────────────────────────────────┘",
        ]

    @durations_test
    def test_durations_hidden(self):
        result = self.run_test(
            "--durations", "10", f"{__name__}.ExampleTests.test_pass"
        )
        assert result.returncode == 0
        lines = result.stderr.splitlines()
        assert lines[2:4] == [
            "Slowest test durations",
            "Durations < 0.001s were hidden. Use -v to show these durations.",
        ]

    @durations_test
    def test_durations_verbose(self):
        result = self.run_test(
            "--durations", "10", "-v", "2", f"{__name__}.ExampleTests.test_pass"
        )
        assert result.returncode == 0
        lines = result.stderr.splitlines()
        assert lines[3:9] == [
            "                     Slowest test durations                      ",
            "┏━━━━━━━━━━┳━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┓",
            "┃ Duration ┃ Test                                               ┃",
            "┡━━━━━━━━━━╇━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┩",
            "│   0.000s │ test_pass (tests.test_test.ExampleTests.test_pass) │",
            "└──────────┴────────────────────────────────────────────────────┘",
        ]

    @durations_test
    def test_durations_shown_hidden(self):
        result = self.run_test(
            "--durations",
            "10",
            f"{__name__}.ExampleTests.test_pass",
            f"{__name__}.ExampleTests.test_slow",
        )
        assert result.returncode == 0
        lines = result.stderr.splitlines()
        assert lines[2:6] == [
            "                     Slowest test durations                      ",
            "┏━━━━━━━━━━┳━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┓",
            "┃ Duration ┃ Test                                               ┃",
            "┡━━━━━━━━━━╇━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┩",
        ]
        assert re.fullmatch(
            re.escape("│   ")
            + r"\d.\d\d\ds "
            + re.escape("│ test_slow (tests.test_test.ExampleTests.test_slow) │"),
            lines[6],
        )
        assert lines[7:9] == [
            "└──────────┴────────────────────────────────────────────────────┘",
            " Durations < 0.001s were hidden. Use -v to show these durations. ",
        ]

    sub_test_test = pytest.mark.skipif(
        sys.version_info < (3, 11),
        reason="addSubTest added in Python 3.11.",
    )

    @sub_test_test
    def test_subtest_upstream_source(self):
        # RichTextTestResult completely replaces _addSubTest(), so check the
        # overridden function for changes that may need copying in.
        source = dedent(
            inspect.getsource(
                unittest.TextTestResult.addSubTest,
            )
        )
        if sys.version_info >= (3, 14):
            expected = dedent(
                """\
                def addSubTest(self, test, subtest, err):
                    if err is not None:
                        t = self._theme
                        if self.showAll:
                            if issubclass(err[0], subtest.failureException):
                                self._write_status(subtest, f"{t.fail}FAIL{t.reset}")
                            else:
                                self._write_status(subtest, f"{t.fail}ERROR{t.reset}")
                        elif self.dots:
                            if issubclass(err[0], subtest.failureException):
                                self.stream.write(f"{t.fail}F{t.reset}")
                            else:
                                self.stream.write(f"{t.fail}E{t.reset}")
                            self.stream.flush()
                    super(TextTestResult, self).addSubTest(test, subtest, err)
                """
            )
        else:
            expected = dedent(
                """\
                def addSubTest(self, test, subtest, err):
                    if err is not None:
                        if self.showAll:
                            if issubclass(err[0], subtest.failureException):
                                self._write_status(subtest, "FAIL")
                            else:
                                self._write_status(subtest, "ERROR")
                        elif self.dots:
                            if issubclass(err[0], subtest.failureException):
                                self.stream.write('F')
                            else:
                                self.stream.write('E')
                            self.stream.flush()
                    super(TextTestResult, self).addSubTest(test, subtest, err)
                """
            )
        assert source == expected

    @sub_test_test
    def test_write_status_upstream_source(self):
        # RichTextTestResult completely replaces _write_status(), so check the
        # overridden function for changes that may need copying in.
        source = dedent(
            inspect.getsource(
                unittest.TextTestResult._write_status,  # type: ignore[attr-defined]
            )
        )
        expected = dedent(
            """\
            def _write_status(self, test, status):
                is_subtest = isinstance(test, _SubTest)
                if is_subtest or self._newline:
                    if not self._newline:
                        self.stream.writeln()
                    if is_subtest:
                        self.stream.write("  ")
                    self.stream.write(self.getDescription(test))
                    self.stream.write(" ... ")
                self.stream.writeln(status)
                self.stream.flush()
                self._newline = True
            """
        )
        assert source == expected

    def test_subtest(self):
        result = self.run_test(f"{__name__}.ExampleTests.test_subtest")
        assert result.returncode == 0
        lines = result.stderr.splitlines()
        assert lines[1] == "."

    def test_subtest_verbose(self):
        result = self.run_test("-v", "2", f"{__name__}.ExampleTests.test_subtest")
        assert result.returncode == 0
        lines = result.stderr.splitlines()
        if sys.version_info >= (3, 11):
            assert (
                lines[1]
                == "test_subtest (tests.test_test.ExampleTests.test_subtest) ... ok"
            )
        else:
            assert lines[1] == "test_subtest (tests.test_test.ExampleTests) ... ok"

    def test_subtest_quiet(self):
        result = self.run_test("-v", "0", f"{__name__}.ExampleTests.test_subtest")
        assert result.returncode == 0
        lines = result.stderr.splitlines()
        assert lines[0] == "━" * 80

    def test_subtest_quiet_fail(self):
        result = self.run_test(
            "-v", "0", f"{__name__}.ExampleTests.test_failure_subtest"
        )
        assert result.returncode == 1
        lines = result.stderr.splitlines()
        if sys.version_info >= (3, 11):
            assert lines[:2] == [
                "─" * 80,
                "FAIL: test_failure_subtest (tests.test_test.ExampleTests.test_failure_subtest) ",
            ]
        else:
            assert lines[:2] == [
                "─" * 80,
                "FAIL: test_failure_subtest (tests.test_test.ExampleTests) (i=1)",
            ]

    def test_failure_subtest(self):
        result = self.run_test(f"{__name__}.ExampleTests.test_failure_subtest")
        assert result.returncode == 1
        lines = result.stderr.splitlines()
        assert lines[1] == "F"

    def test_failure_subtest_verbose(self):
        result = self.run_test(
            "-v", "2", f"{__name__}.ExampleTests.test_failure_subtest"
        )
        assert result.returncode == 1
        lines = result.stderr.splitlines()
        if sys.version_info >= (3, 11):
            assert lines[1:4] == [
                "test_failure_subtest (tests.test_test.ExampleTests.test_failure_subtest) ... ",
                "  test_failure_subtest (tests.test_test.ExampleTests.test_failure_subtest) (i=1) ... FAIL",
                "",
            ]
        else:
            assert lines[1:4] == [
                "test_failure_subtest (tests.test_test.ExampleTests) ... ",
                "  test_failure_subtest (tests.test_test.ExampleTests) (i=1) ... FAIL",
                "",
            ]

    def test_subtest_skip(self):
        result = self.run_test(f"{__name__}.ExampleTests.test_skip_subtest")
        assert result.returncode == 0
        lines = result.stderr.splitlines()
        assert lines[1] == "s"

    def test_subtest_skip_verbose(self):
        result = self.run_test("-v", "2", f"{__name__}.ExampleTests.test_skip_subtest")
        assert result.returncode == 0
        lines = result.stderr.splitlines()
        if sys.version_info >= (3, 11):
            assert lines[1:4] == [
                "test_skip_subtest (tests.test_test.ExampleTests.test_skip_subtest) ... ",
                "  test_skip_subtest (tests.test_test.ExampleTests.test_skip_subtest)  (b=2) ... skipped 'skip'",
                "",
            ]
        else:
            assert lines[1:4] == [
                "test_skip_subtest (tests.test_test.ExampleTests) ... ",
                "  test_skip_subtest (tests.test_test.ExampleTests)  (b=2) ... skipped 'skip'",
                "",
            ]

    def test_subtest_mixed(self):
        result = self.run_test(f"{__name__}.ExampleTests.test_mixed_subtest")
        assert result.returncode == 1
        lines = result.stderr.splitlines()
        assert lines[1] == "sFE"

    def test_subtest_mixed_verbose(self):
        result = self.run_test("-v", "2", f"{__name__}.ExampleTests.test_mixed_subtest")
        assert result.returncode == 1
        lines = result.stderr.splitlines()
        if sys.version_info >= (3, 11):
            assert lines[1:6] == [
                "test_mixed_subtest (tests.test_test.ExampleTests.test_mixed_subtest) ... ",
                "  test_mixed_subtest (tests.test_test.ExampleTests.test_mixed_subtest)  (b=2) ... skipped 'skip'",
                "  test_mixed_subtest (tests.test_test.ExampleTests.test_mixed_subtest)  (c=3) ... FAIL",
                "  test_mixed_subtest (tests.test_test.ExampleTests.test_mixed_subtest)  (d=4) ... ERROR",
                "",
            ]
        else:
            assert lines[1:6] == [
                "test_mixed_subtest (tests.test_test.ExampleTests) ... ",
                "  test_mixed_subtest (tests.test_test.ExampleTests)  (b=2) ... skipped 'skip'",
                "  test_mixed_subtest (tests.test_test.ExampleTests)  (c=3) ... FAIL",
                "  test_mixed_subtest (tests.test_test.ExampleTests)  (d=4) ... ERROR",
                "",
            ]

    def test_tearDown_fail(self):
        result = self.run_test(
            f"{__name__}.TearDownFailTests.test_tearDownError_success"
        )
        assert result.returncode == 1
        lines = result.stderr.splitlines()
        assert lines[1] == "F"

        result = self.run_test(f"{__name__}.TearDownFailTests.test_tearDownError_fail")
        assert result.returncode == 1
        lines = result.stderr.splitlines()
        assert lines[1] == "FF"

        result = self.run_test(f"{__name__}.TearDownFailTests.test_tearDownError_error")
        assert result.returncode == 1
        lines = result.stderr.splitlines()
        assert lines[1] == "EF"

        result = self.run_test(f"{__name__}.TearDownErrorTests.test_tearDownError_skip")
        assert result.returncode == 1
        lines = result.stderr.splitlines()
        assert lines[1] == "sE"

    def test_tearDown_fail_verbose(self):
        result = self.run_test(
            "-v", "2", f"{__name__}.TearDownFailTests.test_tearDownError_success"
        )
        assert result.returncode == 1
        lines = result.stderr.splitlines()
        if sys.version_info >= (3, 11):
            assert (
                lines[1]
                == "test_tearDownError_success (tests.test_test.TearDownFailTests.test_tearDownError_success) ... FAIL"
            )
        else:
            assert (
                lines[1]
                == "test_tearDownError_success (tests.test_test.TearDownFailTests) ... FAIL"
            )

        result = self.run_test(
            "-v", "2", f"{__name__}.TearDownFailTests.test_tearDownError_fail"
        )
        assert result.returncode == 1
        lines = result.stderr.splitlines()
        if sys.version_info >= (3, 11):
            assert lines[1:4] == [
                "test_tearDownError_fail (tests.test_test.TearDownFailTests.test_tearDownError_fail) ... FAIL",
                "test_tearDownError_fail ",
                "(tests.test_test.TearDownFailTests.test_tearDownError_fail) ... FAIL",
            ]
        else:
            assert lines[1:3] == [
                "test_tearDownError_fail (tests.test_test.TearDownFailTests) ... FAIL",
                "test_tearDownError_fail (tests.test_test.TearDownFailTests) ... FAIL",
            ]

        result = self.run_test(
            "-v", "2", f"{__name__}.TearDownFailTests.test_tearDownError_error"
        )
        assert result.returncode == 1
        lines = result.stderr.splitlines()
        if sys.version_info >= (3, 11):
            assert lines[1:4] == [
                "test_tearDownError_error (tests.test_test.TearDownFailTests.test_tearDownError_error) ... ERROR",
                "test_tearDownError_error ",
                "(tests.test_test.TearDownFailTests.test_tearDownError_error) ... FAIL",
            ]
        else:
            assert lines[1:3] == [
                "test_tearDownError_error (tests.test_test.TearDownFailTests) ... ERROR",
                "test_tearDownError_error (tests.test_test.TearDownFailTests) ... FAIL",
            ]

        result = self.run_test(
            "-v", "2", f"{__name__}.TearDownErrorTests.test_tearDownError_skip"
        )
        assert result.returncode == 1
        lines = result.stderr.splitlines()
        if sys.version_info >= (3, 11):
            assert lines[1:4] == [
                "test_tearDownError_skip (tests.test_test.TearDownErrorTests.test_tearDownError_skip) ... skipped 'skip'",
                "test_tearDownError_skip ",
                "(tests.test_test.TearDownErrorTests.test_tearDownError_skip) ... ERROR",
            ]
        else:
            assert lines[1:3] == [
                "test_tearDownError_skip (tests.test_test.TearDownErrorTests) ... skipped 'skip'",
                "test_tearDownError_skip (tests.test_test.TearDownErrorTests) ... ERROR",
            ]
