Berickson/20260210 dashboard updates

VERSION

@@ -1 +1 @@
-0.1.0+2026.02.17T15.09.06.345Z.5f75e49b.berickson.20260217.updated.dead.links
+0.1.0+2026.02.20T19.02.56.547Z.85e344b1.berickson.20260210.dashboard.updates

learning_observer/VERSION

@@ -1 +1 @@
-0.1.0+2026.02.17T15.09.06.345Z.5f75e49b.berickson.20260217.updated.dead.links
+0.1.0+2026.02.20T19.02.56.547Z.85e344b1.berickson.20260210.dashboard.updates

learning_observer/learning_observer/integrations/google.py

@@ -231,14 +231,16 @@ def clean_assignment_docs(google_json):
     Retrieve set of documents per student associated with an assignment
     '''
     student_submissions = google_json.get('studentSubmissions', [])
+    cleaned_submissions = []
     for student_json in student_submissions:
         google_id = student_json[constants.USER_ID]
         local_id = learning_observer.auth.google_id_to_user_id(google_id)
-        student_json[constants.USER_ID] = local_id
         docs = [d['driveFile'] for d in learning_observer.util.get_nested_dict_value(student_json, 'assignmentSubmission.attachments', []) if 'driveFile' in d]
-        student_json['documents'] = docs
-        # TODO we should probably remove some of the keys provided
-    return student_submissions
+        cleaned_submissions.append({
+            constants.USER_ID: local_id,
+            'documents': docs
+        })
+    return cleaned_submissions
 
 
 if __name__ == '__main__':

learning_observer/learning_observer/integrations/schoology.py

@@ -1,23 +1,49 @@
+# learning_observer/integrations/schoology.py
 import learning_observer.constants as constants
-import learning_observer.kvs
 import learning_observer.settings as settings
 
 from . import util
 
 API = 'schoology'
 
+# All endpoints use LTI service URLs, not direct Schoology REST API.
+# These are accessed using the LTI access token negotiated at launch.
+#
+# LTI AGS spec: https://www.imsglobal.org/spec/lti-ags/v2p0
+# LTI NRPS spec: https://www.imsglobal.org/spec/lti-nrps/v2p0
+LTI_SERVICE_BASE = 'https://lti-service.svc.schoology.com/lti-service/tool/{clientId}'
+
 ENDPOINTS = list(map(lambda x: util.Endpoint(**x, api_name=API), [
-    {'name': 'course_list', 'remote_url': 'https://lti-service.svc.schoology.com/lti-service/tool/{clientId}/services/names-roles/v2p0/membership/{courseId}', 'headers': {'Accept': 'application/vnd.ims.lti-nrps.v2.membershipcontainer+json'}},
-    {'name': 'course_roster', 'remote_url': 'https://lti-service.svc.schoology.com/lti-service/tool/{clientId}/services/names-roles/v2p0/membership/{courseId}', 'headers': {'Accept': 'application/vnd.ims.lti-nrps.v2.membershipcontainer+json'}},
-    {'name': 'course_assignments', 'remote_url': 'https://api.schoology.com/v1/sections/{courseId}/assignments', 'headers': {'Accept': 'application/vnd.ims.lis.v2.lineitemcontainer+json'}},
+    {
+        'name': 'course_list',
+        'remote_url': f'{LTI_SERVICE_BASE}/services/names-roles/v2p0/membership/{{courseId}}',
+        'headers': {'Accept': 'application/vnd.ims.lti-nrps.v2.membershipcontainer+json'}  # required Schoology header for LTI membership requests
+    },
+    {
+        'name': 'course_roster',
+        'remote_url': f'{LTI_SERVICE_BASE}/services/names-roles/v2p0/membership/{{courseId}}',
+        'headers': {'Accept': 'application/vnd.ims.lti-nrps.v2.membershipcontainer+json'}  # required Schoology header for LTI membership requests
+    },
+    {
+        # AGS line item container — lists all assignments for the course
+        'name': 'course_assignments',
+        'remote_url': f'{LTI_SERVICE_BASE}/services/ags/v2p0/lineitems/{{courseId}}',
+        'headers': {'Accept': 'application/vnd.ims.lis.v2.lineitemcontainer+json'}
+    },
+    {
+        # AGS results for a specific line item — lists per-student results/submissions
+        # The lineItemId is typically the full line item URL or the trailing segment.
+        'name': 'assignment_results',
+        'remote_url': f'{LTI_SERVICE_BASE}/services/ags/v2p0/lineitems/{{courseId}}/{{courseWorkId}}/results',
+        'headers': {'Accept': 'application/vnd.ims.lis.v2.resultcontainer+json'}
+    },
 ]))
 
 register_cleaner = util.make_cleaner_registrar(ENDPOINTS)
 
 
 def register_endpoints(app):
-    '''
-    '''
+    '''Register Schoology LTI endpoints with the application.'''
     if not settings.feature_flag('schoology_routes'):
         return
 
@@ -29,6 +55,10 @@ def register_endpoints(app):
     )
 
 
+# ---------------------------------------------------------------------------
+# Course list
+# ---------------------------------------------------------------------------
+
 @register_cleaner('course_list', 'courses')
 def clean_course_list(schoology_json):
     '''
