add shelterluv adoptions to 360 response

move shelterluv token to a separate file which is in gitignore

Author: urirot

.gitignore

@@ -18,3 +18,4 @@ start_env.sh
 
 /src/server/venv/
 /src/local_files/
+/src/server/secrets.py

src/client/.gitignore

@@ -20,5 +20,4 @@
 
 npm-debug.log*
 yarn-debug.log*
-yarn-error.log*
-package-lock.json
+yarn-error.log*

src/client/package-lock.json

@@ -2,6 +2,9 @@
 from config import engine
 from flask import jsonify
 from sqlalchemy.sql import text
+import requests
+import json
+from secrets import SHELTERLUV_SECRET_TOKEN
 
 
 @common_api.route('/api/contacts/<search_text>', methods=['GET'])
@@ -41,17 +44,41 @@ def get_360(matching_id):
         for row in result["contact_details"]:
             if row["source_type"] == "salesforcecontacts":
                 donations_query = text("select * from salesforcedonations where contact_id like :salesforcecontacts_id")
-                query_result = connection.execute(donations_query, salesforcecontacts_id=row["source_id"] + "%")
-                salesforcedonations_results = [dict(row) for row in query_result]
-                result['donations'] = salesforcedonations_results
+                salesforce_contacts_query_result = connection.execute(donations_query,
+                                                                      salesforcecontacts_id=row["source_id"] + "%")
+                salesforce_donations_results = [dict(row) for row in salesforce_contacts_query_result]
+                result['donations'] = salesforce_donations_results
 
             if row["source_type"] == "volgistics":
                 shifts_query = text("select * from volgisticsshifts where number = :volgistics_id")
-                query_result = connection.execute(shifts_query, volgistics_id=row["source_id"])
-                volgisticsshifts_results = [dict(row) for row in query_result]
+                volgistics_shifts_query_result = connection.execute(shifts_query, volgistics_id=row["source_id"])
+                volgisticsshifts_results = [dict(row) for row in volgistics_shifts_query_result]
                 result['shifts'] = volgisticsshifts_results
 
-            #todo: add adoptions
+            if row["source_type"] == "shelterluvpeople":
+                adoptions = []
+                person = requests.get("http://shelterluv.com/api/v1/people/{}".format(row["source_id"]),
+                                      headers={"x-api-key": SHELTERLUV_SECRET_TOKEN})
+                person_json = person.json()
+                animal_ids = person_json["Animal_ids"]
 
+                for animal_id in animal_ids:
+                    animal_events = requests.get("http://shelterluv.com/api/v1/animals/{}/events".format(animal_id),
+                                                 headers={"x-api-key": SHELTERLUV_SECRET_TOKEN})
+                    animal_events_json = animal_events.json()
+
+                    for event in animal_events_json["events"]:
+                        for adoption in event["AssociatedRecords"]:
+                            if adoption["Type"] == "Person" and adoption["Id"] == row["source_id"]:
+                                del event["AssociatedRecords"]
+                                animal_details = requests.get(
+                                    "http://shelterluv.com/api/v1/animals/{}".format(animal_id),
+                                    headers={"x-api-key": SHELTERLUV_SECRET_TOKEN})
+
+                                animal_details_json = animal_details.json()
+                                event["animal_details"] = animal_details_json
+                                adoptions.append(event)
+
+                    result['adoptions'] = adoptions
 
         return jsonify({'result': result})

src/server/api/common_api.py

@@ -105,7 +105,7 @@ def volgistics_address(index, street):
         }
     },
     "shelterluvpeople": {
-        "source_id": "id",
+        "source_id": "internal-id",
         "first_name": "firstname",
         "last_name": "lastname",
         "email": "email",

src/server/datasource_manager.py

@@ -1,6 +1,7 @@
 import requests
 import json
 import config
+from secrets import SHELTERLUV_SECRET_TOKEN
 
 #################################
 # This script is used to fetch data from shelterluv API.
@@ -14,24 +15,26 @@
 # /people has all the data. it seems that /person/:id isn't used
 #################################
 
-shelterluv_token = "replace_with_secret_token" #dropbox
-
-
 ''' Iterate over all shelterlove people and store in json file in the raw data folder
 We fetch 100 items in each request, since that is the limit based on our research '''
-def save_shelterluv_people_all():
+def store_shelterluv_people_all():
     offset = 0
     LIMIT = 100
     has_more = True
     shelterluv_people = []
 
     while has_more:
         r = requests.get("http://shelterluv.com/api/v1/people?limit={}&offset={}".format(LIMIT, offset),
-                         headers={"x-api-key": shelterluv_token})
+                         headers={"x-api-key": SHELTERLUV_SECRET_TOKEN})
         response = r.json()
         shelterluv_people += response["people"]
         has_more = response["has_more"]
         offset += 100
 
     with open(config.RAW_DATA_PATH + "shelterLuv_people.json", "w") as outfile:
         json.dump(shelterluv_people, outfile, indent=4)
+
+
+if __name__ == "__main__":
+    # execute only if run as a script
+    store_shelterluv_people_all()