|
1 | 1 | import asyncio |
2 | 2 | import logging |
3 | | -import socket |
4 | 3 | import urllib.parse |
5 | 4 | from typing import Annotated, cast |
6 | 5 |
|
@@ -268,18 +267,21 @@ async def complete_upload_file( |
268 | 267 | name=create_upload_completion_task_name(query_params.user_id, file_id), |
269 | 268 | ) |
270 | 269 | get_completed_upload_tasks(request.app)[task.get_name()] = task |
271 | | - server_ip = socket.gethostbyname(f"{request.url.hostname}") |
272 | | - server_port = f":{request.url.port}" if request.url.port else "" |
273 | 270 |
|
274 | | - route = URL( |
275 | | - request.app.url_path_for( |
276 | | - "is_completed_upload_file", |
277 | | - location_id=f"{location_id}", |
278 | | - file_id=file_id, |
279 | | - future_id=task.get_name(), |
| 271 | + route = ( |
| 272 | + URL(f"{request.url}") |
| 273 | + .with_path( |
| 274 | + request.app.url_path_for( |
| 275 | + "is_completed_upload_file", |
| 276 | + location_id=f"{location_id}", |
| 277 | + file_id=file_id, |
| 278 | + future_id=task.get_name(), |
| 279 | + ) |
280 | 280 | ) |
281 | | - ).with_query(user_id=query_params.user_id) |
282 | | - complete_task_state_url = f"{request.url.scheme}://{server_ip}{server_port}{route}" |
| 281 | + .with_query(user_id=query_params.user_id) |
| 282 | + ) |
| 283 | + complete_task_state_url = f"{route}" |
| 284 | + |
283 | 285 | response = FileUploadCompleteResponse( |
284 | 286 | links=FileUploadCompleteLinks( |
285 | 287 | state=TypeAdapter(AnyUrl).validate_python(complete_task_state_url) |
|
0 commit comments