Function user_settings

app/routers/user.py:42–426

(
    request: Request,
    fragment: str | None = Query(None),
    current_user: User = Depends(get_current_user),
    db: AsyncSession = Depends(get_db),
    settings: Settings = Depends(get_settings),
    queue: ArqRedis = Depends(get_queue),
    redis=Depends(get_redis_client),
)

@router.api_route("/settings", methods=["GET", "POST"], name="user_settings")
async def user_settings(
    request: Request,
    fragment: str | None = Query(None),
    current_user: User = Depends(get_current_user),
    db: AsyncSession = Depends(get_db),
    settings: Settings = Depends(get_settings),
    queue: ArqRedis = Depends(get_queue),
    redis=Depends(get_redis_client),
):
    # Delete
    delete_form: Any = await UserDeleteForm.from_formdata(request, user=current_user)
    if request.method == "POST" and fragment == "danger":
        if await delete_form.validate_on_submit():
            try:
                # User is marked as deleted, actual cleanup is delegated to a job
                current_user.status = "deleted"
                await db.commit()

                await queue.enqueue_job("delete_user", current_user.id)

                flash(
                    request,
                    _(
                        'User "%(name)s" has been marked for deletion.',
                        name=current_user.name,
                    ),
                    "success",
                )

                return RedirectResponse("/auth/logout", status_code=303)
            except Exception as e:
                await db.rollback()
                logger.error(
                    f'Error marking user "{current_user.username}" as deleted: {str(e)}'
                )
                flash(
                    request,
                    _("An error occurred while marking the user for deletion."),
                    "error",
                )

        return RedirectResponse(
            url=str(request.url_for("user_settings")) + "#danger",
            status_code=303,
        )

    # General
    general_form: Any = await UserGeneralForm.from_formdata(
        request,
        data={"name": current_user.name, "username": current_user.username},
        db=db,
        user=current_user,
    )

    if fragment == "general":
        if request.method == "POST" and await general_form.validate_on_submit():
            # Name
            current_user.name = general_form.name.data or ""