package sender

import (
	"github.com/drone/drone/model"
)

type builtin struct {
	store model.SenderStore
	conf  model.ConfigStore
}

// New returns a new local gating service.
func New(store model.SenderStore, conf model.ConfigStore) model.SenderService {
	return &builtin{store, conf}
}

func (b *builtin) SenderAllowed(user *model.User, repo *model.Repo, build *model.Build, conf *model.Config) (bool, error) {
	if build.Event == model.EventPull && build.Sender != user.Login {
		// check to see if the configuration has already been used in an
		// existing build. If yes it is considered approved.
		if ok, _ := b.conf.ConfigFindApproved(conf); ok {
			return true, nil
		}
		// else check to see if the configuration is sent from a user
		// account that is a repositroy approver themselves.
		sender, err := b.store.SenderFind(repo, build.Sender)
		if err != nil || sender.Block {
			return false, nil
		}
	}
	return true, nil
}

func (b *builtin) SenderCreate(repo *model.Repo, sender *model.Sender) error {
	return b.store.SenderCreate(sender)
}

func (b *builtin) SenderUpdate(repo *model.Repo, sender *model.Sender) error {
	return b.store.SenderUpdate(sender)
}

func (b *builtin) SenderDelete(repo *model.Repo, login string) error {
	sender, err := b.store.SenderFind(repo, login)
	if err != nil {
		return err
	}
	return b.store.SenderDelete(sender)
}

func (b *builtin) SenderList(repo *model.Repo) ([]*model.Sender, error) {
	return b.store.SenderList(repo)
}