Kiu/Semaphore
Kiu/Semaphore
1
0
Fork 0
mirror of https://github.com/semaphoreui/semaphore.git synced 2024-11-21 17:01:04 +01:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

feat(task): api

Browse Source
This commit is contained in:
Denis Gukov 2024-10-13 16:46:01 +00:00
parent 494f989c19
commit e879faee0f
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
api/tasks/tasks.go
View File

@ -11,7 +11,7 @@ import (
func TaskMiddleware(next http.Handler) http.Handler {
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
taskID, err := helpers.GetStrParam("task_id", w, r)
taskID, err := helpers.GetIntParam("task_id", w, r)
if err != nil {
helpers.WriteErrorStatus(w, err.Error(), http.StatusBadRequest)
}
@ -61,18 +61,22 @@ func GetTasks(w http.ResponseWriter, r *http.Request) {
func DeleteTask(w http.ResponseWriter, r *http.Request) {
taskID := context.Get(r, "task_id").(string)
taskID := context.Get(r, "task_id").(int)
pool := context.Get(r, "task_pool").(*task2.TaskPool)
var task db.Task
var task *db.Task
for _, t := range pool.Queue {
if t.Task.ID == taskID {
task = t.Task
task = &t.Task
break
}
}
pool.StopTask(task, false)
if task != nil {
pool.StopTask(*task, false)
}
helpers.WriteJSON(w, http.StatusNoContent, nil)
}