1 | """ |
||
2 | Django integration. |
||
3 | |||
4 | Usage: |
||
5 | |||
6 | |||
7 | ``` |
||
8 | #views.py |
||
9 | |||
10 | from .dependency_config import dependencies |
||
11 | |||
12 | |||
13 | @dependencies.bind_view |
||
14 | def index(request, dep: SomeDep=injectable, questions: DjangoModel[Question]=injectable): |
||
15 | new_question = questions.new(question_text="What's next?", pub_date=timezone.now()) |
||
16 | new_question.save() |
||
17 | return HttpResponse(f"plain old function: {dep.message} with {questions.objects.all().count()} questions") |
||
18 | |||
19 | |||
20 | @dependencies.bind_view |
||
21 | class CBVexample(View): |
||
22 | def get(self, request, dep: SomeDep=injectable, settings: DjangoSettings): |
||
23 | # do something with settings |
||
24 | return HttpResponse(f"Class based: {dep.message}") |
||
25 | |||
26 | ``` |
||
27 | |||
28 | ``` |
||
29 | # dependency_config.py |
||
30 | # a per app dep injection container |
||
31 | |||
32 | # Lists all models that should be available |
||
33 | container = Container() |
||
34 | container[SomeService] = SomeService("connection details etc") |
||
35 | |||
36 | dependencies = DjangoIntegration(container, models=[Question], request_singletons=[SomeCache]) |
||
37 | ``` |
||
38 | |||
39 | """ |
||
40 | |||
41 | 1 | import types |
|
42 | 1 | from typing import TypeVar, Generic, List, Type, Optional, Any |
|
43 | |||
44 | 1 | from django.db.models import Manager, Model |
|
45 | 1 | from django.http import HttpRequest |
|
46 | 1 | from django.views import View |
|
47 | |||
48 | 1 | from lagom.interfaces import ExtendableContainer, WriteableContainer |
|
49 | 1 | from lagom.definitions import ConstructionWithoutContainer, PlainInstance |
|
50 | |||
51 | 1 | M = TypeVar("M", bound=Model) |
|
52 | |||
53 | |||
54 | 1 | class _Managers(Generic[M]): |
|
55 | """ |
||
56 | Wraps around a django model and provides access to the class properties. |
||
57 | The intention is that all the Manager objects can be accessed via this. |
||
58 | """ |
||
59 | |||
60 | 1 | def __init__(self, model: Type[M]): |
|
61 | 1 | self.model = model |
|
62 | |||
63 | 1 | def __getattr__(self, item) -> Manager: |
|
64 | 1 | if not hasattr(self.model, item): |
|
65 | 1 | raise KeyError( |
|
66 | f"Django model {self.model.__name__} does not define a property {item}" |
||
67 | ) |
||
68 | 1 | return getattr(self.model, item) |
|
69 | |||
70 | |||
71 | 1 | class _DjangoSettings: |
|
72 | 1 | pass |
|
73 | |||
74 | |||
75 | 1 | DjangoSettings: Any = _DjangoSettings |
|
76 | |||
77 | |||
78 | 1 | class DjangoModel(Generic[M]): |
|
79 | """Wrapper around a django model for injection hinting |
||
80 | Usage: |
||
81 | container = DjangoContainer(models=[Question]) |
||
82 | |||
83 | @bind_to_container(container) |
||
84 | def load_first_question(questions: DjangoModel[Question]): |
||
85 | return questions.objects.first() |
||
86 | |||
87 | """ |
||
88 | |||
89 | 1 | model: Type[M] |
|
90 | 1 | managers: _Managers[M] |
|
91 | |||
92 | 1 | def __init__(self, model: Type[M]): |
|
93 | """ |
||
94 | |||
95 | :param model: The django model class |
||
96 | """ |
||
97 | 1 | self.model = model |
|
98 | 1 | self.managers = _Managers(self.model) |
|
99 | |||
100 | 1 | @property |
|
101 | 1 | def objects(self) -> Manager: |
|
102 | """Equivalent to MyModel.objects |
||
103 | |||
104 | :return: |
||
105 | """ |
||
106 | 1 | return self.managers.objects |
|
107 | |||
108 | 1 | def new(self, **kwargs) -> M: |
|
109 | """Equivalent to MyModel(**kwargs) |
||
110 | |||
111 | :param kwargs: |
||
112 | :return: |
||
113 | """ |
||
114 | 1 | return self.model(**kwargs) |
|
115 | |||
116 | |||
117 | 1 | class DjangoIntegration: |
|
118 | """ |
||
119 | Same behaviour as the basic container bug provides a view method which |
||
120 | should be used as a decorator to wrap views. Once wrapped |
||
121 | the view can reference dependencies which will be auto-wired. |
||
122 | """ |
||
123 | |||
124 | 1 | _request_singletons: List[Type] |
|
125 | 1 | _container: WriteableContainer |
|
126 | |||
127 | 1 | def __init__( |
|
128 | self, |
||
129 | container: ExtendableContainer, |
||
130 | models: Optional[List[Type[Model]]] = None, |
||
131 | request_singletons: Optional[List[Type]] = None, |
||
132 | ): |
||
133 | """ |
||
134 | :param models: List of models which should be available for injection |
||
135 | :param request_singletons: |
||
136 | :param container: |
||
137 | """ |
||
138 | 1 | self._container = container.clone() |
|
139 | 1 | self._request_singletons = request_singletons or [] |
|
140 | 1 | self._container.define( |
|
141 | DjangoSettings, ConstructionWithoutContainer(self._load_settings) |
||
142 | ) |
||
143 | 1 | for model in models or []: |
|
144 | 1 | self._container.define(DjangoModel[model], DjangoModel(model)) # type: ignore |
|
145 | |||
146 | 1 | def bind_view(self, view): |
|
147 | """ |
||
148 | Takes either a plain function view or a class based view |
||
149 | binds it to the container then returns something that can |
||
150 | be used in a django url definition. Only arguments with |
||
151 | a default of "lagom.injectable" will be bound to the container. |
||
152 | :param view: |
||
153 | :return: |
||
154 | """ |
||
155 | if isinstance(view, types.FunctionType): |
||
156 | # Plain old function can be bound to the container |
||
157 | return self._container.partial( |
||
158 | view, |
||
159 | shared=self._request_singletons, |
||
160 | container_updater=_update_container_for_request, |
||
161 | ) |
||
162 | return self._bind_view_methods_to_container(view) |
||
163 | |||
164 | 1 | def magic_bind_view(self, view): |
|
165 | """ |
||
166 | Takes either a plain function view or a class based view |
||
167 | binds it to the container then returns something that can |
||
168 | be used in a django url definition |
||
169 | :param view: |
||
170 | :return: |
||
171 | """ |
||
172 | if isinstance(view, types.FunctionType): |
||
173 | # Plain old function can be bound to the container |
||
174 | return self._container.magic_partial( |
||
175 | view, |
||
176 | shared=self._request_singletons, |
||
177 | skip_pos_up_to=1, |
||
178 | container_updater=_update_container_for_request, |
||
179 | ) |
||
180 | return self._bind_view_methods_to_container(view, magic=True) |
||
181 | |||
182 | 1 | def _bind_view_methods_to_container(self, view, magic=False): |
|
183 | for method in View.http_method_names: |
||
184 | if hasattr(view, method): |
||
185 | if magic: |
||
186 | bound_func = self._container.magic_partial( |
||
187 | getattr(view, method), |
||
188 | shared=self._request_singletons, |
||
189 | skip_pos_up_to=1, |
||
190 | container_updater=_update_container_for_request, |
||
191 | ) |
||
192 | else: |
||
193 | bound_func = self._container.partial( |
||
194 | getattr(view, method), |
||
195 | shared=self._request_singletons, |
||
196 | container_updater=_update_container_for_request, |
||
197 | ) |
||
198 | setattr( |
||
199 | view, |
||
200 | method, |
||
201 | bound_func, |
||
202 | ) |
||
203 | return view |
||
204 | |||
205 | 1 | @staticmethod |
|
206 | 1 | def _load_settings(): |
|
207 | from django.conf import settings |
||
208 | |||
209 | return settings |
||
210 | |||
211 | |||
212 | 1 | def _update_container_for_request( |
|
213 | container: WriteableContainer, call_args, call_kwargs |
||
214 | ): |
||
215 | # The first arg is probably a request. |
||
216 | # lets make that available for injection |
||
217 | if len(call_args) > 0: |
||
218 | request = call_args[0] |
||
219 | if isinstance(request, HttpRequest): |
||
0 ignored issues
–
show
Comprehensibility
Best Practice
introduced
by
![]() |
|||
220 | container[HttpRequest] = PlainInstance(request) |
||
221 |