diff options
| author | Bobby <[email protected]> | 2025-05-09 04:30:23 +0530 |
|---|---|---|
| committer | Bobby <[email protected]> | 2025-05-09 04:30:23 +0530 |
| commit | 596ef846c97d9373ddda711dabfde9720b6931d7 (patch) | |
| tree | 1717fab55a77375f7a41a50b9f62bff404bb0d81 /tasks/tasks.go | |
| parent | b5ea894b18e63fb22f02c32958cb270139cb8c78 (diff) | |
| download | metachan-596ef846c97d9373ddda711dabfde9720b6931d7.tar.xz metachan-596ef846c97d9373ddda711dabfde9720b6931d7.zip | |
task for updating anime
Diffstat (limited to 'tasks/tasks.go')
| -rw-r--r-- | tasks/tasks.go | 17 |
1 files changed, 16 insertions, 1 deletions
diff --git a/tasks/tasks.go b/tasks/tasks.go index 57b34bd..29054e8 100644 --- a/tasks/tasks.go +++ b/tasks/tasks.go @@ -20,6 +20,7 @@ func init() { Database: database.DB, } + // Register AniSync task (weekly) err := GlobalTaskManager.RegisterTask(types.Task{ Name: "AnimeSync", Interval: 7 * 24 * time.Hour, @@ -27,7 +28,21 @@ func init() { }) if err != nil { - logger.Log(fmt.Sprintf("Failed to register task: %v", err), logger.LogOptions{ + logger.Log(fmt.Sprintf("Failed to register AniSync task: %v", err), logger.LogOptions{ + Level: logger.Error, + Prefix: "TaskManager", + }) + } + + // Register AnimeUpdate task (every 15 minutes) + err = GlobalTaskManager.RegisterTask(types.Task{ + Name: "AnimeUpdate", + Interval: 15 * time.Minute, + Execute: AnimeUpdate, + }) + + if err != nil { + logger.Log(fmt.Sprintf("Failed to register AnimeUpdate task: %v", err), logger.LogOptions{ Level: logger.Error, Prefix: "TaskManager", }) |