@@ -45,21 +75,27 @@ def clean_course_list(schoology_json):
     return [course]
 
 
+# ---------------------------------------------------------------------------
+# Roster
+# ---------------------------------------------------------------------------
+
 def _process_schoology_user_for_system(member, google_id):
-    # Skip if no canvas id
-    canvas_id = member.get('user_id')
-    if not canvas_id: return None
+    '''Convert an LTI NRPS member record into an internal user dict.'''
+    lti_user_id = member.get('user_id')
+    if not lti_user_id:
+        return None
 
-    # Skip non students
-    is_student = 'http://purl.imsglobal.org/vocab/lis/v2/membership#Learner' in member.get('roles', [])
+    is_student = (
+        'http://purl.imsglobal.org/vocab/lis/v2/membership#Learner'
+        in member.get('roles', [])
+    )
     if not is_student:
         return None
 
-    # Create user for our system
     email = member.get('email')
     local_id = google_id
     if not local_id:
-        local_id = f'canvas-{canvas_id}'
+        local_id = f'schoology-{lti_user_id}'
 
     member[constants.USER_ID] = local_id
     user = {
@@ -73,18 +109,16 @@ def _process_schoology_user_for_system(member, google_id):
             'photo_url': member.get('picture')
         },
         constants.USER_ID: local_id,
-        # TODO is this needed? Other roster functions in LO include it
-        # 'course_id': course_id
     }
     return user
 
 
 @register_cleaner('course_roster', 'roster')
 async def clean_course_roster(schoology_json):
     '''
-    Retrieve and clean the roster for a Canvas course, alphabetically sorted
+    Retrieve and clean the roster for a Schoology course, alphabetically sorted.
 
-    Conforms to LTI NRPS v2 response format
+    Conforms to LTI NRPS v2 response format.
     https://www.imsglobal.org/spec/lti-nrps/v2p0
     '''
     members = schoology_json.get('members', [])
@@ -97,16 +131,37 @@ async def clean_course_roster(schoology_json):
         user = _process_schoology_user_for_system(member, google_id)
         if user is not None:
             users.append(user)
+
+    users.sort(
+        key=lambda user: user.get('profile', {}).get('name', {}).get('family_name', '')
+    )
     return users
 
 
-@register_cleaner('course_assignments', 'assignments') 
+# ---------------------------------------------------------------------------
+# Assignments (AGS line items)
+# ---------------------------------------------------------------------------
+@register_cleaner('course_assignments', 'assignments')
 def clean_course_assignments(schoology_json):
     '''
-    Clean course line items (assignments) from Schoology
+    TODO implemement this function
+    When launching via LTI, Schoology only allows us to see assignments
+    created by our tool. To see all assignments we require an Oauth workflow.
+    Clean course line items (assignments) from Schoology via LTI AGS.
+    '''
+    raise NotImplemented('Schoology assignments have not yet been implemented.')
+
 
-    Conforms to LTI AGS response format
-    https://www.imsglobal.org/spec/lti-ags/v2p0
+# ---------------------------------------------------------------------------
+# Assignment results / assigned docs (AGS results)
+# ---------------------------------------------------------------------------
+@register_cleaner('assignment_results', 'assigned_docs')
+async def clean_assigned_docs(schoology_json):
+    '''
+    TODO implemement this function
+    When launching via LTI, Schoology only allows us to see assignments
+    created by our tool. To see all assignments we require an Oauth workflow.
+    Extract per-student Google Doc attachments from LTI AGS results
+    for a single assignment.
     '''
-    # print('Schoology assignments TODO', schoology_json)
-    return []
+    raise NotImplemented('Schoology documents from assignments have not yet been implemented.')

learning_observer/learning_observer/integrations/util.py

