✨ Added stats to homepage
This commit is contained in:
@@ -17,6 +17,7 @@ router = APIRouter()
|
||||
@router.post("/create")
|
||||
async def create_quiz_lol(quiz_input: QuizInput, user: User = Depends(get_current_user)):
|
||||
quiz = Quiz(**quiz_input.dict(), user_id=user.id, id=uuid.uuid4())
|
||||
await redis.delete("global_quiz_count")
|
||||
return await quiz.save()
|
||||
|
||||
|
||||
|
||||
@@ -0,0 +1,62 @@
|
||||
import os
|
||||
|
||||
from fastapi import APIRouter, Response
|
||||
from fastapi.background import BackgroundTasks
|
||||
from fastapi.responses import JSONResponse, RedirectResponse
|
||||
from fastapi.security import OAuth2PasswordRequestForm
|
||||
from pydantic import BaseModel
|
||||
from classquiz.auth import *
|
||||
from classquiz.config import redis
|
||||
from classquiz.db.models import *
|
||||
|
||||
router = APIRouter()
|
||||
|
||||
|
||||
@router.get("/quizzes")
|
||||
async def get_quiz_count() -> int:
|
||||
redis_res = await redis.get("global_quiz_count")
|
||||
if redis_res is None:
|
||||
quiz_res = await Quiz.objects.count()
|
||||
await redis.set("global_quiz_count", quiz_res, ex=3600)
|
||||
return quiz_res
|
||||
else:
|
||||
return int(redis_res)
|
||||
|
||||
|
||||
@router.get("/users")
|
||||
async def get_user_count() -> int:
|
||||
redis_res = await redis.get("global_user_count")
|
||||
if redis_res is None:
|
||||
quiz_res = await User.objects.count()
|
||||
await redis.set("global_user_count", quiz_res, ex=3600)
|
||||
return quiz_res
|
||||
else:
|
||||
return int(redis_res)
|
||||
|
||||
|
||||
class CombinedOutput(BaseModel):
|
||||
quiz_count: int
|
||||
user_count: int
|
||||
|
||||
|
||||
@router.get("/combined")
|
||||
async def get_combined_count() -> CombinedOutput:
|
||||
user_count = None
|
||||
quiz_count = None
|
||||
redis_res = await redis.get("global_user_count")
|
||||
if redis_res is None:
|
||||
quiz_res = await User.objects.count()
|
||||
await redis.set("global_user_count", quiz_res, ex=3600)
|
||||
user_count = quiz_res
|
||||
else:
|
||||
user_count = int(redis_res)
|
||||
|
||||
redis_res = await redis.get("global_quiz_count")
|
||||
if redis_res is None:
|
||||
quiz_res = await Quiz.objects.count()
|
||||
await redis.set("global_quiz_count", quiz_res, ex=3600)
|
||||
quiz_count = quiz_res
|
||||
else:
|
||||
quiz_count = int(redis_res)
|
||||
|
||||
return CombinedOutput(quiz_count=quiz_count, user_count=user_count)
|
||||
@@ -36,6 +36,7 @@ async def create_user(user: route_user, background_task: BackgroundTasks) -> Use
|
||||
return JSONResponse({"details": "Username mustn't be 32 characters long"}, 400)
|
||||
await user.save()
|
||||
background_task.add_task(send_register_email, email=user.email)
|
||||
await redis.delete("global_user_count")
|
||||
return user
|
||||
|
||||
|
||||
|
||||
Reference in New Issue
Block a user