package ast

import (
	"fmt"
	"sync"

	"github.com/go-task/task/v3/errors"
	"github.com/go-task/task/v3/internal/deepcopy"

	"gopkg.in/yaml.v3"
)

// Precondition represents a precondition necessary for a task to run
type (
	Preconditions struct {
		Preconditions []*Precondition
		mutex         sync.RWMutex
	}

	Precondition struct {
		Sh  string
		Msg string
	}
)

func NewPreconditions() *Preconditions {
	return &Preconditions{
		Preconditions: make([]*Precondition, 0),
	}
}

func (p *Preconditions) DeepCopy() *Preconditions {
	if p == nil {
		return nil
	}
	defer p.mutex.RUnlock()
	p.mutex.RLock()
	return &Preconditions{
		Preconditions: deepcopy.Slice(p.Preconditions),
	}
}

func (p *Precondition) DeepCopy() *Precondition {
	if p == nil {
		return nil
	}
	return &Precondition{
		Sh:  p.Sh,
		Msg: p.Msg,
	}
}

// UnmarshalYAML implements yaml.Unmarshaler interface.
func (p *Precondition) UnmarshalYAML(node *yaml.Node) error {
	switch node.Kind {

	case yaml.ScalarNode:
		var cmd string
		if err := node.Decode(&cmd); err != nil {
			return errors.NewTaskfileDecodeError(err, node)
		}
		p.Sh = cmd
		p.Msg = fmt.Sprintf("`%s` failed", cmd)
		return nil

	case yaml.MappingNode:
		var sh struct {
			Sh  string
			Msg string
		}
		if err := node.Decode(&sh); err != nil {
			return errors.NewTaskfileDecodeError(err, node)
		}
		p.Sh = sh.Sh
		p.Msg = sh.Msg
		if p.Msg == "" {
			p.Msg = fmt.Sprintf("%s failed", sh.Sh)
		}
		return nil
	}

	return errors.NewTaskfileDecodeError(nil, node).WithTypeMessage("precondition")
}

func (p *Preconditions) UnmarshalYAML(node *yaml.Node) error {
	if p == nil || p.Preconditions == nil {
		*p = *NewPreconditions()
	}

	if err := node.Decode(&p.Preconditions); err != nil {
		return errors.NewTaskfileDecodeError(err, node).WithTypeMessage("preconditions")
	}

	return nil
}