fix atomic operations method config resolution

Author: mahenzon

fastapi_jsonapi/api.py

@@ -22,6 +22,7 @@
 from fastapi_jsonapi.schema_base import BaseModel
 from fastapi_jsonapi.schema_builder import SchemaBuilder
 from fastapi_jsonapi.signature import create_additional_query_params
+from fastapi_jsonapi.utils.dependency_helper import DependencyHelper
 from fastapi_jsonapi.views.utils import (
     HTTPMethod,
     HTTPMethodConfig,
@@ -408,13 +409,6 @@ def _update_method_config_and_get_dependency_params(
 
         return self._create_dependency_params_from_pydantic_model(method_config.dependencies)
 
-    def get_method_config_for_create(self):
-        method_config = self._update_method_config(
-            view=self.list_view_resource,
-            method=HTTPMethod.POST,
-        )
-        return method_config
-
     def prepare_dependencies_handler_signature(
         self,
         custom_handler: Callable[..., Any],
@@ -432,6 +426,35 @@ def prepare_dependencies_handler_signature(
 
         return sig.replace(parameters=params + list(additional_dependency_params) + tail_params)
 
+    async def handle_view_dependencies(
+        self,
+        request: Request,
+        view_cls: Type["ViewBase"],
+        method: HTTPMethod,
+    ) -> Dict[str, Any]:
+        """
+        Consider method config is already prepared for generic views
+        Reuse the same config for atomic operations
+
+        :param request:
+        :param view_cls:
+        :param method:
+        :return:
+        """
+        method_config: HTTPMethodConfig = view_cls.method_dependencies[method]
+
+        def handle_dependencies(**dep_kwargs):
+            return dep_kwargs
+
+        handle_dependencies.__signature__ = self.prepare_dependencies_handler_signature(
+            custom_handler=handle_dependencies,
+            method_config=method_config,
+        )
+
+        dep_helper = DependencyHelper(request=request)
+        dependencies_result: Dict[str, Any] = await dep_helper.run(handle_dependencies)
+        return dependencies_result
+
     def _create_get_resource_list_view(self):
         """
         Create wrapper for GET list (get objects list)

fastapi_jsonapi/atomic/atomic_handler.py

@@ -8,7 +8,6 @@
     Any,
     Awaitable,
     Callable,
-    Dict,
     List,
     Optional,
     TypedDict,
@@ -22,8 +21,6 @@
 from fastapi_jsonapi import RoutersJSONAPI
 from fastapi_jsonapi.atomic.prepared_atomic_operation import LocalIdsType, OperationBase
 from fastapi_jsonapi.atomic.schemas import AtomicOperation, AtomicOperationRequest, AtomicResultResponse
-from fastapi_jsonapi.utils.dependency_helper import DependencyHelper
-from fastapi_jsonapi.views.utils import HTTPMethodConfig
 
 if TYPE_CHECKING:
     from fastapi_jsonapi.data_layers.base import BaseDataLayer
@@ -73,23 +70,6 @@ def __init__(
         self.operations_request = operations_request
         self.local_ids_cache: LocalIdsType = defaultdict(dict)
 
-    async def handle_view_dependencies(
-        self,
-        jsonapi: RoutersJSONAPI,
-    ) -> Dict[str, Any]:
-        method_config: HTTPMethodConfig = jsonapi.get_method_config_for_create()
-
-        def handle_dependencies(**dep_kwargs):
-            return dep_kwargs
-
-        handle_dependencies.__signature__ = jsonapi.prepare_dependencies_handler_signature(
-            custom_handler=handle_dependencies,
-            method_config=method_config,
-        )
-
-        dependencies_result: Dict[str, Any] = await DependencyHelper(request=self.request).run(handle_dependencies)
-        return dependencies_result
-
     async def prepare_one_operation(self, operation: AtomicOperation):
         """
         :param operation:
@@ -102,16 +82,12 @@ async def prepare_one_operation(self, operation: AtomicOperation):
             raise ValueError(msg)
         jsonapi = RoutersJSONAPI.all_jsonapi_routers[operation_type]
 
-        dependencies_result: Dict[str, Any] = await self.handle_view_dependencies(
-            jsonapi=jsonapi,
-        )
-        one_operation = OperationBase.prepare(
+        one_operation = await OperationBase.prepare(
             action=operation.op,
             request=self.request,
             jsonapi=jsonapi,
             ref=operation.ref,
             data=operation.data,
-            data_layer_view_dependencies=dependencies_result,
         )
         return one_operation
 

fastapi_jsonapi/atomic/prepared_atomic_operation.py

@@ -7,6 +7,7 @@
 
 from fastapi_jsonapi import RoutersJSONAPI
 from fastapi_jsonapi.atomic.schemas import AtomicOperationAction, AtomicOperationRef, OperationDataType
+from fastapi_jsonapi.views.utils import HTTPMethod
 
 if TYPE_CHECKING:
     from fastapi_jsonapi.data_layers.base import BaseDataLayer
@@ -27,14 +28,13 @@ class OperationBase:
     op_type: str
 
     @classmethod
-    def prepare(
+    async def prepare(
         cls,
         action: str,
         request: Request,
         jsonapi: RoutersJSONAPI,
         ref: Optional[AtomicOperationRef],
         data: OperationDataType,
-        data_layer_view_dependencies: Dict[str, Any],
     ) -> "OperationBase":
         view_cls: Type[ViewBase] = jsonapi.detail_view_resource
 
@@ -55,6 +55,11 @@ def prepare(
 
         view = view_cls(request=request, jsonapi=jsonapi)
 
+        data_layer_view_dependencies: Dict[str, Any] = await jsonapi.handle_view_dependencies(
+            request=request,
+            view_cls=view_cls,
+            method=operation_cls.http_method,
+        )
         return operation_cls(
             jsonapi=jsonapi,
             view=view,
@@ -127,6 +132,8 @@ class DetailOperationBase(OperationBase):
 
 
 class OperationAdd(ListOperationBase):
+    http_method = HTTPMethod.POST
+
     async def handle(self, dl: BaseDataLayer):
         data_in = self.jsonapi.schema_in_post(data=self.data)
         response = await self.view.process_create_object(
@@ -137,6 +144,8 @@ async def handle(self, dl: BaseDataLayer):
 
 
 class OperationUpdate(DetailOperationBase):
+    http_method = HTTPMethod.PATCH
+
     async def handle(self, dl: BaseDataLayer):
         if self.data is None:
             # TODO: clear to-one relationships
@@ -153,6 +162,8 @@ async def handle(self, dl: BaseDataLayer):
 
 
 class OperationRemove(DetailOperationBase):
+    http_method = HTTPMethod.DELETE
+
     async def handle(
         self,
         dl: BaseDataLayer,