package task

import (
	"time"

	"github.com/go-playground/validator/v10"
	"github.com/rs/xid"
)

const (
	AppName = "task"
)

var (
	validate = validator.New()
)

func (req *CreateTaskRequst) Validate() error {
	return validate.Struct(req)
}
func NewTask(req *CreateTaskRequst) (*Task, error) {
	err := req.Validate()
	if err != nil {
		return nil, err
	}
	ins := NewDefaultTask()
	ins.Data = req
	ins.Id = xid.New().String()
	return ins, nil

	// return &ins{
	// 	Id:   xid.New().String(),
	// 	Data: req,
	// }, nil

}

func NewDefaultTask() *Task {
	return &Task{
		Data:   &CreateTaskRequst{},
		Status: &Status{},
	}
}
func NewCreateTaskRequest() *CreateTaskRequst {
	return &CreateTaskRequst{
		Params: map[string]string{},
		//同步任务默认超时时间
		Timeout: 30 * 60,
	}
}

func (s *Task) Run() {
	s.Status.StartAt = time.Now().UnixMilli()
	s.Status.Stage = Stage_RUNNING
}

func (s *Task) Success() {
	s.Status.Stage = Stage_SUCCESS
	s.Status.EndAt = time.Now().UnixMilli()
}

func (s *Task) Failed(message string) {
	s.Status.EndAt = time.Now().UnixMilli()
	s.Status.Stage = Stage_FAILED
	s.Status.Message = message
}