cron task process_spam_reports

Author: Oleg Komarov

models/user/spamreport.go

@@ -89,6 +89,13 @@ func ListSpamReports(ctx context.Context, opts *ListSpamReportsOptions) ([]*List
 	return spamReports, count, err
 }
 
+func GetPendingSpamReportIDs(ctx context.Context) ([]int64, error) {
+	var ids []int64
+	err := db.GetEngine(ctx).Table("user_spamreport").
+		Select("id").Where("status = ?", SpamReportStatusTypePending).Find(&ids)
+	return ids, err
+}
+
 type SpamReportStatusCounts struct {
 	Count  int64
 	Status SpamReportStatusType

options/locale/locale_en-US.ini

@@ -2982,6 +2982,7 @@ dashboard.sync_branch.started = Branches Sync started
 dashboard.sync_tag.started = Tags Sync started
 dashboard.rebuild_issue_indexer = Rebuild issue indexer
 dashboard.sync_repo_licenses = Sync repo licenses
+dashboard.process_spam_reports = Process spam reports
 
 users.user_manage_panel = User Account Management
 users.new_account = Create User Account

routers/web/admin/spamreports.go

@@ -6,6 +6,7 @@
 package admin
 
 import (
+	"fmt"
 	"net/http"
 	"strconv"
 
@@ -56,6 +57,8 @@ func SpamReports(ctx *context.Context) {
 
 	ctx.Data["Total"] = count
 	ctx.Data["SpamReports"] = spamReports
+	ids, _ := user_model.GetPendingSpamReportIDs(ctx)
+	fmt.Printf("%v", ids)
 
 	pager := context.NewPagination(int(count), opts.PageSize, opts.Page, 5)
 	pager.SetDefaultParams(ctx)

services/cron/cron.go

@@ -31,6 +31,8 @@ func NewContext(original context.Context) {
 	initBasicTasks()
 	initExtendedTasks()
 	initActionsTasks()
+	// BLENDER: spam reporting
+	initSpamReportTasks()
 
 	lock.Lock()
 	for _, task := range tasks {

services/cron/tasks_spamreport.go

@@ -0,0 +1,32 @@
+// Copyright 2025 The Gitea Authors. All rights reserved.
+// SPDX-License-Identifier: MIT
+
+// BLENDER: spam reporting
+
+package cron
+
+import (
+	"context"
+	"fmt"
+
+	user_model "code.gitea.io/gitea/models/user"
+	user_service "code.gitea.io/gitea/services/user"
+)
+
+func registerProcessSpamReports() {
+	RegisterTaskFatal("process_spam_reports", &BaseConfig{
+		Enabled:    true,
+		RunAtStart: true,
+		Schedule:   "@every 5m",
+	}, func(ctx context.Context, doer *user_model.User, _ Config) error {
+		ids, err := user_model.GetPendingSpamReportIDs(ctx)
+		if err != nil {
+			return fmt.Errorf("failed to GetPendingSpamReportIDs: %w", err)
+		}
+		return user_service.ProcessSpamReports(ctx, doer, ids)
+	})
+}
+
+func initSpamReportTasks() {
+	registerProcessSpamReports()
+}