Add reclaim assigned tasks button

api/main.go

@@ -106,6 +106,7 @@ func New() *WebAPI {
 	api.router.POST("/project/webhook_secret/:id", LogRequestMiddleware(api.SetWebhookSecret))
 	api.router.POST("/project/reset_failed_tasks/:id", LogRequestMiddleware(api.ResetFailedTasks))
 	api.router.POST("/project/hard_reset/:id", LogRequestMiddleware(api.HardReset))
+	api.router.POST("/project/reclaim_assigned_tasks/:id", LogRequestMiddleware(api.ReclaimAssignedTasks))
 
 	api.router.POST("/task/submit", LogRequestMiddleware(api.SubmitTask))
 	api.router.GET("/task/get/:project", LogRequestMiddleware(api.GetTaskFromProject))

api/models.go

@@ -318,3 +318,7 @@ type ResetFailedTaskResponse struct {
 type HardResetResponse struct {
 	AffectedTasks int64 `json:"affected_tasks"`
 }
+
+type ReclaimAssignedTasksResponse struct {
+	AffectedTasks int64 `json:"affected_tasks"`
+}

api/project.go

@@ -756,3 +756,35 @@ func (api *WebAPI) HardReset(r *Request) {
 		},
 	})
 }
+
+func (api *WebAPI) ReclaimAssignedTasks(r *Request) {
+
+	pid, err := strconv.ParseInt(r.Ctx.UserValue("id").(string), 10, 64)
+	if err != nil || pid <= 0 {
+		r.Json(JsonResponse{
+			Ok:      false,
+			Message: "Invalid project id",
+		}, 400)
+		return
+	}
+
+	sess := api.Session.StartFasthttp(r.Ctx)
+	manager := sess.Get("manager")
+
+	if !isActionOnProjectAuthorized(pid, manager, storage.RoleMaintenance, api.Database) {
+		r.Json(JsonResponse{
+			Ok:      false,
+			Message: "Unauthorized",
+		}, 403)
+		return
+	}
+
+	res := api.Database.ReclaimAssignedTasks(pid)
+
+	r.OkJson(JsonResponse{
+		Ok: true,
+		Content: ReclaimAssignedTasksResponse{
+			AffectedTasks: res,
+		},
+	})
+}