Button skip logic

Author: “Carmel

__pycache__/app.cpython-311.pyc

@@ -13,6 +13,7 @@
 from new_ldot_workflows.b_2_send_links_to_ldot import send_links_to_ldot
 from new_ldot_workflows.b_3_get_incomplete_subjects import get_incomplete_subjects
 from new_ldot_workflows.b_4_get_individual_progress import get_individual_progress
+from new_ldot_workflows.b_4_send_progress_to_ldot import send_progress_to_ldot
 from new_ldot_workflows.logging_utils import QualtricsAPIError
 
 app = Flask(__name__)
@@ -236,6 +237,13 @@ def button4():
             study_variables.embedded_data_field,
             study_variables.survey_id,
         )
+        send_progress_to_ldot(
+            ldot_client,
+            study_variables.ldot_study_id,
+            study_variables.eaid_survey_progress_completed,
+            participant_to_progress_dict,
+        )
+
     except QualtricsAPIError as e:
         return jsonify({"success": False, "message": str(e)}), 502
     except Exception as e:

app.py

@@ -1,4 +1,5 @@
 from new_ldot_workflows.logging_utils import logged_request
+import json
 
 def get_incomplete_subjects(ldot_client, study_id: str, eaid_survey_invitation_completed: str = None, eaid_survey_progress_completed: str = None) -> list:
     """Get subjects that have not yet completed the survey by checking their event actions"""
