diff options
author | Ethan Koenig <etk39@cornell.edu> | 2016-12-23 20:53:11 -0500 |
---|---|---|
committer | Lunny Xiao <xiaolunwen@gmail.com> | 2016-12-24 09:53:11 +0800 |
commit | 8a4161c72335900407b8f111027ad9ed53c0b631 (patch) | |
tree | ddbb149b5f78d5a3ebf91db1a079ac4be3cc064b /routers/api | |
parent | 25b5ffb6af390eac8d4a76c134379fd1ae88a423 (diff) | |
download | gitea-8a4161c72335900407b8f111027ad9ed53c0b631.tar.gz gitea-8a4161c72335900407b8f111027ad9ed53c0b631.zip |
API Endpoint for watching (#191)
Diffstat (limited to 'routers/api')
-rw-r--r-- | routers/api/v1/api.go | 9 | ||||
-rw-r--r-- | routers/api/v1/user/watch.go | 123 |
2 files changed, 132 insertions, 0 deletions
diff --git a/routers/api/v1/api.go b/routers/api/v1/api.go index 9943b97f78..11adfa5c5f 100644 --- a/routers/api/v1/api.go +++ b/routers/api/v1/api.go @@ -209,6 +209,8 @@ func RegisterRoutes(m *macaron.Macaron) { }) m.Get("/starred", user.GetStarredRepos) + + m.Get("/subscriptions", user.GetWatchedRepos) }) }, reqToken()) @@ -239,6 +241,8 @@ func RegisterRoutes(m *macaron.Macaron) { m.Delete("", user.Unstar) }, context.ExtractOwnerAndRepo()) }) + + m.Get("/subscriptions", user.GetMyWatchedRepos) }, reqToken()) // Repositories @@ -316,6 +320,11 @@ func RegisterRoutes(m *macaron.Macaron) { Patch(reqRepoWriter(), bind(api.EditMilestoneOption{}), repo.EditMilestone). Delete(reqRepoWriter(), repo.DeleteMilestone) }) + m.Group("/subscription", func() { + m.Get("", user.IsWatching) + m.Put("", user.Watch) + m.Delete("", user.Unwatch) + }, context.ExtractOwnerAndRepo()) m.Get("/editorconfig/:filename", context.RepoRef(), repo.GetEditorconfig) m.Group("/pulls", func() { m.Combo("").Get(bind(api.ListPullRequestsOptions{}), repo.ListPullRequests).Post(reqRepoWriter(), bind(api.CreatePullRequestOption{}), repo.CreatePullRequest) diff --git a/routers/api/v1/user/watch.go b/routers/api/v1/user/watch.go new file mode 100644 index 0000000000..6a9ad670d0 --- /dev/null +++ b/routers/api/v1/user/watch.go @@ -0,0 +1,123 @@ +// Copyright 2016 The Gitea Authors. All rights reserved. +// Use of this source code is governed by a MIT-style +// license that can be found in the LICENSE file. + +package user + +import ( + "time" + + api "code.gitea.io/sdk/gitea" + + "code.gitea.io/gitea/models" + "code.gitea.io/gitea/modules/context" + "code.gitea.io/gitea/modules/setting" +) + +// WatchInfo contains information about a watched repository +type WatchInfo struct { + Subscribed bool `json:"subscribed"` + Ignored bool `json:"ignored"` + Reason interface{} `json:"reason"` + CreatedAt time.Time `json:"created_at"` + URL string `json:"url"` + RepositoryURL string `json:"repository_url"` +} + +// getWatchedRepos returns the repos that the user with the specified userID is +// watching +func getWatchedRepos(userID int64, private bool) ([]*api.Repository, error) { + watchedRepos, err := models.GetWatchedRepos(userID, private) + if err != nil { + return nil, err + } + user, err := models.GetUserByID(userID) + if err != nil { + return nil, err + } + + repos := make([]*api.Repository, len(watchedRepos)) + for i, watched := range watchedRepos { + access, err := models.AccessLevel(user, watched) + if err != nil { + return nil, err + } + repos[i] = watched.APIFormat(access) + } + return repos, nil +} + +// GetWatchedRepos returns the repos that the user specified in ctx is watching +func GetWatchedRepos(ctx *context.APIContext) { + user := GetUserByParams(ctx) + private := user.ID == ctx.User.ID + repos, err := getWatchedRepos(user.ID, private) + if err != nil { + ctx.Error(500, "getWatchedRepos", err) + } + ctx.JSON(200, &repos) +} + +// GetMyWatchedRepos returns the repos that the authenticated user is watching +func GetMyWatchedRepos(ctx *context.APIContext) { + repos, err := getWatchedRepos(ctx.User.ID, true) + if err != nil { + ctx.Error(500, "getWatchedRepos", err) + } + ctx.JSON(200, &repos) +} + +// IsWatching returns whether the authenticated user is watching the repo +// specified in ctx +func IsWatching(ctx *context.APIContext) { + if models.IsWatching(ctx.User.ID, ctx.Repo.Repository.ID) { + ctx.JSON(200, WatchInfo{ + Subscribed: true, + Ignored: false, + Reason: nil, + CreatedAt: ctx.Repo.Repository.Created, + URL: subscriptionURL(ctx.Repo.Repository), + RepositoryURL: repositoryURL(ctx.Repo.Repository), + }) + } else { + ctx.Status(404) + } +} + +// Watch the repo specified in ctx, as the authenticated user +func Watch(ctx *context.APIContext) { + err := models.WatchRepo(ctx.User.ID, ctx.Repo.Repository.ID, true) + if err != nil { + ctx.Error(500, "WatchRepo", err) + return + } + ctx.JSON(200, WatchInfo{ + Subscribed: true, + Ignored: false, + Reason: nil, + CreatedAt: ctx.Repo.Repository.Created, + URL: subscriptionURL(ctx.Repo.Repository), + RepositoryURL: repositoryURL(ctx.Repo.Repository), + }) + +} + +// Unwatch the repo specified in ctx, as the authenticated user +func Unwatch(ctx *context.APIContext) { + err := models.WatchRepo(ctx.User.ID, ctx.Repo.Repository.ID, false) + if err != nil { + ctx.Error(500, "UnwatchRepo", err) + return + } + ctx.Status(204) +} + +// subscriptionURL returns the URL of the subscription API endpoint of a repo +func subscriptionURL(repo *models.Repository) string { + return repositoryURL(repo) + "/subscription" +} + +// repositoryURL returns the URL of the API endpoint of a repo +func repositoryURL(repo *models.Repository) string { + return setting.AppURL + "api/v1/" + repo.FullName() +} |