gitea/routers/repo/repo.go

275 lines
7.0 KiB
Go
Raw Normal View History

2014-02-20 02:45:43 +00:00
// 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 (
"fmt"
2014-07-26 04:24:27 +00:00
"os"
2014-03-22 17:50:50 +00:00
"path"
"strings"
2014-03-22 17:50:50 +00:00
2014-07-26 04:24:27 +00:00
"github.com/Unknwon/com"
2014-05-05 23:58:13 +00:00
2014-02-20 02:45:43 +00:00
"github.com/gogits/gogs/models"
"github.com/gogits/gogs/modules/auth"
2014-03-22 17:50:50 +00:00
"github.com/gogits/gogs/modules/base"
2014-07-26 04:24:27 +00:00
"github.com/gogits/gogs/modules/git"
2014-03-19 08:48:45 +00:00
"github.com/gogits/gogs/modules/log"
2014-03-15 13:17:16 +00:00
"github.com/gogits/gogs/modules/middleware"
2014-02-20 02:45:43 +00:00
)
2014-06-23 03:11:12 +00:00
const (
CREATE base.TplName = "repo/create"
MIGRATE base.TplName = "repo/migrate"
)
2014-04-10 22:09:57 +00:00
func Create(ctx *middleware.Context) {
2014-07-26 04:24:27 +00:00
ctx.Data["Title"] = ctx.Tr("new_repo")
// Give default value for template to render.
ctx.Data["gitignore"] = "0"
ctx.Data["license"] = "0"
ctx.Data["Gitignores"] = models.Gitignores
2014-03-19 17:14:56 +00:00
ctx.Data["Licenses"] = models.Licenses
2014-06-25 07:55:59 +00:00
2014-06-28 19:43:25 +00:00
ctxUser := ctx.User
if orgId := com.StrTo(ctx.Query("org")).MustInt64(); orgId > 0 {
org, err := models.GetUserById(orgId)
if err != nil && err != models.ErrUserNotExist {
ctx.Handle(500, "GetUserById", err)
return
}
ctxUser = org
}
2014-06-28 19:43:25 +00:00
ctx.Data["ContextUser"] = ctxUser
if err := ctx.User.GetOrganizations(); err != nil {
ctx.Handle(500, "GetOrganizations", err)
return
}
ctx.Data["Orgs"] = ctx.User.Orgs
2014-06-25 07:55:59 +00:00
2014-06-23 03:11:12 +00:00
ctx.HTML(200, CREATE)
2014-04-10 22:09:57 +00:00
}
2014-04-10 22:09:57 +00:00
func CreatePost(ctx *middleware.Context, form auth.CreateRepoForm) {
2014-07-26 04:24:27 +00:00
ctx.Data["Title"] = ctx.Tr("new_repo")
ctx.Data["Gitignores"] = models.Gitignores
2014-04-10 22:09:57 +00:00
ctx.Data["Licenses"] = models.Licenses
2014-02-20 02:45:43 +00:00
2014-07-26 04:24:27 +00:00
ctxUser := ctx.User
// Not equal means current user is an organization.
if form.Uid != ctx.User.Id {
org, err := models.GetUserById(form.Uid)
if err != nil && err != models.ErrUserNotExist {
ctx.Handle(500, "GetUserById", err)
return
}
ctxUser = org
}
2014-07-26 04:24:27 +00:00
ctx.Data["ContextUser"] = ctxUser
if err := ctx.User.GetOrganizations(); err != nil {
ctx.Handle(500, "GetOrganizations", err)
return
}
ctx.Data["Orgs"] = ctx.User.Orgs
2014-06-25 07:55:59 +00:00
2014-03-22 20:00:46 +00:00
if ctx.HasError() {
2014-06-23 03:11:12 +00:00
ctx.HTML(200, CREATE)
2014-03-22 20:00:46 +00:00
return
}
if ctxUser.IsOrganization() {
2014-06-28 19:43:25 +00:00
// Check ownership of organization.
if !ctxUser.IsOrgOwner(ctx.User.Id) {
2014-06-28 19:43:25 +00:00
ctx.Error(403)
return
}
}
repo, err := models.CreateRepository(ctxUser, form.RepoName, form.Description,
2014-07-26 04:24:27 +00:00
form.Gitignore, form.License, form.Private, false, form.InitReadme)
2014-03-17 15:56:50 +00:00
if err == nil {
log.Trace("Repository created: %s/%s", ctxUser.Name, form.RepoName)
ctx.Redirect("/" + ctxUser.Name + "/" + form.RepoName)
2014-03-09 02:25:38 +00:00
return
2014-03-17 06:36:28 +00:00
} else if err == models.ErrRepoAlreadyExist {
2014-08-01 04:06:19 +00:00
ctx.Data["Err_RepoName"] = true
2014-07-26 04:24:27 +00:00
ctx.RenderWithErr(ctx.Tr("form.repo_name_been_taken"), CREATE, &form)
2014-03-10 00:06:29 +00:00
return
2014-03-20 15:41:24 +00:00
} else if err == models.ErrRepoNameIllegal {
2014-08-01 04:06:19 +00:00
ctx.Data["Err_RepoName"] = true
2014-07-26 04:24:27 +00:00
ctx.RenderWithErr(ctx.Tr("form.illegal_repo_name"), CREATE, &form)
2014-03-20 15:41:24 +00:00
return
2014-03-10 00:06:29 +00:00
}
2014-04-13 00:35:35 +00:00
if repo != nil {
if errDelete := models.DeleteRepository(ctxUser.Id, repo.Id, ctxUser.Name); errDelete != nil {
2014-07-26 04:24:27 +00:00
log.Error(4, "DeleteRepository: %v", errDelete)
2014-04-13 00:35:35 +00:00
}
}
2014-08-01 04:06:19 +00:00
ctx.Handle(500, "CreatePost", err)
2014-04-10 22:09:57 +00:00
}
2014-04-09 13:28:00 +00:00
func Migrate(ctx *middleware.Context) {
2014-08-01 04:06:19 +00:00
ctx.Data["Title"] = ctx.Tr("new_migrate")
ctxUser := ctx.User
if orgId := com.StrTo(ctx.Query("org")).MustInt64(); orgId > 0 {
org, err := models.GetUserById(orgId)
if err != nil && err != models.ErrUserNotExist {
ctx.Handle(500, "GetUserById", err)
return
}
ctxUser = org
}
ctx.Data["ContextUser"] = ctxUser
2014-07-26 04:24:27 +00:00
if err := ctx.User.GetOrganizations(); err != nil {
ctx.Handle(500, "GetOrganizations", err)
return
}
ctx.Data["Orgs"] = ctx.User.Orgs
2014-07-26 04:24:27 +00:00
ctx.HTML(200, MIGRATE)
}
2014-07-26 04:24:27 +00:00
func MigratePost(ctx *middleware.Context, form auth.MigrateRepoForm) {
2014-08-01 04:06:19 +00:00
ctx.Data["Title"] = ctx.Tr("new_migrate")
ctxUser := ctx.User
if orgId := com.StrTo(ctx.Query("org")).MustInt64(); orgId > 0 {
org, err := models.GetUserById(orgId)
if err != nil && err != models.ErrUserNotExist {
ctx.Handle(500, "GetUserById", err)
return
}
ctxUser = org
}
ctx.Data["ContextUser"] = ctxUser
2014-07-26 04:24:27 +00:00
if err := ctx.User.GetOrganizations(); err != nil {
ctx.Handle(500, "GetOrganizations", err)
return
}
ctx.Data["Orgs"] = ctx.User.Orgs
2014-07-26 04:24:27 +00:00
if ctx.HasError() {
ctx.HTML(200, MIGRATE)
return
}
2014-07-26 04:24:27 +00:00
2014-08-01 04:06:19 +00:00
if ctxUser.IsOrganization() {
// Check ownership of organization.
if !ctxUser.IsOrgOwner(ctx.User.Id) {
ctx.Error(403)
return
}
}
2014-07-26 04:24:27 +00:00
authStr := strings.Replace(fmt.Sprintf("://%s:%s",
form.AuthUserName, form.AuthPasswd), "@", "%40", -1)
2014-08-01 04:06:19 +00:00
url := strings.Replace(form.HttpsUrl, "://", authStr+"@", 1)
repo, err := models.MigrateRepository(ctxUser, form.RepoName, form.Description, form.Private,
form.Mirror, url)
if err == nil {
2014-08-01 04:06:19 +00:00
log.Trace("Repository migrated: %s/%s", ctxUser.Name, form.RepoName)
ctx.Redirect("/" + ctxUser.Name + "/" + form.RepoName)
return
} else if err == models.ErrRepoAlreadyExist {
2014-08-01 04:06:19 +00:00
ctx.Data["Err_RepoName"] = true
ctx.RenderWithErr(ctx.Tr("form.repo_name_been_taken"), MIGRATE, &form)
return
} else if err == models.ErrRepoNameIllegal {
2014-08-01 04:06:19 +00:00
ctx.Data["Err_RepoName"] = true
ctx.RenderWithErr(ctx.Tr("form.illegal_repo_name"), MIGRATE, &form)
return
}
2014-07-26 04:24:27 +00:00
if repo != nil {
2014-08-01 04:06:19 +00:00
if errDelete := models.DeleteRepository(ctxUser.Id, repo.Id, ctxUser.Name); errDelete != nil {
log.Error(4, "DeleteRepository: %v", errDelete)
}
}
2014-07-26 04:24:27 +00:00
if strings.Contains(err.Error(), "Authentication failed") {
2014-08-01 04:06:19 +00:00
ctx.Data["Err_Auth"] = true
ctx.RenderWithErr(ctx.Tr("form.auth_failed", err), MIGRATE, &form)
return
}
2014-08-01 04:06:19 +00:00
ctx.Handle(500, "MigratePost", err)
}
2014-07-26 04:24:27 +00:00
2014-08-11 03:11:18 +00:00
func Action(ctx *middleware.Context) {
var err error
switch ctx.Params(":action") {
case "watch":
err = models.WatchRepo(ctx.User.Id, ctx.Repo.Repository.Id, true)
case "unwatch":
err = models.WatchRepo(ctx.User.Id, ctx.Repo.Repository.Id, false)
case "star":
err = models.StarRepo(ctx.User.Id, ctx.Repo.Repository.Id, true)
case "unstar":
err = models.StarRepo(ctx.User.Id, ctx.Repo.Repository.Id, false)
case "desc":
if !ctx.Repo.IsOwner {
ctx.Error(404)
return
}
ctx.Repo.Repository.Description = ctx.Query("desc")
ctx.Repo.Repository.Website = ctx.Query("site")
err = models.UpdateRepository(ctx.Repo.Repository)
}
if err != nil {
log.Error(4, "repo.Action(%s): %v", ctx.Params(":action"), err)
ctx.JSON(200, map[string]interface{}{
"ok": false,
"err": err.Error(),
})
return
}
ctx.Redirect(ctx.Repo.RepoLink)
return
ctx.JSON(200, map[string]interface{}{
"ok": true,
})
}
2014-07-26 04:24:27 +00:00
func Download(ctx *middleware.Context) {
ext := "." + ctx.Params(":ext")
var archivePath string
switch ext {
case ".zip":
archivePath = path.Join(ctx.Repo.GitRepo.Path, "archives/zip")
case ".tar.gz":
archivePath = path.Join(ctx.Repo.GitRepo.Path, "archives/targz")
default:
ctx.Error(404)
2014-06-25 09:35:23 +00:00
return
}
2014-07-26 04:24:27 +00:00
if !com.IsDir(archivePath) {
if err := os.MkdirAll(archivePath, os.ModePerm); err != nil {
ctx.Handle(500, "Download -> os.MkdirAll(archivePath)", err)
2014-06-25 09:35:23 +00:00
return
}
}
2014-07-26 04:24:27 +00:00
archivePath = path.Join(archivePath, ctx.Repo.CommitId+ext)
if !com.IsFile(archivePath) {
if err := ctx.Repo.Commit.CreateArchive(archivePath, git.ZIP); err != nil {
ctx.Handle(500, "Download -> CreateArchive "+archivePath, err)
2014-03-22 17:50:50 +00:00
return
}
}
2014-07-26 04:24:27 +00:00
ctx.ServeFile(archivePath, ctx.Repo.Repository.Name+"-"+base.ShortSha(ctx.Repo.CommitId)+ext)
2014-03-22 17:50:50 +00:00
}