Merge remote-tracking branch 'origin/master'

services/backend/api/v1/task/views.py

@@ -19,6 +19,7 @@ from apps.task.models import (
     CompetitionTaskAttachment,
     CompetitionTaskSubmission,
 )
+from apps.task.tasks import analyze_data_task
 
 router = Router(tags=["competition"])
 
@@ -124,6 +125,7 @@ def submit_task(
             status=CompetitionTaskSubmission.StatusChoices.CHECKING,
             content=content,
         )
+        analyze_data_task.delay(submission_id=submission.id)
 
     return TaskSubmissionOut(submission_id=submission.id)
 
@@ -155,6 +157,4 @@ def get_submissions_history(request, competition_id: UUID, task_id: UUID):
 )
 def get_task_attachments(request, competition_id: UUID, task_id: UUID):
     task = get_object_or_404(CompetitionTask, id=task_id)
-    return status.OK, CompetitionTaskAttachment.objects.filter(
-        task=task
-    ).all()
+    return status.OK, CompetitionTaskAttachment.objects.filter(task=task).all()

services/backend/api/v1/user/schemas.py

@@ -23,3 +23,8 @@ class UserSchema(ModelSchema):
     class Meta:
         model = User
         fields = ["id", "email", "username", "created_at", "achievements"]
+
+
+class StatSchema(Schema):
+    total_attempts: int
+    solved_tasks: int

services/backend/api/v1/user/views.py

@@ -11,15 +11,17 @@ from api.v1.schemas import (
     BadRequestError,
     ConflictError,
     ForbiddenError,
-    NotFoundError,
+    NotFoundError, UnauthorizedError,
 )
 from api.v1.user.schemas import (
     LoginSchema,
     RegisterSchema,
     TokenSchema,
     UserSchema,
+    StatSchema
 )
 from apps.user.models import User
+from apps.task.models import CompetitionTaskSubmission, ReviewStatusChoices
 
 router = Router(tags=["user"])
 
@@ -85,3 +87,31 @@ def get_me(request):
 def get_user(request, user_id: str):
     user = get_object_or_404(User, id=user_id)
     return status.OK, user
+
+
+@router.get(
+    "/me/stat",
+    response={
+        status.OK: StatSchema,
+        status.UNAUTHORIZED: UnauthorizedError
+    },
+)
+def get_my_stat(request):
+    user_submissions = CompetitionTaskSubmission.objects.filter(
+        user=request.auth
+    )
+    checked_attempts = user_submissions.filter(status=CompetitionTaskSubmission.StatusChoices.CHECKED).all()
+    success_attempts_cnt = 0
+
+    for attempt in checked_attempts:
+        is_correct = attempt.result.get("correct", None)
+        if is_correct is None:
+            is_correct = attempt.result.get("total_points", 0) > 0
+
+        if is_correct:
+            success_attempts_cnt += 1
+
+    return StatSchema(
+        total_attempts=len(user_submissions),
+        solved_tasks=success_attempts_cnt
+    )

services/backend/apps/competition/tests.py

@@ -35,7 +35,7 @@ class CompetitionEndpointTests(TestCase):
         self.valid_headers = {"HTTP_AUTHORIZATION": f"Bearer {token}"}
 
     def get_url(self, competition_id):
-        return f"/api/v1/competition/{competition_id}"
+        return f"/api/v1/competitions/{competition_id}"
 
     def test_get_competition_success(self):
         response = self.client.get(

services/backend/apps/task/admin.py

@@ -31,7 +31,7 @@ class CompetitionTaskSubmissionAdmin(admin.ModelAdmin):
         "user__username",
         "user__email",
     )
-    filter = ("plagiarism_checked",)
+    list_filter = ("plagiarism_checked", "status",)
     ordering = ["-timestamp"]
 
     def has_add_permission(self, request, obj=None):

services/backend/apps/task/models.py

@@ -92,9 +92,9 @@ class CompetitionTaskAttachment(BaseModel):
 
 class CompetitionTaskSubmission(BaseModel):
     class StatusChoices(models.TextChoices):
-        SENT = "sent"
-        CHECKING = "checking"
-        CHECKED = "checked"
+        SENT = "sent", "Отправлено на проверку"
+        CHECKING = "checking", "Проверка"
+        CHECKED = "checked", "Проверено"
 
     def submission_content_upload_to(instance, filename) -> str:
         return f"submissions/{instance.id}/content/{filename}"

services/backend/apps/task/tasks.py

@@ -1,4 +1,4 @@
-import requests
+import httpx
 from celery import shared_task
 from django.core.files.base import ContentFile
 
@@ -17,7 +17,7 @@ def analyze_data_task(self, submission_id):
             for f in submission.task.attachments.filter(public=True)
         ]
 
-        response = requests.post(
+        response = httpx.post(
             f"{settings.CHECKER_API_ENDPOINT}/execute",
             files=[("files", (f.name, f)) for f in files]
             + [
@@ -40,10 +40,10 @@ def analyze_data_task(self, submission_id):
         )
         submission.status = CompetitionTaskSubmission.StatusChoices.CHECKED
 
-    except requests.exceptions.RequestException as e:
+    except httpx.RequestError as e:
         self.retry(countdown=2**self.request.retries)
     except Exception as e:
-        submission.result = {"error": str(e)}
+        submission.result = {"error": str(e), "success": False}
         submission.status = CompetitionTaskSubmission.StatusChoices.CHECKED
         submission.earned_points = 0
     finally: