aboutsummaryrefslogtreecommitdiffhomepage
path: root/backend/taskqueue/queue.go
diff options
context:
space:
mode:
authornsfisis <nsfisis@gmail.com>2025-03-08 10:51:41 +0900
committernsfisis <nsfisis@gmail.com>2025-03-08 10:51:41 +0900
commita7ce31249948e4f0c1950de93f3c4f7cdda51cf4 (patch)
treec4c740f0cccd15f825596f7a115f3b8f8eb8ffa7 /backend/taskqueue/queue.go
parent7f4d16dca85263dcbc7b3bb29f5fc50f4371739d (diff)
parentc06d46eae30c9468535fb6af5e9b822acadbbdb6 (diff)
downloadphperkaigi-2025-albatross-a7ce31249948e4f0c1950de93f3c4f7cdda51cf4.tar.gz
phperkaigi-2025-albatross-a7ce31249948e4f0c1950de93f3c4f7cdda51cf4.tar.zst
phperkaigi-2025-albatross-a7ce31249948e4f0c1950de93f3c4f7cdda51cf4.zip
Merge branch 'phperkaigi-2025'
Diffstat (limited to 'backend/taskqueue/queue.go')
-rw-r--r--backend/taskqueue/queue.go65
1 files changed, 2 insertions, 63 deletions
diff --git a/backend/taskqueue/queue.go b/backend/taskqueue/queue.go
index 30fe265..b348fca 100644
--- a/backend/taskqueue/queue.go
+++ b/backend/taskqueue/queue.go
@@ -20,82 +20,21 @@ func (q *Queue) Close() {
q.client.Close()
}
-func (q *Queue) EnqueueTaskCreateSubmissionRecord(
- gameID int,
- userID int,
- code string,
- codeSize int,
- codeHash MD5HexHash,
-) error {
- task, err := newTaskCreateSubmissionRecord(
- gameID,
- userID,
- code,
- codeSize,
- codeHash,
- )
- if err != nil {
- return err
- }
- _, err = q.client.Enqueue(task)
- return err
-}
-
-func (q *Queue) EnqueueTaskCompileSwiftToWasm(
- gameID int,
- userID int,
- code string,
- codeHash MD5HexHash,
- submissionID int,
-) error {
- task, err := newTaskCompileSwiftToWasm(
- gameID,
- userID,
- code,
- codeHash,
- submissionID,
- )
- if err != nil {
- return err
- }
- _, err = q.client.Enqueue(task)
- return err
-}
-
-func (q *Queue) EnqueueTaskCompileWasmToNativeExecutable(
- gameID int,
- userID int,
- codeHash MD5HexHash,
- submissionID int,
-) error {
- task, err := newTaskCompileWasmToNativeExecutable(
- gameID,
- userID,
- codeHash,
- submissionID,
- )
- if err != nil {
- return err
- }
- _, err = q.client.Enqueue(task)
- return err
-}
-
func (q *Queue) EnqueueTaskRunTestcase(
gameID int,
userID int,
- codeHash MD5HexHash,
submissionID int,
testcaseID int,
+ code string,
stdin string,
stdout string,
) error {
task, err := newTaskRunTestcase(
gameID,
userID,
- codeHash,
submissionID,
testcaseID,
+ code,
stdin,
stdout,
)