Silo Server Migration
246c9da6ab
- Add request domain, repository, service, and reconcile task - Add Radarr/Sonarr fulfillment adapters and TMDB discovery - Expose user and admin request APIs with quota and approval rules - Add web UI for browsing, requesting, and admin queue management - Migration 139 introduces media_requests and related tables
60 lines
1.8 KiB
Go
60 lines
1.8 KiB
Go
package tasks
|
|
|
|
import (
|
|
"context"
|
|
"encoding/json"
|
|
"fmt"
|
|
|
|
"github.com/Silo-Server/silo-server/internal/requests"
|
|
"github.com/Silo-Server/silo-server/internal/taskmanager"
|
|
)
|
|
|
|
type RequestReconciler interface {
|
|
ReconcileRequests(ctx context.Context, limit int) (requests.ReconcileResult, error)
|
|
}
|
|
|
|
type ReconcileRequestsTask struct {
|
|
reconciler RequestReconciler
|
|
limit int
|
|
}
|
|
|
|
func NewReconcileRequestsTask(reconciler RequestReconciler, limit int) *ReconcileRequestsTask {
|
|
if limit <= 0 {
|
|
limit = 100
|
|
}
|
|
return &ReconcileRequestsTask{reconciler: reconciler, limit: limit}
|
|
}
|
|
|
|
func (t *ReconcileRequestsTask) Key() string { return "reconcile_requests" }
|
|
func (t *ReconcileRequestsTask) Name() string { return "Reconcile Requests" }
|
|
func (t *ReconcileRequestsTask) Description() string {
|
|
return "Checks approved and active media requests against Radarr, Sonarr, and the Silo catalog"
|
|
}
|
|
func (t *ReconcileRequestsTask) Category() taskmanager.TaskCategory {
|
|
return taskmanager.TaskCategoryLibrary
|
|
}
|
|
func (t *ReconcileRequestsTask) IsHidden() bool { return false }
|
|
|
|
func (t *ReconcileRequestsTask) DefaultTriggers() []taskmanager.TriggerConfig {
|
|
return []taskmanager.TriggerConfig{
|
|
{Type: taskmanager.TriggerTypeInterval, IntervalMs: 5 * 60 * 1000},
|
|
}
|
|
}
|
|
|
|
func (t *ReconcileRequestsTask) Execute(ctx context.Context, progress taskmanager.ProgressReporter) error {
|
|
progress.Report(0, "Reconciling media requests")
|
|
if t.reconciler == nil {
|
|
progress.Report(100, "Request reconciliation unavailable")
|
|
return nil
|
|
}
|
|
result, err := t.reconciler.ReconcileRequests(ctx, t.limit)
|
|
if err != nil {
|
|
return fmt.Errorf("reconcile media requests: %w", err)
|
|
}
|
|
if data, err := json.Marshal(result); err == nil {
|
|
progress.SetResultData(data)
|
|
}
|
|
progress.Report(100, "Request reconciliation complete")
|
|
return nil
|
|
}
|