1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
|
/*
* 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]));
}
}
}
|
