aboutsummaryrefslogtreecommitdiff
path: root/tasks/tasks.go
diff options
context:
space:
mode:
authorBobby <[email protected]>2025-05-09 04:30:23 +0530
committerBobby <[email protected]>2025-05-09 04:30:23 +0530
commit596ef846c97d9373ddda711dabfde9720b6931d7 (patch)
tree1717fab55a77375f7a41a50b9f62bff404bb0d81 /tasks/tasks.go
parentb5ea894b18e63fb22f02c32958cb270139cb8c78 (diff)
downloadmetachan-596ef846c97d9373ddda711dabfde9720b6931d7.tar.xz
metachan-596ef846c97d9373ddda711dabfde9720b6931d7.zip
task for updating anime
Diffstat (limited to 'tasks/tasks.go')
-rw-r--r--tasks/tasks.go17
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",
})