Skip to content

Commit a422ebc

Browse files
authored
Add endpoint to get sessions by instrument name (#552)
1 parent 84770ff commit a422ebc

File tree

2 files changed

+20
-0
lines changed

2 files changed

+20
-0
lines changed

src/murfey/server/api/__init__.py

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1857,6 +1857,16 @@ async def get_sessions(db=murfey_db):
18571857
return res
18581858

18591859

1860+
@router.get("/instruments/{instrument_name}/sessions")
1861+
async def get_sessions_by_instrument_name(
1862+
instrument_name: str, db=murfey_db
1863+
) -> List[Session]:
1864+
sessions = db.exec(
1865+
select(Session).where(Session.instrument_name == instrument_name)
1866+
).all()
1867+
return sessions
1868+
1869+
18601870
@router.post("/instruments/{instrument_name}/clients/{client_id}/session")
18611871
def link_client_to_session(
18621872
instrument_name: str, client_id: int, sess: SessionInfo, db=murfey_db

src/murfey/server/demo_api.py

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1615,6 +1615,16 @@ async def get_sessions(db=murfey_db):
16151615
return res
16161616

16171617

1618+
@router.get("/instruments/{instrument_name}/sessions")
1619+
async def get_sessions_by_instrument_name(
1620+
instrument_name: str, db=murfey_db
1621+
) -> List[Session]:
1622+
sessions = db.exec(
1623+
select(Session).where(Session.instrument_name == instrument_name)
1624+
).all()
1625+
return sessions
1626+
1627+
16181628
@router.post("/instruments/{instrument_name}/clients/{client_id}/session")
16191629
def link_client_to_session(
16201630
instrument_name: str, client_id: int, sess: SessionInfo, db=murfey_db

0 commit comments

Comments
 (0)