package plugin

import (
	"container/list"
	"sync"

	"apigo.cc/gojs"
	"apigo.cc/gojs/goja"
	"github.com/robfig/cron/v3"
)

const pluginName = "task"

type PluginObject struct {
	skipCron  *cron.Cron
	delayCron *cron.Cron
	// asyncCron    *cron.Cron
	stopChan     chan struct{}
	isStarted    bool
	lock         sync.RWMutex
	tasks        map[string]*Task
	taskData     map[string]any
	taskDataLock sync.RWMutex

	taskList     map[string]*list.List
	taskListLock sync.RWMutex
}

var _pluginObject = &PluginObject{
	tasks:    map[string]*Task{},
	taskData: map[string]any{},
	taskList: map[string]*list.List{},
}

func init() {
	tsCode := gojs.MakeTSCode(_pluginObject)
	mappedObj := gojs.ToMap(_pluginObject)
	gojs.Register("apigo.cc/gojs/"+pluginName, gojs.Module{
		ObjectMaker: func(vm *goja.Runtime) gojs.Map {
			return mappedObj
		},
		OnKill: func() {
			_pluginObject.Stop()
		},
		TsCode: tsCode,
		Desc:   "task api",
	})
}