feat: fetch LMS_USER_ID from LMS

license_manager/apps/api/mixins.py

@@ -1,4 +1,6 @@
 from functools import cached_property
+from rest_framework.exceptions import ParseError, status
+from license_manager.apps.api_client.lms import LMSApiClient
 
 from license_manager.apps.api import utils
 
@@ -18,9 +20,14 @@ def decoded_jwt(self):
 
         return utils.get_decoded_jwt(self.request)
 
-    @property
+    @cached_property
     def lms_user_id(self):
-        return utils.get_key_from_jwt(self.decoded_jwt, 'user_id')
+        try:
+            return utils.get_key_from_jwt(self.decoded_jwt, 'user_id')
+        except ParseError:
+            lms_client = LMSApiClient()
+            user_id = lms_client.fetch_lms_user_id(self.request.user.email)
+            return user_id
 
     @property
     def user_email(self):

license_manager/apps/api/v1/views.py

@@ -1,6 +1,7 @@
 import logging
 from collections import OrderedDict
 from contextlib import suppress
+from functools import cached_property
 from uuid import uuid4
 
 from celery import chain
@@ -45,6 +46,7 @@
     track_license_changes_task,
     update_user_email_for_licenses_task,
 )
+from license_manager.apps.api_client.lms import LMSApiClient
 from license_manager.apps.subscriptions import constants, event_utils
 from license_manager.apps.subscriptions.api import revoke_license
 from license_manager.apps.subscriptions.exceptions import (
@@ -1186,6 +1188,18 @@ def _check_param_has_type(self, param_name, required_type):
                 self.validation_errors.append(param_name)
         return param_value
 
+    """"
+    Another approach would be to override this property at child class level.
+    @cached_property
+    def lms_user_id(self):
+        try:
+            return utils.get_key_from_jwt(self.decoded_jwt, 'user_id')
+        except ParseError:
+            lms_client = LMSApiClient()
+            user_id = lms_client.fetch_lms_user_id(self.request.user.email)
+            return user_id
+    """
+
     @property
     def requested_notify_learners(self):
         return self._check_param_has_type('notify', bool)

license_manager/apps/api_client/lms.py

@@ -0,0 +1,41 @@
+import logging
+
+from django.conf import settings
+import requests
+
+from license_manager.apps.api_client.base_oauth import BaseOAuthClient
+logger = logging.getLogger(__name__)
+
+
+class LMSApiClient(BaseOAuthClient):
+    """
+    API client for calls to the LMS.
+    """
+    api_base_url = settings.LMS_URL
+    user_details_endpoint = api_base_url + '/api/user/v1/accounts'
+
+    def fetch_lms_user_id(self, email):
+        """
+        Fetch user details for the specified user email.
+
+        Arguments:
+            email (str): Email of the user for which we want to fetch details for.
+
+        Returns:
+            str: lms_user_id of the user.
+        """
+        # {base_api_url}/api/user/v1/[email protected]
+        try:
+            query_params = {'email': email}
+            response = self.client.get(self.user_details_endpoint, params=query_params)
+            response.raise_for_status()
+            response_json = response.json()
+            return response_json[0].get('id')
+        except requests.exceptions.HTTPError as exc:
+            logger.error(
+                'Failed to fetch user details for user {email} because {reason}'.format(
+                    email=email,
+                    reason=str(exc),
+                )
+            )
+            raise exc