X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fnet%2Fpterodactylus%2Ffcp%2Fquelaton%2FDefaultFcpClientTest.java;fp=src%2Ftest%2Fjava%2Fnet%2Fpterodactylus%2Ffcp%2Fquelaton%2FDefaultFcpClientTest.java;h=8adf900c60cd9b228b0e254ecb6009bee7d96ed4;hb=91de0a638af50527fc314ed97a095d1beaf36866;hp=f7823d63f3ef4a035564caf3973bc8711de5c59a;hpb=88196de42bde3e3a420c40ea78ad8057dab29363;p=jFCPlib.git

diff --git a/src/test/java/net/pterodactylus/fcp/quelaton/DefaultFcpClientTest.java b/src/test/java/net/pterodactylus/fcp/quelaton/DefaultFcpClientTest.java
index f7823d6..8adf900 100644
--- a/src/test/java/net/pterodactylus/fcp/quelaton/DefaultFcpClientTest.java
+++ b/src/test/java/net/pterodactylus/fcp/quelaton/DefaultFcpClientTest.java
@@ -215,6 +215,14 @@ public class DefaultFcpClientTest {
 		assertThat(lines, requestMatcher.get());
 	}
 
+	private void replyWithProtocolError() throws IOException {
+		fcpServer.writeLine(
+			"ProtocolError",
+			"Identifier=" + identifier,
+			"EndMessage"
+		);
+	}
+
 	public class ConnectionsAndKeyPairs {
 
 		public class Connections {
@@ -438,6 +446,14 @@ public class DefaultFcpClientTest {
 					assertThat(peer.get().get().getIdentity(), is("id1"));
 				}
 
+				@Test
+				public void protocolErrorEndsCommand() throws InterruptedException, ExecutionException, IOException {
+					Future<Optional<Peer>> peer = fcpClient.addPeer().fromFile(new File("/tmp/ref.txt")).execute();
+					connectAndAssert(() -> allOf(matchesAddPeer(), hasItem("File=/tmp/ref.txt")));
+					replyWithProtocolError();
+					assertThat(peer.get().isPresent(), is(false));
+				}
+
 				private NodeRef createNodeRef() {
 					NodeRef nodeRef = new NodeRef();
 					nodeRef.setIdentity("id1");
@@ -974,14 +990,6 @@ public class DefaultFcpClientTest {
 
 		}
 
-		private void replyWithProtocolError() throws IOException {
-			fcpServer.writeLine(
-				"ProtocolError",
-				"Identifier=" + identifier,
-				"EndMessage"
-			);
-		}
-
 		public class ReloadPlugin {
 
 			@Test