|
14 | 14 | from botocore.model import OperationModel
|
15 | 15 | from localstack import config
|
16 | 16 | from localstack import config as localstack_config
|
17 |
| -from localstack.aws.api import HttpRequest |
18 | 17 | from localstack.aws.protocol.parser import create_parser
|
19 | 18 | from localstack.aws.spec import load_service
|
20 | 19 | from localstack.config import external_service_url
|
@@ -86,7 +85,7 @@ def proxy_request(self, request: Request, data: bytes) -> Response:
|
86 | 85 | query_string,
|
87 | 86 | )
|
88 | 87 |
|
89 |
| - request = HttpRequest( |
| 88 | + request = Request( |
90 | 89 | body=data,
|
91 | 90 | method=request.method,
|
92 | 91 | headers=request.headers,
|
@@ -157,7 +156,7 @@ def register_in_instance(self):
|
157 | 156 | raise
|
158 | 157 |
|
159 | 158 | def _parse_aws_request(
|
160 |
| - self, request: HttpRequest, service_name: str, region_name: str, client |
| 159 | + self, request: Request, service_name: str, region_name: str, client |
161 | 160 | ) -> Tuple[OperationModel, AWSPreparedRequest, Dict]:
|
162 | 161 | parser = create_parser(load_service(service_name))
|
163 | 162 | operation_model, parsed_request = parser.parse(request)
|
@@ -246,7 +245,7 @@ def _adjust_request_dict(self, service_name: str, request_dict: Dict):
|
246 | 245 | req_json["QueueOwnerAWSAccountId"] = account_id
|
247 | 246 | request_dict["body"] = to_bytes(json.dumps(req_json))
|
248 | 247 |
|
249 |
| - def _fix_headers(self, request: HttpRequest, service_name: str): |
| 248 | + def _fix_headers(self, request: Request, service_name: str): |
250 | 249 | if service_name == "s3":
|
251 | 250 | # fix the Host header, to avoid bucket addressing issues
|
252 | 251 | host = request.headers.get("Host") or ""
|
|
0 commit comments