Scott.Idem/OSIT-AE-API-FastAPI
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Working on the basic SQL select API CRUD

Browse Source
This commit is contained in:
Scott Idem
2021-03-05 17:58:25 -05:00
parent 28cf7ecf11
commit 890263c586
1 changed files with 38 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

51
app/routers/api_crud.py
View File

@@ -13,6 +13,20 @@ from app.db import *
from .user_model import *
from .response_model import *
obj_l1_type_li = {}
obj_l1_type_li['account'] = 'v_account'
obj_l1_type_li['address'] = 'v_address'
obj_l1_type_li['archive'] = 'v_archive'
obj_l1_type_li['contact'] = 'v_contact'
obj_l1_type_li['event'] = 'v_event'
obj_l1_type_li['order'] = 'v_order'
obj_l1_type_li['organization'] = 'v_organization'
obj_l1_type_li['person'] = 'v_person'
obj_l1_type_li['site'] = 'v_site'
obj_l1_type_li['user'] = 'v_user'
router = APIRouter()
@@ -37,10 +51,11 @@ async def get_obj_li(object_l1: str=None, object_l2: str=None, object_l3: str=No
return response_data
@router.get('/{object_l1}/{object_id}')
@router.get('/{object_l1}/{object_l2}/{object_id}')
@router.get('/{object_l1}/{object_l2}/{object_l3}/{object_id}')
async def get_obj(object_l1: str=None, object_l2: str=None, object_l3: str=None, object_id: str=None, x_account_id: str = Header(...),
#@router.get('/{obj_type_l1}/{object_id_int}')
@router.get('/{obj_type_l1}/{object_id}')
@router.get('/{obj_type_l1}/{object_l2}/{object_id}')
@router.get('/{obj_type_l1}/{object_l2}/{object_l3}/{object_id}')
async def get_obj(obj_type_l1: str=None, object_l2: str=None, object_l3: str=None, object_id: str=None, x_account_id: str = Header(...),
qry_str: Optional[str] = Query(None, max_length=50),
qry_int: Optional[int] = None,
by_alias: Optional[bool] = True,
@@ -49,16 +64,26 @@ async def get_obj(object_l1: str=None, object_l2: str=None, object_l3: str=None,
log.setLevel(logging.DEBUG) # DEBUG, INFO, WARNING, ERROR, EXCEPTION, CRITICAL
log.debug(locals())
log.debug(by_alias)
log.debug(exclude_unset)
log.debug(qry_str)
log.debug(qry_int)
debug_data = {}
debug_data['obj_type_l1'] = obj_type_l1
debug_data['object_l2'] = object_l2
debug_data['object_l3'] = object_l3
debug_data['object_id'] = object_id
#debug_data['object_id_int'] = object_id_int
#debug_data['object_id_rand'] = object_id_rand
response_data = {}
response_data['object_l1'] = object_l1
response_data['object_l2'] = object_l2
response_data['object_l3'] = object_l3
response_data['object_id'] = object_id
log.debug(debug_data)
if obj_type_l1 in obj_l1_type_li:
object_type = obj_l1_type_li[obj_type_l1]
else:
return mk_resp(data=False, status_code=400)
# NOTE: Add a check for the object ID... assuming it is a random ID string for now.
sql_result = sql_select(table_name=object_type, record_id_random=object_id)
log.debug(sql_result)
resp_data = User_Base(**sql_result).dict(by_alias=by_alias, exclude_unset=exclude_unset)
return mk_resp(data=resp_data)#, details=debug_data)
data = {}
data['id_random'] = 1