Bump moto-ext to 5.0.6.post2

localstack/services/apigateway/patches.py

@@ -37,50 +37,25 @@ def apigateway_models_Stage_init(
  apigateway_models_Stage_init_orig = apigateway_models.Stage.__init__
  apigateway_models.Stage.__init__ = apigateway_models_Stage_init
 
- @patch(APIGatewayResponse.integrations)
- def apigateway_response_integrations(fn, self, request, *args, **kwargs):
- result = fn(self, request, *args, **kwargs)
-
- if self.method not in ["PUT", "PATCH"]:
- return result
+ @patch(APIGatewayResponse.put_integration)
+ def apigateway_put_integration(fn, self, *args, **kwargs):
+ # TODO: verify if this patch is still necessary, this might have been fixed upstream
+ fn(self, *args, **kwargs)
 
  url_path_parts = self.path.split("/")
  function_id = url_path_parts[2]
  resource_id = url_path_parts[4]
  method_type = url_path_parts[6]
-
  integration = self.backend.get_integration(function_id, resource_id, method_type)
- if not integration:
- return result
-
- if self.method == "PUT":
- timeout_milliseconds = self._get_param("timeoutInMillis")
- cache_key_parameters = self._get_param("cacheKeyParameters") or []
- content_handling = self._get_param("contentHandling")
- integration.cache_namespace = resource_id
- integration.timeout_in_millis = timeout_milliseconds
- integration.cache_key_parameters = cache_key_parameters
- integration.content_handling = content_handling
- return 201, {}, json.dumps(integration.to_json())
-
- if self.method == "PATCH":
- patch_operations = self._get_param("patchOperations")
- apply_json_patch_safe(integration.to_json(), patch_operations, in_place=True)
- # fix data types
- if integration.timeout_in_millis:
- integration.timeout_in_millis = int(integration.timeout_in_millis)
- if skip_verification := (integration.tls_config or {}).get("insecureSkipVerification"):
- integration.tls_config["insecureSkipVerification"] = str_to_bool(skip_verification)
- return 200, {}, json.dumps(integration.to_json())
-
- return result
 
- def backend_update_deployment(self, function_id, deployment_id, patch_operations):
- rest_api = self.get_rest_api(function_id)
- deployment = rest_api.get_deployment(deployment_id)
- deployment = deployment.to_json() or {}
- apply_json_patch_safe(deployment, patch_operations, in_place=True)
- return deployment
+ timeout_milliseconds = self._get_param("timeoutInMillis")
+ cache_key_parameters = self._get_param("cacheKeyParameters") or []
+ content_handling = self._get_param("contentHandling")
+ integration.cache_namespace = resource_id
+ integration.timeout_in_millis = timeout_milliseconds
+ integration.cache_key_parameters = cache_key_parameters
+ integration.content_handling = content_handling
+ return 201, {}, json.dumps(integration.to_json())
 
  # define json-patch operations for backend models
 
@@ -140,9 +115,6 @@ def apigateway_models_resource_get_integration(fn, self, method_type):
  raise NoIntegrationDefined()
  return resource_method.method_integration
 
- if not hasattr(apigateway_models.APIGatewayBackend, "update_deployment"):
- apigateway_models.APIGatewayBackend.update_deployment = backend_update_deployment
-
  @patch(apigateway_models.RestAPI.to_dict)
  def apigateway_models_rest_api_to_dict(fn, self):
  resp = fn(self)
@@ -172,20 +144,6 @@ def apigateway_models_stage_to_json(fn, self):
 
  return result
 
- @patch(APIGatewayResponse.individual_deployment)
- def individual_deployment(fn, self, request, full_url, headers, *args, **kwargs):
- result = fn(self, request, full_url, headers, *args, **kwargs)
- if self.method == "PATCH":
- url_path_parts = self.path.split("/")
- function_id = url_path_parts[2]
- deployment_id = url_path_parts[4]
- patch_operations = self._get_param("patchOperations")
- deployment = self.backend.update_deployment(
- function_id, deployment_id, patch_operations
- )
- return 201, {}, json.dumps(deployment)
- return result
-
  @patch(apigateway_models.APIGatewayBackend.create_rest_api)
  def create_rest_api(fn, self, *args, tags=None, **kwargs):
  """

localstack/services/apigateway/provider.py

@@ -32,6 +32,7 @@
  CreateAuthorizerRequest,
  CreateRestApiRequest,
  CreateStageRequest,
+ Deployment,
  DocumentationPart,
  DocumentationPartIds,
  DocumentationPartLocation,
@@ -1064,6 +1065,32 @@ def _patch_stage_response(self, response: dict):
  if not response.get("variables"):
  response.pop("variables", None)
 
+ def update_deployment(
+ self,
+ context: RequestContext,
+ rest_api_id: String,
+ deployment_id: String,
+ patch_operations: ListOfPatchOperation = None,
+ **kwargs,
+ ) -> Deployment:
+ moto_rest_api = get_moto_rest_api(context, rest_api_id)
+ try:
+ deployment = moto_rest_api.get_deployment(deployment_id)
+ except KeyError:
+ raise NotFoundException("Invalid Deployment identifier specified")
+
+ for patch_operation in patch_operations:
+ # TODO: add validation for unsupported paths
+ # see https://docs.aws.amazon.com/apigateway/latest/api/patch-operations.html#UpdateDeployment-Patch
+ if (
+ patch_operation.get("path") == "/description"
+ and patch_operation.get("op") == "replace"
+ ):
+ deployment.description = patch_operation["value"]
+
+ deployment_response: Deployment = deployment.to_json() or {}
+ return deployment_response
+
  # authorizers
 
  @handler("CreateAuthorizer", expand=False)
@@ -1896,6 +1923,36 @@ def put_integration(
 
  return response
 
+ def update_integration(
+ self,
+ context: RequestContext,
+ rest_api_id: String,
+ resource_id: String,
+ http_method: String,
+ patch_operations: ListOfPatchOperation = None,
+ **kwargs,
+ ) -> Integration:
+ moto_rest_api = get_moto_rest_api(context=context, rest_api_id=rest_api_id)
+ resource = moto_rest_api.resources.get(resource_id)
+ if not resource:
+ raise NotFoundException("Invalid Resource identifier specified")
+
+ method = resource.resource_methods.get(http_method)
+ if not method:
+ raise NotFoundException("Invalid Integration identifier specified")
+
+ integration = method.method_integration
+ _patch_api_gateway_entity(integration, patch_operations)
+
+ # fix data types
+ if integration.timeout_in_millis:
+ integration.timeout_in_millis = int(integration.timeout_in_millis)
+ if skip_verification := (integration.tls_config or {}).get("insecureSkipVerification"):
+ integration.tls_config["insecureSkipVerification"] = str_to_bool(skip_verification)
+
+ integration_dict: Integration = integration.to_json()
+ return integration_dict
+
  def delete_integration(
  self,
  context: RequestContext,

pyproject.toml

@@ -90,7 +90,7 @@ runtime = [
  "json5>=0.9.11",
  "jsonpath-ng>=1.6.1",
  "jsonpath-rw>=1.4.0",
- "moto-ext[all]==5.0.5.post1",
+ "moto-ext[all]==5.0.6.post2",
  "opensearch-py>=2.4.1",
  "pymongo>=4.2.0",
  "pyopenssl>=23.0.0",

requirements-dev.txt

@@ -275,7 +275,7 @@ markupsafe==2.1.5
  # werkzeug
 mdurl==0.1.2
  # via markdown-it-py
-moto-ext==5.0.5.post1
+moto-ext==5.0.6.post2
  # via localstack-core
 mpmath==1.3.0
  # via sympy

requirements-runtime.txt

@@ -212,7 +212,7 @@ markupsafe==2.1.5
  # werkzeug
 mdurl==0.1.2
  # via markdown-it-py
-moto-ext==5.0.5.post1
+moto-ext==5.0.6.post2
  # via localstack-core (pyproject.toml)
 mpmath==1.3.0
  # via sympy

requirements-test.txt

@@ -259,7 +259,7 @@ markupsafe==2.1.5
  # werkzeug
 mdurl==0.1.2
  # via markdown-it-py
-moto-ext==5.0.5.post1
+moto-ext==5.0.6.post2
  # via localstack-core
 mpmath==1.3.0
  # via sympy

requirements-typehint.txt

@@ -279,7 +279,7 @@ markupsafe==2.1.5
  # werkzeug
 mdurl==0.1.2
  # via markdown-it-py
-moto-ext==5.0.5.post1
+moto-ext==5.0.6.post2
  # via localstack-core
 mpmath==1.3.0
  # via sympy