Work on event launcher and related

This commit is contained in:
Scott Idem
2021-10-21 01:08:07 -04:00
parent 53c6c6b51c
commit bde6ec1a2b
6 changed files with 248 additions and 12 deletions

View File

@@ -9,7 +9,7 @@ from app.db_sql import *
from app.routers.api_crud import delete_obj_template, get_obj_template, get_obj_li_template, patch_obj_template, post_obj_template
from app.methods.event_presentation_methods import load_event_presentation_obj
from app.methods.event_presentation_methods import get_event_presentation_rec_list, load_event_presentation_obj
from app.models.event_presentation_models import Event_Presentation_Base
from app.models.response_models import *
@@ -18,7 +18,7 @@ from app.models.response_models import *
router = APIRouter()
@router.post('', response_model=Resp_Body_Base)
@router.post('/event/presentation', response_model=Resp_Body_Base)
async def post_event_presentation_obj(
obj: Event_Presentation_Base,
x_account_id: str = Header(...),
@@ -42,7 +42,7 @@ async def post_event_presentation_obj(
return result
@router.patch('/{obj_id}', response_model=Resp_Body_Base)
@router.patch('/event/presentation/{obj_id}', response_model=Resp_Body_Base)
async def patch_event_presentation_obj(
obj: Event_Presentation_Base,
obj_id: str = Query(..., min_length=1, max_length=22),
@@ -71,7 +71,7 @@ async def patch_event_presentation_obj(
# ### BEGIN ### API Event Presentation ### patch_event_presentation_json() ###
@router.patch('/{event_presentation_id}/json', response_model=Resp_Body_Base)
@router.patch('/event/presentation/{event_presentation_id}/json', response_model=Resp_Body_Base)
async def patch_event_presentation_json(
event_presentation_obj: Event_Presentation_Base,
event_presentation_id: str = Query(..., min_length=1, max_length=22),
@@ -112,7 +112,7 @@ async def patch_event_presentation_json(
# ### BEGIN ### API Event Presentation ### get_event_presentation_obj() ###
# Working well as of 2021-06-07. Using as a template for other routes.
@router.get('/{event_presentation_id}', response_model=Resp_Body_Base)
@router.get('/event/presentation/{event_presentation_id}', response_model=Resp_Body_Base)
async def get_event_presentation_obj(
event_presentation_id: str = Query(..., min_length=1, max_length=22),
enabled: str = 'enabled', # enabled, disabled, all; For now this covers any included objects or object lists
@@ -179,7 +179,75 @@ async def get_event_presentation_obj(
# ### END ### API Event Presentation ### get_event_presentation_obj() ###
@router.delete('/{obj_id}', response_model=Resp_Body_Base)
# ### BEGIN ### API Event Presentation ### get_event_session_event_presentation_li() ###
# Updated 2021-10-20
@router.get('/event/session/{event_session_id}/event/presentation/list', response_model=Resp_Body_Base)
async def get_event_session_event_presentation_li(
event_session_id: str = Query(..., min_length=11, max_length=22),
enabled: str = 'enabled', # enabled, disabled, all
limit: int = 50,
# inc_address: bool = False,
# inc_contact: bool = False,
inc_event_file_list: bool = False,
inc_event_presenter_list: bool = False,
inc_event_person: bool = False, # Intended for event_presenter
# inc_event_person_list: bool = False,
inc_person: bool = False, # Intended for event_presenter > event_person
review: str = 'ready', # ready, not_ready, all
approved: str = 'approved', # approved, not_approved, all
hidden: str = 'not_hidden', # hidden, not_hidden, all
inc_file_count: bool = False, # NOTE: file counts are from separate views
x_account_id: str = Header(...),
by_alias: Optional[bool] = True,
exclude_unset: Optional[bool] = True,
response: Response = Response,
):
log.setLevel(logging.DEBUG) # DEBUG, INFO, WARNING, ERROR, EXCEPTION, CRITICAL
log.debug(locals())
if event_session_id := redis_lookup_id_random(record_id_random=event_session_id, table_name='event_session'): pass
else: return mk_resp(data=None, status_code=404, response=response)
# Updated 2021-10-20
if event_presentation_rec_list_result := get_event_presentation_rec_list(
event_session_id = event_session_id,
review = review, # ready, not_ready, all
approved = approved, # approve(d), not_approved, all
hidden = hidden, # hidden, not_hidden, all
enabled = enabled,
limit = limit,
):
event_presentation_result_list = []
for event_presentation_rec in event_presentation_rec_list_result:
if load_event_presentation_result := load_event_presentation_obj(
event_presentation_id = event_presentation_rec.get('event_presentation_id', None),
enabled = enabled,
# review = review,
# approved = approved,
hidden = hidden,
inc_file_count = inc_file_count,
inc_event_file_list = inc_event_file_list,
inc_event_presenter_list = inc_event_presenter_list,
inc_person = inc_person,
limit = limit,
by_alias = by_alias,
exclude_unset = exclude_unset,
# model_as_dict = model_as_dict,
):
event_presentation_result_list.append(load_event_presentation_result)
else:
event_presentation_result_list.append(None)
response_data = event_presentation_result_list
elif isinstance(event_presentation_rec_list_result, list):
return mk_resp(data=False, status_code=404, response=response) # Not Found
else:
return mk_resp(data=False, status_code=400, response=response) # Bad Request
return mk_resp(data=response_data, response=response)
# ### END ### API Event Presentation ### get_event_session_event_presentation_li() ###
@router.delete('/event/presentation/{obj_id}', response_model=Resp_Body_Base)
async def delete_event_presentation_obj(
obj_id: str = Query(..., min_length=1, max_length=22),
x_account_id: str = Header(...),
@@ -193,4 +261,4 @@ async def delete_event_presentation_obj(
obj_type=obj_type,
obj_id=obj_id,
)
return result
return result