aboutsummaryrefslogtreecommitdiffstats
path: root/models/webhook.go
diff options
context:
space:
mode:
authorThibault Meyer <meyer.thibault@gmail.com>2016-11-10 16:16:32 +0100
committerThibault Meyer <meyer.thibault@gmail.com>2016-11-10 20:59:51 +0100
commita4454f5d0fbeaacb94668012acbb4296465cb28f (patch)
treeeaf39d1935eda44cf16df08234d2bbddd39c3ddd /models/webhook.go
parentc040f2fbb13ef5ba2c6a619322d4801e9f78c885 (diff)
downloadgitea-a4454f5d0fbeaacb94668012acbb4296465cb28f.tar.gz
gitea-a4454f5d0fbeaacb94668012acbb4296465cb28f.zip
Rewrite XORM queries
Diffstat (limited to 'models/webhook.go')
-rw-r--r--models/webhook.go31
1 files changed, 20 insertions, 11 deletions
diff --git a/models/webhook.go b/models/webhook.go
index eb37338d2c..79e5821dd3 100644
--- a/models/webhook.go
+++ b/models/webhook.go
@@ -276,7 +276,10 @@ func GetWebhooksByOrgID(orgID int64) (ws []*Webhook, err error) {
// GetActiveWebhooksByOrgID returns all active webhooks for an organization.
func GetActiveWebhooksByOrgID(orgID int64) (ws []*Webhook, err error) {
- err = x.Where("org_id=?", orgID).And("is_active=?", true).Find(&ws)
+ err = x.
+ Where("org_id=?", orgID).
+ And("is_active=?", true).
+ Find(&ws)
return ws, err
}
@@ -323,8 +326,8 @@ func IsValidHookTaskType(name string) bool {
type HookEventType string
const (
- HookEventCreate HookEventType = "create"
- HookEventPush HookEventType = "push"
+ HookEventCreate HookEventType = "create"
+ HookEventPush HookEventType = "push"
HookEventPullRequest HookEventType = "pull_request"
)
@@ -413,7 +416,11 @@ func (t *HookTask) SimpleMarshalJSON(v interface{}) string {
// HookTasks returns a list of hook tasks by given conditions.
func HookTasks(hookID int64, page int) ([]*HookTask, error) {
tasks := make([]*HookTask, 0, setting.Webhook.PagingNum)
- return tasks, x.Limit(setting.Webhook.PagingNum, (page-1)*setting.Webhook.PagingNum).Where("hook_id=?", hookID).Desc("id").Find(&tasks)
+ return tasks, x.
+ Limit(setting.Webhook.PagingNum, (page-1)*setting.Webhook.PagingNum).
+ Where("hook_id=?", hookID).
+ Desc("id").
+ Find(&tasks)
}
// CreateHookTask creates a new hook task,
@@ -580,13 +587,15 @@ func (t *HookTask) deliver() {
// TODO: shoot more hooks at same time.
func DeliverHooks() {
tasks := make([]*HookTask, 0, 10)
- x.Where("is_delivered=?", false).Iterate(new(HookTask),
- func(idx int, bean interface{}) error {
- t := bean.(*HookTask)
- t.deliver()
- tasks = append(tasks, t)
- return nil
- })
+ x.
+ Where("is_delivered=?", false).
+ Iterate(new(HookTask),
+ func(idx int, bean interface{}) error {
+ t := bean.(*HookTask)
+ t.deliver()
+ tasks = append(tasks, t)
+ return nil
+ })
// Update hook task status.
for _, t := range tasks {