test_executor_thread.py

# type: ignore
from graphql.error import format_error
from graphql.execution import execute
from graphql.language.parser import parse
from graphql.type import (
    GraphQLArgument,
    GraphQLField,
    GraphQLInt,
    GraphQLList,
    GraphQLObjectType,
    GraphQLSchema,
    GraphQLString,
)
from pytest import mark

from ..executors.thread import ThreadExecutor
from .test_mutations import assert_evaluate_mutations_serially
from .utils import rejected, resolved

###
# Disabled because all these tests are flaky
# The culprit is that the `ThreadExecutor` incorrectly assumes that
# the `Promise` class is thread-safe.
# See https://git.io/JeA3s
###


@mark.xfail
def test_executes_arbitary_code():
    # type: () -> None
    class Data(object):
        a = "Apple"
        b = "Banana"
        c = "Cookie"
        d = "Donut"
        e = "Egg"

        @property
        def f(self):
            # type: () -> Promise
            return resolved("Fish")

        def pic(self, size=50):
            # type: (int) -> Promise
            return resolved("Pic of size: {}".format(size))

        def deep(self):
            # type: () -> DeepData
            return DeepData()

        def promise(self):
            # type: () -> Promise
            return resolved(Data())

    class DeepData(object):
        a = "Already Been Done"
        b = "Boring"
        c = ["Contrived", None, resolved("Confusing")]

        def deeper(self):
            # type: () -> List[Union[None, Data, Promise]]
            return [Data(), None, resolved(Data())]

    ast = parse(
        """
        query Example($size: Int) {
            a,
            b,
            x: c
            ...c
            f
            ...on DataType {
                pic(size: $size)
                promise {
                    a
                }
            }
            deep {
                a
                b
                c
                deeper {
                    a
                    b
                }
            }
        }
        fragment c on DataType {
            d
            e
        }
    """
    )

    expected = {
        "a": "Apple",
        "b": "Banana",
        "x": "Cookie",
        "d": "Donut",
        "e": "Egg",
        "f": "Fish",
        "pic": "Pic of size: 100",
        "promise": {"a": "Apple"},
        "deep": {
            "a": "Already Been Done",
            "b": "Boring",
            "c": ["Contrived", None, "Confusing"],
            "deeper": [
                {"a": "Apple", "b": "Banana"},
                None,
                {"a": "Apple", "b": "Banana"},
            ],
        },
    }

    DataType = GraphQLObjectType(
        "DataType",
        lambda: {
            "a": GraphQLField(GraphQLString),
            "b": GraphQLField(GraphQLString),
            "c": GraphQLField(GraphQLString),
            "d": GraphQLField(GraphQLString),
            "e": GraphQLField(GraphQLString),
            "f": GraphQLField(GraphQLString),
            "pic": GraphQLField(
                args={"size": GraphQLArgument(GraphQLInt)},
                type=GraphQLString,
                resolver=lambda obj, info, **args: obj.pic(args["size"]),
            ),
            "deep": GraphQLField(DeepDataType),
            "promise": GraphQLField(DataType),
        },
    )

    DeepDataType = GraphQLObjectType(
        "DeepDataType",
        {
            "a": GraphQLField(GraphQLString),
            "b": GraphQLField(GraphQLString),
            "c": GraphQLField(GraphQLList(GraphQLString)),
            "deeper": GraphQLField(GraphQLList(DataType)),
        },
    )

    schema = GraphQLSchema(query=DataType)

    def handle_result(result):
        # type: (ExecutionResult) -> None
        assert not result.errors
        assert result.data == expected

    handle_result(
        execute(
            schema,
            ast,
            Data(),
            variable_values={"size": 100},
            operation_name="Example",
            executor=ThreadExecutor(),
        )
    )
    handle_result(
        execute(
            schema, ast, Data(), variable_values={"size": 100}, operation_name="Example"
        )
    )


