enroll

konviva-events/app/config.py

@@ -1,6 +1,7 @@
 import os
 
 USER_TABLE: str = os.getenv('USER_TABLE')  # type: ignore
+ENROLLMENT_TABLE: str = os.getenv('ENROLLMENT_TABLE')  # type: ignore
 
 KONVIVA_API_URL: str = os.getenv('KONVIVA_API_URL')  # type: ignore
 KONVIVA_SECRET_KEY: str = os.getenv('KONVIVA_SECRET_KEY')  # type:ignore

konviva-events/app/events/enroll.py

@@ -4,13 +4,37 @@ from aws_lambda_powertools.utilities.data_classes import (
     event_source,
 )
 from aws_lambda_powertools.utilities.typing import LambdaContext
+from layercake.dynamodb import DynamoDBPersistenceLayer, KeyPair
+
+import konviva
+from boto3clients import dynamodb_client
+from config import ENROLLMENT_TABLE
 
 logger = Logger(__name__)
+enrollment_layer = DynamoDBPersistenceLayer(ENROLLMENT_TABLE, dynamodb_client)
 
 
 @event_source(data_class=EventBridgeEvent)
 @logger.inject_lambda_context
 def lambda_handler(event: EventBridgeEvent, context: LambdaContext) -> bool:
     new_image = event.detail['new_image']
+    user_id = new_image['user_id']
+    class_id = new_image['class_id']
 
-    return True
+    try:
+        enrollment_id = konviva.enroll(
+            user_id,
+            class_id,
+        )
+    except konviva.KonvivaError as err:
+        logger.exception(err)
+        return False
+
+    return enrollment_layer.update_item(
+        key=KeyPair(new_image['id'], 'konviva'),
+        update_expr='SET enrollment_id = :enrollment_id',
+        cond_expr='attribute_exists(sk)',
+        expr_attr_values={
+            ':enrollment_id': enrollment_id,
+        },
+    )

konviva-events/app/konviva.py

@@ -1,4 +1,3 @@
-from dataclasses import dataclass
 from urllib.parse import quote_plus, urlparse
 
 import requests
@@ -27,15 +26,6 @@ class EmailAlreadyExistsError(KonvivaError):
     pass
 
 
-@dataclass(frozen=True)
-class User:
-    IDUsuario: int
-    Identificador: str
-    NomeUsuario: str
-    Email: str
-    CPF: str | None = None
-
-
 def create_user(
     id: str,
     name: str,
@@ -97,7 +87,6 @@ def update_user(id: str, **kwargs) -> dict:
     )
     r.raise_for_status()
 
-    # Because Konviva does not return the proper HTTP status code
     if err := glom(r.json(), 'errors', default=None):
         err = err[0] if isinstance(err, list) else err
         raise KonvivaError(err)
@@ -120,3 +109,24 @@ def get_users_by_email(email: str) -> list[dict]:
         return []
 
     return r.json()
+
+
+def enroll(user_id: str, class_id: str) -> str:
+    url = urlparse(KONVIVA_API_URL)._replace(path='/action/api/integrarMatricula')
+
+    r = requests.post(
+        url=url.geturl(),
+        headers=headers,
+        json={
+            'IDUsuario': str(user_id),
+            'IDTurma': str(class_id),
+            'StatusMatricula': 'MATRICULADO',
+        },
+    )
+    r.raise_for_status()
+
+    if err := glom(r.json(), 'errors', default=None):
+        err = err[0] if isinstance(err, list) else err
+        raise KonvivaError(err)
+
+    return r.json().get('IDMatricula')