package tests

import (
	"context"
	"errors"
	"fmt"
	"time"

	"github.com/spiral/roadrunner/v2"
	"github.com/spiral/roadrunner/v2/plugins/config"
	"github.com/spiral/roadrunner/v2/plugins/factory"
)

type Foo2 struct {
	configProvider config.Provider
	wf             factory.AppFactory
}

func (f *Foo2) Init(p config.Provider, workerFactory factory.AppFactory) error {
	f.configProvider = p
	f.wf = workerFactory
	return nil
}

func (f *Foo2) Serve() chan error {
	errCh := make(chan error, 1)

	r := &factory.Config{}
	err := f.configProvider.UnmarshalKey("app", r)
	if err != nil {
		errCh <- err
		return errCh
	}

	cmd, err := f.wf.NewCmdFactory(nil)
	if err != nil {
		errCh <- err
		return errCh
	}
	if cmd == nil {
		errCh <- errors.New("command is nil")
		return errCh
	}
	a := cmd()
	out, err := a.Output()
	if err != nil {
		errCh <- err
		return errCh
	}

	w, err := f.wf.NewWorker(context.Background(), nil)
	if err != nil {
		errCh <- err
		return errCh
	}

	_ = w

	poolConfig := roadrunner.Config{
		NumWorkers:      10,
		MaxJobs:         100,
		AllocateTimeout: time.Second * 10,
		DestroyTimeout:  time.Second * 10,
		Supervisor: &roadrunner.SupervisorConfig{
			WatchTick:       60,
			TTL:             1000,
			IdleTTL:         10,
			ExecTTL:         10,
			MaxWorkerMemory: 1000,
		},
	}

	pool, err := f.wf.NewWorkerPool(context.Background(), poolConfig, nil)
	if err != nil {
		errCh <- err
		return errCh
	}

	_ = pool

	fmt.Println(string(out))

	return errCh
}

func (f *Foo2) Stop() error {
	return nil
}