Create tasks & attendance records using Python & API server using locally

Author: AleksandrMolchagin

docs/attendance-task-create.py

@@ -0,0 +1,75 @@
+import csv
+import asyncio
+import aiohttp
+import ssl
+
+ssl_context = ssl.create_default_context()
+ssl_context.check_hostname = False
+ssl_context.verify_mode = ssl.CERT_NONE
+
+with open('./data/attendance-task/results.csv', newline='') as csvfile:
+    reader = csv.reader(csvfile)
+    counter = 0
+    total_coutner = 0
+    memo = {}
+    for row in reader:
+        if total_coutner == 0:
+            total_coutner += 1
+            continue
+
+        sessionId = row[0]
+        if sessionId == "a0pcX0000005lZNQAY":
+            continue
+        coach1 = row[4]
+        coach2 = row[5]
+        attendanceDate = row[6]
+        memo[sessionId] = (coach1, coach2, attendanceDate)
+
+        total_coutner += 1
+
+
+    # reader = csv.reader(csvfile)
+    # print(f"Total coach mismatches: {counter}")
+    # print(f"Total records: {total_coutner}")
+    async def send_post_request(http_session, session, coach, endOfTeamSeason):
+        url = "https://localhost:8091/api/tasks"
+        headers = {
+            'Content-Type': 'application/json'
+        }
+        payload = {
+                "AssignedBy": "",
+                "AssignedTo": coach,
+                "CreatedByContact": "0051T000009eHfvQAE",
+                "CreatedContact": "",
+                "LastModifiedBy": "0051T000009eHfvQAE",
+                "LastModifiedContact": "",
+                "OwnerId": "0051T000009eHfvQAE",
+                "DueDate": endOfTeamSeason,
+                "Session": session,
+                "Name": "Catch-up attendance",
+                "TaskStatus": "To Do",
+                "TaskType": "Take Attendance"
+            }
+
+        try:
+            async with http_session.post(url, headers=headers, json=payload, ssl=ssl_context) as response:
+                return await response.text(), response.status
+        except Exception as e:
+            print(e)
+            return None, None
+
+    async def main():
+        async with aiohttp.ClientSession() as http_session:
+            for session_id, (coach1, coach2, end_of_team_season) in memo.items():
+                print(f"Processing session {session_id} with coaches {coach1} and {coach2} ({end_of_team_season})")
+                if coach1 == coach2:
+                    resp = await send_post_request(http_session, session_id, coach1, end_of_team_season)
+                    print(resp)
+                else:
+                    resp1 = await send_post_request(http_session, session_id, coach1, end_of_team_season)
+                    print(resp1)
+                    resp2 = await send_post_request(http_session, session_id, coach2, end_of_team_season)
+                    print(resp2)
+                print(f"------------------------------------------------------------------------------------------")
+
+    asyncio.run(main())

docs/data/attendance-task/query.txt

@@ -0,0 +1,14 @@
+SELECT
+    Id,
+    Session_Date__c,
+    Team_Season__c,
+    Session_Topic__c,
+    Team_Season__r.Coach_Soccer__c,
+    Team_Season__r.Coach_Writing__c
+FROM Session__c
+WHERE
+    Session_Date__c >= 2025-01-01 AND
+    Id NOT IN (
+        SELECT Session__c
+        FROM SCORES_Task__c
+    )

docs/data/attendance-task/results.csv

@@ -0,0 +1,2 @@
+"Id","Session_Date__c","Team_Season__c","Session_Topic__c","Team_Season__r.Coach_Soccer__c","Team_Season__r.Coach_Writing__c","Team_Season__r.Season_End_Date__c"
+"a0pcX0000005lZNQA2","2026-09-23","a0qcX000000GEggQA2","Soccer","003Hs00004W5kzXIA2","003cX000005TYcvQA2","2025-06-21"

scripts/exchange-update.py

@@ -351,6 +351,11 @@ def increment_version(version_str):
         identical, details = are_files_identical("salesforce-data-api.zip", "new_salesforce-data-api.zip", ignore_list=ignore_patterns)
         if identical:
             print("Files are identical. No need to upload asset.")
+            if change_api_specification(latest_version, token):
+                print("API specification updated successfully.")
+            else:
+                print("Failed to update API specification.")
+                exit(1)
             print("=======================================")
             print("  SUCCESS: Asset updated successfully")
             print("=======================================")