@@ -19,6 +19,7 @@
 
 import aiohttp
 import aiohttp.web
+import aiohttp_session
 
 import learning_observer.constants as constants
 import learning_observer.settings as settings
@@ -99,12 +100,24 @@ async def raw_api_ajax(
     request = runtime.get_request()
     url = target_url.format(**kwargs)
     user = await learning_observer.auth.get_active_user(request)
-    if constants.AUTH_HEADERS not in request or user is None:
+
+    # Auth headers may live on the request (set during the LTI launch
+    # redirect) OR in the session (persisted for subsequent requests).
+    # We need to check both sources.
+    auth_headers = request.get(constants.AUTH_HEADERS)
+    if auth_headers is None:
+        session = await aiohttp_session.get_session(request)
+        auth_headers = session.get(constants.AUTH_HEADERS)
+        # Populate request so downstream code can find them too
+        if auth_headers is not None:
+            request[constants.AUTH_HEADERS] = auth_headers
+
+    if auth_headers is None or user is None:
         raise aiohttp.web.HTTPUnauthorized(text="Please log in")
 
     if headers is None:
         headers = {}
-    headers.update(request.get(constants.AUTH_HEADERS, {}))
+    headers.update(auth_headers)
 
     method = method.lower()
     cache_available = method == 'get' and cache is not None and cache_key_prefix is not None

learning_observer/learning_observer/rosters.py

@@ -360,7 +360,7 @@ def init():
     # Google, Canvas, and Schoology all use integrations instead of ajax when called
     elif roster_source in ["google_api"]:
         ajax = google_ajax
-    elif roster_source in ["canvas_api", 'schoology_api']:
+    elif roster_source in ["canvas_api", 'schoology']:
         pass
     elif roster_source in ["all"]:
         ajax = all_ajax
@@ -369,7 +369,7 @@ def init():
             "Settings file `roster_data` element should have `source` field\n"
             "set to either:\n"
             "  test        (retrieve from files courses.json and students.json)\n"
-            "  google_api | canvas_api | schoology_api  (retrieve roster data from an api)\n"
+            "  google_api | canvas_api | schoology  (retrieve roster data from an api)\n"
             "  filesystem  (retrieve roster data from file system hierarchy\n"
             "  all  (retrieve roster data as all students)"
         )
@@ -555,16 +555,55 @@ async def courseroster(request, course_id):
     return roster
 
 
+async def courseassignments(request, course_id):
+    '''Fetch all the assignments for a given course
+    '''
+    assignments = await run_additional_module_func(request, 'assignments', kwargs={'courseId': course_id})
+    if assignments is not None:
+        return assignments
+    return []
+
+
+async def courseassignment_assigned_docs(request, course_id, assignment_id):
+    '''
+    Fetch all assigned docs for a given assignment
+    '''
+    assigned_docs = await run_additional_module_func(request, 'assigned_docs', kwargs={'courseId': course_id, 'courseWorkId': assignment_id})
+    if assigned_docs is not None:
+        return assigned_docs
+    return []
+
+
 async def courselist_api(request):
     '''
     List all of the courses a teacher manages: Handler
     '''
     return aiohttp.web.json_response(await courselist(request))
 
 
+async def course_api(request):
+    '''
+    Fetch course information
+    '''
+    course_id = request.match_info['course_id']
+    courses = await courselist(request)
+    for course in courses:
+        if course['id'] == course_id:
+            return aiohttp.web.json_response(course)
+    return aiohttp.web.json_response({})
+
+
 async def courseroster_api(request):
     '''
     List all of the students in a course: Handler
     '''
     course_id = int(request.match_info['course_id'])
     return aiohttp.web.json_response(await courseroster(request, course_id))
+
+
+async def courseassignments_api(request):
+    '''
+    List all of the assignments in a course: Handler
+    '''
+    course_id = request.match_info['course_id']
+    return aiohttp.web.json_response(await courseassignments(request, course_id))

learning_observer/learning_observer/routes.py

@@ -72,9 +72,15 @@ def tracemalloc_handler(request):
         aiohttp.web.get(
             '/webapi/courselist/',
             rosters.courselist_api),
+        aiohttp.web.get(
+            '/webapi/course/{course_id}',
+            rosters.course_api),
         aiohttp.web.get(
             '/webapi/courseroster/{course_id}',
             rosters.courseroster_api),
+        aiohttp.web.get(
+            '/webapi/courseassignments/{course_id}',
+            rosters.courseassignments_api),
     ])
 
     register_auth_webapp_views(app)