Skip to content

55 agent management modal #78

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
d-linko merged 8 commits into from
May 22, 2024
Merged

55 agent management modal #78

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
31cb26a
#55: Updated pagination styling/position, added build button to launc…
njbrunner Feb 24, 2024
11d4122
#55: Added build modal and logic to track selection of agents
njbrunner Feb 24, 2024
8565ed2
#55: Updates to all parameter components. Integrated ARI builder into…
njbrunner May 1, 2024
504abf7
#55: Finished Manage Agent Modal
njbrunner May 16, 2024
9fe1526
#55: Updated build page with new parameter classes
njbrunner May 16, 2024
1dc8640
added the string cbor option to the build vue
May 17, 2024
e0da15b
updated to text using cbor prop
May 17, 2024
12cf625
55# Small styling cleanups
njbrunner May 17, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 12 additions & 1 deletion anms-core/anms/routes/transcoder.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -56,6 +56,10 @@ async def paged_transcoder_log(query: str, params: Params = Depends()):
TranscoderLog.cbor.ilike(query)
)).order_by(desc(TranscoderLog.transcoder_log_id)), params)

@router.get("/db/id/{id}", status_code=status.HTTP_200_OK, response_model=TL)
async def transcoder_log_by_id(id: str):
with get_session() as session:
return TranscoderLog.query.filter_by(transcoder_log_id=id).first()

# PUT /ui/incoming/{cbor}/hex
@router.put("/ui/incoming/{cbor}/hex", status_code=status.HTTP_200_OK)
Expand All @@ -81,13 +85,20 @@ def transcoder_put_str(ari: str):
ari = ari.strip()
msg = json.dumps({"uri": ari})
logger.info(ari)
transcoder_log_id = None
with get_session() as session:
curr_uri = TranscoderLog.query.filter_by(input_string=ari).first()
if curr_uri is None:
c1 = TranscoderLog(input_string=ari, parsed_as='pending')
session.add(c1)
session.flush()
session.refresh(c1)
transcoder_log_id = c1.transcoder_log_id
session.commit()
else:
transcoder_log_id = curr_uri.transcoder_log_id

logger.info('PUBLISH to transcode/CoreFacing/Outgoing, msg = %s' % msg)
MQTT_CLIENT.publish("transcode/CoreFacing/Outgoing", msg)
return status.HTTP_200_OK

return {"id": transcoder_log_id}
Loading