Function enroll_user

apps/api/src/services/admin/admin.py:234–303

Enroll a user in a course on their behalf.

(
    request: Request,
    token_user: APITokenUser,
    user_id: int,
    course_uuid: str,
    db_session: AsyncSession,
)

async def enroll_user(
    request: Request,
    token_user: APITokenUser,
    user_id: int,
    course_uuid: str,
    db_session: AsyncSession,
) -> TrailRead:
    """Enroll a user in a course on their behalf."""

    await _get_user_in_org(user_id, token_user.org_id, db_session)

    course = (await db_session.execute(
        select(Course).where(
            Course.course_uuid == course_uuid,
            Course.org_id == token_user.org_id,
        )
    )).scalars().first()
    if not course:
        raise HTTPException(status_code=404, detail="Course not found")

    # Ensure trail exists
    trail = (await db_session.execute(
        select(Trail).where(Trail.org_id == token_user.org_id, Trail.user_id == user_id)
    )).scalars().first()
    if not trail:
        trail = Trail(
            org_id=token_user.org_id,
            user_id=user_id,
            trail_uuid=f"trail_{uuid4()}",
            creation_date=str(datetime.now()),
            update_date=str(datetime.now()),
        )
        db_session.add(trail)
        await db_session.commit()
        await db_session.refresh(trail)

    # Check for existing enrollment
    existing = (await db_session.execute(
        select(TrailRun).where(
            TrailRun.course_id == course.id,
            TrailRun.user_id == user_id,
            TrailRun.org_id == token_user.org_id,
        )
    )).scalars().first()
    if existing:
        raise HTTPException(status_code=400, detail="User is already enrolled in this course")

    trail_run = TrailRun(
        trail_id=trail.id if trail.id is not None else 0,
        course_id=course.id if course.id is not None else 0,
        org_id=token_user.org_id,
        user_id=user_id,
        creation_date=str(datetime.now()),
        update_date=str(datetime.now()),
    )
    db_session.add(trail_run)
    await db_session.commit()
    await db_session.refresh(trail_run)