-
Notifications
You must be signed in to change notification settings - Fork 1.3k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
7 changed files
with
201 additions
and
33 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,12 @@ | ||
from collections.abc import Sequence | ||
|
||
from sqlalchemy import select | ||
from sqlalchemy.orm import Session | ||
|
||
from danswer.db.models import User | ||
|
||
|
||
def list_users(db_session: Session) -> Sequence[User]: | ||
"""List all users. No pagination as of now, as the # of users | ||
is assumed to be relatively small (<< 1 million)""" | ||
return db_session.scalars(select(User)).unique().all() |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,45 @@ | ||
from fastapi import APIRouter | ||
from fastapi import Depends | ||
from fastapi import HTTPException | ||
from fastapi_users.db import SQLAlchemyUserDatabase | ||
from fastapi_users_db_sqlalchemy import UUID_ID | ||
from sqlalchemy.ext.asyncio import AsyncSession | ||
from sqlalchemy.orm import Session | ||
|
||
from danswer.auth.schemas import UserRead | ||
from danswer.auth.schemas import UserRole | ||
from danswer.auth.users import current_admin_user | ||
from danswer.db.engine import get_session | ||
from danswer.db.engine import get_sqlalchemy_async_engine | ||
from danswer.db.models import User | ||
from danswer.db.users import list_users | ||
from danswer.server.models import UserByEmail | ||
|
||
|
||
router = APIRouter(prefix="/manage") | ||
|
||
|
||
@router.patch("/promote-user-to-admin") | ||
async def promote_admin( | ||
user_email: UserByEmail, user: User = Depends(current_admin_user) | ||
) -> None: | ||
if user.role != UserRole.ADMIN: | ||
raise HTTPException(status_code=401, detail="Unauthorized") | ||
async with AsyncSession(get_sqlalchemy_async_engine()) as asession: | ||
user_db = SQLAlchemyUserDatabase[User, UUID_ID](asession, User) | ||
user_to_promote = await user_db.get_by_email(user_email.user_email) | ||
if not user_to_promote: | ||
raise HTTPException(status_code=404, detail="User not found") | ||
user_to_promote.role = UserRole.ADMIN | ||
asession.add(user_to_promote) | ||
await asession.commit() | ||
return | ||
|
||
|
||
@router.get("/users") | ||
def list_all_users( | ||
_: User | None = Depends(current_admin_user), | ||
db_session: Session = Depends(get_session), | ||
) -> list[UserRead]: | ||
users = list_users(db_session) | ||
return [UserRead.from_orm(user) for user in users] |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,111 @@ | ||
"use client"; | ||
|
||
import { Button } from "@/components/Button"; | ||
import { LoadingAnimation } from "@/components/Loading"; | ||
import { BasicTable } from "@/components/admin/connectors/BasicTable"; | ||
import { Popup, usePopup } from "@/components/admin/connectors/Popup"; | ||
import { KeyIcon, TrashIcon, UsersIcon } from "@/components/icons/icons"; | ||
import { ApiKeyForm } from "@/components/openai/ApiKeyForm"; | ||
import { GEN_AI_API_KEY_URL } from "@/components/openai/constants"; | ||
import { fetcher } from "@/lib/fetcher"; | ||
import { User } from "@/lib/types"; | ||
import { useState } from "react"; | ||
import useSWR, { mutate } from "swr"; | ||
|
||
const columns = [ | ||
{ | ||
header: "Email", | ||
key: "email", | ||
}, | ||
{ | ||
header: "Role", | ||
key: "role", | ||
}, | ||
{ | ||
header: "Promote", | ||
key: "promote", | ||
}, | ||
]; | ||
|
||
const UsersTable = () => { | ||
const { popup, setPopup } = usePopup(); | ||
|
||
const { data, isLoading, error } = useSWR<User[]>( | ||
"/api/manage/users", | ||
fetcher | ||
); | ||
|
||
if (isLoading) { | ||
return <LoadingAnimation text="Loading" />; | ||
} | ||
|
||
if (error || !data) { | ||
return <div className="text-red-600">Error loading users</div>; | ||
} | ||
|
||
return ( | ||
<div> | ||
{popup} | ||
<BasicTable | ||
columns={columns} | ||
data={data.map((user) => { | ||
return { | ||
email: user.email, | ||
role: <i>{user.role === "admin" ? "Admin" : "User"}</i>, | ||
promote: | ||
user.role !== "admin" ? ( | ||
<Button | ||
onClick={async () => { | ||
const res = await fetch( | ||
"/api/manage/promote-user-to-admin", | ||
{ | ||
method: "PATCH", | ||
headers: { | ||
"Content-Type": "application/json", | ||
}, | ||
body: JSON.stringify({ | ||
user_email: user.email, | ||
}), | ||
} | ||
); | ||
if (!res.ok) { | ||
const errorMsg = await res.text(); | ||
setPopup({ | ||
message: `Unable to promote user - ${errorMsg}`, | ||
type: "error", | ||
}); | ||
} else { | ||
mutate("/api/manage/users"); | ||
setPopup({ | ||
message: "User promoted to admin!", | ||
type: "success", | ||
}); | ||
} | ||
}} | ||
> | ||
Promote to Admin! | ||
</Button> | ||
) : ( | ||
"" | ||
), | ||
}; | ||
})} | ||
/> | ||
</div> | ||
); | ||
}; | ||
|
||
const Page = () => { | ||
return ( | ||
<div> | ||
<div className="border-solid border-gray-600 border-b pb-2 mb-4 flex"> | ||
<UsersIcon size={32} /> | ||
<h1 className="text-3xl font-bold pl-2">Manage Users</h1> | ||
</div> | ||
|
||
<UsersTable /> | ||
</div> | ||
); | ||
}; | ||
|
||
export default Page; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
b27107c
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Successfully deployed to the following URLs:
internal-search – ./
internal-search-danswer.vercel.app
internal-search.vercel.app
internal-search-git-main-danswer.vercel.app
www.danswer.dev
danswer.dev