Compare commits
5 commits
f34c4f49d6
...
c0f808c20b
Author | SHA1 | Date | |
---|---|---|---|
c0f808c20b | |||
b9f347253d | |||
0785c87b8b | |||
b945c853ff | |||
48da59ad19 |
12 changed files with 204 additions and 50 deletions
|
@ -44,16 +44,6 @@ class UserIsNotPresentException(BlackPhoenixException):
|
|||
status_code = status.HTTP_401_UNAUTHORIZED
|
||||
|
||||
|
||||
class PasswordIsTooShortException(BlackPhoenixException):
|
||||
status_code = status.HTTP_409_CONFLICT
|
||||
detail = "Пароль должен быть не менее 8 символов"
|
||||
|
||||
|
||||
class IncorrectLengthOfNicknameException(BlackPhoenixException):
|
||||
status_code = status.HTTP_409_CONFLICT
|
||||
detail = "Ник должен быть не короче 2 и не длиннее 30 символов"
|
||||
|
||||
|
||||
class UserDontHavePermissionException(BlackPhoenixException):
|
||||
status_code = status.HTTP_409_CONFLICT
|
||||
detail = "У вас нет прав для этого действия"
|
||||
|
@ -64,3 +54,11 @@ class MessageNotFoundException(BlackPhoenixException):
|
|||
detail = "Сообщение не найдено"
|
||||
|
||||
|
||||
class IncorrectPasswordException(BlackPhoenixException):
|
||||
status_code = status.HTTP_409_CONFLICT
|
||||
detail = "Введён не верный пароль"
|
||||
|
||||
|
||||
class PasswordsМismatchException(BlackPhoenixException):
|
||||
status_code = status.HTTP_409_CONFLICT
|
||||
detail = "Пароли не совпадают"
|
||||
|
|
|
@ -29,6 +29,7 @@ app.add_middleware(
|
|||
"Set-Cookie",
|
||||
"Access-Control-Allow-Headers",
|
||||
"Authorization",
|
||||
"Accept"
|
||||
],
|
||||
)
|
||||
|
||||
|
|
|
@ -42,6 +42,3 @@ async def authenticate_user_by_username(username: str, password: str):
|
|||
if not user or not verify_password(password, user.hashed_password):
|
||||
return None
|
||||
return user
|
||||
|
||||
|
||||
|
||||
|
|
|
@ -16,8 +16,9 @@ router = APIRouter(
|
|||
|
||||
|
||||
@router.get("")
|
||||
async def root():
|
||||
return [1]
|
||||
async def root(user: Users = Depends(get_current_user)):
|
||||
print(user)
|
||||
return user.id
|
||||
|
||||
|
||||
@router.post("", status_code=status.HTTP_201_CREATED)
|
||||
|
|
|
@ -14,7 +14,7 @@ class Users(Base):
|
|||
username: Mapped[str]
|
||||
hashed_password: Mapped[str]
|
||||
role: Mapped[int]
|
||||
black_phoenix: Mapped[int]
|
||||
black_phoenix: Mapped[int] # Заменить на bool
|
||||
avatar_image: Mapped[Optional[str]] = mapped_column(server_default='app/static/images/ты уже пешка BP.png')
|
||||
date_of_birth: Mapped[date]
|
||||
|
||||
|
|
|
@ -1,14 +1,15 @@
|
|||
from fastapi import APIRouter, Response, Depends
|
||||
from fastapi.responses import RedirectResponse
|
||||
from starlette import status
|
||||
|
||||
from app.exceptions import UserAlreadyExistsException, IncorrectAuthDataException, UsernameAlreadyInUseException, \
|
||||
PasswordIsTooShortException, IncorrectLengthOfNicknameException
|
||||
IncorrectPasswordException, PasswordsМismatchException
|
||||
from app.users.auth import get_password_hash, authenticate_user_by_email, authenticate_user_by_username, \
|
||||
create_access_token
|
||||
create_access_token, verify_password
|
||||
from app.users.dao import UserDAO
|
||||
from app.users.dependencies import get_current_user
|
||||
from app.users.models import Users
|
||||
from app.users.schemas import SUserLogin, SUserRegister
|
||||
from app.users.schemas import SUserLogin, SUserRegister, SUser, SUserName, SUserPassword
|
||||
|
||||
router = APIRouter(
|
||||
prefix="/users",
|
||||
|
@ -16,18 +17,18 @@ router = APIRouter(
|
|||
)
|
||||
|
||||
|
||||
@router.get("/teleport")
|
||||
async def get_teleport() -> RedirectResponse:
|
||||
@router.get("/teleport", response_class=RedirectResponse, status_code=status.HTTP_307_TEMPORARY_REDIRECT)
|
||||
async def get_teleport():
|
||||
return RedirectResponse(url="https://www.youtube.com/watch?v=dQw4w9WgXcQ")
|
||||
|
||||
|
||||
@router.get("")
|
||||
@router.get("", response_model=list[SUser])
|
||||
async def get_all_users():
|
||||
users = await UserDAO.find_all()
|
||||
return users
|
||||
|
||||
|
||||
@router.post("/register")
|
||||
@router.post("/register", response_model=dict[str, str])
|
||||
async def register_user(response: Response, user_data: SUserRegister):
|
||||
existing_user = await UserDAO.find_one_or_none(email=user_data.email)
|
||||
if existing_user:
|
||||
|
@ -35,21 +36,22 @@ async def register_user(response: Response, user_data: SUserRegister):
|
|||
existing_user = await UserDAO.find_one_or_none(username=user_data.username)
|
||||
if existing_user:
|
||||
raise UserAlreadyExistsException
|
||||
if len(user_data.password) < 8:
|
||||
raise PasswordIsTooShortException
|
||||
if len(user_data.username) < 2 or len(user_data.username) > 30:
|
||||
raise IncorrectLengthOfNicknameException
|
||||
hashed_password = get_password_hash(user_data.password)
|
||||
await UserDAO.add(email=user_data.email, hashed_password=hashed_password,
|
||||
username=user_data.username, date_of_birth=user_data.date_of_birth,
|
||||
role=0, black_phoenix=0)
|
||||
await UserDAO.add(
|
||||
email=user_data.email,
|
||||
hashed_password=hashed_password,
|
||||
username=user_data.username,
|
||||
date_of_birth=user_data.date_of_birth,
|
||||
role=0,
|
||||
black_phoenix=0
|
||||
)
|
||||
user = await authenticate_user_by_email(user_data.email, user_data.password)
|
||||
access_token = create_access_token({"sub": str(user.id)})
|
||||
response.set_cookie("black_phoenix_access_token", access_token, httponly=True)
|
||||
response.set_cookie(key="black_phoenix_access_token", value=access_token, httponly=True)
|
||||
return {"access_token": access_token}
|
||||
|
||||
|
||||
@router.post("/login")
|
||||
@router.post("/login", response_model=dict[str, str])
|
||||
async def login_user(response: Response, user_data: SUserLogin):
|
||||
user = await authenticate_user_by_email(user_data.email_or_username, user_data.password)
|
||||
if not user:
|
||||
|
@ -61,30 +63,31 @@ async def login_user(response: Response, user_data: SUserLogin):
|
|||
return {"access_token": access_token}
|
||||
|
||||
|
||||
@router.post("/logout")
|
||||
@router.post("/logout", status_code=status.HTTP_200_OK)
|
||||
async def logout_user(response: Response):
|
||||
response.delete_cookie("black_phoenix_access_token")
|
||||
|
||||
|
||||
@router.get("/me")
|
||||
@router.get("/me", response_model=SUser)
|
||||
async def read_users_me(current_user: Users = Depends(get_current_user)):
|
||||
return current_user
|
||||
|
||||
|
||||
@router.patch("/rename")
|
||||
async def rename_user(new_username, current_user: Users = Depends(get_current_user)):
|
||||
if len(new_username) < 2 or len(new_username) > 30:
|
||||
raise IncorrectLengthOfNicknameException
|
||||
existing_user = await UserDAO.find_one_or_none(username=new_username)
|
||||
@router.patch("/rename", response_model=str)
|
||||
async def rename_user(new_username: SUserName, current_user: Users = Depends(get_current_user)):
|
||||
existing_user = await UserDAO.find_one_or_none(username=new_username.username)
|
||||
if existing_user:
|
||||
raise UsernameAlreadyInUseException
|
||||
new_username = await UserDAO.change_data(current_user.id, username=new_username)
|
||||
new_username = await UserDAO.change_data(current_user.id, username=new_username.username)
|
||||
return new_username
|
||||
|
||||
|
||||
@router.patch("/change_password")
|
||||
async def change_password(new_password, current_user: Users = Depends(get_current_user)):
|
||||
if len(new_password) < 8:
|
||||
raise PasswordIsTooShortException
|
||||
hashed_password = get_password_hash(new_password)
|
||||
@router.patch("/change_password", status_code=status.HTTP_200_OK)
|
||||
async def change_password(new_password: SUserPassword, current_user: Users = Depends(get_current_user)):
|
||||
existing_user = await UserDAO.find_one_or_none(id=current_user.id)
|
||||
if not verify_password(new_password.password, existing_user.hashed_password):
|
||||
raise IncorrectPasswordException
|
||||
if new_password.new_password != new_password.new_password2:
|
||||
raise PasswordsМismatchException
|
||||
hashed_password = get_password_hash(new_password.new_password)
|
||||
await UserDAO.change_data(current_user.id, hashed_password=hashed_password)
|
||||
|
|
|
@ -1,22 +1,39 @@
|
|||
from datetime import date
|
||||
|
||||
from pydantic import BaseModel, EmailStr
|
||||
from fastapi import Query
|
||||
|
||||
|
||||
class SUserLogin(BaseModel):
|
||||
email_or_username: EmailStr | str
|
||||
password: str
|
||||
|
||||
class Config:
|
||||
from_attributes = True
|
||||
|
||||
|
||||
class SUserRegister(BaseModel):
|
||||
email: EmailStr
|
||||
username: str = Query(None, min_length=2, max_length=30)
|
||||
password: str = Query(None, min_length=8)
|
||||
date_of_birth: date
|
||||
|
||||
|
||||
class SUser(BaseModel):
|
||||
email: EmailStr
|
||||
id: int
|
||||
username: str
|
||||
password: str
|
||||
avatar_image: str
|
||||
black_phoenix: int
|
||||
date_of_birth: date
|
||||
|
||||
class Config:
|
||||
from_attributes = True
|
||||
|
||||
|
||||
class SUserName(BaseModel):
|
||||
username: str = Query(None, min_length=2, max_length=30)
|
||||
|
||||
|
||||
class SUserPassword(BaseModel):
|
||||
password: str = Query(None, min_length=8)
|
||||
new_password: str = Query(None, min_length=8)
|
||||
new_password2: str = Query(None, min_length=8)
|
||||
|
||||
|
|
|
@ -6,6 +6,16 @@ export function fakeFetchCrypto() {
|
|||
resolve(cryptoData)
|
||||
}, 2000)
|
||||
})
|
||||
.then(function (response) {
|
||||
return response.json();
|
||||
})
|
||||
.then(function (data) {
|
||||
console.log(data);
|
||||
return data;
|
||||
})
|
||||
.catch(function (error) {
|
||||
console.log('Ошибка:', error);
|
||||
});
|
||||
}
|
||||
|
||||
export function fetchAssets() {
|
||||
|
@ -31,4 +41,5 @@ export async function fetchUsers() {
|
|||
console.log('Ошибка:', err);
|
||||
})
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
|
|
17
front/src/chat/components/AppContent.jsx
Normal file
17
front/src/chat/components/AppContent.jsx
Normal file
|
@ -0,0 +1,17 @@
|
|||
import {Layout} from "antd";
|
||||
import {users} from "../../api.js";
|
||||
|
||||
|
||||
|
||||
const contentStyle = {
|
||||
textAlign: 'center',
|
||||
minHeight: 120,
|
||||
lineHeight: 'calc(100vh - 64px)',
|
||||
color: '#fff',
|
||||
backgroundColor: '#001529',
|
||||
padding: '1rem',
|
||||
};
|
||||
|
||||
export default function () {
|
||||
return (<Layout.Content style={contentStyle}>users</Layout.Content>)
|
||||
}
|
11
front/src/chat/components/AppFooter.jsx
Normal file
11
front/src/chat/components/AppFooter.jsx
Normal file
|
@ -0,0 +1,11 @@
|
|||
import {Layout} from "antd";
|
||||
|
||||
const footerStyle = {
|
||||
textAlign: 'center',
|
||||
color: '#fff',
|
||||
backgroundColor: '#4096ff',
|
||||
};
|
||||
|
||||
export default function () {
|
||||
return (<Layout.Footer style={footerStyle}>Footer</Layout.Footer>)
|
||||
}
|
13
front/src/chat/components/AppHeader.jsx
Normal file
13
front/src/chat/components/AppHeader.jsx
Normal file
|
@ -0,0 +1,13 @@
|
|||
import {Layout} from "antd";
|
||||
|
||||
const headerStyle = {
|
||||
textAlign: 'center',
|
||||
color: '#fff',
|
||||
paddingInline: 48,
|
||||
lineHeight: '64px',
|
||||
backgroundColor: '#4096ff',
|
||||
};
|
||||
|
||||
export default function () {
|
||||
return (<Layout.Header style={headerStyle}>Header</Layout.Header>)
|
||||
}
|
85
front/src/chat/components/AppZalupa.jsx
Normal file
85
front/src/chat/components/AppZalupa.jsx
Normal file
|
@ -0,0 +1,85 @@
|
|||
import React, { useEffect, useState } from 'react';
|
||||
import { Avatar, Button, Skeleton, List} from 'antd';
|
||||
|
||||
|
||||
const count = 3;
|
||||
const fakeDataUrl = `http://localhost:8000/api/users`;
|
||||
|
||||
export default function () {
|
||||
const [initLoading, setInitLoading] = useState(true);
|
||||
const [loading, setLoading] = useState(false);
|
||||
const [data, setData] = useState([]);
|
||||
const [list, setList] = useState([]);
|
||||
useEffect(() => {
|
||||
fetch(fakeDataUrl)
|
||||
.then((res) => res.json())
|
||||
.then((res) => {
|
||||
setInitLoading(false);
|
||||
setData(res.results);
|
||||
setList(res.results);
|
||||
});
|
||||
}, []);
|
||||
const onLoadMore = () => {
|
||||
setLoading(true);
|
||||
setList(
|
||||
data.concat(
|
||||
[...new Array(count)].map(() => ({
|
||||
loading: true,
|
||||
name: {},
|
||||
picture: {},
|
||||
})),
|
||||
),
|
||||
);
|
||||
fetch(fakeDataUrl)
|
||||
.then((res) => res.json())
|
||||
.then((res) => {
|
||||
const newData = data.concat(res.results);
|
||||
setData(newData);
|
||||
setList(newData);
|
||||
setLoading(false);
|
||||
// Resetting window's offsetTop so as to display react-virtualized demo underfloor.
|
||||
// In real scene, you can using public method of react-virtualized:
|
||||
// https://stackoverflow.com/questions/46700726/how-to-use-public-method-updateposition-of-react-virtualized
|
||||
window.dispatchEvent(new Event('resize'));
|
||||
});
|
||||
};
|
||||
const loadMore =
|
||||
!initLoading && !loading ? (
|
||||
<div
|
||||
style={{
|
||||
textAlign: 'center',
|
||||
marginTop: 12,
|
||||
height: 32,
|
||||
lineHeight: '32px',
|
||||
}}
|
||||
>
|
||||
<Button onClick={onLoadMore}>loading more</Button>
|
||||
</div>
|
||||
) : null;
|
||||
return (
|
||||
<List
|
||||
className="demo-loadmore-list"
|
||||
loading={initLoading}
|
||||
itemLayout="horizontal"
|
||||
loadMore={loadMore}
|
||||
dataSource={list}
|
||||
renderItem={(item) => (
|
||||
<List.Item
|
||||
actions={[<a key="list-loadmore-edit">edit</a>, <a key="list-loadmore-more">more</a>]}
|
||||
>
|
||||
<Skeleton avatar title={false} loading={item.loading} active>
|
||||
<List.Item.Meta
|
||||
avatar={<Avatar src={item.picture.large} />}
|
||||
title={<a href="https://ant.design">{item.name?.last}</a>}
|
||||
description="Ant Design, a design language for background applications, is refined by Ant UED Team"
|
||||
/>
|
||||
<div>content</div>
|
||||
</Skeleton>
|
||||
</List.Item>
|
||||
)}
|
||||
/>
|
||||
);
|
||||
};
|
||||
|
||||
|
||||
|
Loading…
Add table
Reference in a new issue