Skip to content

Commit e46a4af

Browse files
committed
client_file -> user_file
1 parent 60a1662 commit e46a4af

File tree

2 files changed

+33
-17
lines changed

2 files changed

+33
-17
lines changed

services/api-server/openapi.json

Lines changed: 26 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -451,13 +451,13 @@
451451
"schema": {
452452
"anyOf": [
453453
{
454-
"$ref": "#/components/schemas/ClientFileInProgramJob"
454+
"$ref": "#/components/schemas/ClientFileToProgramJob"
455455
},
456456
{
457457
"$ref": "#/components/schemas/ClientFile"
458458
}
459459
],
460-
"title": "Client File"
460+
"title": "User File"
461461
}
462462
}
463463
}
@@ -6045,28 +6045,44 @@
60456045
"schemas": {
60466046
"Body_abort_multipart_upload_v0_files__file_id__abort_post": {
60476047
"properties": {
6048-
"client_file": {
6049-
"$ref": "#/components/schemas/ClientFile"
6048+
"user_file": {
6049+
"anyOf": [
6050+
{
6051+
"$ref": "#/components/schemas/ClientFileToProgramJob"
6052+
},
6053+
{
6054+
"$ref": "#/components/schemas/ClientFile"
6055+
}
6056+
],
6057+
"title": "User File"
60506058
}
60516059
},
60526060
"type": "object",
60536061
"required": [
6054-
"client_file"
6062+
"user_file"
60556063
],
60566064
"title": "Body_abort_multipart_upload_v0_files__file_id__abort_post"
60576065
},
60586066
"Body_complete_multipart_upload_v0_files__file_id__complete_post": {
60596067
"properties": {
6060-
"client_file": {
6061-
"$ref": "#/components/schemas/ClientFile"
6068+
"user_file": {
6069+
"anyOf": [
6070+
{
6071+
"$ref": "#/components/schemas/ClientFileToProgramJob"
6072+
},
6073+
{
6074+
"$ref": "#/components/schemas/ClientFile"
6075+
}
6076+
],
6077+
"title": "User File"
60626078
},
60636079
"uploaded_parts": {
60646080
"$ref": "#/components/schemas/FileUploadCompletionBody"
60656081
}
60666082
},
60676083
"type": "object",
60686084
"required": [
6069-
"client_file",
6085+
"user_file",
60706086
"uploaded_parts"
60716087
],
60726088
"title": "Body_complete_multipart_upload_v0_files__file_id__complete_post"
@@ -6114,7 +6130,7 @@
61146130
"title": "ClientFile",
61156131
"description": "Represents a file stored on the client side"
61166132
},
6117-
"ClientFileInProgramJob": {
6133+
"ClientFileToProgramJob": {
61186134
"properties": {
61196135
"filename": {
61206136
"type": "string",
@@ -6170,7 +6186,7 @@
61706186
"job_id",
61716187
"workspace_path"
61726188
],
6173-
"title": "ClientFileInProgramJob"
6189+
"title": "ClientFileToProgramJob"
61746190
},
61756191
"ClientFileUploadData": {
61766192
"properties": {

services/api-server/src/simcore_service_api_server/api/routes/files.py

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -270,21 +270,21 @@ async def upload_files(files: list[UploadFile] = FileParam(...)):
270270
@cancel_on_disconnect
271271
async def get_upload_links(
272272
request: Request,
273-
client_file: ClientFileToProgramJob | ClientFile,
273+
user_file: ClientFileToProgramJob | ClientFile,
274274
user_id: Annotated[PositiveInt, Depends(get_current_user_id)],
275275
webserver_api: Annotated[AuthSession, Depends(get_webserver_session)],
276276
):
277277
"""Get upload links for uploading a file to storage"""
278278
assert request # nosec
279-
file_meta = await _create_domain_file(webserver_api, client_file)
279+
file_meta = await _create_domain_file(webserver_api, user_file)
280280
_, upload_links = await get_upload_links_from_s3(
281281
user_id=user_id,
282282
store_name=None,
283283
store_id=SIMCORE_LOCATION,
284284
s3_object=file_meta.storage_file_id,
285285
client_session=None,
286286
link_type=LinkType.PRESIGNED,
287-
file_size=ByteSize(client_file.filesize),
287+
file_size=ByteSize(user_file.filesize),
288288
is_directory=False,
289289
sha256_checksum=file_meta.sha256_checksum,
290290
)
@@ -382,7 +382,7 @@ async def delete_file(
382382
async def abort_multipart_upload(
383383
request: Request,
384384
file_id: UUID,
385-
client_file: Annotated[ClientFileToProgramJob | ClientFile, Body(..., embed=True)],
385+
user_file: Annotated[ClientFileToProgramJob | ClientFile, Body(..., embed=True)],
386386
storage_client: Annotated[StorageApi, Depends(get_api_client(StorageApi))],
387387
user_id: Annotated[PositiveInt, Depends(get_current_user_id)],
388388
webserver_api: Annotated[AuthSession, Depends(get_webserver_session)],
@@ -391,7 +391,7 @@ async def abort_multipart_upload(
391391
assert request # nosec
392392
assert user_id # nosec
393393

394-
file = await _create_domain_file(webserver_api, client_file)
394+
file = await _create_domain_file(webserver_api, user_file)
395395
abort_link: URL = await storage_client.create_abort_upload_link(
396396
file=file, query={"user_id": str(user_id)}
397397
)
@@ -409,7 +409,7 @@ async def abort_multipart_upload(
409409
async def complete_multipart_upload(
410410
request: Request,
411411
file_id: UUID,
412-
client_file: Annotated[ClientFileToProgramJob | ClientFile, Body(...)],
412+
user_file: Annotated[ClientFileToProgramJob | ClientFile, Body(...)],
413413
uploaded_parts: Annotated[FileUploadCompletionBody, Body(...)],
414414
storage_client: Annotated[StorageApi, Depends(get_api_client(StorageApi))],
415415
user_id: Annotated[PositiveInt, Depends(get_current_user_id)],
@@ -418,7 +418,7 @@ async def complete_multipart_upload(
418418
assert file_id # nosec
419419
assert request # nosec
420420
assert user_id # nosec
421-
file = await _create_domain_file(webserver_api, client_file)
421+
file = await _create_domain_file(webserver_api, user_file)
422422
complete_link: URL = await storage_client.create_complete_upload_link(
423423
file=file, query={"user_id": str(user_id)}
424424
)

0 commit comments

Comments
 (0)