Function create_accounts

api/oss/src/services/db_manager.py:1056–1096

Create a new account in the database. Args: payload (dict): The payload to create the user Returns: UserDB: instance of user

(payload: dict)

async def create_accounts(payload: dict) -> UserDB:
    """Create a new account in the database.

    Args:
        payload (dict): The payload to create the user

    Returns:
        UserDB: instance of user
    """

    # pop required fields for organization & workspace creation
    organization_id = payload.pop("organization_id")

    # create user
    user_info = {**payload, "username": payload["email"].split("@")[0]}
    user_db = await user_service.create_new_user(payload=user_info)

    # only update organization to have user_db as its "owner" if it does not yet have one
    # ---> updating the organization only happens in the first-user scenario
    #   where the first-user becomes the organization/workspace owner.
    try:
        await get_organization_owner(organization_id=organization_id)
    except (NoResultFound, ValueError):
        await update_organization(
            organization_id=organization_id, values_to_update={"owner": str(user_db.id)}
        )

    # get project belonging to organization
    project_db = await get_project_by_organization_id(organization_id=organization_id)

    # update user invitation in the case the user was invited
    invitation = await get_project_invitation_by_email(
        project_id=str(project_db.id), email=payload["email"]
    )
    if invitation is not None:
        await update_invitation(
            invitation_id=str(invitation.id),
            values_to_update={"user_id": str(user_db.id), "used": True},
        )

    return user_db


async def create_organization(name: str):