You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
166 lines
4.3 KiB
Go
166 lines
4.3 KiB
Go
10 years ago
|
// Copyright 2014 The Gogs Authors. All rights reserved.
|
||
|
// Use of this source code is governed by a MIT-style
|
||
|
// license that can be found in the LICENSE file.
|
||
|
|
||
9 years ago
|
package repo
|
||
10 years ago
|
|
||
|
import (
|
||
10 years ago
|
"encoding/json"
|
||
9 years ago
|
|
||
|
"github.com/Unknwon/com"
|
||
10 years ago
|
|
||
10 years ago
|
api "github.com/gogits/go-gogs-client"
|
||
|
|
||
10 years ago
|
"github.com/gogits/gogs/models"
|
||
|
"github.com/gogits/gogs/modules/middleware"
|
||
9 years ago
|
to "github.com/gogits/gogs/routers/api/v1/utils"
|
||
10 years ago
|
)
|
||
|
|
||
9 years ago
|
// https://github.com/gogits/go-gogs-client/wiki/Repositories#list-hooks
|
||
9 years ago
|
func ListHooks(ctx *middleware.Context) {
|
||
9 years ago
|
hooks, err := models.GetWebhooksByRepoID(ctx.Repo.Repository.ID)
|
||
10 years ago
|
if err != nil {
|
||
9 years ago
|
ctx.APIError(500, "GetWebhooksByRepoID", err)
|
||
10 years ago
|
return
|
||
|
}
|
||
|
|
||
10 years ago
|
apiHooks := make([]*api.Hook, len(hooks))
|
||
10 years ago
|
for i := range hooks {
|
||
9 years ago
|
apiHooks[i] = to.ApiHook(ctx.Repo.RepoLink, hooks[i])
|
||
10 years ago
|
}
|
||
|
|
||
|
ctx.JSON(200, &apiHooks)
|
||
|
}
|
||
10 years ago
|
|
||
9 years ago
|
// https://github.com/gogits/go-gogs-client/wiki/Repositories#create-a-hook
|
||
9 years ago
|
func CreateHook(ctx *middleware.Context, form api.CreateHookOption) {
|
||
10 years ago
|
if !models.IsValidHookTaskType(form.Type) {
|
||
9 years ago
|
ctx.APIError(422, "", "Invalid hook type")
|
||
10 years ago
|
return
|
||
|
}
|
||
|
for _, name := range []string{"url", "content_type"} {
|
||
|
if _, ok := form.Config[name]; !ok {
|
||
9 years ago
|
ctx.APIError(422, "", "Missing config option: "+name)
|
||
10 years ago
|
return
|
||
|
}
|
||
|
}
|
||
|
if !models.IsValidHookContentType(form.Config["content_type"]) {
|
||
9 years ago
|
ctx.APIError(422, "", "Invalid content type")
|
||
10 years ago
|
return
|
||
|
}
|
||
|
|
||
9 years ago
|
if len(form.Events) == 0 {
|
||
|
form.Events = []string{"push"}
|
||
|
}
|
||
10 years ago
|
w := &models.Webhook{
|
||
9 years ago
|
RepoID: ctx.Repo.Repository.ID,
|
||
|
URL: form.Config["url"],
|
||
10 years ago
|
ContentType: models.ToHookContentType(form.Config["content_type"]),
|
||
|
Secret: form.Config["secret"],
|
||
|
HookEvent: &models.HookEvent{
|
||
9 years ago
|
ChooseEvents: true,
|
||
|
HookEvents: models.HookEvents{
|
||
|
Create: com.IsSliceContainsStr(form.Events, string(models.HOOK_EVENT_CREATE)),
|
||
|
Push: com.IsSliceContainsStr(form.Events, string(models.HOOK_EVENT_PUSH)),
|
||
|
},
|
||
10 years ago
|
},
|
||
|
IsActive: form.Active,
|
||
|
HookTaskType: models.ToHookTaskType(form.Type),
|
||
|
}
|
||
|
if w.HookTaskType == models.SLACK {
|
||
|
channel, ok := form.Config["channel"]
|
||
|
if !ok {
|
||
9 years ago
|
ctx.APIError(422, "", "Missing config option: channel")
|
||
10 years ago
|
return
|
||
|
}
|
||
9 years ago
|
meta, err := json.Marshal(&models.SlackMeta{
|
||
9 years ago
|
Channel: channel,
|
||
|
Username: form.Config["username"],
|
||
|
IconURL: form.Config["icon_url"],
|
||
|
Color: form.Config["color"],
|
||
10 years ago
|
})
|
||
|
if err != nil {
|
||
9 years ago
|
ctx.APIError(500, "slack: JSON marshal failed", err)
|
||
10 years ago
|
return
|
||
|
}
|
||
|
w.Meta = string(meta)
|
||
|
}
|
||
|
|
||
|
if err := w.UpdateEvent(); err != nil {
|
||
9 years ago
|
ctx.APIError(500, "UpdateEvent", err)
|
||
10 years ago
|
return
|
||
|
} else if err := models.CreateWebhook(w); err != nil {
|
||
9 years ago
|
ctx.APIError(500, "CreateWebhook", err)
|
||
10 years ago
|
return
|
||
|
}
|
||
|
|
||
9 years ago
|
ctx.JSON(201, to.ApiHook(ctx.Repo.RepoLink, w))
|
||
10 years ago
|
}
|
||
|
|
||
9 years ago
|
// https://github.com/gogits/go-gogs-client/wiki/Repositories#edit-a-hook
|
||
9 years ago
|
func EditHook(ctx *middleware.Context, form api.EditHookOption) {
|
||
9 years ago
|
w, err := models.GetWebhookByID(ctx.ParamsInt64(":id"))
|
||
10 years ago
|
if err != nil {
|
||
9 years ago
|
if models.IsErrWebhookNotExist(err) {
|
||
|
ctx.Error(404)
|
||
|
} else {
|
||
|
ctx.APIError(500, "GetWebhookById", err)
|
||
|
}
|
||
10 years ago
|
return
|
||
|
}
|
||
|
|
||
|
if form.Config != nil {
|
||
|
if url, ok := form.Config["url"]; ok {
|
||
9 years ago
|
w.URL = url
|
||
10 years ago
|
}
|
||
|
if ct, ok := form.Config["content_type"]; ok {
|
||
|
if !models.IsValidHookContentType(ct) {
|
||
9 years ago
|
ctx.APIError(422, "", "Invalid content type")
|
||
10 years ago
|
return
|
||
|
}
|
||
|
w.ContentType = models.ToHookContentType(ct)
|
||
|
}
|
||
|
|
||
|
if w.HookTaskType == models.SLACK {
|
||
|
if channel, ok := form.Config["channel"]; ok {
|
||
9 years ago
|
meta, err := json.Marshal(&models.SlackMeta{
|
||
9 years ago
|
Channel: channel,
|
||
|
Username: form.Config["username"],
|
||
|
IconURL: form.Config["icon_url"],
|
||
|
Color: form.Config["color"],
|
||
10 years ago
|
})
|
||
|
if err != nil {
|
||
9 years ago
|
ctx.APIError(500, "slack: JSON marshal failed", err)
|
||
10 years ago
|
return
|
||
|
}
|
||
|
w.Meta = string(meta)
|
||
|
}
|
||
|
}
|
||
|
}
|
||
|
|
||
9 years ago
|
// Update events
|
||
9 years ago
|
if len(form.Events) == 0 {
|
||
|
form.Events = []string{"push"}
|
||
|
}
|
||
9 years ago
|
w.PushOnly = false
|
||
|
w.SendEverything = false
|
||
|
w.ChooseEvents = true
|
||
|
w.Create = com.IsSliceContainsStr(form.Events, string(models.HOOK_EVENT_CREATE))
|
||
|
w.Push = com.IsSliceContainsStr(form.Events, string(models.HOOK_EVENT_PUSH))
|
||
|
if err = w.UpdateEvent(); err != nil {
|
||
9 years ago
|
ctx.APIError(500, "UpdateEvent", err)
|
||
9 years ago
|
return
|
||
|
}
|
||
|
|
||
10 years ago
|
if form.Active != nil {
|
||
|
w.IsActive = *form.Active
|
||
|
}
|
||
|
|
||
|
if err := models.UpdateWebhook(w); err != nil {
|
||
9 years ago
|
ctx.APIError(500, "UpdateWebhook", err)
|
||
10 years ago
|
return
|
||
|
}
|
||
|
|
||
9 years ago
|
ctx.JSON(200, to.ApiHook(ctx.Repo.RepoLink, w))
|
||
10 years ago
|
}
|