Skip to content

Commit 0c07e27

Browse files
committed
could not get the real IP
1 parent b5d3765 commit 0c07e27

File tree

1 file changed

+13
-11
lines changed
  • services/storage/src/simcore_service_storage/api/rest

1 file changed

+13
-11
lines changed

services/storage/src/simcore_service_storage/api/rest/_files.py

Lines changed: 13 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
import asyncio
22
import logging
3-
import socket
43
import urllib.parse
54
from typing import Annotated, cast
65

@@ -268,18 +267,21 @@ async def complete_upload_file(
268267
name=create_upload_completion_task_name(query_params.user_id, file_id),
269268
)
270269
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 ""
273270

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+
)
280280
)
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+
283285
response = FileUploadCompleteResponse(
284286
links=FileUploadCompleteLinks(
285287
state=TypeAdapter(AnyUrl).validate_python(complete_task_state_url)

0 commit comments

Comments
 (0)