Skip to content

Commit 7da87a3

Browse files
committed
Rationalise the api
1 parent 5bf67cc commit 7da87a3

File tree

6 files changed

+46
-36
lines changed

6 files changed

+46
-36
lines changed

src/murfey/server/api/file_io_instrument.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ class SuggestedPathParameters(BaseModel):
3434
extra_directory: str = ""
3535

3636

37-
@router.post("/visits/{visit_name}/{session_id}/suggested_path")
37+
@router.post("/visits/{visit_name}/sessions/{session_id}/suggested_path")
3838
def suggest_path(
3939
visit_name: str, session_id: int, params: SuggestedPathParameters, db=murfey_db
4040
):
@@ -125,7 +125,7 @@ class FractionationParameters(BaseModel):
125125
fractionation_file_name: str = "eer_fractionation.txt"
126126

127127

128-
@router.post("/visits/{visit_name}/{session_id}/eer_fractionation_file")
128+
@router.post("/visits/{visit_name}/sessions/{session_id}/eer_fractionation_file")
129129
async def write_eer_fractionation_file(
130130
visit_name: str,
131131
session_id: int,

src/murfey/server/api/instrument.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -353,7 +353,7 @@ async def request_gain_reference_upload(
353353
return data
354354

355355

356-
@router.post("/visits/{visit_name}/{session_id}/upstream_tiff_data_request")
356+
@router.post("/visits/{visit_name}/sessions/{session_id}/upstream_tiff_data_request")
357357
async def request_upstream_tiff_data_download(
358358
visit_name: str, session_id: MurfeySessionID, db=murfey_db
359359
):

src/murfey/server/api/session_control.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -424,7 +424,9 @@ async def find_upstream_visits(session_id: MurfeySessionID, db=murfey_db):
424424
return upstream_visits
425425

426426

427-
@correlative_router.get("/visits/{visit_name}/{session_id}/upstream_tiff_paths")
427+
@correlative_router.get(
428+
"/visits/{visit_name}/sessions/{session_id}/upstream_tiff_paths"
429+
)
428430
async def gather_upstream_tiffs(visit_name: str, session_id: int, db=murfey_db):
429431
"""
430432
Looks for TIFF files associated with the current session in the permitted storage
@@ -446,7 +448,7 @@ async def gather_upstream_tiffs(visit_name: str, session_id: int, db=murfey_db):
446448

447449

448450
@correlative_router.get(
449-
"/visits/{visit_name}/{session_id}/upstream_tiff/{tiff_path:path}"
451+
"/visits/{visit_name}/sessions/{session_id}/upstream_tiff/{tiff_path:path}"
450452
)
451453
async def get_tiff(visit_name: str, session_id: int, tiff_path: str, db=murfey_db):
452454
instrument_name = (

src/murfey/server/api/session_info.py

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -135,7 +135,7 @@ class SessionClients(BaseModel):
135135
clients: List[ClientEnvironment]
136136

137137

138-
@router.get("/session/{session_id}")
138+
@router.get("/sessions/{session_id}")
139139
async def get_session(session_id: MurfeySessionID, db=murfey_db) -> SessionClients:
140140
session = db.exec(select(Session).where(Session.id == session_id)).one()
141141
clients = db.exec(
@@ -419,7 +419,9 @@ async def find_upstream_visits(session_id: MurfeySessionID, db=murfey_db):
419419
return upstream_visits
420420

421421

422-
@correlative_router.get("/visits/{visit_name}/{session_id}/upstream_tiff_paths")
422+
@correlative_router.get(
423+
"/visits/{visit_name}/sessions/{session_id}/upstream_tiff_paths"
424+
)
423425
async def gather_upstream_tiffs(visit_name: str, session_id: int, db=murfey_db):
424426
"""
425427
Looks for TIFF files associated with the current session in the permitted storage
@@ -441,7 +443,7 @@ async def gather_upstream_tiffs(visit_name: str, session_id: int, db=murfey_db):
441443

442444

443445
@correlative_router.get(
444-
"/visits/{visit_name}/{session_id}/upstream_tiff/{tiff_path:path}"
446+
"/visits/{visit_name}/sessions/{session_id}/upstream_tiff/{tiff_path:path}"
445447
)
446448
async def get_tiff(visit_name: str, session_id: int, tiff_path: str, db=murfey_db):
447449
instrument_name = (

src/murfey/server/api/workflow.py

Lines changed: 16 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,9 @@ class DCGroupParameters(BaseModel):
9090
atlas_pixel_size: float = 0
9191

9292

93-
@router.post("/visits/{visit_name}/{session_id}/register_data_collection_group")
93+
@router.post(
94+
"/visits/{visit_name}/sessions/{session_id}/register_data_collection_group"
95+
)
9496
def register_dc_group(
9597
visit_name, session_id: MurfeySessionID, dcg_params: DCGroupParameters, db=murfey_db
9698
):
@@ -197,7 +199,7 @@ class DCParameters(BaseModel):
197199
data_collection_tag: str = ""
198200

199201

200-
@router.post("/visits/{visit_name}/{session_id}/start_data_collection")
202+
@router.post("/visits/{visit_name}/sessions/{session_id}/start_data_collection")
201203
def start_dc(
202204
visit_name, session_id: MurfeySessionID, dc_params: DCParameters, db=murfey_db
203205
):
@@ -263,7 +265,7 @@ class ProcessingJobParameters(BaseModel):
263265
experiment_type: str = "spa"
264266

265267

266-
@router.post("/visits/{visit_name}/{session_id}/register_processing_job")
268+
@router.post("/visits/{visit_name}/sessions/{session_id}/register_processing_job")
267269
def register_proc(
268270
visit_name: str,
269271
session_id: MurfeySessionID,
@@ -346,7 +348,7 @@ class Tag(BaseModel):
346348
tag: str
347349

348350

349-
@spa_router.post("/visits/{visit_name}/{session_id}/flush_spa_processing")
351+
@spa_router.post("/visits/{visit_name}/sessions/{session_id}/flush_spa_processing")
350352
def flush_spa_processing(
351353
visit_name: str, session_id: MurfeySessionID, tag: Tag, db=murfey_db
352354
):
@@ -378,7 +380,7 @@ class SPAProcessFile(BaseModel):
378380
source: str = ""
379381

380382

381-
@spa_router.post("/visits/{visit_name}/{session_id}/spa_preprocess")
383+
@spa_router.post("/visits/{visit_name}/sessions/{session_id}/spa_preprocess")
382384
async def request_spa_preprocessing(
383385
visit_name: str,
384386
session_id: MurfeySessionID,
@@ -553,7 +555,9 @@ class Source(BaseModel):
553555
rsync_source: str
554556

555557

556-
@tomo_router.post("/visits/{visit_name}/{session_id}/flush_tomography_processing")
558+
@tomo_router.post(
559+
"/visits/{visit_name}/sessions/{session_id}/flush_tomography_processing"
560+
)
557561
def flush_tomography_processing(
558562
visit_name: str, session_id: MurfeySessionID, rsync_source: Source, db=murfey_db
559563
):
@@ -638,7 +642,7 @@ class TomoProcessFile(BaseModel):
638642
group_tag: Optional[str] = None
639643

640644

641-
@tomo_router.post("/visits/{visit_name}/{session_id}/tomography_preprocess")
645+
@tomo_router.post("/visits/{visit_name}/sessions/{session_id}/tomography_preprocess")
642646
async def request_tomography_preprocessing(
643647
visit_name: str,
644648
session_id: MurfeySessionID,
@@ -741,7 +745,7 @@ async def request_tomography_preprocessing(
741745
return proc_file
742746

743747

744-
@tomo_router.post("/visits/{visit_name}/{session_id}/completed_tilt_series")
748+
@tomo_router.post("/visits/{visit_name}/sesisons{session_id}/completed_tilt_series")
745749
def register_completed_tilt_series(
746750
visit_name: str,
747751
session_id: MurfeySessionID,
@@ -872,7 +876,7 @@ class TiltInfo(BaseModel):
872876
source: str
873877

874878

875-
@tomo_router.post("/visits/{visit_name}/{session_id}/tilt")
879+
@tomo_router.post("/visits/{visit_name}/sessions{session_id}/tilt")
876880
async def register_tilt(
877881
visit_name: str, session_id: MurfeySessionID, tilt_info: TiltInfo, db=murfey_db
878882
):
@@ -1006,7 +1010,9 @@ class MillingParameters(BaseModel):
10061010
raw_directory: str
10071011

10081012

1009-
@correlative_router.post("/visits/{year}/{visit_name}/{session_id}/make_milling_gif")
1013+
@correlative_router.post(
1014+
"/year/{year}/visits/{visit_name}/sessions/{session_id}/make_milling_gif"
1015+
)
10101016
async def make_gif(
10111017
year: int,
10121018
visit_name: str,

src/murfey/util/route_manifest.yaml

Lines changed: 18 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -436,7 +436,7 @@ murfey.server.api.file_io_frontend.router:
436436
methods:
437437
- POST
438438
murfey.server.api.file_io_instrument.router:
439-
- path: /file_io/instrument/visits/{visit_name}/{session_id}/suggested_path
439+
- path: /file_io/instrument/visits/{visit_name}/sessions/{session_id}/suggested_path
440440
function: suggest_path
441441
path_params:
442442
- name: visit_name
@@ -457,7 +457,7 @@ murfey.server.api.file_io_instrument.router:
457457
path_params: []
458458
methods:
459459
- POST
460-
- path: /file_io/instrument/visits/{visit_name}/{session_id}/eer_fractionation_file
460+
- path: /file_io/instrument/visits/{visit_name}/sessions/{session_id}/eer_fractionation_file
461461
function: write_eer_fractionation_file
462462
path_params:
463463
- name: visit_name
@@ -542,7 +542,7 @@ murfey.server.api.instrument.router:
542542
path_params: []
543543
methods:
544544
- POST
545-
- path: /instrument_server/visits/{visit_name}/{session_id}/upstream_tiff_data_request
545+
- path: /instrument_server/visits/{visit_name}/sessions/{session_id}/upstream_tiff_data_request
546546
function: request_upstream_tiff_data_download
547547
path_params:
548548
- name: visit_name
@@ -671,7 +671,7 @@ murfey.server.api.session_control.correlative_router:
671671
path_params: []
672672
methods:
673673
- GET
674-
- path: /session_control/correlative/visits/{visit_name}/{session_id}/upstream_tiff_paths
674+
- path: /session_control/correlative/visits/{visit_name}/sessions/{session_id}/upstream_tiff_paths
675675
function: gather_upstream_tiffs
676676
path_params:
677677
- name: visit_name
@@ -680,7 +680,7 @@ murfey.server.api.session_control.correlative_router:
680680
type: int
681681
methods:
682682
- GET
683-
- path: /session_control/correlative/visits/{visit_name}/{session_id}/upstream_tiff/{tiff_path:path}
683+
- path: /session_control/correlative/visits/{visit_name}/sessions/{session_id}/upstream_tiff/{tiff_path:path}
684684
function: get_tiff
685685
path_params:
686686
- name: visit_name
@@ -861,7 +861,7 @@ murfey.server.api.session_info.correlative_router:
861861
path_params: []
862862
methods:
863863
- GET
864-
- path: /session_info/correlative/visits/{visit_name}/{session_id}/upstream_tiff_paths
864+
- path: /session_info/correlative/visits/{visit_name}/sessions/{session_id}/upstream_tiff_paths
865865
function: gather_upstream_tiffs
866866
path_params:
867867
- name: visit_name
@@ -870,7 +870,7 @@ murfey.server.api.session_info.correlative_router:
870870
type: int
871871
methods:
872872
- GET
873-
- path: /session_info/correlative/visits/{visit_name}/{session_id}/upstream_tiff/{tiff_path:path}
873+
- path: /session_info/correlative/visits/{visit_name}/sessions/{session_id}/upstream_tiff/{tiff_path:path}
874874
function: get_tiff
875875
path_params:
876876
- name: visit_name
@@ -918,7 +918,7 @@ murfey.server.api.session_info.router:
918918
path_params: []
919919
methods:
920920
- GET
921-
- path: /session_info/session/{session_id}
921+
- path: /session_info/sessions/{session_id}
922922
function: get_session
923923
path_params: []
924924
methods:
@@ -1105,7 +1105,7 @@ murfey.server.api.workflow.correlative_router:
11051105
type: str
11061106
methods:
11071107
- POST
1108-
- path: /workflow/correlative/visits/{year}/{visit_name}/{session_id}/make_milling_gif
1108+
- path: /workflow/correlative/year/{year}/visits/{visit_name}/sessions/{session_id}/make_milling_gif
11091109
function: make_gif
11101110
path_params:
11111111
- name: year
@@ -1117,21 +1117,21 @@ murfey.server.api.workflow.correlative_router:
11171117
methods:
11181118
- POST
11191119
murfey.server.api.workflow.router:
1120-
- path: /workflow/visits/{visit_name}/{session_id}/register_data_collection_group
1120+
- path: /workflow/visits/{visit_name}/sessions/{session_id}/register_data_collection_group
11211121
function: register_dc_group
11221122
path_params:
11231123
- name: visit_name
11241124
type: typing.Any
11251125
methods:
11261126
- POST
1127-
- path: /workflow/visits/{visit_name}/{session_id}/start_data_collection
1127+
- path: /workflow/visits/{visit_name}/sessions/{session_id}/start_data_collection
11281128
function: start_dc
11291129
path_params:
11301130
- name: visit_name
11311131
type: typing.Any
11321132
methods:
11331133
- POST
1134-
- path: /workflow/visits/{visit_name}/{session_id}/register_processing_job
1134+
- path: /workflow/visits/{visit_name}/sessions/{session_id}/register_processing_job
11351135
function: register_proc
11361136
path_params:
11371137
- name: visit_name
@@ -1144,14 +1144,14 @@ murfey.server.api.workflow.spa_router:
11441144
path_params: []
11451145
methods:
11461146
- POST
1147-
- path: /workflow/spa/visits/{visit_name}/{session_id}/flush_spa_processing
1147+
- path: /workflow/spa/visits/{visit_name}/sessions/{session_id}/flush_spa_processing
11481148
function: flush_spa_processing
11491149
path_params:
11501150
- name: visit_name
11511151
type: str
11521152
methods:
11531153
- POST
1154-
- path: /workflow/spa/visits/{visit_name}/{session_id}/spa_preprocess
1154+
- path: /workflow/spa/visits/{visit_name}/sessions/{session_id}/spa_preprocess
11551155
function: request_spa_preprocessing
11561156
path_params:
11571157
- name: visit_name
@@ -1164,7 +1164,7 @@ murfey.server.api.workflow.tomo_router:
11641164
path_params: []
11651165
methods:
11661166
- POST
1167-
- path: /workflow/tomo/visits/{visit_name}/{session_id}/flush_tomography_processing
1167+
- path: /workflow/tomo/visits/{visit_name}/sessions/{session_id}/flush_tomography_processing
11681168
function: flush_tomography_processing
11691169
path_params:
11701170
- name: visit_name
@@ -1185,14 +1185,14 @@ murfey.server.api.workflow.tomo_router:
11851185
type: int
11861186
methods:
11871187
- POST
1188-
- path: /workflow/tomo/visits/{visit_name}/{session_id}/tomography_preprocess
1188+
- path: /workflow/tomo/visits/{visit_name}/sessions/{session_id}/tomography_preprocess
11891189
function: request_tomography_preprocessing
11901190
path_params:
11911191
- name: visit_name
11921192
type: str
11931193
methods:
11941194
- POST
1195-
- path: /workflow/tomo/visits/{visit_name}/{session_id}/completed_tilt_series
1195+
- path: /workflow/tomo/visits/{visit_name}/sessions/{session_id}/completed_tilt_series
11961196
function: register_completed_tilt_series
11971197
path_params:
11981198
- name: visit_name
@@ -1206,7 +1206,7 @@ murfey.server.api.workflow.tomo_router:
12061206
type: str
12071207
methods:
12081208
- POST
1209-
- path: /workflow/tomo/visits/{visit_name}/{session_id}/tilt
1209+
- path: /workflow/tomo/visits/{visit_name}/sessions/{session_id}/tilt
12101210
function: register_tilt
12111211
path_params:
12121212
- name: visit_name

0 commit comments

Comments
 (0)