41 lines
1.1 KiB
Python
41 lines
1.1 KiB
Python
import model_messege as mm
|
|
|
|
from fastapi import APIRouter
|
|
import httpx
|
|
|
|
router = APIRouter(prefix="/api")
|
|
|
|
@router.post("/api/validation_collection_form")
|
|
async def validation_collection_form():
|
|
|
|
|
|
return {
|
|
"message": "Ошибка валидации формы"
|
|
}
|
|
|
|
@router.post("/api/login")
|
|
async def login(auth_request: mm.Login):
|
|
login = auth_request.login
|
|
password = auth_request.password
|
|
print(f"login: {login}, password: {password}")
|
|
|
|
# Отправляем данные в другую API
|
|
async with httpx.AsyncClient() as client:
|
|
response = await client.post("http://api-data-base:8001/api-data-base/login", json={'login': login, 'password': password})
|
|
|
|
# Проверяем статус ответа
|
|
if response.status_code == 200:
|
|
user_data = response.json()
|
|
return {
|
|
"message": "Авторизация успешна.",
|
|
"user": user_data
|
|
}
|
|
else:
|
|
return {
|
|
"message": "Ошибка авторизации",
|
|
"user": None
|
|
}
|
|
|
|
@router.on_event("shutdown")
|
|
def shutdown_event():
|
|
producer.close() |