@mark.xfail
def test_synchronous_error_nulls_out_error_subtrees():
    # type: () -> None
    ast = parse(
        """
    {
        sync
        syncError
        syncReturnError
        syncReturnErrorList
        asyncBasic
        asyncReject
        asyncEmptyReject
        asyncReturnError
    }
    """
    )

    class Data:
        def sync(self):
            # type: () -> str
            return "sync"

        def syncError(self):
            # type: () -> NoReturn
            raise Exception("Error getting syncError")

        def syncReturnError(self):
            # type: () -> Exception
            return Exception("Error getting syncReturnError")

        def syncReturnErrorList(self):
            # type: () -> List[Union[Exception, str]]
            return [
                "sync0",
                Exception("Error getting syncReturnErrorList1"),
                "sync2",
                Exception("Error getting syncReturnErrorList3"),
            ]

        def asyncBasic(self):
            # type: () -> Promise
            return resolved("async")

        def asyncReject(self):
            # type: () -> Promise
            return rejected(Exception("Error getting asyncReject"))

        def asyncEmptyReject(self):
            # type: () -> Promise
            return rejected(Exception("An unknown error occurred."))

        def asyncReturnError(self):
            # type: () -> Promise
            return resolved(Exception("Error getting asyncReturnError"))

    schema = GraphQLSchema(
        query=GraphQLObjectType(
            name="Type",
            fields={
                "sync": GraphQLField(GraphQLString),
                "syncError": GraphQLField(GraphQLString),
                "syncReturnError": GraphQLField(GraphQLString),
                "syncReturnErrorList": GraphQLField(GraphQLList(GraphQLString)),
                "asyncBasic": GraphQLField(GraphQLString),
                "asyncReject": GraphQLField(GraphQLString),
                "asyncEmptyReject": GraphQLField(GraphQLString),
                "asyncReturnError": GraphQLField(GraphQLString),
            },
        )
    )

    def sort_key(item):
        # type: (Dict[str, Any]) -> Tuple[int, int]
        locations = item["locations"][0]
        return (locations["line"], locations["column"])

    def handle_results(result):
        # type: (ExecutionResult) -> None
        assert result.data == {
            "asyncBasic": "async",
            "asyncEmptyReject": None,
            "asyncReject": None,
            "asyncReturnError": None,
            "sync": "sync",
            "syncError": None,
            "syncReturnError": None,
            "syncReturnErrorList": ["sync0", None, "sync2", None],
        }
        assert sorted(list(map(format_error, result.errors)), key=sort_key) == sorted(
            [
                {
                    "locations": [{"line": 4, "column": 9}],
                    "path": ["syncError"],
                    "message": "Error getting syncError",
                },
                {
                    "locations": [{"line": 5, "column": 9}],
                    "path": ["syncReturnError"],
                    "message": "Error getting syncReturnError",
                },
                {
                    "locations": [{"line": 6, "column": 9}],
                    "path": ["syncReturnErrorList", 1],
                    "message": "Error getting syncReturnErrorList1",
                },
                {
                    "locations": [{"line": 6, "column": 9}],
                    "path": ["syncReturnErrorList", 3],
                    "message": "Error getting syncReturnErrorList3",
                },
                {
                    "locations": [{"line": 8, "column": 9}],
                    "path": ["asyncReject"],
                    "message": "Error getting asyncReject",
                },
                {
                    "locations": [{"line": 9, "column": 9}],
                    "path": ["asyncEmptyReject"],
                    "message": "An unknown error occurred.",
                },
                {
                    "locations": [{"line": 10, "column": 9}],
                    "path": ["asyncReturnError"],
                    "message": "Error getting asyncReturnError",
                },
            ],
            key=sort_key,
        )

    handle_results(execute(schema, ast, Data(), executor=ThreadExecutor()))


@mark.xfail
def test_evaluates_mutations_serially():
    # type: () -> None
    assert_evaluate_mutations_serially(executor=ThreadExecutor())