feat(submit): consecutive submissions interval 20s

Author: zdszero

deploy/supervisord-debug.conf

@@ -0,0 +1,62 @@
+[supervisord]
+logfile=%(ENV_WORKDIR)s/data/log/supervisord.log
+logfile_maxbytes=10MB
+logfile_backups=10
+loglevel=info
+pidfile=/tmp/supervisord.pid
+nodaemon=true
+childlogdir=%(ENV_WORKDIR)s/data/log
+
+[inet_http_server]
+port=0.0.0.0:9001
+username=onl
+password=onl
+
+[rpcinterface:supervisor]
+supervisor.rpcinterface_factory=supervisor.rpcinterface:make_main_rpcinterface
+
+[unix_http_server]
+file=/tmp/supervisor.sock   ; unix socket file
+
+[supervisorctl]
+serverurl=unix:///tmp/supervisor.sock   ; connect to supervisord through unix socket
+
+[program:redis]
+command=redis-server --port 7777
+directory=%(ENV_WORKDIR)s
+stdout_logfile=%(ENV_WORKDIR)s/data/log/redis.log
+stderr_logfile=%(ENV_WORKDIR)s/data/log/redis.log
+stdout_logfile_maxbytes = 10MB
+autostart=true
+autorestart=true
+
+[program:gunicorn]
+command=python3 manage.py runserver 0.0.0.0:7890
+directory=%(ENV_WORKDIR)s
+stdout_logfile=%(ENV_WORKDIR)s/data/log/onl_backend.log
+stderr_logfile=%(ENV_WORKDIR)s/data/log/onl_backend.log
+stdout_logfile_maxbytes = 10MB
+autostart=true
+autorestart=true
+killasgroup=true
+
+[program:onl_frontend]
+command=node build/dev-server.js
+directory=%(ENV_FRONTEND)s
+stdout_logfile=%(ENV_WORKDIR)s/data/log/onl_fe.log
+stderr_logfile=%(ENV_WORKDIR)s/data/log/onl_fe.log
+stdout_logfile_maxbytes = 10MB
+autostart=true
+autorestart=true
+startsecs=5
+stopwaitsecs = 5
+
+[program:dramatiq]
+command=python3 manage.py rundramatiq --processes %(ENV_MAX_WORKER_NUM)s --threads 1
+directory=%(ENV_WORKDIR)s
+stdout_logfile=%(ENV_WORKDIR)s/data/log/dramatiq.log
+stderr_logfile=%(ENV_WORKDIR)s/data/log/dramatiq.log
+stdout_logfile_maxbytes = 10MB
+autostart=true
+autorestart=true
+killasgroup=true

manage

@@ -2,14 +2,17 @@
 
 function print_help {
   echo "usage:"
-  echo "    ./manage [makemigrations|migrate|clean|rebuild|run|stop]"
+  echo "    ./manage [makemigrations|migrate|clean|rebuild|run|debug|stop]"
 }
 
 [[ $# -ne 1 ]] && print_help && exit
 
 cmd=$1
+mode="release"
 apps=("account" "announcement" "conf" "contest" "options" "problem" "submission")
+supervisor_grep="supervisord -c ./deploy/supervisord"
 supervisor_cmd="supervisord -c ./deploy/supervisord.conf"
+supervisor_debug_cmd="supervisord -c ./deploy/supervisord-debug.conf"
 
 function clean {
   rm -rf ./data/zips
@@ -46,9 +49,13 @@ function run_onl {
   echo "starting ${process_num} procs"
 
   # run onl
-  if ! command pgrep -f "$supervisor_cmd" > /dev/null; then
+  if ! command pgrep -f "$supervisor_grep" > /dev/null; then
     echo "running onl controller ..."
-    FRONTEND=$FRONTEND WORKDIR=$workdir MAX_WORKER_NUM=$process_num $supervisor_cmd > /dev/null &
+    if [[ "$mode" == "debug" ]]; then
+      FRONTEND=$FRONTEND WORKDIR=$workdir MAX_WORKER_NUM=$process_num $supervisor_debug_cmd > /dev/null &
+    else
+      FRONTEND=$FRONTEND WORKDIR=$workdir MAX_WORKER_NUM=$process_num $supervisor_cmd > /dev/null &
+    fi
     [[ $? -ne 0 ]] && echo "Error: fail to run onl"
   else
     echo "onl is already running"
@@ -57,7 +64,7 @@ function run_onl {
 }
 
 function stop_onl {
-  pkill -f "$supervisor_cmd"
+  pkill -f "$supervisor_grep"
   [[ $? -eq 0 ]] && echo "stop supervisord"
 }
 
@@ -80,6 +87,10 @@ case $cmd in
   "run" )
     run_onl
     ;;
+  "debug" )
+    mode="debug"
+    run_onl
+    ;;
   "stop" )
     stop_onl
     ;;

submission/views/user.py

@@ -2,8 +2,10 @@
 import hashlib
 import requests
 import logging
+import time
 from django.db import transaction
 from django.db.models import Q
+from django.core.cache import cache
 
 from account.decorators import login_required, check_contest_permission
 from account.models import User, UserProfile
@@ -70,11 +72,17 @@ def check_contest_permission(self, request):
     @login_required
     def post(self, request):
         # print(request.data)
-        data = request.data
+        user_id = request.user.id
+        last_submit_time = cache.get(f"last_submit_time_{user_id}")
+        if last_submit_time:
+            current_time = time.time()
+            time_diff = current_time - last_submit_time
+            if time_diff < 15:
+                return self.error("Submissions are too frequent, please try again later")
+
+        cache.set(f'last_submit_time_{user_id}', time.time())
 
-        error = self.throttling(request)
-        if error:
-            return self.error(error)
+        data = request.data
 
         # get contset and check
         try: