Set up GET to get subjects ready for a survey

Author: “Carmel

app.py

@@ -1,6 +1,7 @@
 from flask import Flask, json, render_template, request, jsonify
 import requests
 
+from new_ldot_workflows.b_1_get_new_subjects import get_new_subjects
 from new_ldot_workflows.b_2_get_qualtrics_links import add_individuals_to_survey
 from new_ldot_workflows.b_2_send_links_to_ldot import send_links_to_ldot
 from new_ldot_workflows.b_4_get_individual_progress import get_individual_progress
@@ -9,7 +10,6 @@
 
 STUDIES = json.load(open("ldot_study_configs.json"))
 
-
 @app.route("/")
 def index():
     return render_template("index.html", studies=STUDIES)
@@ -22,7 +22,7 @@ def button1():
     study_id = data.get("study_id")
 
     # TODO: Replace this with your actual API call that returns subject IDs
-    subject_ids = ["subject1", "subject2", "subject3"]
+    subject_ids = get_new_subjects(study_id)
 
     message = f"Found {len(subject_ids)} subject IDs for study {study_id}" if study_id else f"Found {len(subject_ids)} subject IDs"
     return jsonify({"success": True, "message": message, "subject_ids": subject_ids})

ldot_study_configs.json

@@ -1,17 +1,20 @@
 {
-    "LDOT-001": {"name": "PIAMA study", "variables": {"survey_id": "SV_efCMOg6wHU0T8ii",
+    "LDOT-001": {"name": "PIAMA study", "variables": {"ldot_study_id": "96a54061-555d-d74b-8e0b-84d43853897e", 
+                                                    "survey_id": "SV_efCMOg6wHU0T8ii",
                                                       "directory_id": "POOL_10pyxk9leSUisrT",
                                                       "distribution_id": "EMD_7AEa416lRwFhrkF",
                                                          "mailing_list_id": "CG_2dMbO6WUBMnCeIK",
                                                          "embedded_data_field": "study_id_child"}},
-    "LDOT-002": {"name": "LDOT Study 002", "variables": {"survey_id": "value3",
+    "LDOT-002": {"name": "LDOT Study 002", "variables": {"ldot_study_id": "value1",
+    "survey_id": "value3",
                                                          "directory_id": "POOL_10pyxk9leSUisrT",
                                                          "distribution_id": "EMD_7AEa416lRwFhrkF",
                                                          "mailing_list_id": "value4",
                                                          "embedded_data_field": "study_id_child"}},
-    "LDOT-003": {"name": "LDOT Study 003", "variables": {"survey_id": "value5",
+    "LDOT-003": {"name": "LDOT Study 003", "variables": {"ldot_study_id": "value2",
+                                                         "survey_id": "value5",
                                                          "directory_id": "POOL_10pyxk9leSUisrT",
                                                          "distribution_id": "EMD_7AEa416lRwFhrkF",
                                                          "mailing_list_id": "value6",
-                                                         "embedded_data_field": "study_id_child"}},
+                                                         "embedded_data_field": "study_id_child"}}
 }

new_ldot_workflows/b_1_get_new_subjects.py

@@ -1,12 +1,3 @@
-
-# 1. First, query Ldot to find new people who need to be added to Qualtrics. This will be done by looking for people who have been added to Ldot in the last 24 hours and checking if they are already in Qualtrics.
-# 2. For each new person, add them to the appropriate mailing list in Qualtrics. This will involve using the Qualtrics API to add the person's information to the mailing list.
-# 3. After adding the person to the mailing list, send them an email invitation to
-
-# Grab the client ID and secret from the config file new_ldot_workflows\ldot_config.json
-
-
-
 import json
 import requests
 
@@ -16,41 +7,37 @@
 CLIENT_SECRET = config["client_secret"]
 LDOT_API_URL = config["LDOT_API_URL"]
 
-
-response = requests.post(
-    "https://accware.memic.maastrichtuniversity.nl/ldot_identity_server/connect/token",
-    data={
-        "grant_type": "client_credentials",
-        "client_id": CLIENT_ID,
-        "client_secret": CLIENT_SECRET
-    }
-)
-
-token = response.json()["access_token"]
-print(token)
-
-headers={"accept": "application/json",
-        "Authorization": f"Bearer {token}"
-         }
-
-response = requests.get(
-    "https://accware.memic.maastrichtuniversity.nl/memic_ldot_api/api/v1.1/5c9c6a47-c8d7-8142-a8c8-ccdcb8a8044b/Action",
-    headers=headers
-)
-
-print(response.status_code)
-print(response.text)
-
-
-
-
-# Assuming the response contains a list of participants under the key 'participants'
-
-
-
-
-# Client ID for the PIAMA study: piama_api_qualtrics
-# Study GUID:  5c9c6a47-c8d7-8142-a8c8-ccdcb8a8044b
-
-
-# 
+def get_new_subjects(study_id: str, link_creation_eaid: str) -> list:
+    """Get subjects that have not yet been added to Qualtrics by checking their event actions"""
+
+    response = requests.post(
+        "https://accware.memic.maastrichtuniversity.nl/ldot_identity_server/connect/token",
+        data={
+            "grant_type": "client_credentials",
+            "client_id": CLIENT_ID,
+            "client_secret": CLIENT_SECRET
+        }
+    )
+
+    token = response.json()["access_token"]
+
+    headers={"accept": "application/json",
+            "Authorization": f"Bearer {token}"
+            }
+
+    response = requests.get(
+        f"https://accware.memic.maastrichtuniversity.nl/memic_ldot_api/api/v1.1/{study_id}/Action/{link_creation_eaid}",
+        headers=headers
+    )
+
+    response.raise_for_status()
+    payload = response.json()
+    study_event_actions = payload.get("Data", {}).get("StudyEventActions", [])
+    return [
+        action["SubjectGuid"]
+        for action in study_event_actions
+        if action.get("SubjectGuid")
+    ]
+
+if __name__ == "__main__":
+    print(get_new_subjects("5c9c6a47-c8d7-8142-a8c8-ccdcb8a8044b", "5d31129c-d814-5d4b-a96f-048cadc150ce"))