package job

import (
	"context"
	infra "gitee.com/banyanhouse/distill-infra"
	"gitee.com/banyanhouse/distill-infra/hook"
	"k8s.io/klog/v2"
	"time"
)

var job Jobber

type Jobber interface {
	Run()
}

type BaseJobber struct {
}

func (b BaseJobber) Run() {
	klog.Info("BaseJobber Run Starting...")
	time.Sleep(3 * time.Second)
	klog.Info("BaseJobber Run Finished.")
}

type JobStarter struct {
	infra.BaseStarter
}

func (j *JobStarter) Setup(ctx context.Context) {
	conf := infra.Props(ctx)
	klog.Info("JobStarter Setup Begin.")
	klog.Info(conf.App.Name)
	job = new(BaseJobber)
	klog.Info("JobStarter Setup Finish.")
}

func (j *JobStarter) Start(ctx context.Context) {
	klog.Info("JobStarter Start Begin.")
	job.Run()
	klog.Info("JobStarter Start Finish.")
	hook.CloseBlockHookStarter()
}

func (j *JobStarter) Stop(ctx context.Context) {
	klog.Info("JobStarter Stop Begin.")
	klog.Info("JobStarter Stop Finish.")
}