#12, add/edit hook

2 files changed, 143 insertions, 20 deletions

diff --git a/routers/api/v1/repo.go b/routers/api/v1/repo.go
index 39a4c1d42c..e2d1dcb724 100644
--- a/routers/api/v1/repo.go
+++ b/routers/api/v1/repo.go
@@ -172,13 +172,9 @@ func Migrate(ctx *middleware.Context, form auth.MigrateRepoForm) {
 	})
 }
 
-// /user/repos: https://developer.github.com/v3/repos/#list-your-repositories
+// GET /user/repos
+// https://developer.github.com/v3/repos/#list-your-repositories
 func ListMyRepos(ctx *middleware.Context) {
-	if !ctx.IsSigned {
-		ctx.Error(403)
-		return
-	}
-
 	ownRepos, err := models.GetRepositories(ctx.User.Id, true)
 	if err != nil {
 		ctx.JSON(500, map[string]interface{}{
diff --git a/routers/api/v1/repo_hooks.go b/routers/api/v1/repo_hooks.go
index b2f13c79de..2dcb558737 100644
--- a/routers/api/v1/repo_hooks.go
+++ b/routers/api/v1/repo_hooks.go
@@ -5,24 +5,23 @@
 package v1
 
 import (
+	"encoding/json"
+
 	"github.com/gogits/gogs/models"
+	"github.com/gogits/gogs/modules/base"
 	"github.com/gogits/gogs/modules/middleware"
 )
 
-type apiHookConfig struct {
-	Url         string `json:"url"`
-	ContentType string `json:"content_type"`
-}
-
 type ApiHook struct {
-	Id     int64         `json:"id"`
-	Type   string        `json:"type"`
-	Events []string      `json:"events"`
-	Active bool          `json:"active"`
-	Config apiHookConfig `json:"config"`
+	Id     int64             `json:"id"`
+	Type   string            `json:"type"`
+	Events []string          `json:"events"`
+	Active bool              `json:"active"`
+	Config map[string]string `json:"config"`
 }
 
-// /repos/:username/:reponame/hooks: https://developer.github.com/v3/repos/hooks/#list-hooks
+// GET /repos/:username/:reponame/hooks
+// https://developer.github.com/v3/repos/hooks/#list-hooks
 func ListRepoHooks(ctx *middleware.Context) {
 	hooks, err := models.GetWebhooksByRepoId(ctx.Repo.Repository.Id)
 	if err != nil {
@@ -35,16 +34,144 @@ func ListRepoHooks(ctx *middleware.Context) {
 
 	apiHooks := make([]*ApiHook, len(hooks))
 	for i := range hooks {
-		apiHooks[i] = &ApiHook{
+		h := &ApiHook{
 			Id:     hooks[i].Id,
 			Type:   hooks[i].HookTaskType.Name(),
 			Active: hooks[i].IsActive,
-			Config: apiHookConfig{hooks[i].Url, hooks[i].ContentType.Name()},
+			Config: make(map[string]string),
 		}
 
 		// Currently, onle have push event.
-		apiHooks[i].Events = []string{"push"}
+		h.Events = []string{"push"}
+
+		h.Config["url"] = hooks[i].Url
+		h.Config["content_type"] = hooks[i].ContentType.Name()
+		if hooks[i].HookTaskType == models.SLACK {
+			s := hooks[i].GetSlackHook()
+			h.Config["channel"] = s.Channel
+		}
+
+		apiHooks[i] = h
 	}
 
 	ctx.JSON(200, &apiHooks)
 }
+
+type CreateRepoHookForm struct {
+	Type   string            `json:"type" binding:"Required"`
+	Config map[string]string `json:"config" binding:"Required"`
+	Active bool              `json:"active"`
+}
+
+// POST /repos/:username/:reponame/hooks
+// https://developer.github.com/v3/repos/hooks/#create-a-hook
+func CreateRepoHook(ctx *middleware.Context, form CreateRepoHookForm) {
+	if !models.IsValidHookTaskType(form.Type) {
+		ctx.JSON(422, &base.ApiJsonErr{"invalid hook type", DOC_URL})
+		return
+	}
+	for _, name := range []string{"url", "content_type"} {
+		if _, ok := form.Config[name]; !ok {
+			ctx.JSON(422, &base.ApiJsonErr{"missing config option: " + name, DOC_URL})
+			return
+		}
+	}
+	if !models.IsValidHookContentType(form.Config["content_type"]) {
+		ctx.JSON(422, &base.ApiJsonErr{"invalid content type", DOC_URL})
+		return
+	}
+
+	w := &models.Webhook{
+		RepoId:      ctx.Repo.Repository.Id,
+		Url:         form.Config["url"],
+		ContentType: models.ToHookContentType(form.Config["content_type"]),
+		Secret:      form.Config["secret"],
+		HookEvent: &models.HookEvent{
+			PushOnly: true, // Only support it now.
+		},
+		IsActive:     form.Active,
+		HookTaskType: models.ToHookTaskType(form.Type),
+	}
+	if w.HookTaskType == models.SLACK {
+		channel, ok := form.Config["channel"]
+		if !ok {
+			ctx.JSON(422, &base.ApiJsonErr{"missing config option: channel", DOC_URL})
+			return
+		}
+		meta, err := json.Marshal(&models.Slack{
+			Channel: channel,
+		})
+		if err != nil {
+			ctx.JSON(500, &base.ApiJsonErr{"slack: JSON marshal failed: " + err.Error(), DOC_URL})
+			return
+		}
+		w.Meta = string(meta)
+	}
+
+	if err := w.UpdateEvent(); err != nil {
+		ctx.JSON(500, &base.ApiJsonErr{"UpdateEvent: " + err.Error(), DOC_URL})
+		return
+	} else if err := models.CreateWebhook(w); err != nil {
+		ctx.JSON(500, &base.ApiJsonErr{"CreateWebhook: " + err.Error(), DOC_URL})
+		return
+	}
+
+	ctx.JSON(201, map[string]interface{}{
+		"ok": true,
+	})
+}
+
+type EditRepoHookForm struct {
+	Config map[string]string `json:"config"`
+	Active *bool             `json:"active"`
+}
+
+// PATCH /repos/:username/:reponame/hooks/:id
+// https://developer.github.com/v3/repos/hooks/#edit-a-hook
+func EditRepoHook(ctx *middleware.Context, form EditRepoHookForm) {
+	w, err := models.GetWebhookById(ctx.ParamsInt64(":id"))
+	if err != nil {
+		ctx.JSON(500, &base.ApiJsonErr{"GetWebhookById: " + err.Error(), DOC_URL})
+		return
+	}
+
+	if form.Config != nil {
+		if url, ok := form.Config["url"]; ok {
+			w.Url = url
+		}
+		if ct, ok := form.Config["content_type"]; ok {
+			if !models.IsValidHookContentType(ct) {
+				ctx.JSON(422, &base.ApiJsonErr{"invalid content type", DOC_URL})
+				return
+			}
+			w.ContentType = models.ToHookContentType(ct)
+		}
+
+		if w.HookTaskType == models.SLACK {
+			if channel, ok := form.Config["channel"]; ok {
+				meta, err := json.Marshal(&models.Slack{
+					Channel: channel,
+				})
+				if err != nil {
+					ctx.JSON(500, &base.ApiJsonErr{"slack: JSON marshal failed: " + err.Error(), DOC_URL})
+					return
+				}
+				w.Meta = string(meta)
+			}
+		}
+	}
+
+	if form.Active != nil {
+		w.IsActive = *form.Active
+	}
+
+	// FIXME: edit events
+	if err := models.UpdateWebhook(w); err != nil {
+		ctx.JSON(500, &base.ApiJsonErr{"UpdateWebhook: " + err.Error(), DOC_URL})
+		return
+	}
+
+	ctx.JSON(200, map[string]interface{}{
+		"ok": true,
+	})
+}