mirror of
https://github.com/scm-manager/scm-manager.git
synced 2025-11-02 03:25:56 +01:00
return changeset count for bundle and unbundle command
This commit is contained in:
@@ -0,0 +1,121 @@
|
||||
/**
|
||||
* Copyright (c) 2014, Sebastian Sdorra All rights reserved.
|
||||
*
|
||||
* Redistribution and use in source and binary forms, with or without
|
||||
* modification, are permitted provided that the following conditions are met:
|
||||
*
|
||||
* 1. Redistributions of source code must retain the above copyright notice,
|
||||
* this list of conditions and the following disclaimer. 2. Redistributions in
|
||||
* binary form must reproduce the above copyright notice, this list of
|
||||
* conditions and the following disclaimer in the documentation and/or other
|
||||
* materials provided with the distribution. 3. Neither the name of SCM-Manager;
|
||||
* nor the names of its contributors may be used to endorse or promote products
|
||||
* derived from this software without specific prior written permission.
|
||||
*
|
||||
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
|
||||
* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
|
||||
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
|
||||
* ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE FOR
|
||||
* ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
|
||||
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
|
||||
* SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
|
||||
* CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
|
||||
* OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
|
||||
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
||||
*
|
||||
* http://bitbucket.org/sdorra/scm-manager
|
||||
*
|
||||
*/
|
||||
|
||||
|
||||
|
||||
package sonia.scm.repository.api;
|
||||
|
||||
//~--- non-JDK imports --------------------------------------------------------
|
||||
|
||||
import com.google.common.base.Objects;
|
||||
|
||||
/**
|
||||
* Abstract class for bundle or unbundle command.
|
||||
*
|
||||
* @author Sebastian Sdorra
|
||||
* @since 1.43
|
||||
*/
|
||||
public abstract class AbstractBundleOrUnbundleCommandResponse
|
||||
{
|
||||
|
||||
/**
|
||||
* Constructs a new bundle/unbundle response.
|
||||
*
|
||||
*
|
||||
* @param changesetCount count of bundled/unbundled changesets
|
||||
*/
|
||||
protected AbstractBundleOrUnbundleCommandResponse(long changesetCount)
|
||||
{
|
||||
this.changesetCount = changesetCount;
|
||||
}
|
||||
|
||||
//~--- methods --------------------------------------------------------------
|
||||
|
||||
/**
|
||||
* {@inheritDoc}
|
||||
*/
|
||||
@Override
|
||||
public boolean equals(Object obj)
|
||||
{
|
||||
if (obj == null)
|
||||
{
|
||||
return false;
|
||||
}
|
||||
|
||||
if (getClass() != obj.getClass())
|
||||
{
|
||||
return false;
|
||||
}
|
||||
|
||||
final AbstractBundleOrUnbundleCommandResponse other =
|
||||
(AbstractBundleOrUnbundleCommandResponse) obj;
|
||||
|
||||
return Objects.equal(changesetCount, other.changesetCount);
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritDoc}
|
||||
*/
|
||||
@Override
|
||||
public int hashCode()
|
||||
{
|
||||
return Objects.hashCode(changesetCount);
|
||||
}
|
||||
|
||||
/**
|
||||
* {@inheritDoc}
|
||||
*/
|
||||
@Override
|
||||
public String toString()
|
||||
{
|
||||
//J-
|
||||
return Objects.toStringHelper(this)
|
||||
.add("changesetCount", changesetCount)
|
||||
.toString();
|
||||
//J+
|
||||
}
|
||||
|
||||
//~--- get methods ----------------------------------------------------------
|
||||
|
||||
/**
|
||||
* Returns the count of bundled/unbundled changesets.
|
||||
*
|
||||
*
|
||||
* @return count of bundled/unbundled changesets
|
||||
*/
|
||||
public long getChangesetCount()
|
||||
{
|
||||
return changesetCount;
|
||||
}
|
||||
|
||||
//~--- fields ---------------------------------------------------------------
|
||||
|
||||
/** count of bundled/unbundled changesets */
|
||||
private final long changesetCount;
|
||||
}
|
||||
@@ -34,9 +34,23 @@
|
||||
package sonia.scm.repository.api;
|
||||
|
||||
/**
|
||||
* Response of {@link BundleCommandBuilder}.
|
||||
* Response of bundle command.
|
||||
*
|
||||
* @author Sebastian Sdorra <s.sdorra@gmail.com>
|
||||
* @since 1.43
|
||||
*/
|
||||
public class BundleResponse {}
|
||||
public final class BundleResponse
|
||||
extends AbstractBundleOrUnbundleCommandResponse
|
||||
{
|
||||
|
||||
/**
|
||||
* Constructs a new bundle response.
|
||||
*
|
||||
*
|
||||
* @param changesetCount count of bundled changesets
|
||||
*/
|
||||
public BundleResponse(long changesetCount)
|
||||
{
|
||||
super(changesetCount);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -34,9 +34,22 @@
|
||||
package sonia.scm.repository.api;
|
||||
|
||||
/**
|
||||
* Response of {@link UnbundleCommandBuilder}.
|
||||
* Response of unbundle command.
|
||||
*
|
||||
* @author Sebastian Sdorra <s.sdorra@gmail.com>
|
||||
* @since 1.43
|
||||
*/
|
||||
public class UnbundleResponse {}
|
||||
public class UnbundleResponse extends AbstractBundleOrUnbundleCommandResponse
|
||||
{
|
||||
|
||||
/**
|
||||
* Constructs a new unbundle response.
|
||||
*
|
||||
*
|
||||
* @param changesetCount count of unbundled changesets
|
||||
*/
|
||||
public UnbundleResponse(long changesetCount)
|
||||
{
|
||||
super(changesetCount);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -125,6 +125,8 @@ public class SvnBundleCommand extends AbstractSvnCommand
|
||||
ByteSink archive = checkNotNull(request.getArchive(),
|
||||
"archive is required");
|
||||
|
||||
BundleResponse response;
|
||||
|
||||
SVNClientManager clientManager = null;
|
||||
|
||||
try
|
||||
@@ -134,6 +136,7 @@ public class SvnBundleCommand extends AbstractSvnCommand
|
||||
SVNAdminClient adminClient = clientManager.getAdminClient();
|
||||
|
||||
dump(adminClient, context.getDirectory(), archive);
|
||||
response = new BundleResponse(context.open().getLatestRevision());
|
||||
}
|
||||
catch (SVNException ex)
|
||||
{
|
||||
@@ -144,6 +147,6 @@ public class SvnBundleCommand extends AbstractSvnCommand
|
||||
SvnUtil.dispose(clientManager);
|
||||
}
|
||||
|
||||
return new BundleResponse();
|
||||
return response;
|
||||
}
|
||||
}
|
||||
|
||||
@@ -105,6 +105,8 @@ public class SvnUnbundleCommand extends AbstractSvnCommand
|
||||
logger.debug("archive repository {} to {}", context.getDirectory(),
|
||||
archive);
|
||||
|
||||
UnbundleResponse response;
|
||||
|
||||
SVNClientManager clientManager = null;
|
||||
|
||||
try
|
||||
@@ -114,6 +116,8 @@ public class SvnUnbundleCommand extends AbstractSvnCommand
|
||||
SVNAdminClient adminClient = clientManager.getAdminClient();
|
||||
|
||||
restore(adminClient, archive, context.getDirectory());
|
||||
|
||||
response = new UnbundleResponse(context.open().getLatestRevision());
|
||||
}
|
||||
catch (SVNException ex)
|
||||
{
|
||||
@@ -124,7 +128,7 @@ public class SvnUnbundleCommand extends AbstractSvnCommand
|
||||
SvnUtil.dispose(clientManager);
|
||||
}
|
||||
|
||||
return new UnbundleResponse();
|
||||
return response;
|
||||
}
|
||||
|
||||
/**
|
||||
|
||||
@@ -77,7 +77,8 @@ public class SvnBundleCommandTest extends AbstractSvnCommandTestBase
|
||||
BundleResponse res = new SvnBundleCommand(createContext(),
|
||||
repository).bundle(req);
|
||||
|
||||
assertNotNull(res);
|
||||
assertThat(res, notNullValue());
|
||||
assertThat(res.getChangesetCount(), is(5l));
|
||||
assertTrue("file does not exists", file.exists());
|
||||
assertThat(file.length(), greaterThan(0l));
|
||||
}
|
||||
|
||||
@@ -86,7 +86,8 @@ public class SvnUnbundleCommandTest extends AbstractSvnCommandTestBase
|
||||
);
|
||||
//J+
|
||||
|
||||
assertNotNull(res);
|
||||
assertThat(res, notNullValue());
|
||||
assertThat(res.getChangesetCount(), is(5l));
|
||||
|
||||
SVNRepository repo = ctx.open();
|
||||
|
||||
|
||||
Reference in New Issue
Block a user