package job

import (
	"time"

	"github.com/wallace5303/ee-go/elog"
	"github.com/wallace5303/ee-go/eruntime"
	"github.com/wallace5303/ee-go/etask"
	"github.com/wallace5303/ee-go/eutil"
)

var (
	checkStatusInterval = 5
)

func Boot() {
	if eruntime.IsDev() {
		checkStatusInterval = 2
	}
	go etask.Every(1000*time.Millisecond, etask.ExecTask)
	go etask.Every(time.Duration(checkStatusInterval)*time.Second, etask.Status)

	// test task
	AddTestTask()
}

func AddTestTask() {
	count := 10
	for i := 0; i < count; i++ {
		etask.AddTask("task.demo", hello)
	}
}

func hello() {
	defer eutil.Recover()
	elog.Logger.Info("[task] hello")
}