Working on membership, fundraising, and products and other things

app/routers/membership_group.py

@@ -9,7 +9,7 @@ from app.db_sql import sql_insert, sql_update, sql_insert_or_update, sql_select,
 
 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.membership_group_methods import load_membership_group_obj
+from app.methods.membership_group_methods import get_membership_group_rec_list, load_membership_group_obj
 
 from app.models.membership_group_models import Membership_Group_Base
 from app.models.response_models import Resp_Body_Base, mk_resp
@@ -18,7 +18,7 @@ from app.models.response_models import Resp_Body_Base, mk_resp
 router = APIRouter()
 
 
-@router.post('', response_model=Resp_Body_Base)
+@router.post('/membership/group', response_model=Resp_Body_Base)
 async def post_membership_group_obj(
         obj: Membership_Group_Base,
         x_account_id: str = Header(...),
@@ -41,7 +41,7 @@ async def post_membership_group_obj(
     return result
 
 
-@router.patch('/{obj_id}', response_model=Resp_Body_Base)
+@router.patch('/membership/group/{obj_id}', response_model=Resp_Body_Base)
 async def patch_membership_group_obj(
         obj_id: str = Query(..., min_length=1, max_length=22),
         obj: Membership_Group_Base = None,
@@ -68,7 +68,7 @@ async def patch_membership_group_obj(
     return result
 
 
-@router.get('/list', response_model=Resp_Body_Base)
+@router.get('/membership/group/list', response_model=Resp_Body_Base)
 async def get_membership_group_obj_li(
         for_obj_type: Optional[str] = Query(None, min_length=2, max_length=50),
         for_obj_id: Optional[str] = Query(None, min_length=1, max_length=22),
@@ -90,8 +90,73 @@ async def get_membership_group_obj_li(
     return result
 
 
+# ### BEGIN ### API Membership Group Methods ### get_account_membership_group_obj_li() ###
+# Updated 2021-07-01
+@router.get('/account/{account_id}/membership/group/list', response_model=Resp_Body_Base)
+async def get_account_membership_group_obj_li(
+        account_id: str = Query(..., min_length=1, max_length=22),
+        # product_id: Optional[str] = Query(None, min_length=1, max_length=22),
+        # type_level: Optional[int] = None,
+        enabled: str = 'enabled',
+        limit: int = 1000,
+        inc_address: bool = False,
+        inc_contact: bool = False,
+        inc_membership_cfg: bool = False,
+        inc_membership_group_member_list: bool = False,
+        inc_organization: bool = False,
+        inc_person: bool = False,
+        inc_product_list: bool = False,
+        inc_user: bool = False,
+        x_account_id: str = Header(...),
+        by_alias: Optional[bool] = True,
+        exclude_unset: Optional[bool] = True,
+        ):
+    log.setLevel(logging.DEBUG) # DEBUG, INFO, WARNING, ERROR, EXCEPTION, CRITICAL
+    log.debug(locals())
+
+    if account_id := redis_lookup_id_random(record_id_random=account_id, table_name='account'): pass
+    else: return mk_resp(data=None, status_code=404)
+
+
+    # Updated 2021-07-01
+    if membership_group_rec_list_result := get_membership_group_rec_list(
+            account_id = account_id,
+            # product_id = product_id,
+            # type_level = type_level,
+            limit = limit,
+            enabled = enabled,
+            ):
+        membership_group_result_list = []
+        for membership_group_rec in membership_group_rec_list_result:
+            if load_membership_group_result := load_membership_group_obj(
+                    membership_group_id = membership_group_rec.get('membership_group_id', None),
+                    enabled = enabled,
+                    limit = limit,
+                    inc_address = inc_address,
+                    inc_contact = inc_contact,
+                    inc_membership_cfg = inc_membership_cfg,
+                    inc_membership_group_member_list = inc_membership_group_member_list,
+                    inc_organization = inc_organization,
+                    inc_person = inc_person,
+                    inc_product_list = inc_product_list,
+                    inc_user = inc_user,
+                    by_alias = by_alias,
+                    exclude_unset = exclude_unset,
+                    # model_as_dict = model_as_dict,
+                    ):
+                membership_group_result_list.append(load_membership_group_result)
+            else:
+                membership_group_result_list.append(None)
+        response_data = membership_group_result_list
+    else:
+        return mk_resp(data=False, status_code=400) # Bad Request
+
+    return mk_resp(data=response_data)
+# ### BEGIN ### API Membership Group Methods ### get_account_membership_group_obj_li() ###
+
+
 # Look up is only for account, person, or user records
-@router.get('/lookup', response_model=Resp_Body_Base)
+@router.get('/membership/group/lookup', response_model=Resp_Body_Base)
 async def lookup_membership_group_obj(
         for_obj_id: Union[int,str],
         for_obj_type: str = Query(..., min_length=2, max_length=50),
@@ -180,7 +245,7 @@ async def lookup_membership_group_obj(
 
 # ### BEGIN ### API Membership Group ### get_membership_group_obj() ###
 # Working well as of 2021-06-21. Using as a template for other routes.
-@router.get('/{membership_group_id}', response_model=Resp_Body_Base)
+@router.get('/membership/group/{membership_group_id}', response_model=Resp_Body_Base)
 async def get_membership_group_obj(
         membership_group_id: str = Query(..., min_length=1, max_length=22),
         enabled: str = 'enabled', # For now this covers any included objects or object lists
@@ -234,7 +299,7 @@ async def get_membership_group_obj(
 # ### END ### API Membership ### get_membership_group_obj() ###
 
 
-@router.delete('/{obj_id}', response_model=Resp_Body_Base)
+@router.delete('/membership/group/{obj_id}', response_model=Resp_Body_Base)
 async def delete_membership_group_obj(
         obj_id: str = Query(..., min_length=1, max_length=22),
         x_account_id: str = Header(...),