Compare commits
No commits in common. "master" and "feature/search" have entirely different histories.
master
...
feature/se
@ -12,20 +12,11 @@ from ..dependencies import database, cookie
|
|||||||
|
|
||||||
SECRET_KEY = "09d25e094faa6ca2556c818166b7a9563b93f7099f6f0f4caa6cf63b88e8d3e7"
|
SECRET_KEY = "09d25e094faa6ca2556c818166b7a9563b93f7099f6f0f4caa6cf63b88e8d3e7"
|
||||||
ALGORITHM = "HS256"
|
ALGORITHM = "HS256"
|
||||||
ACCESS_TOKEN_EXPIRE_MINUTES = 30
|
|
||||||
|
|
||||||
pwd_context = CryptContext(schemes=["bcrypt"], deprecated="auto")
|
pwd_context = CryptContext(schemes=["bcrypt"], deprecated="auto")
|
||||||
|
|
||||||
oauth2_scheme = cookie.OAuth2PasswordBearerWithCookie(tokenUrl="token")
|
oauth2_scheme = cookie.OAuth2PasswordBearerWithCookie(tokenUrl="token")
|
||||||
|
|
||||||
def create_access_token(data: dict, expires_delta: timedelta | None = None):
|
|
||||||
to_encode = data.copy()
|
|
||||||
expire = datetime.utcnow() + (expires_delta or timedelta(minutes=ACCESS_TOKEN_EXPIRE_MINUTES))
|
|
||||||
to_encode.update({"exp": expire})
|
|
||||||
encoded_jwt = jwt.encode(to_encode, SECRET_KEY, algorithm=ALGORITHM)
|
|
||||||
return encoded_jwt
|
|
||||||
|
|
||||||
|
|
||||||
def verify_password(plain_password, hashed_password):
|
def verify_password(plain_password, hashed_password):
|
||||||
return pwd_context.verify(plain_password, hashed_password)
|
return pwd_context.verify(plain_password, hashed_password)
|
||||||
|
|
||||||
|
@ -1,7 +1,7 @@
|
|||||||
from fastapi import FastAPI
|
from fastapi import FastAPI
|
||||||
from fastapi.middleware.cors import CORSMiddleware
|
from fastapi.middleware.cors import CORSMiddleware
|
||||||
|
|
||||||
from .routers import users, token, mail, events, tags, password
|
from .routers import users, token, mail, events
|
||||||
from .dependencies import user_add
|
from .dependencies import user_add
|
||||||
|
|
||||||
import os
|
import os
|
||||||
@ -29,8 +29,7 @@ app.include_router(users.router)
|
|||||||
app.include_router(token.router)
|
app.include_router(token.router)
|
||||||
app.include_router(mail.router)
|
app.include_router(mail.router)
|
||||||
app.include_router(events.router)
|
app.include_router(events.router)
|
||||||
app.include_router(tags.router)
|
|
||||||
app.include_router(password.router)
|
|
||||||
|
|
||||||
@app.on_event("startup")
|
@app.on_event("startup")
|
||||||
async def startup_event():
|
async def startup_event():
|
||||||
|
@ -1,24 +0,0 @@
|
|||||||
from pydantic import BaseModel, EmailStr
|
|
||||||
from pydantic_mongo import AbstractRepository, ObjectIdField
|
|
||||||
from datetime import datetime, date
|
|
||||||
|
|
||||||
class Tags(BaseModel):
|
|
||||||
id: ObjectIdField = None
|
|
||||||
name: str
|
|
||||||
created_at: datetime = datetime.today()
|
|
||||||
|
|
||||||
class TagsOut(BaseModel):
|
|
||||||
id: ObjectIdField = None
|
|
||||||
name: str
|
|
||||||
|
|
||||||
|
|
||||||
class TagsIn(BaseModel):
|
|
||||||
name: str
|
|
||||||
|
|
||||||
class TagsIDS(BaseModel):
|
|
||||||
ids: list[str]
|
|
||||||
|
|
||||||
|
|
||||||
class TagsRepository(AbstractRepository[Tags]):
|
|
||||||
class Meta:
|
|
||||||
collection_name = "tags"
|
|
@ -11,7 +11,7 @@ class User(BaseModel):
|
|||||||
roles: str = "User"
|
roles: str = "User"
|
||||||
status: int = 0
|
status: int = 0
|
||||||
email: EmailStr
|
email: EmailStr
|
||||||
birth: datetime | None = None
|
birth: str | None = None
|
||||||
created_at: datetime = datetime.today()
|
created_at: datetime = datetime.today()
|
||||||
connected_at: datetime | None = None
|
connected_at: datetime | None = None
|
||||||
updated_at: datetime | None = None
|
updated_at: datetime | None = None
|
||||||
@ -42,12 +42,7 @@ class UserCreate(BaseModel):
|
|||||||
username: str
|
username: str
|
||||||
password: str
|
password: str
|
||||||
email: EmailStr
|
email: EmailStr
|
||||||
birth: str
|
|
||||||
firstName: str
|
|
||||||
name: str
|
|
||||||
|
|
||||||
class UserForgotPassword(BaseModel):
|
|
||||||
email: EmailStr
|
|
||||||
|
|
||||||
class UserInDB(User):
|
class UserInDB(User):
|
||||||
password: str
|
password: str
|
||||||
|
@ -2,220 +2,117 @@ from fastapi import APIRouter, Depends, HTTPException, status, Response
|
|||||||
from fastapi.responses import JSONResponse
|
from fastapi.responses import JSONResponse
|
||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
from ..dependencies import users_token, permissions_checker, database
|
from ..dependencies import users_token, permissions_checker, database
|
||||||
from ..models import events, users, tags
|
from ..models import events, users
|
||||||
from pydantic import EmailStr
|
from pydantic import EmailStr
|
||||||
from typing import Annotated, Union
|
from typing import Annotated
|
||||||
from bson import ObjectId
|
from bson import ObjectId
|
||||||
from datetime import datetime
|
|
||||||
router = APIRouter()
|
router = APIRouter()
|
||||||
|
|
||||||
def build_location_filter(min_lat, max_lat, min_lon, max_lon):
|
|
||||||
"""Build location-based query filters."""
|
|
||||||
if min_lat is not None and max_lat is not None and min_lon is not None and max_lon is not None:
|
|
||||||
return [
|
|
||||||
{"latitude": {"$gte": min_lat}},
|
|
||||||
{"latitude": {"$lte": max_lat}},
|
|
||||||
{"longitude": {"$gte": min_lon}},
|
|
||||||
{"longitude": {"$lte": max_lon}},
|
|
||||||
]
|
|
||||||
return []
|
|
||||||
|
|
||||||
def build_datetime_filter(current_datetime):
|
|
||||||
"""Build filters for current datetime."""
|
|
||||||
if current_datetime:
|
|
||||||
return {
|
|
||||||
"$or": [
|
|
||||||
{"start_date": {"$gte": current_datetime}}, # Upcoming events
|
|
||||||
{
|
|
||||||
"$and": [
|
|
||||||
{"start_date": {"$lte": current_datetime}}, # Already started
|
|
||||||
{"$or": [
|
|
||||||
{"end_date": {"$gte": current_datetime}}, # Ongoing
|
|
||||||
{"end_date": None}, # No end date
|
|
||||||
]},
|
|
||||||
],
|
|
||||||
},
|
|
||||||
],
|
|
||||||
}
|
|
||||||
return None
|
|
||||||
|
|
||||||
def build_date_filter(start_date, end_date):
|
|
||||||
"""Build date range filters."""
|
|
||||||
if start_date and end_date:
|
|
||||||
return [
|
|
||||||
{"start_date": {"$gte": datetime.combine(start_date, datetime.min.time())}},
|
|
||||||
{"start_date": {"$lte": datetime.combine(end_date, datetime.max.time())}},
|
|
||||||
]
|
|
||||||
return []
|
|
||||||
|
|
||||||
def build_text_filter(item):
|
|
||||||
"""Build text-based search filters."""
|
|
||||||
if item:
|
|
||||||
return {
|
|
||||||
"$or": [
|
|
||||||
{"name": {"$regex": item, "$options": "i"}},
|
|
||||||
{"tags": {"$regex": item, "$options": "i"}},
|
|
||||||
{"organizers": {"$regex": item, "$options": "i"}},
|
|
||||||
]
|
|
||||||
}
|
|
||||||
return None
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@router.get("/events", tags=["events"], response_model=list[events.EventOut])
|
@router.get("/events", tags=["events"], response_model=list[events.EventOut])
|
||||||
async def read_events(
|
async def read_events(authorize: Annotated[bool, Depends(permissions_checker.PermissionChecker(roles=["Admin", "User"]))], skip: int = 0, limit: int = 20, id_event: str | None = None, name: str | None = None, status: int = 1, tags: str | None = None, organizers: str | None = None):
|
||||||
authorize: Annotated[bool, Depends(permissions_checker.PermissionChecker(roles=["Admin", "User"]))],
|
|
||||||
skip: int = 0,
|
|
||||||
limit: int = 20,
|
|
||||||
id_event: str | None = None,
|
|
||||||
name: str | None = None,
|
|
||||||
status: int = 1,
|
|
||||||
tags: str | None = None,
|
|
||||||
organizers: str | None = None,
|
|
||||||
current_datetime: datetime | None = None,
|
|
||||||
date_event: datetime | None = None,
|
|
||||||
start_date: datetime | None = None,
|
|
||||||
end_date: datetime | None = None,
|
|
||||||
):
|
|
||||||
# Validate `skip` and `limit`
|
|
||||||
if limit < 1 or skip < 0 or limit < skip:
|
if limit < 1 or skip < 0 or limit < skip:
|
||||||
raise HTTPException(
|
raise HTTPException(
|
||||||
status_code=status.HTTP_400_BAD_REQUEST,
|
status_code=status.HTTP_400_BAD_REQUEST,
|
||||||
detail="`skip` should be >= 0 and `limit` should be > 0 and greater than `skip`.",
|
detail="skip should be greater than 0 and limit should be greater than 1. Limit should be greater than skip"
|
||||||
)
|
)
|
||||||
skip = limit * skip
|
limit = limit + skip
|
||||||
# Initialize filters
|
listEvents = []
|
||||||
filters = []
|
|
||||||
|
|
||||||
# Add status filter
|
|
||||||
filters.append({"status": {"$eq": status}})
|
|
||||||
|
|
||||||
# Add date filters
|
|
||||||
if date_event:
|
|
||||||
start_of_day = datetime.combine(date_event, datetime.min.time())
|
|
||||||
end_of_day = datetime.combine(date_event, datetime.max.time())
|
|
||||||
filters.extend(build_date_filter(start_of_day, end_of_day))
|
|
||||||
elif start_date and end_date:
|
|
||||||
filters.extend(build_date_filter(start_date, end_date))
|
|
||||||
|
|
||||||
# Add current datetime filter
|
|
||||||
datetime_filter = build_datetime_filter(current_datetime)
|
|
||||||
if datetime_filter:
|
|
||||||
filters.append(datetime_filter)
|
|
||||||
|
|
||||||
# Add text-based filters
|
|
||||||
if name:
|
|
||||||
filters.append(build_text_filter(name))
|
|
||||||
if tags:
|
|
||||||
filters.append({"tags": {"$eq": tags}})
|
|
||||||
if organizers:
|
|
||||||
filters.append({"organizers": {"$eq": organizers}})
|
|
||||||
|
|
||||||
# Add ID filter
|
|
||||||
if id_event:
|
|
||||||
try:
|
|
||||||
event_id = ObjectId(id_event)
|
|
||||||
filters.append({"_id": {"$eq": event_id}})
|
|
||||||
except Exception:
|
|
||||||
raise HTTPException(status_code=status.HTTP_400_BAD_REQUEST, detail="Invalid event ID format.")
|
|
||||||
|
|
||||||
# Combine all filters
|
|
||||||
object_search = {"$and": filters} if filters else {}
|
|
||||||
|
|
||||||
# Fetch and return results
|
|
||||||
event_repository = events.EventRepository(database=database.database)
|
event_repository = events.EventRepository(database=database.database)
|
||||||
list_events = []
|
object_search = {}
|
||||||
for event_index in event_repository.find_by(object_search, limit=limit, skip=skip):
|
if status is not 1:
|
||||||
event = events.EventOut(
|
object_search = {"status":{"$eq": status}}
|
||||||
id=event_index.id,
|
|
||||||
tags=event_index.tags,
|
|
||||||
imgUrl=event_index.imgUrl,
|
|
||||||
name=event_index.name,
|
|
||||||
description=event_index.description,
|
|
||||||
place=event_index.place,
|
|
||||||
status=event_index.status,
|
|
||||||
start_date=event_index.start_date,
|
|
||||||
end_date=event_index.end_date,
|
|
||||||
)
|
|
||||||
list_events.append(event)
|
|
||||||
|
|
||||||
return list_events
|
if tags is not None:
|
||||||
|
object_search = {"$and":[{"tags":{"$eq": tags}}, {"status":{"$eq":status}}]}
|
||||||
|
if organizers is not None:
|
||||||
|
object_search = {"$and":[{"organizers":{"$eq": organizers}}, {"status":{"$eq":status}}]}
|
||||||
|
if id_event is not None:
|
||||||
|
eventid = ObjectId(id_event)
|
||||||
|
object_search = {"$and":[{"id":{"$regex": eventid}}, {"status":{"$eq":status}}]}
|
||||||
|
if name is not None:
|
||||||
|
object_search = {"$and":[{"name":{"$regex": name}}, {"status":{"$eq":status}}]}
|
||||||
|
|
||||||
|
|
||||||
|
for event_index in event_repository.find_by(object_search, limit=limit, skip=skip):
|
||||||
|
event = events.EventOut(id=event_index.id, tags=event_index.tags, imgUrl=event_index.imgUrl, name=event_index.name, description=event_index.description, place=event_index.place, status=event_index.status, start_date=event_index.start_date, end_date=event_index.end_date)
|
||||||
|
listEvents.append(event)
|
||||||
|
return listEvents
|
||||||
|
|
||||||
|
|
||||||
@router.get("/events/search", tags=["events"], response_model=list[events.EventOut])
|
@router.get("/events/search", tags=["events"], response_model=list[events.EventOut])
|
||||||
async def search_events(
|
async def search_events(authorize: Annotated[bool, Depends(permissions_checker.PermissionChecker(roles=["Admin", "User"]))], skip: int = 0, limit: int = 20, item: str | None = None, status: int = 1, min_lat: float | None = None, max_lat: float | None = None, min_lon: float | None = None, max_lon: float | None = None):
|
||||||
authorize: Annotated[bool, Depends(permissions_checker.PermissionChecker(roles=["Admin", "User"]))],
|
|
||||||
skip: int = 0,
|
|
||||||
limit: int = 20,
|
|
||||||
item: Union[str, None] = None,
|
|
||||||
status: int = 1,
|
|
||||||
min_lat: Union[float, None] = None,
|
|
||||||
max_lat: Union[float, None] = None,
|
|
||||||
min_lon: Union[float, None] = None,
|
|
||||||
max_lon: Union[float, None] = None,
|
|
||||||
current_datetime: Union[datetime, None] = None,
|
|
||||||
date_event: Union[datetime, None] = None,
|
|
||||||
start_date: Union[datetime, None] = None,
|
|
||||||
end_date: Union[datetime, None] = None,
|
|
||||||
tags: Union[str, None] = None,
|
|
||||||
):
|
|
||||||
if limit < 1 or skip < 0 or limit < skip:
|
if limit < 1 or skip < 0 or limit < skip:
|
||||||
raise HTTPException(
|
raise HTTPException(
|
||||||
status_code=status.HTTP_400_BAD_REQUEST,
|
status_code=status.HTTP_400_BAD_REQUEST,
|
||||||
detail="`skip` should be >= 0 and `limit` should be > 0 and greater than `skip`.",
|
detail="skip should be greater than 0 and limit should be greater than 1. Limit should be greater than skip"
|
||||||
)
|
)
|
||||||
skip = limit * skip
|
limit = limit + skip
|
||||||
|
listEvents = []
|
||||||
# Initialize filters
|
|
||||||
filters = [{"status": {"$eq": status}}]
|
|
||||||
|
|
||||||
# Date filters
|
|
||||||
if date_event:
|
|
||||||
start_of_day = datetime.combine(date_event, datetime.min.time())
|
|
||||||
end_of_day = datetime.combine(date_event, datetime.max.time())
|
|
||||||
filters.extend(build_date_filter(start_of_day, end_of_day))
|
|
||||||
else:
|
|
||||||
filters.extend(build_date_filter(start_date, end_date))
|
|
||||||
|
|
||||||
# Add location filter
|
|
||||||
filters.extend(build_location_filter(min_lat, max_lat, min_lon, max_lon))
|
|
||||||
|
|
||||||
# Add datetime filter
|
|
||||||
datetime_filter = build_datetime_filter(current_datetime)
|
|
||||||
if datetime_filter:
|
|
||||||
filters.append(datetime_filter)
|
|
||||||
|
|
||||||
# Add text filter
|
|
||||||
text_filter = build_text_filter(item)
|
|
||||||
if text_filter:
|
|
||||||
filters.append(text_filter)
|
|
||||||
|
|
||||||
if tags is not None:
|
|
||||||
filters.append({"tags": {"$eq": tags}})
|
|
||||||
|
|
||||||
# Combine filters
|
|
||||||
object_search = {"$and": filters} if filters else {}
|
|
||||||
|
|
||||||
# Fetch and return results
|
|
||||||
event_repository = events.EventRepository(database=database.database)
|
event_repository = events.EventRepository(database=database.database)
|
||||||
list_events = []
|
object_search = {}
|
||||||
|
if min_lat is not None and max_lat is not None and min_lon is not None and max_lon is not None:
|
||||||
|
object_search = {
|
||||||
|
"$and": [
|
||||||
|
{"status": {"$eq": status}},
|
||||||
|
{
|
||||||
|
"latitude": {"$gte": min_lat}, # Minimum latitude
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"latitude": {"$lte": max_lat}, # Maximum latitude
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"longitude": {"$gte": min_lon}, # Minimum longitude
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"longitude": {"$lte": max_lon}, # Maximum longitude
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
if item is not None:
|
||||||
|
object_search = {
|
||||||
|
"$and": [
|
||||||
|
{
|
||||||
|
"$or": [
|
||||||
|
{"name": {"$regex": item}},
|
||||||
|
{"tags": {"$regex": item}},
|
||||||
|
{"organizers": {"$regex": item}}
|
||||||
|
]
|
||||||
|
},
|
||||||
|
{"status": {"$eq": status}}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
if min_lat is not None and max_lat is not None and min_lon is not None and max_lon is not None:
|
||||||
|
object_search = {
|
||||||
|
"$and": [
|
||||||
|
{
|
||||||
|
"$or": [
|
||||||
|
{"name": {"$regex": item}},
|
||||||
|
{"tags": {"$regex": item}},
|
||||||
|
{"organizers": {"$regex": item}}
|
||||||
|
]
|
||||||
|
},
|
||||||
|
{"status": {"$eq": status}},
|
||||||
|
{
|
||||||
|
"latitude": {"$gte": min_lat}, # Minimum latitude
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"latitude": {"$lte": max_lat}, # Maximum latitude
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"longitude": {"$gte": min_lon}, # Minimum longitude
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"longitude": {"$lte": max_lon}, # Maximum longitude
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
|
||||||
for event_index in event_repository.find_by(object_search, limit=limit, skip=skip):
|
for event_index in event_repository.find_by(object_search, limit=limit, skip=skip):
|
||||||
event = events.EventOut(
|
event = events.EventOut(id=event_index.id, tags=event_index.tags, imgUrl=event_index.imgUrl, name=event_index.name, description=event_index.description, place=event_index.place, status=event_index.status, start_date=event_index.start_date, end_date=event_index.end_date)
|
||||||
id=event_index.id,
|
listEvents.append(event)
|
||||||
tags=event_index.tags,
|
return listEvents
|
||||||
imgUrl=event_index.imgUrl,
|
|
||||||
name=event_index.name,
|
|
||||||
description=event_index.description,
|
|
||||||
place=event_index.place,
|
|
||||||
status=event_index.status,
|
|
||||||
start_date=event_index.start_date,
|
|
||||||
end_date=event_index.end_date,
|
|
||||||
)
|
|
||||||
list_events.append(event)
|
|
||||||
|
|
||||||
return list_events
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@router.get("/events/me",tags=["events"])
|
@router.get("/events/me",tags=["events"])
|
||||||
@ -329,12 +226,8 @@ async def update_events(authorize: Annotated[bool, Depends(permissions_checker.P
|
|||||||
detail="Body request is empty"
|
detail="Body request is empty"
|
||||||
)
|
)
|
||||||
event_repository = events.EventRepository(database=database.database)
|
event_repository = events.EventRepository(database=database.database)
|
||||||
tags_repository = tags.TagsRepository(database=database.database)
|
|
||||||
|
|
||||||
event = event_repository.find_one_by( {"$and": [
|
event = event_repository.find_one_by({"name": {'$eq': eventSingle.name}})
|
||||||
{"start_date": {"$eq": eventSingle.start_date}}, # Already started
|
|
||||||
{"name": {"$eq": eventSingle.name}},
|
|
||||||
]})
|
|
||||||
if event is not None:
|
if event is not None:
|
||||||
raise HTTPException(
|
raise HTTPException(
|
||||||
status_code=status.HTTP_204_NO_CONTENT,
|
status_code=status.HTTP_204_NO_CONTENT,
|
||||||
@ -350,11 +243,6 @@ async def update_events(authorize: Annotated[bool, Depends(permissions_checker.P
|
|||||||
event.longitude = eventSingle.longitude
|
event.longitude = eventSingle.longitude
|
||||||
event.imgUrl = eventSingle.imgUrl
|
event.imgUrl = eventSingle.imgUrl
|
||||||
event.tags = eventSingle.tags
|
event.tags = eventSingle.tags
|
||||||
for tag_name in eventSingle.tags:
|
|
||||||
tag = tags_repository.find_one_by({"name": {'$eq': tag_name}})
|
|
||||||
if tag is None:
|
|
||||||
tag = tags.Tags(name=tag_name)
|
|
||||||
tags_repository.save(tag)
|
|
||||||
event.status = 1
|
event.status = 1
|
||||||
event.created_at = datetime.today()
|
event.created_at = datetime.today()
|
||||||
event_repository.save(event)
|
event_repository.save(event)
|
||||||
@ -371,7 +259,7 @@ async def update_events_id(item_id: str, authorize: Annotated[bool, Depends(perm
|
|||||||
detail="Body request is empty"
|
detail="Body request is empty"
|
||||||
)
|
)
|
||||||
event_repository = events.EventRepository(database=database.database)
|
event_repository = events.EventRepository(database=database.database)
|
||||||
tags_repository = tags.TagsRepository(database=database)
|
|
||||||
event = event_repository.find_one_by({"id": {'$eq': ObjectId(item_id)}})
|
event = event_repository.find_one_by({"id": {'$eq': ObjectId(item_id)}})
|
||||||
if event is None:
|
if event is None:
|
||||||
raise HTTPException(
|
raise HTTPException(
|
||||||
@ -386,11 +274,6 @@ async def update_events_id(item_id: str, authorize: Annotated[bool, Depends(perm
|
|||||||
event.end_date = eventSingle.end_date
|
event.end_date = eventSingle.end_date
|
||||||
event.organizers = eventSingle.organizers
|
event.organizers = eventSingle.organizers
|
||||||
event.tags = eventSingle.tags
|
event.tags = eventSingle.tags
|
||||||
for tag_name in eventSingle:
|
|
||||||
tag = tags_repository.find_one_by({"name": {'$eq': tag_name}})
|
|
||||||
if tag is None:
|
|
||||||
tag = Tags(name=tag_name)
|
|
||||||
tags_repository.save(tag)
|
|
||||||
event.latitude = eventSingle.latitude
|
event.latitude = eventSingle.latitude
|
||||||
event.longitude = eventSingle.longitude
|
event.longitude = eventSingle.longitude
|
||||||
event.updated_at = datetime.today()
|
event.updated_at = datetime.today()
|
||||||
|
@ -1,18 +1,12 @@
|
|||||||
from fastapi import APIRouter, HTTPException, status, Request
|
from fastapi import APIRouter, HTTPException, status
|
||||||
from fastapi.templating import Jinja2Templates
|
|
||||||
from ..dependencies import users_token, database, mail
|
from ..dependencies import users_token, database, mail
|
||||||
from ..models import users, email
|
from ..models import users, email
|
||||||
from fastapi.responses import JSONResponse, HTMLResponse
|
from fastapi.responses import JSONResponse
|
||||||
from fastapi_mail import MessageSchema, MessageType, FastMail
|
from fastapi_mail import MessageSchema, MessageType, FastMail
|
||||||
import random, os
|
import random
|
||||||
router = APIRouter()
|
router = APIRouter()
|
||||||
|
|
||||||
|
|
||||||
# Assurer que le chemin vers "templates" est correct
|
|
||||||
BASE_DIR = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
|
|
||||||
templates = Jinja2Templates(directory=os.path.join(BASE_DIR, "templates"))
|
|
||||||
|
|
||||||
|
|
||||||
@router.post("/mail",tags=["mail"])
|
@router.post("/mail",tags=["mail"])
|
||||||
async def create_user(userSingle: users.UserCreate | None = None):
|
async def create_user(userSingle: users.UserCreate | None = None):
|
||||||
if userSingle is None:
|
if userSingle is None:
|
||||||
@ -25,7 +19,7 @@ async def create_user(userSingle: users.UserCreate | None = None):
|
|||||||
if user is not None:
|
if user is not None:
|
||||||
raise HTTPException(
|
raise HTTPException(
|
||||||
status_code=status.HTTP_204_NO_CONTENT,
|
status_code=status.HTTP_204_NO_CONTENT,
|
||||||
detail="User already exists"
|
detail="User is already exist"
|
||||||
)
|
)
|
||||||
|
|
||||||
fm = FastMail(mail.conf)
|
fm = FastMail(mail.conf)
|
||||||
@ -41,32 +35,26 @@ async def create_user(userSingle: users.UserCreate | None = None):
|
|||||||
)
|
)
|
||||||
|
|
||||||
await fm.send_message(message, template_name="mailer.html")
|
await fm.send_message(message, template_name="mailer.html")
|
||||||
current_user = users.User(username=userSingle.username, password=users_token.get_password_hash(userSingle.password), email=userSingle.email, name=userSingle.name, firstName=userSingle.firstName)
|
current_user = users.User(username=userSingle.username, password=users_token.get_password_hash(userSingle.password), email=userSingle.email)
|
||||||
current_user.status = 0
|
|
||||||
user_repository.save(current_user)
|
user_repository.save(current_user)
|
||||||
database.connect_redis.set(userSingle.username, key_hashed)
|
database.connect_redis.set(userSingle.username, key_hashed)
|
||||||
return JSONResponse(status_code=status.HTTP_200_OK, content={"message": "email has been sent"})
|
return JSONResponse(status_code=status.HTTP_200_OK, content={"message": "email has been sent"})
|
||||||
|
|
||||||
@router.get("/mail", tags=["mail"])
|
@router.get("/mail",tags=["mail"])
|
||||||
async def confirm_user(request: Request, key: str | None = None, username: str | None = None):
|
async def confirm_user(key: str | None = None, username: str | None = None):
|
||||||
if key is None or username is None:
|
if key is None or username is None:
|
||||||
raise HTTPException(
|
raise HTTPException(
|
||||||
status_code=status.HTTP_400_BAD_REQUEST,
|
status_code=status.HTTP_400_BAD_REQUEST,
|
||||||
detail="Parameter key or/and username is empty"
|
detail="Parameter key or/and username is empty"
|
||||||
)
|
)
|
||||||
|
|
||||||
user_repository = users.UserRepository(database=database.database)
|
user_repository = users.UserRepository(database=database.database)
|
||||||
user = user_repository.find_one_by({"username": {'$eq': username}})
|
user = user_repository.find_one_by({"username": {'$eq': username}})
|
||||||
key_hashed = database.connect_redis.get(username)
|
key_hashed = database.connect_redis.get(username)
|
||||||
|
|
||||||
if key_hashed != key:
|
if key_hashed != key:
|
||||||
raise HTTPException(
|
raise HTTPException(
|
||||||
status_code=status.HTTP_400_BAD_REQUEST,
|
status_code=status.HTTP_400_BAD_REQUEST,
|
||||||
detail="Key is invalid"
|
detail="Key is invalid"
|
||||||
)
|
)
|
||||||
|
user.confirmed = True
|
||||||
user.status = 1
|
|
||||||
user_repository.save(user)
|
user_repository.save(user)
|
||||||
|
return JSONResponse(status_code=status.HTTP_200_OK, content={"message": "user account confirmed"})
|
||||||
# Rendre la page HTML avec Jinja2 et passer la variable username
|
|
||||||
return templates.TemplateResponse("confirm.html", {"request": request, "username": username})
|
|
@ -1,137 +0,0 @@
|
|||||||
from fastapi import APIRouter, HTTPException, status, Request, Form
|
|
||||||
from fastapi.templating import Jinja2Templates
|
|
||||||
from ..dependencies import users_token, database, mail
|
|
||||||
from ..models import users, email
|
|
||||||
from fastapi.responses import JSONResponse, HTMLResponse
|
|
||||||
from fastapi_mail import MessageSchema, MessageType, FastMail
|
|
||||||
import random, os, bcrypt
|
|
||||||
|
|
||||||
router = APIRouter()
|
|
||||||
|
|
||||||
# Assurer que le chemin vers "templates" est correct
|
|
||||||
BASE_DIR = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
|
|
||||||
templates = Jinja2Templates(directory=os.path.join(BASE_DIR, "templates"))
|
|
||||||
|
|
||||||
@router.post("/password/forgot", tags=["password"])
|
|
||||||
async def forgot_password(userSingle: users.UserForgotPassword):
|
|
||||||
if not userSingle.email:
|
|
||||||
raise HTTPException(
|
|
||||||
status_code=status.HTTP_400_BAD_REQUEST,
|
|
||||||
detail="Email is required"
|
|
||||||
)
|
|
||||||
|
|
||||||
# Recherche de l'utilisateur dans la base de données
|
|
||||||
user_repository = users.UserRepository(database=database.database)
|
|
||||||
user = user_repository.find_one_by({"email": {"$eq": userSingle.email}})
|
|
||||||
|
|
||||||
if user is None:
|
|
||||||
raise HTTPException(
|
|
||||||
status_code=status.HTTP_404_NOT_FOUND,
|
|
||||||
detail="User not found"
|
|
||||||
)
|
|
||||||
|
|
||||||
# Génération d'un token temporaire pour réinitialisation
|
|
||||||
reset_token = str(random.randint(100000, 999999))
|
|
||||||
key_hashed = users_token.get_password_hash(reset_token)
|
|
||||||
|
|
||||||
# Créer le lien de réinitialisation
|
|
||||||
reset_link = f"https://backend.valczeryba.ovh/password/reset?key={reset_token}&email={user.email}"
|
|
||||||
|
|
||||||
# Préparer les données à envoyer au template
|
|
||||||
email_body = {
|
|
||||||
"username": user.username,
|
|
||||||
"reset_link": reset_link
|
|
||||||
}
|
|
||||||
|
|
||||||
# Créer le message à envoyer
|
|
||||||
message = MessageSchema(
|
|
||||||
subject="Password Reset Request",
|
|
||||||
recipients=[user.email],
|
|
||||||
template_body=email_body,
|
|
||||||
subtype=MessageType.html,
|
|
||||||
)
|
|
||||||
|
|
||||||
# Utilisation de FastMail pour envoyer l'email
|
|
||||||
fm = FastMail(mail.conf)
|
|
||||||
await fm.send_message(message, template_name="forgot_password_email.html")
|
|
||||||
|
|
||||||
# Stockage du token temporaire dans Redis avec une expiration d'1 heure
|
|
||||||
database.connect_redis.setex(user.email, 3600, key_hashed)
|
|
||||||
|
|
||||||
return JSONResponse(status_code=status.HTTP_200_OK, content={"message": "Password reset email has been sent"})
|
|
||||||
|
|
||||||
@router.get("/password/reset", tags=["password"])
|
|
||||||
async def reset_password(request: Request, key: str | None = None, email: str | None = None):
|
|
||||||
if not key or not email:
|
|
||||||
raise HTTPException(
|
|
||||||
status_code=status.HTTP_400_BAD_REQUEST,
|
|
||||||
detail="Parameters 'key' and 'email' are required"
|
|
||||||
)
|
|
||||||
|
|
||||||
# Récupérer la clé hachée depuis Redis
|
|
||||||
key_hashed = database.connect_redis.get(email)
|
|
||||||
|
|
||||||
if key_hashed is None:
|
|
||||||
raise HTTPException(
|
|
||||||
status_code=status.HTTP_400_BAD_REQUEST,
|
|
||||||
detail="Invalid or expired reset key"
|
|
||||||
)
|
|
||||||
|
|
||||||
# Redis stocke les valeurs en `bytes`, donc il faut décoder si nécessaire
|
|
||||||
if isinstance(key_hashed, bytes):
|
|
||||||
key_hashed = key_hashed.decode()
|
|
||||||
|
|
||||||
|
|
||||||
# Vérifier que la clé en clair correspond au hash stocké
|
|
||||||
if not bcrypt.checkpw(key.encode(), key_hashed.encode()):
|
|
||||||
raise HTTPException(
|
|
||||||
status_code=status.HTTP_400_BAD_REQUEST,
|
|
||||||
detail="Invalid reset key"
|
|
||||||
)
|
|
||||||
|
|
||||||
|
|
||||||
# Afficher la page HTML de réinitialisation du mot de passe
|
|
||||||
return templates.TemplateResponse("reset_password.html", {"request": request, "email": email, "key": key})
|
|
||||||
|
|
||||||
@router.post("/password/update", tags=["password"])
|
|
||||||
async def update_password(request: Request, email: str = Form(...), key: str = Form(...), new_password: str = Form(...)): # Vérification du token dans Redis
|
|
||||||
# Récupérer la clé hachée depuis Redis
|
|
||||||
key_hashed = database.connect_redis.get(email)
|
|
||||||
|
|
||||||
if key_hashed is None:
|
|
||||||
raise HTTPException(
|
|
||||||
status_code=status.HTTP_400_BAD_REQUEST,
|
|
||||||
detail="Invalid or expired reset key"
|
|
||||||
)
|
|
||||||
|
|
||||||
# Redis stocke les valeurs en `bytes`, donc il faut décoder si nécessaire
|
|
||||||
if isinstance(key_hashed, bytes):
|
|
||||||
key_hashed = key_hashed.decode()
|
|
||||||
|
|
||||||
|
|
||||||
# Vérifier que la clé en clair correspond au hash stocké
|
|
||||||
if not bcrypt.checkpw(key.encode(), key_hashed.encode()):
|
|
||||||
raise HTTPException(
|
|
||||||
status_code=status.HTTP_400_BAD_REQUEST,
|
|
||||||
detail="Invalid reset key"
|
|
||||||
)
|
|
||||||
|
|
||||||
# Recherche de l'utilisateur dans la base de données
|
|
||||||
user_repository = users.UserRepository(database=database.database)
|
|
||||||
user = user_repository.find_one_by({"email": {"$eq": email}})
|
|
||||||
|
|
||||||
if user is None:
|
|
||||||
raise HTTPException(
|
|
||||||
status_code=status.HTTP_404_NOT_FOUND,
|
|
||||||
detail="User not found"
|
|
||||||
)
|
|
||||||
|
|
||||||
# Mise à jour du mot de passe de l'utilisateur
|
|
||||||
user.password = users_token.get_password_hash(new_password)
|
|
||||||
user_repository.save(user)
|
|
||||||
|
|
||||||
# Suppression du token temporaire dans Redis
|
|
||||||
database.connect_redis.delete(email)
|
|
||||||
|
|
||||||
# Afficher un message de succès dans une réponse HTML
|
|
||||||
return templates.TemplateResponse("password_update_success.html", {"request": request, "email": email})
|
|
@ -1,119 +0,0 @@
|
|||||||
from fastapi import APIRouter, Depends, HTTPException, status, Response
|
|
||||||
from fastapi.responses import JSONResponse
|
|
||||||
from datetime import datetime
|
|
||||||
from ..dependencies import users_token, permissions_checker, database
|
|
||||||
from ..models import tags, users
|
|
||||||
from pydantic import EmailStr
|
|
||||||
from typing import Annotated, Union
|
|
||||||
from bson import ObjectId
|
|
||||||
from datetime import datetime
|
|
||||||
router = APIRouter()
|
|
||||||
|
|
||||||
|
|
||||||
@router.get("/tags", tags=["tags"], response_model=list[tags.TagsOut])
|
|
||||||
async def read_tags(
|
|
||||||
authorize: Annotated[bool, Depends(permissions_checker.PermissionChecker(roles=["Admin", "User"]))],
|
|
||||||
skip: int = 0,
|
|
||||||
limit: int = 20,
|
|
||||||
id_tags: str | None = None,
|
|
||||||
name: str | None = None
|
|
||||||
):
|
|
||||||
# Validate `skip` and `limit`
|
|
||||||
if limit < 1 or skip < 0 or limit < skip:
|
|
||||||
raise HTTPException(
|
|
||||||
status_code=status.HTTP_400_BAD_REQUEST,
|
|
||||||
detail="`skip` should be >= 0 and `limit` should be > 0 and greater than `skip`.",
|
|
||||||
)
|
|
||||||
limit = limit + skip
|
|
||||||
|
|
||||||
# Initialize filters
|
|
||||||
filters = []
|
|
||||||
|
|
||||||
|
|
||||||
if name:
|
|
||||||
filters.append({"name": {"$regex": name, "$options": "i"}})
|
|
||||||
|
|
||||||
# Add ID filter
|
|
||||||
if id_tags:
|
|
||||||
try:
|
|
||||||
tags_id = ObjectId(id_tags)
|
|
||||||
filters.append({"_id": {"$eq": event_id}})
|
|
||||||
except Exception:
|
|
||||||
raise HTTPException(status_code=status.HTTP_400_BAD_REQUEST, detail="Invalid event ID format.")
|
|
||||||
|
|
||||||
# Combine all filters
|
|
||||||
object_search = {"$and": filters} if filters else {}
|
|
||||||
|
|
||||||
# Fetch and return results
|
|
||||||
tags_repository = tags.TagsRepository(database=database.database)
|
|
||||||
list_tags = []
|
|
||||||
for tag_index in tags_repository.find_by(object_search, limit=limit, skip=skip):
|
|
||||||
tag = tags.TagsOut(
|
|
||||||
id=tag_index.id,
|
|
||||||
name=tag_index.name
|
|
||||||
)
|
|
||||||
list_tags.append(tag)
|
|
||||||
|
|
||||||
return list_tags
|
|
||||||
|
|
||||||
@router.get("/tags/count", tags=["tags"])
|
|
||||||
async def read_tags_count(authorize: Annotated[bool, Depends(permissions_checker.PermissionChecker(roles=["Admin", "User"]))]):
|
|
||||||
count = database.database.get_collection("tags").estimated_document_count()
|
|
||||||
content = {"count":count}
|
|
||||||
response = JSONResponse(content=content)
|
|
||||||
return response
|
|
||||||
|
|
||||||
|
|
||||||
@router.get("/tags/{item_id}", tags=["tags"], response_model=tags.Tags)
|
|
||||||
async def read_tags_id(item_id : str, authorize: Annotated[bool, Depends(permissions_checker.PermissionChecker(roles=["Admin"]))]):
|
|
||||||
tags_repository = tags.TagsRepository(database=database.database)
|
|
||||||
tag = tags_repository.find_one_by_id(ObjectId(item_id))
|
|
||||||
return tag
|
|
||||||
|
|
||||||
|
|
||||||
@router.delete("/tags/groups",tags=["tags"])
|
|
||||||
async def delete_tags_groups(authorize: Annotated[bool, Depends(permissions_checker.PermissionChecker(roles=["Admin"]))], tagsids: tags.TagsIDS | None = None):
|
|
||||||
if len(tagsids.ids) == 0:
|
|
||||||
raise HTTPException(
|
|
||||||
status_code=status.HTTP_400_BAD_REQUEST,
|
|
||||||
detail="eventids should be greater than 0"
|
|
||||||
)
|
|
||||||
|
|
||||||
tag_repository = tags.TagsRepository(database=database.database)
|
|
||||||
for i in tagsids.ids:
|
|
||||||
tag = tag_repository.find_one_by_id(ObjectId(i))
|
|
||||||
tag_repository.delete_one(tag)
|
|
||||||
content = {"message": "tags removed"}
|
|
||||||
response = JSONResponse(content=content)
|
|
||||||
return response
|
|
||||||
|
|
||||||
@router.delete("/tags/{item_id}", tags=["tags"])
|
|
||||||
async def delete_tags_id(item_id : str, authorize: Annotated[bool, Depends(permissions_checker.PermissionChecker(roles=["Admin"]))]):
|
|
||||||
tag_repository = tags.TagsRepository(database=database.database)
|
|
||||||
tag = tag_repository.find_one_by_id(ObjectId(item_id))
|
|
||||||
event_repository.delete_one(event)
|
|
||||||
content = {"message": "tags delete"}
|
|
||||||
response = JSONResponse(content=content)
|
|
||||||
return responsed
|
|
||||||
|
|
||||||
@router.put("/tags", tags=["tags"], status_code=status.HTTP_201_CREATED)
|
|
||||||
async def update_tags(authorize: Annotated[bool, Depends(permissions_checker.PermissionChecker(roles=["Admin"]))], tagSingle: tags.TagsIn | None = None):
|
|
||||||
if tagSingle is None:
|
|
||||||
raise HTTPException(
|
|
||||||
status_code=status.HTTP_400_BAD_REQUEST,
|
|
||||||
detail="Body request is empty"
|
|
||||||
)
|
|
||||||
tag_repository = tags.TagsRepository(database=database.database)
|
|
||||||
|
|
||||||
tag = tag_repository.find_one_by({"name": {'$eq': tagSingle.name}})
|
|
||||||
if tag is not None:
|
|
||||||
raise HTTPException(
|
|
||||||
status_code=status.HTTP_204_NO_CONTENT,
|
|
||||||
detail="name"
|
|
||||||
)
|
|
||||||
tag = tags.Tags(name=tagSingle.name)
|
|
||||||
tag.created_at = datetime.today()
|
|
||||||
tag_repository.save(event)
|
|
||||||
content = {"message": "tags created"}
|
|
||||||
response = JSONResponse(content=content, status_code=status.HTTP_201_CREATED)
|
|
||||||
return response
|
|
@ -1,7 +1,7 @@
|
|||||||
from datetime import datetime, timedelta
|
from datetime import datetime, timedelta
|
||||||
|
|
||||||
from typing import Annotated
|
from typing import Annotated
|
||||||
from fastapi import Depends, FastAPI, HTTPException, status, APIRouter, Form
|
from fastapi import Depends, FastAPI, HTTPException, status, APIRouter
|
||||||
from fastapi.responses import JSONResponse
|
from fastapi.responses import JSONResponse
|
||||||
from fastapi.security import OAuth2PasswordBearer, OAuth2PasswordRequestForm
|
from fastapi.security import OAuth2PasswordBearer, OAuth2PasswordRequestForm
|
||||||
from ..dependencies import users_token, permissions_checker
|
from ..dependencies import users_token, permissions_checker
|
||||||
@ -13,19 +13,15 @@ ACCESS_TOKEN_EXPIRE_MINUTES = 30
|
|||||||
|
|
||||||
@router.post("/token", tags=["token"])
|
@router.post("/token", tags=["token"])
|
||||||
async def login_for_access_token(
|
async def login_for_access_token(
|
||||||
form_data: Annotated[OAuth2PasswordRequestForm, Depends()],
|
form_data: Annotated[OAuth2PasswordRequestForm, Depends()]):
|
||||||
remember_me: bool = Form(False)):
|
|
||||||
user = users_token.authenticate_user(form_data.username, form_data.password)
|
user = users_token.authenticate_user(form_data.username, form_data.password)
|
||||||
expires_access_token_time = ACCESS_TOKEN_EXPIRE_MINUTES
|
|
||||||
if remember_me:
|
|
||||||
expires_access_token_time=120
|
|
||||||
if not user:
|
if not user:
|
||||||
raise HTTPException(
|
raise HTTPException(
|
||||||
status_code=status.HTTP_401_UNAUTHORIZED,
|
status_code=status.HTTP_401_UNAUTHORIZED,
|
||||||
detail="Incorrect username or password",
|
detail="Incorrect username or password",
|
||||||
headers={"WWW-Authenticate": "Bearer"},
|
headers={"WWW-Authenticate": "Bearer"},
|
||||||
)
|
)
|
||||||
access_token_expires = timedelta(minutes=expires_access_token_time)
|
access_token_expires = timedelta(minutes=ACCESS_TOKEN_EXPIRE_MINUTES)
|
||||||
access_token = users_token.create_access_token(
|
access_token = users_token.create_access_token(
|
||||||
data={"sub": user.username}, expires_delta=access_token_expires
|
data={"sub": user.username}, expires_delta=access_token_expires
|
||||||
)
|
)
|
||||||
|
@ -139,17 +139,13 @@ async def delete_users_id(item_id : str, authorize: Annotated[bool, Depends(perm
|
|||||||
response = JSONResponse(content=content)
|
response = JSONResponse(content=content)
|
||||||
return response
|
return response
|
||||||
|
|
||||||
|
|
||||||
@router.put("/users/me",tags=["users"])
|
@router.put("/users/me",tags=["users"])
|
||||||
async def update_users_me(current_user: Annotated[users.User, Depends(users_token.get_current_active_user)], authorize: Annotated[bool, Depends(permissions_checker.PermissionChecker(roles=["Admin", "User"]))], userSingle: users.UserIn | None = None):
|
async def update_users_me(current_user: Annotated[users.User, Depends(users_token.get_current_active_user)], authorize: Annotated[bool, Depends(permissions_checker.PermissionChecker(roles=["Admin", "User"]))], userSingle: users.UserIn | None = None):
|
||||||
user_repository = users.UserRepository(database=database.database)
|
user_repository = users.UserRepository(database=database.database)
|
||||||
current_user.username = userSingle.username
|
current_user.username = userSingle.username
|
||||||
if len(userSingle.password) > 0:
|
current_user.password = user_token.get_password_hash(userSingle.password)
|
||||||
current_user.password = user_token.get_password_hash(userSingle.password)
|
current_user.roles = userSingle.roles
|
||||||
current_user.email = userSingle.email
|
current_user.email = userSingle.email
|
||||||
current_user.name = userSingle.name
|
|
||||||
current_user.firstName = userSingle.firstName
|
|
||||||
current_user.birth = userSingle.birth
|
|
||||||
user_repository.save(current_user)
|
user_repository.save(current_user)
|
||||||
content = {"message": "user is updated"}
|
content = {"message": "user is updated"}
|
||||||
response = JSONResponse(content=content)
|
response = JSONResponse(content=content)
|
||||||
@ -206,8 +202,7 @@ async def update_users_id(item_id: str, authorize: Annotated[bool, Depends(permi
|
|||||||
)
|
)
|
||||||
|
|
||||||
user.username = userSingle.username
|
user.username = userSingle.username
|
||||||
if len(userSingle.password) > 0:
|
user.password = users_token.get_password_hash(userSingle.password)
|
||||||
user.password = users_token.get_password_hash(userSingle.password)
|
|
||||||
user.roles = userSingle.roles
|
user.roles = userSingle.roles
|
||||||
user.email = userSingle.email
|
user.email = userSingle.email
|
||||||
user.firstName = userSingle.firstName
|
user.firstName = userSingle.firstName
|
||||||
|
@ -1,58 +0,0 @@
|
|||||||
<!DOCTYPE html>
|
|
||||||
<html>
|
|
||||||
<head>
|
|
||||||
<meta charset="UTF-8">
|
|
||||||
<title>Votre compte est activé</title>
|
|
||||||
<style>
|
|
||||||
body {
|
|
||||||
font-family: Arial, sans-serif;
|
|
||||||
background-color: #f4f4f4;
|
|
||||||
margin: 0;
|
|
||||||
padding: 0;
|
|
||||||
}
|
|
||||||
.container {
|
|
||||||
max-width: 600px;
|
|
||||||
margin: 20px auto;
|
|
||||||
background: #ffffff;
|
|
||||||
padding: 20px;
|
|
||||||
border-radius: 10px;
|
|
||||||
box-shadow: 0 2px 5px rgba(0,0,0,0.1);
|
|
||||||
text-align: center;
|
|
||||||
}
|
|
||||||
h2 {
|
|
||||||
color: #333;
|
|
||||||
}
|
|
||||||
p {
|
|
||||||
color: #666;
|
|
||||||
font-size: 16px;
|
|
||||||
}
|
|
||||||
.button {
|
|
||||||
display: inline-block;
|
|
||||||
background: #007BFF;
|
|
||||||
color: white;
|
|
||||||
padding: 12px 20px;
|
|
||||||
text-decoration: none;
|
|
||||||
border-radius: 5px;
|
|
||||||
font-size: 16px;
|
|
||||||
font-weight: bold;
|
|
||||||
margin-top: 20px;
|
|
||||||
}
|
|
||||||
.button:hover {
|
|
||||||
background: #0056b3;
|
|
||||||
}
|
|
||||||
.footer {
|
|
||||||
margin-top: 20px;
|
|
||||||
font-size: 12px;
|
|
||||||
color: #888;
|
|
||||||
}
|
|
||||||
</style>
|
|
||||||
</head>
|
|
||||||
<body>
|
|
||||||
<div class="container">
|
|
||||||
<h2>Félicitations, {{ username }} ! 🎉</h2>
|
|
||||||
<p>Votre compte a été activé avec succès.</p>
|
|
||||||
<p>Vous pouvez maintenant vous connecter et profiter pleinement de nos services.</p>
|
|
||||||
<p class="footer">Si vous avez des questions, n'hésitez pas à nous contacter.</p>
|
|
||||||
</div>
|
|
||||||
</body>
|
|
||||||
</html>
|
|
@ -1,69 +0,0 @@
|
|||||||
<!-- forgot_password_email.html -->
|
|
||||||
<!DOCTYPE html>
|
|
||||||
<html lang="fr">
|
|
||||||
<head>
|
|
||||||
<meta charset="UTF-8">
|
|
||||||
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
|
||||||
<title>Réinitialisation de votre mot de passe</title>
|
|
||||||
<style>
|
|
||||||
body {
|
|
||||||
font-family: Arial, sans-serif;
|
|
||||||
background-color: #f4f4f9;
|
|
||||||
color: #333;
|
|
||||||
margin: 0;
|
|
||||||
padding: 0;
|
|
||||||
}
|
|
||||||
.container {
|
|
||||||
width: 100%;
|
|
||||||
max-width: 600px;
|
|
||||||
margin: 50px auto;
|
|
||||||
padding: 20px;
|
|
||||||
background-color: white;
|
|
||||||
box-shadow: 0 4px 8px rgba(0, 0, 0, 0.1);
|
|
||||||
border-radius: 8px;
|
|
||||||
}
|
|
||||||
h1 {
|
|
||||||
color: #4CAF50;
|
|
||||||
text-align: center;
|
|
||||||
}
|
|
||||||
p {
|
|
||||||
font-size: 16px;
|
|
||||||
line-height: 1.5;
|
|
||||||
text-align: center;
|
|
||||||
}
|
|
||||||
.cta-button {
|
|
||||||
display: inline-block;
|
|
||||||
background-color: #4CAF50;
|
|
||||||
color: white;
|
|
||||||
padding: 10px 20px;
|
|
||||||
text-decoration: none;
|
|
||||||
border-radius: 4px;
|
|
||||||
font-weight: bold;
|
|
||||||
text-align: center;
|
|
||||||
}
|
|
||||||
.cta-button:hover {
|
|
||||||
background-color: #45a049;
|
|
||||||
}
|
|
||||||
.footer {
|
|
||||||
margin-top: 20px;
|
|
||||||
font-size: 14px;
|
|
||||||
color: #888;
|
|
||||||
text-align: center;
|
|
||||||
}
|
|
||||||
</style>
|
|
||||||
</head>
|
|
||||||
<body>
|
|
||||||
<div class="container">
|
|
||||||
<h1>Demande de réinitialisation du mot de passe</h1>
|
|
||||||
<p>Bonjour {{ username }},</p>
|
|
||||||
<p>Nous avons reçu une demande pour réinitialiser votre mot de passe sur notre site. Si vous n'êtes pas à l'origine de cette demande, vous pouvez ignorer cet email.</p>
|
|
||||||
<p>Pour réinitialiser votre mot de passe, cliquez sur le lien ci-dessous :</p>
|
|
||||||
<p><a href="{{ reset_link }}" class="cta-button">Réinitialiser mon mot de passe</a></p>
|
|
||||||
<p>Le lien est valable pendant une heure. Si vous ne pouvez pas cliquer dessus, copiez et collez-le dans votre navigateur.</p>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div class="footer">
|
|
||||||
<p>© Covas - Tous droits réservés.</p>
|
|
||||||
</div>
|
|
||||||
</body>
|
|
||||||
</html>
|
|
@ -1,59 +1,6 @@
|
|||||||
<!DOCTYPE html>
|
|
||||||
<html>
|
<html>
|
||||||
<head>
|
<head><title>Email</title></head>
|
||||||
<meta charset="UTF-8">
|
<body><p>Voici un lien https://localhost:8080/api/mail?key={{ key }}&username={{ username }}
|
||||||
<title>Confirmation de votre compte</title>
|
</p></body>
|
||||||
<style>
|
|
||||||
body {
|
|
||||||
font-family: Arial, sans-serif;
|
|
||||||
background-color: #f4f4f4;
|
|
||||||
margin: 0;
|
|
||||||
padding: 0;
|
|
||||||
}
|
|
||||||
.container {
|
|
||||||
max-width: 600px;
|
|
||||||
margin: 20px auto;
|
|
||||||
background: #ffffff;
|
|
||||||
padding: 20px;
|
|
||||||
border-radius: 10px;
|
|
||||||
box-shadow: 0 2px 5px rgba(0,0,0,0.1);
|
|
||||||
text-align: center;
|
|
||||||
}
|
|
||||||
h2 {
|
|
||||||
color: #333;
|
|
||||||
}
|
|
||||||
p {
|
|
||||||
color: #666;
|
|
||||||
font-size: 16px;
|
|
||||||
}
|
|
||||||
.button {
|
|
||||||
display: inline-block;
|
|
||||||
background: #28a745;
|
|
||||||
color: white;
|
|
||||||
padding: 12px 20px;
|
|
||||||
text-decoration: none;
|
|
||||||
border-radius: 5px;
|
|
||||||
font-size: 16px;
|
|
||||||
font-weight: bold;
|
|
||||||
margin-top: 20px;
|
|
||||||
}
|
|
||||||
.button:hover {
|
|
||||||
background: #218838;
|
|
||||||
}
|
|
||||||
.footer {
|
|
||||||
margin-top: 20px;
|
|
||||||
font-size: 12px;
|
|
||||||
color: #888;
|
|
||||||
}
|
|
||||||
</style>
|
|
||||||
</head>
|
|
||||||
<body>
|
|
||||||
<div class="container">
|
|
||||||
<h2>Bienvenue, {{ username }} ! 🎉</h2>
|
|
||||||
<p>Merci de vous être inscrit sur notre plateforme.</p>
|
|
||||||
<p>Pour finaliser votre inscription, veuillez confirmer votre compte en cliquant sur le bouton ci-dessous :</p>
|
|
||||||
<a href="https://backend.valczeryba.ovh/mail?key={{ key }}&username={{ username }}" class="button">Confirmer mon compte</a>
|
|
||||||
<p class="footer">Si vous n'êtes pas à l'origine de cette inscription, ignorez simplement cet email.</p>
|
|
||||||
</div>
|
|
||||||
</body>
|
|
||||||
</html>
|
</html>
|
||||||
|
@ -1,65 +0,0 @@
|
|||||||
<!-- password_update_success.html -->
|
|
||||||
<!DOCTYPE html>
|
|
||||||
<html lang="fr">
|
|
||||||
<head>
|
|
||||||
<meta charset="UTF-8">
|
|
||||||
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
|
||||||
<title>Mot de Passe Mis à Jour</title>
|
|
||||||
<style>
|
|
||||||
body {
|
|
||||||
font-family: Arial, sans-serif;
|
|
||||||
background-color: #f4f4f9;
|
|
||||||
color: #333;
|
|
||||||
margin: 0;
|
|
||||||
padding: 0;
|
|
||||||
}
|
|
||||||
.container {
|
|
||||||
width: 100%;
|
|
||||||
max-width: 600px;
|
|
||||||
margin: 50px auto;
|
|
||||||
padding: 20px;
|
|
||||||
background-color: white;
|
|
||||||
box-shadow: 0 4px 8px rgba(0, 0, 0, 0.1);
|
|
||||||
border-radius: 8px;
|
|
||||||
}
|
|
||||||
h1 {
|
|
||||||
color: #4CAF50;
|
|
||||||
text-align: center;
|
|
||||||
}
|
|
||||||
p {
|
|
||||||
font-size: 16px;
|
|
||||||
line-height: 1.5;
|
|
||||||
text-align: center;
|
|
||||||
}
|
|
||||||
.cta-button {
|
|
||||||
display: inline-block;
|
|
||||||
background-color: #4CAF50;
|
|
||||||
color: white;
|
|
||||||
padding: 10px 20px;
|
|
||||||
text-decoration: none;
|
|
||||||
border-radius: 4px;
|
|
||||||
font-weight: bold;
|
|
||||||
text-align: center;
|
|
||||||
}
|
|
||||||
.cta-button:hover {
|
|
||||||
background-color: #45a049;
|
|
||||||
}
|
|
||||||
.footer {
|
|
||||||
margin-top: 20px;
|
|
||||||
font-size: 14px;
|
|
||||||
color: #888;
|
|
||||||
text-align: center;
|
|
||||||
}
|
|
||||||
</style>
|
|
||||||
</head>
|
|
||||||
<body>
|
|
||||||
<div class="container">
|
|
||||||
<h1>Votre mot de passe a été mis à jour avec succès</h1>
|
|
||||||
<p>Votre mot de passe a été réinitialisé avec succès. Vous pouvez maintenant utiliser votre nouveau mot de passe pour vous connecter.</p>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div class="footer">
|
|
||||||
<p>© {{ current_year }} Covas - Tous droits réservés.</p>
|
|
||||||
</div>
|
|
||||||
</body>
|
|
||||||
</html>
|
|
@ -1,87 +0,0 @@
|
|||||||
<!DOCTYPE html>
|
|
||||||
<html lang="fr">
|
|
||||||
<head>
|
|
||||||
<meta charset="UTF-8">
|
|
||||||
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
|
||||||
<title>Réinitialisation du mot de passe</title>
|
|
||||||
<style>
|
|
||||||
body {
|
|
||||||
font-family: Arial, sans-serif;
|
|
||||||
margin: 0;
|
|
||||||
padding: 0;
|
|
||||||
background-color: #f4f7fc;
|
|
||||||
color: #333;
|
|
||||||
}
|
|
||||||
.container {
|
|
||||||
width: 100%;
|
|
||||||
max-width: 600px;
|
|
||||||
margin: 50px auto;
|
|
||||||
padding: 20px;
|
|
||||||
background-color: #ffffff;
|
|
||||||
border-radius: 8px;
|
|
||||||
box-shadow: 0 2px 5px rgba(0, 0, 0, 0.1);
|
|
||||||
}
|
|
||||||
h2 {
|
|
||||||
text-align: center;
|
|
||||||
color: #2a9d8f;
|
|
||||||
}
|
|
||||||
.form-group {
|
|
||||||
margin-bottom: 20px;
|
|
||||||
}
|
|
||||||
label {
|
|
||||||
font-weight: bold;
|
|
||||||
display: block;
|
|
||||||
margin-bottom: 5px;
|
|
||||||
}
|
|
||||||
input[type="password"], input[type="email"] {
|
|
||||||
width: 100%;
|
|
||||||
padding: 10px;
|
|
||||||
margin: 5px 0 10px 0;
|
|
||||||
border: 1px solid #ddd;
|
|
||||||
border-radius: 4px;
|
|
||||||
}
|
|
||||||
input[type="submit"] {
|
|
||||||
background-color: #2a9d8f;
|
|
||||||
color: white;
|
|
||||||
border: none;
|
|
||||||
padding: 10px 20px;
|
|
||||||
font-size: 16px;
|
|
||||||
cursor: pointer;
|
|
||||||
border-radius: 4px;
|
|
||||||
width: 100%;
|
|
||||||
}
|
|
||||||
input[type="submit"]:hover {
|
|
||||||
background-color: #1e7c68;
|
|
||||||
}
|
|
||||||
.message {
|
|
||||||
text-align: center;
|
|
||||||
margin-top: 20px;
|
|
||||||
}
|
|
||||||
.message a {
|
|
||||||
color: #2a9d8f;
|
|
||||||
text-decoration: none;
|
|
||||||
}
|
|
||||||
</style>
|
|
||||||
</head>
|
|
||||||
<body>
|
|
||||||
<div class="container">
|
|
||||||
<h2>Réinitialisation du mot de passe</h2>
|
|
||||||
|
|
||||||
<form method="post" action="/password/update">
|
|
||||||
<input type="hidden" name="email" value="{{ email }}">
|
|
||||||
<input type="hidden" name="key" value="{{ key }}">
|
|
||||||
|
|
||||||
<div class="form-group">
|
|
||||||
<label for="new_password">Nouveau mot de passe :</label>
|
|
||||||
<input type="password" id="new_password" name="new_password" required>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<input type="submit" value="Mettre à jour le mot de passe">
|
|
||||||
</form>
|
|
||||||
|
|
||||||
<div class="message">
|
|
||||||
<p>Vous avez des questions ? <a href="mailto:support@votresite.com">Contactez-nous</a></p>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
</body>
|
|
||||||
</html>
|
|
Loading…
x
Reference in New Issue
Block a user