From fa298a2c30c358dbfa47fc123c6aca83fe9eb999 Mon Sep 17 00:00:00 2001
From: Unknwon <u@gogs.io>
Date: Sat, 25 Jul 2015 21:32:04 +0800
Subject: #835: Realtime webhooks

---
 routers/install.go      | 1 +
 routers/repo/http.go    | 5 ++++-
 routers/repo/setting.go | 4 ++++
 3 files changed, 9 insertions(+), 1 deletion(-)

(limited to 'routers')

diff --git a/routers/install.go b/routers/install.go
index 055c1ccd..58c38c31 100644
--- a/routers/install.go
+++ b/routers/install.go
@@ -68,6 +68,7 @@ func GlobalInit() {
 
 		models.HasEngine = true
 		cron.NewCronContext()
+		models.InitDeliverHooks()
 		log.NewGitLogger(path.Join(setting.LogRootPath, "http.log"))
 	}
 	if models.EnableSQLite3 {
diff --git a/routers/repo/http.go b/routers/repo/http.go
index 8395d1c0..4e5aba04 100644
--- a/routers/repo/http.go
+++ b/routers/repo/http.go
@@ -190,7 +190,10 @@ func Http(ctx *middleware.Context) {
 						refName := fields[2]
 
 						// FIXME: handle error.
-						models.Update(refName, oldCommitId, newCommitId, authUsername, username, reponame, authUser.Id)
+						if err = models.Update(refName, oldCommitId, newCommitId, authUsername, username, reponame, authUser.Id); err == nil {
+							models.HookQueue.AddRepoID(repo.Id)
+						}
+
 					}
 					lastLine = lastLine + size
 				} else {
diff --git a/routers/repo/setting.go b/routers/repo/setting.go
index 756f2979..c3714808 100644
--- a/routers/repo/setting.go
+++ b/routers/repo/setting.go
@@ -634,3 +634,7 @@ func GitHooksEditPost(ctx *middleware.Context) {
 	}
 	ctx.Redirect(ctx.Repo.RepoLink + "/settings/hooks/git")
 }
+
+func TriggerHook(ctx *middleware.Context) {
+	models.HookQueue.AddRepoID(ctx.Repo.Repository.Id)
+}
-- 
cgit v1.2.3