Revise, complete, and fully test the FORK rpc

James Moger

2014-05-08 813a1fab72a462bdd9387ac3f137055853a69710

 src/main/java/com/gitblit/servlet/RpcServlet.java

@@ -27,7 +27,6 @@
import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;



import com.gitblit.models.*;

import org.eclipse.jgit.lib.Repository;



import com.gitblit.Constants;

@@ -36,6 +35,12 @@
import com.gitblit.IStoredSettings;

import com.gitblit.Keys;

import com.gitblit.manager.IGitblit;

import com.gitblit.models.RefModel;

import com.gitblit.models.RegistrantAccessPermission;

import com.gitblit.models.RepositoryModel;

import com.gitblit.models.ServerSettings;

import com.gitblit.models.TeamModel;

import com.gitblit.models.UserModel;

import com.gitblit.utils.DeepCopier;

import com.gitblit.utils.HttpUtils;

import com.gitblit.utils.JGitUtils;

@@ -53,7 +58,7 @@


    private static final long serialVersionUID = 1L;



    public static final int PROTOCOL_VERSION = 7;

    public static final int PROTOCOL_VERSION = 8;



    private IStoredSettings settings;



@@ -192,21 +197,30 @@
            }

        } else if (RpcRequest.FORK_REPOSITORY.equals(reqType)) {

            // fork repository

            UserRepositoryCompositeModel userRepositoryCompositeModel = deserialize(request, response,

                    UserRepositoryCompositeModel.class);

            RepositoryModel repoModel = userRepositoryCompositeModel.getRepositoryModel();

            UserModel userModel = userRepositoryCompositeModel.getUserModel();

            try {

                if (repoModel != null && userModel != null) {

                    gitblit.fork(repoModel, userModel);

                } else {

                    System.out.println("Non existing user model or repo model");

           RepositoryModel origin = gitblit.getRepositoryModel(objectName);

           if (origin == null) {

              // failed to find repository, error is logged by the repository manager

                    response.setStatus(failureCode);

           } else {

              if (user == null || !user.canFork(origin)) {

                 logger.error("User {} is not permitted to fork '{}'!",

                       user == null ? "anonymous" : user.username, objectName);

                 response.setStatus(failureCode);

              } else {

                 try {

                    // fork the origin

                    RepositoryModel fork = gitblit.fork(origin, user);

                    if (fork == null) {

                       logger.error("Failed to fork repository '{}'!", objectName);

                       response.setStatus(failureCode);

                    } else {

                       logger.info("User {} has forked '{}'!", user.username, objectName);

                }



            } catch (GitBlitException e) {

                response.setStatus(failureCode);

            }

              }

           }

        } else if (RpcRequest.EDIT_REPOSITORY.equals(reqType)) {

            // edit repository

            RepositoryModel model = deserialize(request, response, RepositoryModel.class);