2017-04-11 19:06:45 +02:00
|
|
|
package sender
|
|
|
|
|
|
|
|
import (
|
2019-04-04 20:51:20 +02:00
|
|
|
"github.com/laszlocph/drone-oss-08/model"
|
2017-04-11 19:06:45 +02:00
|
|
|
)
|
|
|
|
|
|
|
|
type builtin struct {
|
|
|
|
store model.SenderStore
|
2017-05-05 20:05:42 +02:00
|
|
|
conf model.ConfigStore
|
2017-04-11 19:06:45 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
// New returns a new local gating service.
|
2017-05-05 20:05:42 +02:00
|
|
|
func New(store model.SenderStore, conf model.ConfigStore) model.SenderService {
|
|
|
|
return &builtin{store, conf}
|
2017-04-11 19:06:45 +02:00
|
|
|
}
|
|
|
|
|
2017-05-05 19:13:40 +02:00
|
|
|
func (b *builtin) SenderAllowed(user *model.User, repo *model.Repo, build *model.Build, conf *model.Config) (bool, error) {
|
2017-05-05 20:05:42 +02:00
|
|
|
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.
|
2017-04-11 19:06:45 +02:00
|
|
|
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)
|
|
|
|
}
|