| | |
| | | import com.gitblit.IStoredSettings;
|
| | | import com.gitblit.Keys;
|
| | | import com.gitblit.client.Translation;
|
| | | import com.gitblit.extensions.ReceiveHook;
|
| | | import com.gitblit.manager.IGitblit;
|
| | | import com.gitblit.models.RepositoryModel;
|
| | | import com.gitblit.models.UserModel;
|
| | |
| | | setAllowDeletes(user.canDeleteRef(repository));
|
| | | setAllowNonFastForwards(user.canRewindRef(repository));
|
| | |
|
| | | int maxObjectSz = settings.getInteger(Keys.git.maxObjectSizeLimit, -1);
|
| | | if (maxObjectSz >= 0) {
|
| | | setMaxObjectSizeLimit(maxObjectSz);
|
| | | }
|
| | | int maxPackSz = settings.getInteger(Keys.git.maxPackSizeLimit, -1);
|
| | | if (maxPackSz >= 0) {
|
| | | setMaxPackSizeLimit(maxPackSz);
|
| | | }
|
| | | setCheckReceivedObjects(settings.getBoolean(Keys.git.checkReceivedObjects, true));
|
| | | setCheckReferencedObjectsAreReachable(settings.getBoolean(Keys.git.checkReferencedObjectsAreReachable, true));
|
| | |
|
| | | // setup pre and post receive hook
|
| | | setPreReceiveHook(this);
|
| | | setPostReceiveHook(this);
|
| | | }
|
| | |
|
| | | /**
|
| | | * Returns true if the user is permitted to apply the receive commands to
|
| | | * the repository.
|
| | | *
|
| | | * @param commands
|
| | | * @return true if the user may push these commands
|
| | | */
|
| | | protected boolean canPush(Collection<ReceiveCommand> commands) {
|
| | | // TODO Consider supporting branch permissions here (issue-36)
|
| | | // Not sure if that should be Gerrit-style, refs/meta/config, or
|
| | | // gitolite-style, permissions in users.conf
|
| | | //
|
| | | // How could commands be empty?
|
| | | //
|
| | | // Because a subclass, like PatchsetReceivePack, filters receive
|
| | | // commands before this method is called. This makes it possible for
|
| | | // this method to test an empty list. In this case, we assume that the
|
| | | // subclass receive pack properly enforces push restrictions. for the
|
| | | // ref.
|
| | | //
|
| | | // The empty test is not explicitly required, it's written here to
|
| | | // clarify special-case behavior.
|
| | |
|
| | | return commands.isEmpty() ? true : user.canPush(repository);
|
| | | }
|
| | |
|
| | | /**
|
| | |
| | | */
|
| | | @Override
|
| | | public void onPreReceive(ReceivePack rp, Collection<ReceiveCommand> commands) {
|
| | |
|
| | | if (commands.size() == 0) {
|
| | | // no receive commands to process
|
| | | // this can happen if receive pack subclasses intercept and filter
|
| | | // the commands
|
| | | LOGGER.debug("skipping pre-receive processing, no refs created, updated, or removed");
|
| | | return;
|
| | | }
|
| | |
|
| | | if (repository.isMirror) {
|
| | | // repository is a mirror
|
| | |
| | | return;
|
| | | }
|
| | |
|
| | | if (!user.canPush(repository)) {
|
| | | if (!canPush(commands)) {
|
| | | // user does not have push permissions
|
| | | for (ReceiveCommand cmd : commands) {
|
| | | sendRejection(cmd, "User \"{0}\" does not have push permissions for \"{1}\"!", user.username, repository.name);
|
| | |
| | | }
|
| | | }
|
| | |
|
| | | // call pre-receive plugins
|
| | | for (ReceiveHook hook : gitblit.getExtensions(ReceiveHook.class)) {
|
| | | try {
|
| | | hook.onPreReceive(this, commands);
|
| | | } catch (Exception e) {
|
| | | LOGGER.error("Failed to execute extension", e);
|
| | | }
|
| | | }
|
| | |
|
| | | Set<String> scripts = new LinkedHashSet<String>();
|
| | | scripts.addAll(gitblit.getPreReceiveScriptsInherited(repository));
|
| | | if (!ArrayUtils.isEmpty(repository.preReceiveScripts)) {
|
| | |
| | | @Override
|
| | | public void onPostReceive(ReceivePack rp, Collection<ReceiveCommand> commands) {
|
| | | if (commands.size() == 0) {
|
| | | LOGGER.debug("skipping post-receive hooks, no refs created, updated, or removed");
|
| | | LOGGER.debug("skipping post-receive processing, no refs created, updated, or removed");
|
| | | return;
|
| | | }
|
| | |
|
| | |
| | | LOGGER.error(MessageFormat.format("Failed to update {0} pushlog", repository.name), e);
|
| | | }
|
| | |
|
| | | // check for updates pushed to the BranchTicketService branch
|
| | | // if the BranchTicketService is active it will reindex, as appropriate
|
| | | for (ReceiveCommand cmd : commands) {
|
| | | if (Result.OK.equals(cmd.getResult())
|
| | | && BranchTicketService.BRANCH.equals(cmd.getRefName())) {
|
| | | rp.getRepository().fireEvent(new ReceiveCommandEvent(repository, cmd));
|
| | | }
|
| | | }
|
| | |
|
| | | // call post-receive plugins
|
| | | for (ReceiveHook hook : gitblit.getExtensions(ReceiveHook.class)) {
|
| | | try {
|
| | | hook.onPostReceive(this, commands);
|
| | | } catch (Exception e) {
|
| | | LOGGER.error("Failed to execute extension", e);
|
| | | }
|
| | | }
|
| | |
|
| | | // run Groovy hook scripts
|
| | | Set<String> scripts = new LinkedHashSet<String>();
|
| | | scripts.addAll(gitblit.getPostReceiveScriptsInherited(repository));
|
| | |
| | | this.gitblitUrl = url;
|
| | | }
|
| | |
|
| | | protected void sendRejection(final ReceiveCommand cmd, final String why, Object... objects) {
|
| | | public void sendRejection(final ReceiveCommand cmd, final String why, Object... objects) {
|
| | | String text;
|
| | | if (ArrayUtils.isEmpty(objects)) {
|
| | | text = why;
|
| | |
| | | LOGGER.error(text + " (" + user.username + ")");
|
| | | }
|
| | |
|
| | | protected void sendHeader(String msg, Object... objects) {
|
| | | public void sendHeader(String msg, Object... objects) {
|
| | | sendInfo("--> ", msg, objects);
|
| | | }
|
| | |
|
| | | protected void sendInfo(String msg, Object... objects) {
|
| | | public void sendInfo(String msg, Object... objects) {
|
| | | sendInfo(" ", msg, objects);
|
| | | }
|
| | |
|
| | | protected void sendInfo(String prefix, String msg, Object... objects) {
|
| | | private void sendInfo(String prefix, String msg, Object... objects) {
|
| | | String text;
|
| | | if (ArrayUtils.isEmpty(objects)) {
|
| | | text = msg;
|
| | |
| | | }
|
| | | }
|
| | |
|
| | | protected void sendError(String msg, Object... objects) {
|
| | | public void sendError(String msg, Object... objects) {
|
| | | String text;
|
| | | if (ArrayUtils.isEmpty(objects)) {
|
| | | text = msg;
|
| | |
| | | }
|
| | | }
|
| | | }
|
| | |
|
| | | public IGitblit getGitblit() {
|
| | | return gitblit;
|
| | | }
|
| | |
|
| | | public RepositoryModel getRepositoryModel() {
|
| | | return repository;
|
| | | }
|
| | |
|
| | | public UserModel getUserModel() {
|
| | | return user;
|
| | | }
|
| | | }
|