tasks/tasks.go


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

package tasks

import (
	"metachan/types"
	"metachan/utils/logger"
	"sync"
	"time"
)

var GlobalTaskManager *TaskManager

func init() {
	GlobalTaskManager = &TaskManager{
		Tasks:   make(map[string]types.Task),
		Tickers: make(map[string]*time.Ticker),
		Done:    make(map[string]chan bool),
		Mutex:   sync.Mutex{},
	}

	err := GlobalTaskManager.RegisterTask(types.Task{
		Name:     "AnimeFetch",
		Interval: 7 * 24 * time.Hour,
		Execute:  AniFetch,
	})

	if err != nil {
		logger.Errorf("TaskManager", "Failed to register AnimeFetch task: %v", err)
	}
}