| | |
| | | import java.util.HashMap;
|
| | | import java.util.List;
|
| | | import java.util.Map;
|
| | | import java.util.Properties;
|
| | |
|
| | | import javax.servlet.ServletException;
|
| | | import javax.servlet.http.HttpServletRequest;
|
| | |
| | |
|
| | | import com.gitblit.Constants.RpcRequest;
|
| | | import com.gitblit.models.RepositoryModel;
|
| | | import com.gitblit.models.SettingModel;
|
| | | import com.gitblit.models.UserModel;
|
| | | import com.gitblit.utils.HttpUtils;
|
| | | import com.gitblit.utils.RpcUtils;
|
| | |
| | | } else if (RpcRequest.CREATE_REPOSITORY.equals(reqType)) {
|
| | | // create repository
|
| | | RepositoryModel model = deserialize(request, response, RepositoryModel.class);
|
| | | GitBlit.self().updateRepositoryModel(model.name, model, true);
|
| | | try {
|
| | | GitBlit.self().updateRepositoryModel(model.name, model, true);
|
| | | } catch (GitBlitException e) {
|
| | | response.setStatus(failureCode);
|
| | | }
|
| | | } else if (RpcRequest.EDIT_REPOSITORY.equals(reqType)) {
|
| | | // edit repository
|
| | | RepositoryModel model = deserialize(request, response, RepositoryModel.class);
|
| | |
| | | if (repoName == null) {
|
| | | repoName = model.name;
|
| | | }
|
| | | GitBlit.self().updateRepositoryModel(repoName, model, false);
|
| | | try {
|
| | | GitBlit.self().updateRepositoryModel(repoName, model, false);
|
| | | } catch (GitBlitException e) {
|
| | | response.setStatus(failureCode);
|
| | | }
|
| | | } else if (RpcRequest.DELETE_REPOSITORY.equals(reqType)) {
|
| | | // delete repository
|
| | | RepositoryModel model = deserialize(request, response, RepositoryModel.class);
|
| | |
| | | } else if (RpcRequest.CREATE_USER.equals(reqType)) {
|
| | | // create user
|
| | | UserModel model = deserialize(request, response, UserModel.class);
|
| | | GitBlit.self().updateUserModel(model.username, model, true);
|
| | | try {
|
| | | GitBlit.self().updateUserModel(model.username, model, true);
|
| | | } catch (GitBlitException e) {
|
| | | response.setStatus(failureCode);
|
| | | }
|
| | | } else if (RpcRequest.EDIT_USER.equals(reqType)) {
|
| | | // edit user
|
| | | UserModel model = deserialize(request, response, UserModel.class);
|
| | |
| | | if (username == null) {
|
| | | username = model.username;
|
| | | }
|
| | | GitBlit.self().updateUserModel(username, model, false);
|
| | | try {
|
| | | GitBlit.self().updateUserModel(username, model, false);
|
| | | } catch (GitBlitException e) {
|
| | | response.setStatus(failureCode);
|
| | | }
|
| | | } else if (RpcRequest.DELETE_USER.equals(reqType)) {
|
| | | // delete user
|
| | | UserModel model = deserialize(request, response, UserModel.class);
|
| | | GitBlit.self().deleteUser(model.username);
|
| | | if (!GitBlit.self().deleteUser(model.username)) {
|
| | | response.setStatus(failureCode);
|
| | | }
|
| | | } else if (RpcRequest.LIST_REPOSITORY_MEMBERS.equals(reqType)) {
|
| | | // get repository members
|
| | | RepositoryModel model = GitBlit.self().getRepositoryModel(objectName);
|
| | |
| | | Collection<String> names = deserialize(request, response, RpcUtils.NAMES_TYPE);
|
| | | List<String> users = new ArrayList<String>(names);
|
| | | if (!GitBlit.self().setRepositoryUsers(model, users)) {
|
| | | response.setStatus(HttpServletResponse.SC_BAD_REQUEST);
|
| | | response.setStatus(failureCode);
|
| | | }
|
| | | } else if (RpcRequest.LIST_FEDERATION_REGISTRATIONS.equals(reqType)) {
|
| | | // return the list of federation registrations
|
| | |
| | | if (GitBlit.canFederate()) {
|
| | | result = GitBlit.self().getFederationResultRegistrations();
|
| | | } else {
|
| | | response.sendError(HttpServletResponse.SC_FORBIDDEN);
|
| | | response.sendError(notAllowedCode);
|
| | | }
|
| | | } else if (RpcRequest.LIST_FEDERATION_PROPOSALS.equals(reqType)) {
|
| | | // return the list of federation proposals
|
| | | if (GitBlit.canFederate()) {
|
| | | result = GitBlit.self().getPendingFederationProposals();
|
| | | } else {
|
| | | response.sendError(HttpServletResponse.SC_FORBIDDEN);
|
| | | response.sendError(notAllowedCode);
|
| | | }
|
| | | } else if (RpcRequest.LIST_FEDERATION_SETS.equals(reqType)) {
|
| | | // return the list of federation sets
|
| | |
| | | String gitblitUrl = HttpUtils.getGitblitURL(request);
|
| | | result = GitBlit.self().getFederationSets(gitblitUrl);
|
| | | } else {
|
| | | response.sendError(HttpServletResponse.SC_FORBIDDEN);
|
| | | response.sendError(notAllowedCode);
|
| | | }
|
| | | } else if (RpcRequest.LIST_SETTINGS.equals(reqType)) {
|
| | | // return the server's settings
|
| | | Properties settings = new Properties(); |
| | | List<String> keys = GitBlit.getAllKeys(null);
|
| | | for (String key:keys) {
|
| | | String value = GitBlit.getString(key, null);
|
| | | if (value != null) {
|
| | | settings.put(key, value);
|
| | | }
|
| | | if (GitBlit.getBoolean(Keys.web.enableRpcAdministration, false)) {
|
| | | result = GitBlit.self().getSettingsModel();
|
| | | } else {
|
| | | response.sendError(notAllowedCode);
|
| | | }
|
| | | result = settings;
|
| | | } else if (RpcRequest.EDIT_SETTINGS.equals(reqType)) {
|
| | | // update settings on the server
|
| | | if (GitBlit.getBoolean(Keys.web.enableRpcAdministration, false)) {
|
| | | Collection<SettingModel> settings = deserialize(request, response,
|
| | | RpcUtils.SETTINGS_TYPE);
|
| | | GitBlit.self().updateSettings(settings);
|
| | | } else {
|
| | | response.sendError(notAllowedCode);
|
| | | }
|
| | | } else if (RpcRequest.LIST_STATUS.equals(reqType)) {
|
| | | // return the server's status information
|
| | | result = GitBlit.self().getStatus();
|
| | | }
|
| | |
|
| | | // send the result of the request
|