]> source.dussan.org Git - gitea.git/commitdiff
Finish edit and remove web hook
authorUnknown <joe2010xtmf@163.com>
Tue, 6 May 2014 01:36:08 +0000 (21:36 -0400)
committerUnknown <joe2010xtmf@163.com>
Tue, 6 May 2014 01:36:08 +0000 (21:36 -0400)
cmd/web.go
models/repo.go
models/webhook.go
routers/repo/setting.go
templates/repo/hooks.tmpl
templates/repo/hooks_add.tmpl
templates/repo/hooks_edit.tmpl

index be489c1be461a19192ef7c1a8f4288b86eae9f61..74da86d40ee9492cb2b4e9387925da673a92936c 100644 (file)
@@ -165,21 +165,22 @@ func runWeb(*cli.Context) {
                m.Get("/template/**", dev.TemplatePreview)
        }
 
-       reqOwner := middleware.RequireOwner
+       reqOwner := middleware.RequireOwner()
 
        m.Group("/:username/:reponame", func(r martini.Router) {
                r.Get("/settings", repo.Setting)
                r.Post("/settings", bindIgnErr(auth.RepoSettingForm{}), repo.SettingPost)
                r.Get("/settings/collaboration", repo.Collaboration)
                r.Post("/settings/collaboration", repo.CollaborationPost)
-               r.Get("/settings/hooks", repo.WebHooks) // TODO
+               r.Get("/settings/hooks", repo.WebHooks)
                r.Get("/settings/hooks/add", repo.WebHooksAdd)
                r.Post("/settings/hooks/add", bindIgnErr(auth.NewWebhookForm{}), repo.WebHooksAddPost)
-               r.Get("/settings/hooks/id", repo.WebHooksEdit)
-       }, reqSignIn, middleware.RepoAssignment(true), reqOwner())
+               r.Get("/settings/hooks/:id", repo.WebHooksEdit)
+               r.Post("/settings/hooks/:id", bindIgnErr(auth.NewWebhookForm{}), repo.WebHooksEditPost)
+       }, reqSignIn, middleware.RepoAssignment(true), reqOwner)
 
        m.Group("/:username/:reponame", func(r martini.Router) {
-               r.Get("/action/:action", repo.Action)
+               r.Get("/action/:action", repo.Action) // TODO
                r.Get("/issues/new", repo.CreateIssue)
                r.Post("/issues/new", bindIgnErr(auth.CreateIssueForm{}), repo.CreateIssuePost)
                r.Post("/issues/:index", bindIgnErr(auth.CreateIssueForm{}), repo.UpdateIssue)
index e8baadf6b0ddb23e96a3e30a9aeaecca39749e7b..d2b92be4875723a9eab774754a1530de27e44d1f 100644 (file)
@@ -690,7 +690,7 @@ func GetRepositoryById(id int64) (*Repository, error) {
        } else if !has {
                return nil, ErrRepoNotExist
        }
-       return repo, err
+       return repo, nil
 }
 
 // GetRepositories returns the list of repositories of given user.
index 78d984cfe760d58ce463e5118c4c793e7c12927e..daa4510f2deb82f0917183c104a59da6983af3c5 100644 (file)
@@ -6,10 +6,15 @@ package models
 
 import (
        "encoding/json"
+       "errors"
 
        "github.com/gogits/gogs/modules/log"
 )
 
+var (
+       ErrWebhookNotExist = errors.New("Webhook does not exist")
+)
+
 // Content types.
 const (
        CT_JSON = iota + 1
@@ -27,20 +32,20 @@ type Webhook struct {
        ContentType int
        Secret      string `xorm:"TEXT"`
        Events      string `xorm:"TEXT"`
+       *HookEvent  `xorm:"-"`
        IsSsl       bool
        IsActive    bool
 }
 
-func (w *Webhook) GetEvent() *HookEvent {
-       h := &HookEvent{}
-       if err := json.Unmarshal([]byte(w.Events), h); err != nil {
+func (w *Webhook) GetEvent() {
+       w.HookEvent = &HookEvent{}
+       if err := json.Unmarshal([]byte(w.Events), w.HookEvent); err != nil {
                log.Error("webhook.GetEvent(%d): %v", w.Id, err)
        }
-       return h
 }
 
-func (w *Webhook) SaveEvent(h *HookEvent) error {
-       data, err := json.Marshal(h)
+func (w *Webhook) SaveEvent() error {
+       data, err := json.Marshal(w.HookEvent)
        w.Events = string(data)
        return err
 }
@@ -51,8 +56,32 @@ func CreateWebhook(w *Webhook) error {
        return err
 }
 
+// UpdateWebhook updates information of webhook.
+func UpdateWebhook(w *Webhook) error {
+       _, err := orm.AllCols().Update(w)
+       return err
+}
+
+// GetWebhookById returns webhook by given ID.
+func GetWebhookById(hookId int64) (*Webhook, error) {
+       w := &Webhook{Id: hookId}
+       has, err := orm.Get(w)
+       if err != nil {
+               return nil, err
+       } else if !has {
+               return nil, ErrWebhookNotExist
+       }
+       return w, nil
+}
+
 // GetWebhooksByRepoId returns all webhooks of repository.
 func GetWebhooksByRepoId(repoId int64) (ws []*Webhook, err error) {
        err = orm.Find(&ws, &Webhook{RepoId: repoId})
        return ws, err
 }
+
+// DeleteWebhook deletes webhook of repository.
+func DeleteWebhook(hookId int64) error {
+       _, err := orm.Delete(&Webhook{Id: hookId})
+       return err
+}
index d49c93375b69693ae18624e9b7b2a241083ad920..6937d0b42aca8cc6d8649360de2ad7469efe2ec7 100644 (file)
@@ -8,6 +8,8 @@ import (
        "fmt"
        "strings"
 
+       "github.com/go-martini/martini"
+
        "github.com/gogits/git"
 
        "github.com/gogits/gogs/models"
@@ -39,13 +41,13 @@ func SettingPost(ctx *middleware.Context, form auth.RepoSettingForm) {
                if ctx.Repo.Repository.Name != newRepoName {
                        isExist, err := models.IsRepositoryExist(ctx.Repo.Owner, newRepoName)
                        if err != nil {
-                               ctx.Handle(500, "repo.SettingPost(update: check existence)", err)
+                               ctx.Handle(500, "setting.SettingPost(update: check existence)", err)
                                return
                        } else if isExist {
                                ctx.RenderWithErr("Repository name has been taken in your repositories.", "repo/setting", nil)
                                return
                        } else if err = models.ChangeRepositoryName(ctx.Repo.Owner.Name, ctx.Repo.Repository.Name, newRepoName); err != nil {
-                               ctx.Handle(500, "repo.SettingPost(change repository name)", err)
+                               ctx.Handle(500, "setting.SettingPost(change repository name)", err)
                                return
                        }
                        log.Trace("%s Repository name changed: %s/%s -> %s", ctx.Req.RequestURI, ctx.User.Name, ctx.Repo.Repository.Name, newRepoName)
@@ -63,7 +65,7 @@ func SettingPost(ctx *middleware.Context, form auth.RepoSettingForm) {
                ctx.Repo.Repository.IsPrivate = form.Private
                ctx.Repo.Repository.IsGoget = form.GoGet
                if err := models.UpdateRepository(ctx.Repo.Repository); err != nil {
-                       ctx.Handle(404, "repo.SettingPost(update)", err)
+                       ctx.Handle(404, "setting.SettingPost(update)", err)
                        return
                }
                log.Trace("%s Repository updated: %s/%s", ctx.Req.RequestURI, ctx.Repo.Owner.Name, ctx.Repo.Repository.Name)
@@ -72,7 +74,7 @@ func SettingPost(ctx *middleware.Context, form auth.RepoSettingForm) {
                        if form.Interval > 0 {
                                ctx.Repo.Mirror.Interval = form.Interval
                                if err := models.UpdateMirror(ctx.Repo.Mirror); err != nil {
-                                       log.Error("repo.SettingPost(UpdateMirror): %v", err)
+                                       log.Error("setting.SettingPost(UpdateMirror): %v", err)
                                }
                        }
                }
@@ -89,13 +91,13 @@ func SettingPost(ctx *middleware.Context, form auth.RepoSettingForm) {
                // Check if new owner exists.
                isExist, err := models.IsUserExist(newOwner)
                if err != nil {
-                       ctx.Handle(500, "repo.SettingPost(transfer: check existence)", err)
+                       ctx.Handle(500, "setting.SettingPost(transfer: check existence)", err)
                        return
                } else if !isExist {
                        ctx.RenderWithErr("Please make sure you entered owner name is correct.", "repo/setting", nil)
                        return
                } else if err = models.TransferOwnership(ctx.User, newOwner, ctx.Repo.Repository); err != nil {
-                       ctx.Handle(500, "repo.SettingPost(transfer repository)", err)
+                       ctx.Handle(500, "setting.SettingPost(transfer repository)", err)
                        return
                }
                log.Trace("%s Repository transfered: %s/%s -> %s", ctx.Req.RequestURI, ctx.User.Name, ctx.Repo.Repository.Name, newOwner)
@@ -108,7 +110,7 @@ func SettingPost(ctx *middleware.Context, form auth.RepoSettingForm) {
                }
 
                if err := models.DeleteRepository(ctx.User.Id, ctx.Repo.Repository.Id, ctx.User.LowerName); err != nil {
-                       ctx.Handle(500, "repo.Delete", err)
+                       ctx.Handle(500, "setting.Delete", err)
                        return
                }
                log.Trace("%s Repository deleted: %s/%s", ctx.Req.RequestURI, ctx.User.LowerName, ctx.Repo.Repository.LowerName)
@@ -126,7 +128,7 @@ func Collaboration(ctx *middleware.Context) {
        remove := strings.ToLower(ctx.Query("remove"))
        if len(remove) > 0 && remove != ctx.Repo.Owner.LowerName {
                if err := models.DeleteAccess(&models.Access{UserName: remove, RepoName: repoLink}); err != nil {
-                       ctx.Handle(500, "repo.Collaboration(DeleteAccess)", err)
+                       ctx.Handle(500, "setting.Collaboration(DeleteAccess)", err)
                        return
                }
                ctx.Flash.Success("Collaborator has been removed.")
@@ -136,7 +138,7 @@ func Collaboration(ctx *middleware.Context) {
 
        names, err := models.GetCollaborators(repoLink)
        if err != nil {
-               ctx.Handle(500, "repo.Collaboration(GetCollaborators)", err)
+               ctx.Handle(500, "setting.Collaboration(GetCollaborators)", err)
                return
        }
 
@@ -144,7 +146,7 @@ func Collaboration(ctx *middleware.Context) {
        for i, name := range names {
                us[i], err = models.GetUserByName(name)
                if err != nil {
-                       ctx.Handle(500, "repo.Collaboration(GetUserByName)", err)
+                       ctx.Handle(500, "setting.Collaboration(GetUserByName)", err)
                        return
                }
        }
@@ -162,7 +164,7 @@ func CollaborationPost(ctx *middleware.Context) {
        }
        has, err := models.HasAccess(name, repoLink, models.AU_WRITABLE)
        if err != nil {
-               ctx.Handle(500, "repo.CollaborationPost(HasAccess)", err)
+               ctx.Handle(500, "setting.CollaborationPost(HasAccess)", err)
                return
        } else if has {
                ctx.Redirect(ctx.Req.RequestURI)
@@ -175,20 +177,20 @@ func CollaborationPost(ctx *middleware.Context) {
                        ctx.Flash.Error("Given user does not exist.")
                        ctx.Redirect(ctx.Req.RequestURI)
                } else {
-                       ctx.Handle(500, "repo.CollaborationPost(GetUserByName)", err)
+                       ctx.Handle(500, "setting.CollaborationPost(GetUserByName)", err)
                }
                return
        }
 
        if err = models.AddAccess(&models.Access{UserName: name, RepoName: repoLink,
                Mode: models.AU_WRITABLE}); err != nil {
-               ctx.Handle(500, "repo.CollaborationPost(AddAccess)", err)
+               ctx.Handle(500, "setting.CollaborationPost(AddAccess)", err)
                return
        }
 
        if base.Service.NotifyMail {
                if err = mailer.SendCollaboratorMail(ctx.Render, u, ctx.User, ctx.Repo.Repository); err != nil {
-                       ctx.Handle(500, "repo.CollaborationPost(SendCollaboratorMail)", err)
+                       ctx.Handle(500, "setting.CollaborationPost(SendCollaboratorMail)", err)
                        return
                }
        }
@@ -201,9 +203,21 @@ func WebHooks(ctx *middleware.Context) {
        ctx.Data["IsRepoToolbarWebHooks"] = true
        ctx.Data["Title"] = strings.TrimPrefix(ctx.Repo.RepoLink, "/") + " - Webhooks"
 
+       // Delete webhook.
+       remove, _ := base.StrTo(ctx.Query("remove")).Int64()
+       if remove > 0 {
+               if err := models.DeleteWebhook(remove); err != nil {
+                       ctx.Handle(500, "setting.WebHooks(DeleteWebhook)", err)
+                       return
+               }
+               ctx.Flash.Success("Webhook has been removed.")
+               ctx.Redirect(ctx.Repo.RepoLink + "/settings/hooks")
+               return
+       }
+
        ws, err := models.GetWebhooksByRepoId(ctx.Repo.Repository.Id)
        if err != nil {
-               ctx.Handle(500, "repo.WebHooks(GetWebhooksByRepoId)", err)
+               ctx.Handle(500, "setting.WebHooks(GetWebhooksByRepoId)", err)
                return
        }
 
@@ -227,7 +241,7 @@ func WebHooksAddPost(ctx *middleware.Context, form auth.NewWebhookForm) {
        }
 
        ct := models.CT_JSON
-       if form.ContentType == "form" {
+       if form.ContentType == "2" {
                ct = models.CT_FORM
        }
 
@@ -236,16 +250,16 @@ func WebHooksAddPost(ctx *middleware.Context, form auth.NewWebhookForm) {
                Payload:     form.Url,
                ContentType: ct,
                Secret:      form.Secret,
-               IsActive:    form.Active,
+               HookEvent: &models.HookEvent{
+                       PushOnly: form.PushOnly,
+               },
+               IsActive: form.Active,
        }
-       h := &models.HookEvent{
-               PushOnly: form.PushOnly,
-       }
-       if err := w.SaveEvent(h); err != nil {
-               ctx.Handle(500, "repo.WebHooksAddPost(SaveEvent)", err)
+       if err := w.SaveEvent(); err != nil {
+               ctx.Handle(500, "setting.WebHooksAddPost(SaveEvent)", err)
                return
        } else if err := models.CreateWebhook(w); err != nil {
-               ctx.Handle(500, "repo.WebHooksAddPost(CreateWebhook)", err)
+               ctx.Handle(500, "setting.WebHooksAddPost(CreateWebhook)", err)
                return
        }
 
@@ -253,8 +267,70 @@ func WebHooksAddPost(ctx *middleware.Context, form auth.NewWebhookForm) {
        ctx.Redirect(ctx.Repo.RepoLink + "/settings/hooks")
 }
 
-func WebHooksEdit(ctx *middleware.Context) {
+func WebHooksEdit(ctx *middleware.Context, params martini.Params) {
        ctx.Data["IsRepoToolbarWebHooks"] = true
        ctx.Data["Title"] = strings.TrimPrefix(ctx.Repo.RepoLink, "/") + " - Webhook"
+
+       hookId, _ := base.StrTo(params["id"]).Int64()
+       if hookId == 0 {
+               ctx.Handle(404, "setting.WebHooksEdit", nil)
+               return
+       }
+
+       w, err := models.GetWebhookById(hookId)
+       if err != nil {
+               if err == models.ErrWebhookNotExist {
+                       ctx.Handle(404, "setting.WebHooksEdit(GetWebhookById)", nil)
+               } else {
+                       ctx.Handle(500, "setting.WebHooksEdit(GetWebhookById)", err)
+               }
+               return
+       }
+
+       w.GetEvent()
+       ctx.Data["Webhook"] = w
        ctx.HTML(200, "repo/hooks_edit")
 }
+
+func WebHooksEditPost(ctx *middleware.Context, params martini.Params, form auth.NewWebhookForm) {
+       ctx.Data["IsRepoToolbarWebHooks"] = true
+       ctx.Data["Title"] = strings.TrimPrefix(ctx.Repo.RepoLink, "/") + " - Webhook"
+
+       if ctx.HasError() {
+               ctx.HTML(200, "repo/hooks_add")
+               return
+       }
+
+       hookId, _ := base.StrTo(params["id"]).Int64()
+       if hookId == 0 {
+               ctx.Handle(404, "setting.WebHooksEditPost", nil)
+               return
+       }
+
+       ct := models.CT_JSON
+       if form.ContentType == "2" {
+               ct = models.CT_FORM
+       }
+
+       w := &models.Webhook{
+               Id:          hookId,
+               RepoId:      ctx.Repo.Repository.Id,
+               Payload:     form.Url,
+               ContentType: ct,
+               Secret:      form.Secret,
+               HookEvent: &models.HookEvent{
+                       PushOnly: form.PushOnly,
+               },
+               IsActive: form.Active,
+       }
+       if err := w.SaveEvent(); err != nil {
+               ctx.Handle(500, "setting.WebHooksEditPost(SaveEvent)", err)
+               return
+       } else if err := models.UpdateWebhook(w); err != nil {
+               ctx.Handle(500, "setting.WebHooksEditPost(WebHooksEditPost)", err)
+               return
+       }
+
+       ctx.Flash.Success("Webhook has been updated.")
+       ctx.Redirect(fmt.Sprintf("%s/settings/hooks/%d", ctx.Repo.RepoLink, hookId))
+}
index eed35c3583c3a8bbea69ae3953a9d0517ce56987..e1b36a67e87b7565685a866f5c02e8e9fd29aee8 100644 (file)
@@ -15,7 +15,7 @@
                 <ul id="repo-hooks-list" class="list-unstyled">
                     {{range .Webhooks}}
                     <li>
-                        <span class="pull-left status text-success"><i class="fa fa-check"></i></span>
+                        {{if .IsActive}}<span class="pull-left status text-success"><i class="fa fa-check"></i></span>{{else}}<span class="pull-left status"><i class="fa fa-times"></i></span>{{end}}
                         <a class="link" href="{{$.RepoLink}}/settings/hooks/{{.Id}}">{{.Payload}}</a>
                         <a href="{{$.RepoLink}}/settings/hooks?remove={{.Id}}" class="remove-hook pull-right"><i class="fa fa-times"></i></a>
                         <a href="{{$.RepoLink}}/settings/hooks/{{.Id}}" class="edit-hook pull-right"><i class="fa fa-pencil"></i></a>
index cd4e6e7a9e0b7ef3ba6e8c79c5e39c895cfce2c3..df3ff3bdf41f3a554c15a0c1efaa111d3a261d6c 100644 (file)
                             <label for="payload-url">Payload URL</label>
                             <input id="payload-url" name="url" class="form-control" type="url" required="required"/>
                         </div>
+
                         <div class="form-group">
                             <label for="content-type">Content type</label>
                             <select id="content-type" name="content_type" class="form-control">
-                                <option value="json">application/json</option>
+                                <option value="1">application/json</option>
                             </select>
                         </div>
+
                         <div class="form-group">
                             <label for="payload-secret">Secret</label>
                             <input id="payload-secret" name="secret" class="form-control" type="text"/>
@@ -43,8 +45,7 @@
                         <hr/>
                         <div class="form-group">
                             <label>
-                                <input type="checkbox" name="active" checked/>&nbsp;&nbsp;
-                                Active
+                                <input type="checkbox" name="active" checked/>&nbsp;&nbsp;Active
                             </label>
                             <p class="help-block">We will deliver event details when this hook is triggered.</p>
                         </div>
index cac2ff6538338ba4582f9ba8bc3ee09455f10ad7..f98ccef6f316695c4271d6605ac49fb845547787 100644 (file)
@@ -6,7 +6,8 @@
     {{template "repo/setting_nav" .}}
     <div id="repo-setting-container" class="col-md-10">
         {{template "base/alert" .}}
-        <form id="repo-hooks-edit-form" action="/{{.Owner.Name}}/{{.Repository.Name}}/settings/hooks/edit" method="post">
+        <form id="repo-hooks-edit-form" action="{{.RepoLink}}/settings/hooks/{{.Webhook.Id}}" method="post">
+            {{.CsrfTokenHtml}}
             <div class="panel panel-default">
                 <div class="panel-heading">
                     Manage Webhook
                         <hr/>
                         <div class="form-group">
                             <label for="payload-url">Payload URL</label>
-                            <input id="payload-url" class="form-control" type="url" required="required" name="url"/>
+                            <input id="payload-url" name="url" class="form-control" type="url" required="required" value="{{.Webhook.Payload}}" />
                         </div>
+
                         <div class="form-group">
-                            <label for="payload-version">Payload Version</label>
-                            <select name="version" id="payload-version" class="form-control">
-                                <option value="json">application/json</option>
+                            <label for="payload-version">Content type</label>
+                            <select id="content-type" name="content_type" class="form-control">
+                                <option value="1">application/json</option>
                             </select>
                         </div>
+
                         <div class="form-group">
                             <label for="payload-secret">Secret</label>
-                            <input id="payload-secret" class="form-control" type="text" required="required" name="secret"/>
+                            <input id="payload-secret" name="secret" class="form-control" type="text" value="{{.Webhook.Secret}}" />
                         </div>
                         <hr/>
                         <div class="form-group">
                             <label>Which events would you like to trigger this webhook?</label>
-
                             <div class="radio">
                                 <label>
-                                    <input class="form-control" type="radio" value="push" checked name="trigger"/> Just the
-                                    <i>push</i> event.
+                                    <input class="form-control" name="push_only" type="radio" {{if .Webhook.HookEvent.PushOnly}}checked {{end}}name="trigger"/> Just the <i>push</i> event.
                                 </label>
                             </div>
                         </div>
                         <hr/>
                         <div class="form-group">
                             <label>
-                                <input type="checkbox" name="active" value="Active" checked/>&nbsp;&nbsp;
-                                Active
+                                <input type="checkbox" name="active" {{if .Webhook.IsActive}}checked{{end}}/>&nbsp;&nbsp;Active
                             </label>
-
                             <p class="help-block">We will deliver event details when this hook is triggered.</p>
                         </div>
                     </div>
@@ -55,7 +54,7 @@
 
                 <div class="panel-footer">
                     <button class="btn btn-primary">Update Webhook</button>&nbsp;&nbsp;
-                    <a href="/{{.Owner.Name}}/{{.Repository.Name}}/settings/hooks?remove="><button class="btn btn-danger">Delete Webhook</button></a>
+                    <a type="button" href="{{.RepoLink}}/settings/hooks?remove={{.Webhook.Id}}" class="btn btn-danger">Delete Webhook</a>
                 </div>
             </div>
         </form>