@@ -17,11 +18,11 @@ def get_incomplete_subjects(ldot_client, study_id: str, eaid_survey_invitation_c
 
     subjects_with_survey_invitation_completed = set()
 
-    # print(result.json())
-    # for action in result.json().get("Data", {}).get("StudyEventActions", []):
-    #     subjects_with_survey_invitation_completed.add(action["SubjectGuid"])
+    print(result.json())
+    for action in result.json().get("Data", {}).get("StudyEventActions", []):
+        subjects_with_survey_invitation_completed.add(action["SubjectGuid"])
 
-    # print(f"Subjects with survey invitation completed: {subjects_with_survey_invitation_completed}")
+    print(f"Subjects with survey invitation completed: {subjects_with_survey_invitation_completed}")
 
     result = logged_request(
         "GET",
@@ -33,19 +34,33 @@ def get_incomplete_subjects(ldot_client, study_id: str, eaid_survey_invitation_c
     )
     print(result.json())
 
-    # subjects_with_survey_progress_completed = set()
-    # for action in result.json().get("Data", {}).get("StudyEventActions", []):
-    #     subjects_with_survey_progress_completed.add(action["SubjectGuid"])
+    subjects_with_survey_progress_completed = set()
+    for action in result.json().get("Data", {}).get("StudyEventActions", []):
+        subjects_with_survey_progress_completed.add(action["SubjectGuid"])
 
-    # print(f"Subjects with survey progress completed: {subjects_with_survey_progress_completed}")
+    print(f"Subjects with survey progress completed: {subjects_with_survey_progress_completed}")
 
-    # incomplete_subjects = subjects_with_survey_invitation_completed - subjects_with_survey_progress_completed
-    # return list(incomplete_subjects)
+    incomplete_subjects = subjects_with_survey_invitation_completed - subjects_with_survey_progress_completed
+    return list(incomplete_subjects)
 
 if __name__ == "__main__":
     # This would typically be initialized with the actual Ldot client
-    ldot_client = None  # Replace with actual Ldot client initialization
-    ldot_study_id = "5c9c6a47-c8d7-8142-a8c8-ccdcb8a8044b"
-    eaid_survey_invitation_completed = "337ecba2-3dd3-1141-8c38-6cffdcfbd7eb"
-    eaid_survey_progress_completed = "120d298d-9aa9-084b-abc6-432148db0e10"
-    print(get_incomplete_subjects(ldot_study_id, eaid_survey_invitation_completed, eaid_survey_progress_completed))
+    with open("new_ldot_workflows/ldot_config.json") as f:
+        config = json.load(f)
+    LDOT_TOKEN_URL = config["LDOT_TOKEN_URL"]
+    LDOT_API_URL = config["LDOT_API_URL"]
+    CLIENT_ID = config["client_id"]
+    CLIENT_SECRET = config["client_secret"]
+
+    # ldot_client = LdotClient(
+    #     token_url=LDOT_TOKEN_URL,
+    #     api_url=LDOT_API_URL,
+    #     client_id=CLIENT_ID,
+    #     client_secret=CLIENT_SECRET
+    # )
+    # # print(ldot_client.headers)
+
+    # ldot_study_id = "5c9c6a47-c8d7-8142-a8c8-ccdcb8a8044b"
+    # eaid_survey_invitation_completed = "337ecba2-3dd3-1141-8c38-6cffdcfbd7eb"
+    # eaid_survey_progress_completed = "120d298d-9aa9-084b-abc6-432148db0e10"
+    # print(get_incomplete_subjects(ldot_client, ldot_study_id, eaid_survey_invitation_completed, eaid_survey_progress_completed))

logs/api_calls.log

@@ -6,6 +6,7 @@
 import json
 
 from new_ldot_workflows.logging_utils import QualtricsAPIError, logged_request
+# from ldot_client import LdotClient
 
 with open("new_ldot_workflows/qualtrics_config.json") as f:
     config = json.load(f)
@@ -232,19 +233,34 @@ def get_individual_progress(ldot_client, ldot_study_id: str, id_deelnemer_entity
     return participant_to_progress_dict
 
 if __name__ == "__main__":
-    # # Example usage
-    survey_id="SV_efCMOg6wHU0T8ii"
-    embedded_data_field = "study_id_child"
+    with open("ldot_config.json") as f:
+        config = json.load(f)
+    LDOT_TOKEN_URL = config["LDOT_TOKEN_URL"]
+    LDOT_API_URL = config["LDOT_API_URL"]
+    CLIENT_ID = config["client_id"]
+    CLIENT_SECRET = config["client_secret"]
 
+    ldot_client = LdotClient(
+        token_url=LDOT_TOKEN_URL,
+        api_url=LDOT_API_URL,
+        client_id=CLIENT_ID,
+        client_secret=CLIENT_SECRET
+    )
+    print(ldot_client.headers)
 
-    ldot_study_id = "5c9c6a47-c8d7-8142-a8c8-ccdcb8a8044b"
-    subject_ids = ["352fb9d8-962f-4735-9fc7-7b4e18109a51"]
-    id_deelnemer_entity = "7f61b810-00ed-1d41-8a33-4164f25ebad0"
-    id_location = "427f304f-9d95-44f5-8f7b-d6a1ce1db293"
-    embedded_data_field = "study_id_child"
+    # # # Example usage
+    # survey_id="SV_efCMOg6wHU0T8ii"
+    # embedded_data_field = "study_id_child"
 
-    participant_to_progress_dict = get_individual_progress(ldot_study_id, id_deelnemer_entity, id_location, subject_ids, embedded_data_field, survey_id)
-    print(participant_to_progress_dict)
 
+    # ldot_study_id = "5c9c6a47-c8d7-8142-a8c8-ccdcb8a8044b"
+    # subject_ids = ["352fb9d8-962f-4735-9fc7-7b4e18109a51"]
+    # id_deelnemer_entity = "7f61b810-00ed-1d41-8a33-4164f25ebad0"
+    # id_location = "427f304f-9d95-44f5-8f7b-d6a1ce1db293"
+    # embedded_data_field = "study_id_child"
 
-    # subject_id_to_study_identifier_dict = subject_id_to_study_identifier(ldot_study_id, id_deelnemer_entity, id_location, subject_ids)
+    # participant_to_progress_dict = get_individual_progress(ldot_study_id, id_deelnemer_entity, id_location, subject_ids, embedded_data_field, survey_id)
+    # print(participant_to_progress_dict)
+
+
+    # # subject_id_to_study_identifier_dict = subject_id_to_study_identifier(ldot_study_id, id_deelnemer_entity, id_location, subject_ids)