X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fnet%2Fpterodactylus%2Ffcp%2Fquelaton%2FDefaultFcpClientTest.java;h=4fcd3fe6f084fbbaf8c25f0f10a6f655903ecc38;hb=6ca400777e801ad1b4e26460b58950dc04fb39c4;hp=c555f204069bbe0c5320684ccf21a861313d47d4;hpb=ef3a2dc2937162bc808695cd2d948a07db0f011f;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 c555f20..4fcd3fe 100644
--- a/src/test/java/net/pterodactylus/fcp/quelaton/DefaultFcpClientTest.java
+++ b/src/test/java/net/pterodactylus/fcp/quelaton/DefaultFcpClientTest.java
@@ -2136,4 +2136,57 @@ public class DefaultFcpClientTest {
 
 	}
 
+	public class ReloadPlugin {
+
+		private static final String CLASS_NAME = "foo.plugin.Plugin";
+		private List<String> lines;
+		private String identifier;
+
+		private void connectAndAssert(Supplier<Matcher<List<String>>> requestMatcher)
+		throws InterruptedException, ExecutionException, IOException {
+			connectNode();
+			lines = fcpServer.collectUntil(is("EndMessage"));
+			identifier = extractIdentifier(lines);
+			assertThat(lines, requestMatcher.get());
+		}
+
+		@Test
+		public void reloadingPluginWorks() throws InterruptedException, ExecutionException, IOException {
+			Future<Optional<PluginInfo>> pluginInfo = fcpClient.reloadPlugin().plugin(CLASS_NAME).execute();
+			connectAndAssert(() -> matchesFcpMessage(
+				"ReloadPlugin",
+				"Identifier=" + identifier,
+				"PluginName=" + CLASS_NAME,
+				"EndMessage"
+			));
+			replyWithPluginInfo();
+			verifyPluginInfo(pluginInfo);
+		}
+
+		private void replyWithPluginInfo() throws IOException {
+			fcpServer.writeLine(
+				"PluginInfo",
+				"Identifier=" + identifier,
+				"PluginName=superPlugin",
+				"IsTalkable=true",
+				"LongVersion=1.2.3",
+				"Version=42",
+				"OriginUri=superPlugin",
+				"Started=true",
+				"EndMessage"
+			);
+		}
+
+		private void verifyPluginInfo(Future<Optional<PluginInfo>> pluginInfo)
+		throws InterruptedException, ExecutionException {
+			assertThat(pluginInfo.get().get().getPluginName(), is("superPlugin"));
+			assertThat(pluginInfo.get().get().getOriginalURI(), is("superPlugin"));
+			assertThat(pluginInfo.get().get().isTalkable(), is(true));
+			assertThat(pluginInfo.get().get().getVersion(), is("42"));
+			assertThat(pluginInfo.get().get().getLongVersion(), is("1.2.3"));
+			assertThat(pluginInfo.get().get().isStarted(), is(true));
+		}
+
+	}
+
 }