|
1 | 1 | import asyncio |
2 | 2 | import inspect |
3 | 3 | from functools import lru_cache |
| 4 | +from itertools import zip_longest |
4 | 5 | from typing import ( |
5 | 6 | Any, |
6 | 7 | Callable, |
| 8 | + Generic, |
7 | 9 | Optional, |
| 10 | + Protocol, |
8 | 11 | TypeVar, |
| 12 | + Union, |
9 | 13 | get_origin, |
10 | 14 | ) |
11 | 15 | from typing_extensions import get_args |
12 | 16 |
|
13 | | -from strawberry.utils.typing import is_generic_alias |
14 | | - |
15 | 17 |
|
16 | 18 | def in_async_context() -> bool: |
17 | 19 | # Based on the way django checks if there's an event loop in the current thread |
@@ -67,57 +69,60 @@ class IntBarFoo(IntBar, Foo[str]): ... |
67 | 69 | # {} |
68 | 70 |
|
69 | 71 | get_specialized_type_var_map(Bar) |
70 | | - # {~T: ~T} |
| 72 | + # {} |
71 | 73 |
|
72 | 74 | get_specialized_type_var_map(IntBar) |
73 | | - # {~T: int} |
| 75 | + # {~T: int, ~K: int} |
74 | 76 |
|
75 | 77 | get_specialized_type_var_map(IntBarSubclass) |
76 | | - # {~T: int} |
| 78 | + # {~T: int, ~K: int} |
77 | 79 |
|
78 | 80 | get_specialized_type_var_map(IntBarFoo) |
79 | 81 | # {~T: int, ~K: str} |
80 | 82 | ``` |
81 | 83 | """ |
82 | 84 | from strawberry.types.base import has_object_definition |
83 | 85 |
|
84 | | - orig_bases = getattr(cls, "__orig_bases__", None) |
85 | | - if orig_bases is None: |
86 | | - # Specialized generic aliases will not have __orig_bases__ |
87 | | - if get_origin(cls) is not None and is_generic_alias(cls): |
88 | | - orig_bases = (cls,) |
89 | | - else: |
90 | | - # Not a specialized type |
91 | | - return None |
92 | | - |
93 | | - type_var_map = {} |
94 | | - |
95 | | - # only get type vars for base generics (ie. Generic[T]) and for strawberry types |
| 86 | + param_args: dict[TypeVar, Union[None, TypeVar, type]] = {} |
96 | 87 |
|
97 | | - orig_bases = [b for b in orig_bases if has_object_definition(b)] |
| 88 | + types: list[type] = [cls] |
| 89 | + while types: |
| 90 | + tp = types.pop(0) |
| 91 | + if (origin := get_origin(tp)) is None or origin in (Generic, Protocol): |
| 92 | + origin = tp |
98 | 93 |
|
99 | | - for base in orig_bases: |
100 | | - # Recursively get type var map from base classes |
101 | | - if base is not cls: |
102 | | - base_type_var_map = get_specialized_type_var_map(base) |
103 | | - if base_type_var_map is not None: |
104 | | - type_var_map.update(base_type_var_map) |
105 | | - |
106 | | - args = get_args(base) |
107 | | - origin = getattr(base, "__origin__", None) |
108 | | - |
109 | | - params = origin and getattr(origin, "__parameters__", None) |
110 | | - if params is None: |
111 | | - params = getattr(base, "__parameters__", None) |
112 | | - |
113 | | - if not params: |
| 94 | + # only get type vars for base generics (i.e. Generic[T]) and for strawberry types |
| 95 | + if not has_object_definition(origin): |
114 | 96 | continue |
115 | 97 |
|
116 | | - type_var_map.update( |
117 | | - {p.__name__: a for p, a in zip(params, args) if not isinstance(a, TypeVar)} |
118 | | - ) |
119 | | - |
120 | | - return type_var_map |
| 98 | + if (type_params := getattr(origin, "__parameters__", None)) is not None: |
| 99 | + args = get_args(tp) |
| 100 | + for type_param, arg in zip_longest(type_params, args): |
| 101 | + if type_param not in param_args: |
| 102 | + param_args[type_param] = arg |
| 103 | + |
| 104 | + if orig_bases := getattr(origin, "__orig_bases__", None): |
| 105 | + types.extend(orig_bases) |
| 106 | + if not param_args: |
| 107 | + return None |
| 108 | + |
| 109 | + resolve = True |
| 110 | + while resolve: |
| 111 | + resolve = False |
| 112 | + for type_param, arg in list(param_args.items()): |
| 113 | + if arg is None or not isinstance(arg, TypeVar): |
| 114 | + continue |
| 115 | + resolved_arg = param_args.get(arg) if arg is not type_param else None |
| 116 | + param_args[type_param] = resolved_arg |
| 117 | + |
| 118 | + if resolved_arg: |
| 119 | + resolve = True |
| 120 | + |
| 121 | + return { |
| 122 | + k.__name__: v |
| 123 | + for k, v in reversed(param_args.items()) |
| 124 | + if v is not None and not isinstance(v, TypeVar) |
| 125 | + } |
121 | 126 |
|
122 | 127 |
|
123 | 128 | __all__ = ["get_func_args", "get_specialized_type_var_map", "in_async_context"] |
0 commit comments