blob: cf8c5ffe79619cc168e8a4458bc40182ae783826 [file] [log] [blame]
/*
* Copyright (c) 2022 Darius Jokilehto <darius.jokilehto+os@gmail.com>
* Copyright (c) 2022 Antonio Barone <syntonyze@gmail.com>
*
* This program and the accompanying materials are made available under the
* terms of the Eclipse Distribution License v. 1.0 which is available at
* https://www.eclipse.org/org/documents/edl-v10.php.
*
* SPDX-License-Identifier: BSD-3-Clause
*/
package org.eclipse.jgit.transport;
import org.eclipse.jgit.errors.NoRemoteRepositoryException;
import org.eclipse.jgit.errors.TransportException;
import org.eclipse.jgit.internal.JGitText;
import org.junit.Test;
import java.io.ByteArrayInputStream;
import java.io.EOFException;
import java.io.IOException;
import java.util.Arrays;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.endsWith;
import static org.hamcrest.Matchers.hasItem;
import static org.hamcrest.Matchers.instanceOf;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertThrows;
public class BasePackPushConnectionTest {
@Test
public void testNoRemoteRepository() {
NoRemoteRepositoryException openFetchException =
new NoRemoteRepositoryException( new URIish(), "not found");
IOException ioException = new IOException("not read");
try (FailingBasePackPushConnection fbppc =
new FailingBasePackPushConnection(openFetchException)) {
TransportException result = fbppc.noRepository(ioException);
assertEquals(openFetchException, result);
assertThat(Arrays.asList(result.getSuppressed()),
hasItem(ioException));
}
}
@Test
public void testPushNotPermitted() {
URIish uri = new URIish();
TransportException openFetchException = new TransportException(uri,
"a transport exception");
IOException ioException = new IOException("not read");
try (FailingBasePackPushConnection fbppc =
new FailingBasePackPushConnection(openFetchException)) {
TransportException result = fbppc.noRepository(ioException);
assertEquals(TransportException.class, result.getClass());
assertThat(result.getMessage(),
endsWith(JGitText.get().pushNotPermitted));
assertEquals(openFetchException, result.getCause());
assertThat(Arrays.asList(result.getSuppressed()),
hasItem(ioException));
}
}
@Test
public void testReadAdvertisedRefPropagatesCauseAndSuppressedExceptions() {
IOException ioException = new IOException("not read");
try (FailingBasePackPushConnection basePackConnection =
new FailingBasePackPushConnection(
new NoRemoteRepositoryException(
new URIish(), "not found", ioException))) {
Exception result = assertThrows(NoRemoteRepositoryException.class,
basePackConnection::readAdvertisedRefs);
assertEquals(ioException, result.getCause());
assertThat(Arrays.asList(result.getSuppressed()),
hasItem(instanceOf(EOFException.class)));
}
}
private static class FailingBasePackPushConnection
extends BasePackPushConnection {
FailingBasePackPushConnection(TransportException openFetchException) {
super(new TransportLocal(new URIish(),
new java.io.File("")) {
@Override public FetchConnection openFetch()
throws TransportException {
throw openFetchException;
}
});
pckIn = new PacketLineIn(new ByteArrayInputStream(new byte[0]));
}
}
}