X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fnet%2Fpterodactylus%2Ffcp%2Fquelaton%2FDefaultFcpClientTest.java;h=4fad0ead72cba863764672e332b252013b913334;hb=cd753d3f782e0024fd3edaa97b40f8e86bc3a8b3;hp=557350b1a109790abfcc860a86cb8c7821af59f4;hpb=be6c1651ce3c53daa254fb2dbce9221450d381e8;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 557350b..4fad0ea 100644
--- a/src/test/java/net/pterodactylus/fcp/quelaton/DefaultFcpClientTest.java
+++ b/src/test/java/net/pterodactylus/fcp/quelaton/DefaultFcpClientTest.java
@@ -1993,20 +1993,20 @@ public class DefaultFcpClientTest {
 		assertThat(newConfigData.get().getCurrent("foo.bar"), is("baz"));
 	}
 
-	public class PluginCommands {
+	private List<String> lines;
+	private String identifier;
 
-		private static final String CLASS_NAME = "foo.plugin.Plugin";
+	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());
+	}
 
-		private List<String> lines;
-		private String identifier;
+	public class PluginCommands {
 
-		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());
-		}
+		private static final String CLASS_NAME = "foo.plugin.Plugin";
 
 		private void replyWithPluginInfo() throws IOException {
 			fcpServer.writeLine(
@@ -2285,4 +2285,24 @@ public class DefaultFcpClientTest {
 
 	}
 
+	public class UskSubscriptionCommands {
+
+		private static final String URI = "SSK@some,uri/file.txt";
+
+		@Test
+		public void subscriptionWorks() throws InterruptedException, ExecutionException, IOException {
+			Future<Optional<UskSubscription>> uskSubscription = fcpClient.subscribeUsk().uri(URI).execute();
+			connectAndAssert(() -> matchesFcpMessage("SubscribeUSK", "URI=" + URI, "EndMessage"));
+			fcpServer.writeLine(
+				"SubscribedUSK",
+				"Identifier=" + identifier,
+				"URI=" + URI,
+				"DontPoll=false",
+				"EndMessage"
+			);
+			assertThat(uskSubscription.get().get().getUri(), is(URI));
+		}
+
+	}
+
 }