Feat/reverse many to many (#34)

* feat: Add reverse mn lookup.

Author: loganripplinger

README.md

@@ -264,6 +264,7 @@ You can also give more than one item. Given that you have a list of relationship
 
 Results in `[2,4]`.
 
+
 ## Configuration
 
 The following parameters can be adjusted to serve testing, development, or particular deployment needs. 

data_resource_api/api/v1_0_0/resource_handler.py

@@ -409,10 +409,17 @@ def get_many_one(self, id: int, parent: str, child: str):
         #     return {'error': f"relationship '{child}' of '{parent}' not found."}
         try:
             session = Session()
-            cols = {f'{parent}_id': id}
+            parent_col_str = f'{parent}_id'
+            child_col_str = f'{child}_id'
+
+            cols = {parent_col_str: id}
             query = session.query(join_table).filter_by(**cols).all()
 
-            children = [value[1] for value in query]
+            children = []
+            for row in query:
+                row_dict = row._asdict()  # example - {'programs_id': 2, 'credentials_id': 3}
+                children.append(row_dict[child_col_str])
+
         except Exception:
             raise InternalServerError()
 

data_resource_api/factories/data_resource_factory.py

@@ -61,6 +61,7 @@ def create_api_from_dict(self, api_schema: dict, endpoint_name: str, table_name:
                 #     f'/{custom_table[1]}/<id>/{custom_table[2]}/<child_id>'
                 # ) # DELETE route
                 many_resources.append(f'/{custom_table[1]}/<int:id>/{custom_table[2]}')
+                many_resources.append(f'/{custom_table[2]}/<int:id>/{custom_table[1]}')
 
         flask_restful_many_resource = type(f'{endpoint_name}Many', (VersionedResourceMany,), {
             'data_resource_name': table_name,

tests/test_custom_descriptor.py

@@ -70,10 +70,19 @@ def check_for_skills_on_framework(c, framework_id: int, skills_list: list):
         route = f'/frameworks/{framework_id}/skills'
         response = c.get(route)
         body = json.loads(response.data)
-        
+
         expect(response.status_code).to(equal(200))
         expect(body['skills']).to(equal(skills_list))
 
+    @staticmethod
+    def get_frameworks_on_skill(c, skill_id: int):
+        route = f'/skills/{skill_id}/frameworks'
+        response = c.get(route)
+        body = json.loads(response.data)
+
+        expect(response.status_code).to(equal(200))
+        return body
+
     @staticmethod
     def delete_a_framework_skill(c, framework_id: int, skills_list: list):
         route = f'/frameworks/{framework_id}/skills'
@@ -94,8 +103,8 @@ def test_load_descriptor(self, frameworks_skills_client):
         skill_1 = ApiHelper.post_a_skill(c, "skill1")
         skill_2 = ApiHelper.post_a_skill(c, "skill2")
         skills_list = [skill_1, skill_2]
-
         framework_id = ApiHelper.post_a_framework(c, skills_list)
+
         ApiHelper.check_for_skills_on_framework(c, framework_id, skills_list)
 
     def test_relationships(self, frameworks_skills_client):
@@ -132,8 +141,8 @@ def test_mn_put(self, frameworks_skills_client):
         skill_2 = ApiHelper.post_a_skill(c, "skill2")
         skills_list = [skill_1, skill_2]
         skill_3 = ApiHelper.post_a_skill(c, "skill3")
-
         framework_id = ApiHelper.post_a_framework(c, skills_list)
+
         ApiHelper.put_a_framework_skill(c, framework_id, [skill_3])
         ApiHelper.check_for_skills_on_framework(c, framework_id, [skill_3])
 
@@ -168,8 +177,8 @@ def test_mn_delete_many(self, frameworks_skills_client):
         skill_2 = ApiHelper.post_a_skill(c, "skill2")
         skill_3 = ApiHelper.post_a_skill(c, "skill3")
         skills_list = [skill_1, skill_2, skill_3]
-
         framework_id = ApiHelper.post_a_framework(c, skills_list)
+
         resp = ApiHelper.delete_a_framework_skill(c, framework_id, [skill_1, skill_3])
 
         expect(resp['skills']).to(equal([skill_2]))
@@ -181,8 +190,18 @@ def test_mn_delete_relationship_that_does_not_exist(self, frameworks_skills_clie
         skill_2 = ApiHelper.post_a_skill(c, "skill2")
         skill_3 = ApiHelper.post_a_skill(c, "skill3")
         skills_list = [skill_1, skill_2]
-
         framework_id = ApiHelper.post_a_framework(c, skills_list)
+
         resp = ApiHelper.delete_a_framework_skill(c, framework_id, [skill_3])
 
         expect(resp['skills']).to(equal([skill_1, skill_2]))
+
+    def test_mn_reverse_relationship(self, frameworks_skills_client):
+        c = frameworks_skills_client
+
+        skill_1 = ApiHelper.post_a_skill(c, "skill1")
+        framework_id = ApiHelper.post_a_framework(c, [skill_1])
+
+        resp = ApiHelper.get_frameworks_on_skill(c, skill_1)
+
+        expect(resp['frameworks']).to(equal([framework_id]))