From 56dd430a10bf5281caf648344e4660fbdc5d4dee Mon Sep 17 00:00:00 2001
From: Unknwon <u@gogs.io>
Date: Fri, 4 Dec 2015 17:16:42 -0500
Subject: refactor API routes and some work for #976
---
routers/api/v1/repo/repo.go | 298 ++++++++++++++++++++++++++++++++++++++++++++
1 file changed, 298 insertions(+)
create mode 100644 routers/api/v1/repo/repo.go
(limited to 'routers/api/v1/repo/repo.go')
diff --git a/routers/api/v1/repo/repo.go b/routers/api/v1/repo/repo.go
new file mode 100644
index 00000000..864cb4dd
--- /dev/null
+++ b/routers/api/v1/repo/repo.go
@@ -0,0 +1,298 @@
+// 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.
+
+package repo
+
+import (
+ "path"
+
+ "github.com/Unknwon/com"
+
+ api "github.com/gogits/go-gogs-client"
+
+ "github.com/gogits/gogs/models"
+ "github.com/gogits/gogs/modules/auth"
+ "github.com/gogits/gogs/modules/log"
+ "github.com/gogits/gogs/modules/middleware"
+ "github.com/gogits/gogs/modules/setting"
+ to "github.com/gogits/gogs/routers/api/v1/utils"
+)
+
+// https://github.com/gogits/go-gogs-client/wiki/Repositories#search-repositories
+func Search(ctx *middleware.Context) {
+ opt := models.SearchOption{
+ Keyword: path.Base(ctx.Query("q")),
+ Uid: com.StrTo(ctx.Query("uid")).MustInt64(),
+ Limit: com.StrTo(ctx.Query("limit")).MustInt(),
+ }
+ if opt.Limit == 0 {
+ opt.Limit = 10
+ }
+
+ // Check visibility.
+ if ctx.IsSigned && opt.Uid > 0 {
+ if ctx.User.Id == opt.Uid {
+ opt.Private = true
+ } else {
+ u, err := models.GetUserByID(opt.Uid)
+ if err != nil {
+ ctx.JSON(500, map[string]interface{}{
+ "ok": false,
+ "error": err.Error(),
+ })
+ return
+ }
+ if u.IsOrganization() && u.IsOwnedBy(ctx.User.Id) {
+ opt.Private = true
+ }
+ // FIXME: how about collaborators?
+ }
+ }
+
+ repos, err := models.SearchRepositoryByName(opt)
+ if err != nil {
+ ctx.JSON(500, map[string]interface{}{
+ "ok": false,
+ "error": err.Error(),
+ })
+ return
+ }
+
+ results := make([]*api.Repository, len(repos))
+ for i := range repos {
+ if err = repos[i].GetOwner(); err != nil {
+ ctx.JSON(500, map[string]interface{}{
+ "ok": false,
+ "error": err.Error(),
+ })
+ return
+ }
+ results[i] = &api.Repository{
+ Id: repos[i].ID,
+ FullName: path.Join(repos[i].Owner.Name, repos[i].Name),
+ }
+ }
+
+ ctx.JSON(200, map[string]interface{}{
+ "ok": true,
+ "data": results,
+ })
+}
+
+// https://github.com/gogits/go-gogs-client/wiki/Repositories#list-your-repositories
+func ListMyRepos(ctx *middleware.Context) {
+ ownRepos, err := models.GetRepositories(ctx.User.Id, true)
+ if err != nil {
+ ctx.APIError(500, "GetRepositories", err)
+ return
+ }
+ numOwnRepos := len(ownRepos)
+
+ accessibleRepos, err := ctx.User.GetRepositoryAccesses()
+ if err != nil {
+ ctx.APIError(500, "GetRepositoryAccesses", err)
+ return
+ }
+
+ repos := make([]*api.Repository, numOwnRepos+len(accessibleRepos))
+ for i := range ownRepos {
+ repos[i] = to.ApiRepository(ctx.User, ownRepos[i], api.Permission{true, true, true})
+ }
+ i := numOwnRepos
+
+ for repo, access := range accessibleRepos {
+ repos[i] = to.ApiRepository(repo.Owner, repo, api.Permission{
+ Admin: access >= models.ACCESS_MODE_ADMIN,
+ Push: access >= models.ACCESS_MODE_WRITE,
+ Pull: true,
+ })
+ i++
+ }
+
+ ctx.JSON(200, &repos)
+}
+
+func createRepo(ctx *middleware.Context, owner *models.User, opt api.CreateRepoOption) {
+ repo, err := models.CreateRepository(owner, models.CreateRepoOptions{
+ Name: opt.Name,
+ Description: opt.Description,
+ Gitignores: opt.Gitignores,
+ License: opt.License,
+ Readme: opt.Readme,
+ IsPrivate: opt.Private,
+ AutoInit: opt.AutoInit,
+ })
+ if err != nil {
+ if models.IsErrRepoAlreadyExist(err) ||
+ models.IsErrNameReserved(err) ||
+ models.IsErrNamePatternNotAllowed(err) {
+ ctx.APIError(422, "", err)
+ } else {
+ if repo != nil {
+ if err = models.DeleteRepository(ctx.User.Id, repo.ID); err != nil {
+ log.Error(4, "DeleteRepository: %v", err)
+ }
+ }
+ ctx.APIError(500, "CreateRepository", err)
+ }
+ return
+ }
+
+ ctx.JSON(201, to.ApiRepository(owner, repo, api.Permission{true, true, true}))
+}
+
+// https://github.com/gogits/go-gogs-client/wiki/Repositories#create
+func Create(ctx *middleware.Context, opt api.CreateRepoOption) {
+ // Shouldn't reach this condition, but just in case.
+ if ctx.User.IsOrganization() {
+ ctx.APIError(422, "", "not allowed creating repository for organization")
+ return
+ }
+ createRepo(ctx, ctx.User, opt)
+}
+
+func CreateOrgRepo(ctx *middleware.Context, opt api.CreateRepoOption) {
+ org, err := models.GetOrgByName(ctx.Params(":org"))
+ if err != nil {
+ if models.IsErrUserNotExist(err) {
+ ctx.APIError(422, "", err)
+ } else {
+ ctx.APIError(500, "GetOrgByName", err)
+ }
+ return
+ }
+
+ if !org.IsOwnedBy(ctx.User.Id) {
+ ctx.APIError(403, "", "Given user is not owner of organization.")
+ return
+ }
+ createRepo(ctx, org, opt)
+}
+
+// https://github.com/gogits/go-gogs-client/wiki/Repositories#migrate
+func Migrate(ctx *middleware.Context, form auth.MigrateRepoForm) {
+ ctxUser := ctx.User
+ // Not equal means context user is an organization,
+ // or is another user/organization if current user is admin.
+ if form.Uid != ctxUser.Id {
+ org, err := models.GetUserByID(form.Uid)
+ if err != nil {
+ if models.IsErrUserNotExist(err) {
+ ctx.APIError(422, "", err)
+ } else {
+ ctx.APIError(500, "GetUserByID", err)
+ }
+ return
+ }
+ ctxUser = org
+ }
+
+ if ctx.HasError() {
+ ctx.APIError(422, "", ctx.GetErrMsg())
+ return
+ }
+
+ if ctxUser.IsOrganization() && !ctx.User.IsAdmin {
+ // Check ownership of organization.
+ if !ctxUser.IsOwnedBy(ctx.User.Id) {
+ ctx.APIError(403, "", "Given user is not owner of organization.")
+ return
+ }
+ }
+
+ remoteAddr, err := form.ParseRemoteAddr(ctx.User)
+ if err != nil {
+ if models.IsErrInvalidCloneAddr(err) {
+ addrErr := err.(models.ErrInvalidCloneAddr)
+ switch {
+ case addrErr.IsURLError:
+ ctx.APIError(422, "", err)
+ case addrErr.IsPermissionDenied:
+ ctx.APIError(422, "", "You are not allowed to import local repositories.")
+ case addrErr.IsInvalidPath:
+ ctx.APIError(422, "", "Invalid local path, it does not exist or not a directory.")
+ default:
+ ctx.APIError(500, "ParseRemoteAddr", "Unknown error type (ErrInvalidCloneAddr): "+err.Error())
+ }
+ } else {
+ ctx.APIError(500, "ParseRemoteAddr", err)
+ }
+ return
+ }
+
+ repo, err := models.MigrateRepository(ctxUser, models.MigrateRepoOptions{
+ Name: form.RepoName,
+ Description: form.Description,
+ IsPrivate: form.Private || setting.Repository.ForcePrivate,
+ IsMirror: form.Mirror,
+ RemoteAddr: remoteAddr,
+ })
+ if err != nil {
+ if repo != nil {
+ if errDelete := models.DeleteRepository(ctxUser.Id, repo.ID); errDelete != nil {
+ log.Error(4, "DeleteRepository: %v", errDelete)
+ }
+ }
+ ctx.APIError(500, "MigrateRepository", err)
+ return
+ }
+
+ log.Trace("Repository migrated: %s/%s", ctxUser.Name, form.RepoName)
+ ctx.JSON(201, to.ApiRepository(ctxUser, repo, api.Permission{true, true, true}))
+}
+
+func parseOwnerAndRepo(ctx *middleware.Context) (*models.User, *models.Repository) {
+ owner, err := models.GetUserByName(ctx.Params(":username"))
+ if err != nil {
+ if models.IsErrUserNotExist(err) {
+ ctx.APIError(422, "", err)
+ } else {
+ ctx.APIError(500, "GetUserByName", err)
+ }
+ return nil, nil
+ }
+
+ repo, err := models.GetRepositoryByName(owner.Id, ctx.Params(":reponame"))
+ if err != nil {
+ if models.IsErrRepoNotExist(err) {
+ ctx.Error(404)
+ } else {
+ ctx.APIError(500, "GetRepositoryByName", err)
+ }
+ return nil, nil
+ }
+
+ return owner, repo
+}
+
+// https://github.com/gogits/go-gogs-client/wiki/Repositories#get
+func Get(ctx *middleware.Context) {
+ owner, repo := parseOwnerAndRepo(ctx)
+ if ctx.Written() {
+ return
+ }
+
+ ctx.JSON(200, to.ApiRepository(owner, repo, api.Permission{true, true, true}))
+}
+
+// https://github.com/gogits/go-gogs-client/wiki/Repositories#delete
+func Delete(ctx *middleware.Context) {
+ owner, repo := parseOwnerAndRepo(ctx)
+ if ctx.Written() {
+ return
+ }
+
+ if owner.IsOrganization() && !owner.IsOwnedBy(ctx.User.Id) {
+ ctx.APIError(403, "", "Given user is not owner of organization.")
+ return
+ }
+
+ if err := models.DeleteRepository(owner.Id, repo.ID); err != nil {
+ ctx.APIError(500, "DeleteRepository", err)
+ return
+ }
+
+ log.Trace("Repository deleted: %s/%s", owner.Name, repo.Name)
+ ctx.Status(204)
+}
--
cgit v1.2.3