From: David ‘Bombe’ Roden <bombe@freenetproject.org>
Date: Thu, 9 Jul 2015 05:18:37 +0000 (+0200)
Subject: Add test for sending TestDDAResponse if reading the file fails
X-Git-Url: https://git.pterodactylus.net/?a=commitdiff_plain;h=9b883b8dc655fbc663af2ea96fabd3273c9d8500;p=jFCPlib.git

Add test for sending TestDDAResponse if reading the file fails
---

diff --git a/src/test/java/net/pterodactylus/fcp/quelaton/DefaultFcpClientTest.java b/src/test/java/net/pterodactylus/fcp/quelaton/DefaultFcpClientTest.java
index da454df..623d345 100644
--- a/src/test/java/net/pterodactylus/fcp/quelaton/DefaultFcpClientTest.java
+++ b/src/test/java/net/pterodactylus/fcp/quelaton/DefaultFcpClientTest.java
@@ -516,4 +516,41 @@ public class DefaultFcpClientTest {
 		));
 	}
 
+	@Test
+	public void clientPutSendsResponseEvenIfFileCanNotBeRead()
+	throws IOException, ExecutionException, InterruptedException {
+		File tempFile = createTempFile();
+		fcpClient.clientPut().from(new File(tempFile.getParent(), "test.dat")).key(new Key("KSK@foo.txt"));
+		connectNode();
+		List<String> lines = fcpServer.collectUntil(is("EndMessage"));
+		String identifier = extractIdentifier(lines);
+		fcpServer.writeLine(
+			"ProtocolError",
+			"Identifier=" + identifier,
+			"Code=25",
+			"EndMessage"
+		);
+		lines = fcpServer.collectUntil(is("EndMessage"));
+		assertThat(lines, matchesFcpMessage(
+			"TestDDARequest",
+			"Directory=" + tempFile.getParent(),
+			"WantReadDirectory=true",
+			"WantWriteDirectory=false",
+			"EndMessage"
+		));
+		fcpServer.writeLine(
+			"TestDDAReply",
+			"Directory=" + tempFile.getParent(),
+			"ReadFilename=" + tempFile + ".foo",
+			"EndMessage"
+		);
+		lines = fcpServer.collectUntil(is("EndMessage"));
+		assertThat(lines, matchesFcpMessage(
+			"TestDDAResponse",
+			"Directory=" + tempFile.getParent(),
+			"ReadContent=failed-to-read",
+			"EndMessage"
+		));
+	}
+
 }