wrapper

type ConfigParser interface {
	Parse(map[string]any, Wrapper) error
}

type Event struct {
	Id        string `json:"id"`
	Timestamp int64  `json:"timestamp"`
	Name      string `json:"name"`
	Data      any    `json:"data"`
}

type Hook interface {
	Execute(context.Context, []byte) error
}

type Map interface {
	GetInt8(string, int8) int8
	GetUint8(string, uint8) uint8
	GetInt16(string, int16) int16
	GetUint16(string, uint16) uint16
	GetInt32(string, int32) int32
	GetUint32(string, uint32) uint32
	GetInt64(string, int64) int64
	GetUint64(string, uint64) uint64
	GetBool(string, bool) bool
	GetString(string, string) string
	GetMap(string, Map) Map
}

type Options struct {
	Program  string
	Args     []string
	Dir      string
	Env      []string
	Graceful struct {
		Timeout time.Duration
		Stopper Stopper
	}
	Tasks         []Task
	Services      []Service
	ConfigParsers []ConfigParser
	Logger        *slog.Logger
}

type ProcessLogEvent struct {
	Message string `json:"message"`
}

type Registry struct {
	Tasks    []Task
	Services []Service

	Stoppers        map[string]func(map[string]any) Stopper
	LoggingHandlers map[string]func(map[string]any) slog.Handler
	Hooks           map[string]func(map[string]any) Hook
	ConfigParser    map[string]func(map[string]any) ConfigParser
}

type ServerState struct {
	Status  ServerState_Status  `json:"status"`
	Players ServerState_Players `json:"players"`
}

type ServerState_Player struct {
	Id         string         `json:"id"`
	Attributes map[string]any `json:"attributes"`
}

type ServerState_Players struct {
	Count int                  `json:"count"`
	Max   int                  `json:"max"`
	List  []ServerState_Player `json:"list"`
}

type ServerState_Status struct {
	Description string `json:"description"`
}

type Service interface {
	Register(grpc.ServiceRegistrar)
}

type StateUpdateEvent struct {
	State ServerState `json:"state"`
}

type States struct {
	// contains filtered or unexported fields
}

type Stopper func(Wrapper) error

type Task interface {
	Name() string
	Run(context.Context, Wrapper) error
}

type Wrapper interface {
	Files() fs.FS
	WriteStdin(command string) error
	SendSignal(signal os.Signal) error
	SubscribeLogs() pubsub.Subscriber[string]
	SubscribeEvents() pubsub.Subscriber[Event]
	EmitEvent(event any)
	GetState() ServerState
	SubscribeStates() pubsub.Subscriber[ServerState]
	UpdateState(func(ServerState) ServerState)
	Logger() *slog.Logger
	GetServerConfig() (Map, error)
}

type WrapperContext struct {
	// contains filtered or unexported fields
}