import html import json import uuid from datetime import datetime from aiohttp import ClientSession from classquiz.config import settings, storage, meilisearch from classquiz.db.models import Quiz, QuizAnswer, QuizQuestion, User from classquiz.kahoot_importer.get import get as get_quiz from classquiz.helpers import get_meili_data settings = settings() async def _download_image(url: str) -> bytes: async with ClientSession() as session, session.get(url) as resp: return await resp.read() async def import_quiz(quiz_id: str, user: User) -> Quiz | str: """ Imports a quiz from Kahoot. :param user: The user object :param quiz_id: The ID of the quiz to import. :return: True if the import was successful, False otherwise. """ quiz = await get_quiz(quiz_id) if quiz is None: return "quiz not found" quiz_questions: list[dict] = [] quiz_id = uuid.uuid4() for q in quiz.kahoot.questions: answers: list[QuizAnswer] = [] image = None if q.image is not None and q.image != "": image_bytes = await _download_image(q.image) image_name = f"{quiz_id}--{uuid.uuid4()}" image = await storage.upload(file_name=image_name, file_data=image_bytes) image = f"{settings.root_address}/api/v1/storage/download/{image_name}" for a in q.choices: answers.append((QuizAnswer(right=a.correct, answer=html.unescape(a.answer)))) quiz_questions.append( QuizQuestion( question=q.question, answers=answers, time=str(q.time / 1000), image=image, ).dict() ) quiz_data = Quiz( id=quiz_id, public=True, title=quiz.kahoot.title, description=quiz.kahoot.description, created_at=datetime.now(), updated_at=datetime.now(), user_id=user.id, questions=json.dumps(quiz_questions), ) meilisearch.index(settings.meilisearch_index).add_documents([await get_meili_data(quiz_data)]) return await quiz_data.save()