* make repo as "pending transfer" if on transfer start doer has no right to create repo in new destination * if new pending transfer ocured, create UI & Mail notifications
		
			
				
	
	
		
			122 lines
		
	
	
	
		
			3.5 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
			
		
		
	
	
			122 lines
		
	
	
	
		
			3.5 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
// Copyright 2020 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 repo
 | 
						|
 | 
						|
import (
 | 
						|
	"fmt"
 | 
						|
	"net/http"
 | 
						|
 | 
						|
	"code.gitea.io/gitea/models"
 | 
						|
	"code.gitea.io/gitea/modules/context"
 | 
						|
	"code.gitea.io/gitea/modules/convert"
 | 
						|
	"code.gitea.io/gitea/modules/log"
 | 
						|
	"code.gitea.io/gitea/modules/structs"
 | 
						|
	api "code.gitea.io/gitea/modules/structs"
 | 
						|
	"code.gitea.io/gitea/modules/web"
 | 
						|
	repo_service "code.gitea.io/gitea/services/repository"
 | 
						|
)
 | 
						|
 | 
						|
// Transfer transfers the ownership of a repository
 | 
						|
func Transfer(ctx *context.APIContext) {
 | 
						|
	// swagger:operation POST /repos/{owner}/{repo}/transfer repository repoTransfer
 | 
						|
	// ---
 | 
						|
	// summary: Transfer a repo ownership
 | 
						|
	// produces:
 | 
						|
	// - application/json
 | 
						|
	// parameters:
 | 
						|
	// - name: owner
 | 
						|
	//   in: path
 | 
						|
	//   description: owner of the repo to transfer
 | 
						|
	//   type: string
 | 
						|
	//   required: true
 | 
						|
	// - name: repo
 | 
						|
	//   in: path
 | 
						|
	//   description: name of the repo to transfer
 | 
						|
	//   type: string
 | 
						|
	//   required: true
 | 
						|
	// - name: body
 | 
						|
	//   in: body
 | 
						|
	//   description: "Transfer Options"
 | 
						|
	//   required: true
 | 
						|
	//   schema:
 | 
						|
	//     "$ref": "#/definitions/TransferRepoOption"
 | 
						|
	// responses:
 | 
						|
	//   "202":
 | 
						|
	//     "$ref": "#/responses/Repository"
 | 
						|
	//   "403":
 | 
						|
	//     "$ref": "#/responses/forbidden"
 | 
						|
	//   "404":
 | 
						|
	//     "$ref": "#/responses/notFound"
 | 
						|
	//   "422":
 | 
						|
	//     "$ref": "#/responses/validationError"
 | 
						|
 | 
						|
	opts := web.GetForm(ctx).(*api.TransferRepoOption)
 | 
						|
 | 
						|
	newOwner, err := models.GetUserByName(opts.NewOwner)
 | 
						|
	if err != nil {
 | 
						|
		if models.IsErrUserNotExist(err) {
 | 
						|
			ctx.Error(http.StatusNotFound, "", "The new owner does not exist or cannot be found")
 | 
						|
			return
 | 
						|
		}
 | 
						|
		ctx.InternalServerError(err)
 | 
						|
		return
 | 
						|
	}
 | 
						|
 | 
						|
	if newOwner.Type == models.UserTypeOrganization {
 | 
						|
		if !ctx.User.IsAdmin && newOwner.Visibility == structs.VisibleTypePrivate && !newOwner.HasMemberWithUserID(ctx.User.ID) {
 | 
						|
			// The user shouldn't know about this organization
 | 
						|
			ctx.Error(http.StatusNotFound, "", "The new owner does not exist or cannot be found")
 | 
						|
			return
 | 
						|
		}
 | 
						|
	}
 | 
						|
 | 
						|
	var teams []*models.Team
 | 
						|
	if opts.TeamIDs != nil {
 | 
						|
		if !newOwner.IsOrganization() {
 | 
						|
			ctx.Error(http.StatusUnprocessableEntity, "repoTransfer", "Teams can only be added to organization-owned repositories")
 | 
						|
			return
 | 
						|
		}
 | 
						|
 | 
						|
		org := convert.ToOrganization(newOwner)
 | 
						|
		for _, tID := range *opts.TeamIDs {
 | 
						|
			team, err := models.GetTeamByID(tID)
 | 
						|
			if err != nil {
 | 
						|
				ctx.Error(http.StatusUnprocessableEntity, "team", fmt.Errorf("team %d not found", tID))
 | 
						|
				return
 | 
						|
			}
 | 
						|
 | 
						|
			if team.OrgID != org.ID {
 | 
						|
				ctx.Error(http.StatusForbidden, "team", fmt.Errorf("team %d belongs not to org %d", tID, org.ID))
 | 
						|
				return
 | 
						|
			}
 | 
						|
 | 
						|
			teams = append(teams, team)
 | 
						|
		}
 | 
						|
	}
 | 
						|
 | 
						|
	if err := repo_service.StartRepositoryTransfer(ctx.User, newOwner, ctx.Repo.Repository, teams); err != nil {
 | 
						|
		if models.IsErrRepoTransferInProgress(err) {
 | 
						|
			ctx.Error(http.StatusConflict, "CreatePendingRepositoryTransfer", err)
 | 
						|
			return
 | 
						|
		}
 | 
						|
 | 
						|
		if models.IsErrRepoAlreadyExist(err) {
 | 
						|
			ctx.Error(http.StatusUnprocessableEntity, "CreatePendingRepositoryTransfer", err)
 | 
						|
			return
 | 
						|
		}
 | 
						|
 | 
						|
		ctx.InternalServerError(err)
 | 
						|
		return
 | 
						|
	}
 | 
						|
 | 
						|
	if ctx.Repo.Repository.Status == models.RepositoryPendingTransfer {
 | 
						|
		log.Trace("Repository transfer initiated: %s -> %s", ctx.Repo.Repository.FullName(), newOwner.Name)
 | 
						|
		ctx.JSON(http.StatusCreated, convert.ToRepo(ctx.Repo.Repository, models.AccessModeAdmin))
 | 
						|
		return
 | 
						|
	}
 | 
						|
 | 
						|
	log.Trace("Repository transferred: %s -> %s", ctx.Repo.Repository.FullName(), newOwner.Name)
 | 
						|
	ctx.JSON(http.StatusAccepted, convert.ToRepo(ctx.Repo.Repository, models.AccessModeAdmin))
 | 
						|
}
 |