package net.pterodactylus.fcp.quelaton;
import static org.hamcrest.MatcherAssert.assertThat;
+import static org.hamcrest.Matchers.containsInAnyOrder;
import static org.hamcrest.Matchers.is;
import java.io.IOException;
+import java.nio.charset.StandardCharsets;
+import java.util.List;
+import java.util.Optional;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import net.pterodactylus.fcp.FcpKeyPair;
+import net.pterodactylus.fcp.Priority;
import net.pterodactylus.fcp.fake.FakeTcpServer;
+import net.pterodactylus.fcp.quelaton.ClientGetCommand.Data;
+import com.google.common.io.ByteStreams;
+import org.junit.After;
import org.junit.Test;
/**
*/
public class DefaultFcpClientTest {
+ private static final String INSERT_URI = "SSK@RVCHbJdkkyTCeNN9AYukEg76eyqmiosSaNKgE3U9zUw,7SHH53gletBVb9JD7nBsyClbLQsBubDPEIcwg908r7Y,AQECAAE/";
+ private static final String REQUEST_URI = "SSK@wtbgd2loNcJCXvtQVOftl2tuWBomDQHfqS6ytpPRhfw,7SHH53gletBVb9JD7nBsyClbLQsBubDPEIcwg908r7Y,AQACAAE/";
+
private final ExecutorService threadPool = Executors.newCachedThreadPool();
private final FakeTcpServer fcpServer;
private final DefaultFcpClient fcpClient;
fcpClient = new DefaultFcpClient(threadPool, "localhost", fcpServer.getPort(), () -> "Test", () -> "2.0");
}
+ @After
+ public void tearDown() throws IOException {
+ fcpServer.close();
+ }
+
@Test
public void defaultFcpClientCanGenerateKeypair() throws ExecutionException, InterruptedException, IOException {
Future<FcpKeyPair> keyPairFuture = fcpClient.generateKeypair().execute();
connectNode();
fcpServer.collectUntil(is("EndMessage"));
- fcpServer.writeLine("SSKKeypair\n"
- + "InsertURI=freenet:SSK@AKTTKG6YwjrHzWo67laRcoPqibyiTdyYufjVg54fBlWr,AwUSJG5ZS-FDZTqnt6skTzhxQe08T-fbKXj8aEHZsXM/\n"
- + "RequestURI=freenet:SSK@BnHXXv3Fa43w~~iz1tNUd~cj4OpUuDjVouOWZ5XlpX0,AwUSJG5ZS-FDZTqnt6skTzhxQe08T-fbKXj8aEHZsXM,AQABAAE/\n"
- + "Identifier=My Identifier from GenerateSSK\n"
- + "EndMessage");
+ fcpServer.writeLine("SSKKeypair",
+ "InsertURI=" + INSERT_URI + "",
+ "RequestURI=" + REQUEST_URI + "",
+ "Identifier=My Identifier from GenerateSSK",
+ "EndMessage");
FcpKeyPair keyPair = keyPairFuture.get();
- assertThat(keyPair.getPublicKey(),
- is("freenet:SSK@BnHXXv3Fa43w~~iz1tNUd~cj4OpUuDjVouOWZ5XlpX0,AwUSJG5ZS-FDZTqnt6skTzhxQe08T-fbKXj8aEHZsXM,AQABAAE/"));
- assertThat(keyPair.getPrivateKey(), is(
- "freenet:SSK@AKTTKG6YwjrHzWo67laRcoPqibyiTdyYufjVg54fBlWr,AwUSJG5ZS-FDZTqnt6skTzhxQe08T-fbKXj8aEHZsXM/"));
+ assertThat(keyPair.getPublicKey(), is(REQUEST_URI));
+ assertThat(keyPair.getPrivateKey(), is(INSERT_URI));
}
private void connectNode() throws InterruptedException, ExecutionException, IOException {
fcpServer.connect().get();
fcpServer.collectUntil(is("EndMessage"));
- fcpServer.writeLine("NodeHello\n"
- + "FCPVersion=2.0\n"
- + "ConnectionIdentifier=754595fc35701d76096d8279d15c57e6\n"
- + "Version=Fred,0.7,1.0,1231\n"
- + "Node=Fred\n"
- + "NodeLanguage=ENGLISH\n"
- + "ExtRevision=23771\n"
- + "Build=1231\n"
- + "Testnet=false\n"
- + "ExtBuild=26\n"
- + "CompressionCodecs=3 - GZIP(0), BZIP2(1), LZMA(2)\n"
- + "Revision=@custom@\n"
- + "EndMessage");
+ fcpServer.writeLine("NodeHello",
+ "CompressionCodecs=4 - GZIP(0), BZIP2(1), LZMA(2), LZMA_NEW(3)",
+ "Revision=build01466",
+ "Testnet=false",
+ "Version=Fred,0.7,1.0,1466",
+ "Build=1466",
+ "ConnectionIdentifier=14318898267048452a81b36e7f13a3f0",
+ "Node=Fred",
+ "ExtBuild=29",
+ "FCPVersion=2.0",
+ "NodeLanguage=ENGLISH",
+ "ExtRevision=v29",
+ "EndMessage"
+ );
+ }
+
+ @Test
+ public void clientGetCanDownloadData() throws InterruptedException, ExecutionException, IOException {
+ Future<Optional<Data>> dataFuture = fcpClient.clientGet().identifier("test").uri("KSK@foo.txt");
+ connectNode();
+ List<String> lines = fcpServer.collectUntil(is("EndMessage"));
+ assertThat(lines, containsInAnyOrder(
+ "ClientGet",
+ "Identifier=test",
+ "ReturnType=direct",
+ "URI=KSK@foo.txt",
+ "EndMessage"
+ ));
+ fcpServer.writeLine(
+ "AllData",
+ "Identifier=test",
+ "DataLength=6",
+ "StartupTime=1435610539000",
+ "CompletionTime=1435610540000",
+ "Metadata.ContentType=text/plain;charset=utf-8",
+ "Data",
+ "Hello"
+ );
+ Optional<Data> data = dataFuture.get();
+ assertThat(data.get().getMimeType(), is("text/plain;charset=utf-8"));
+ assertThat(data.get().size(), is(6L));
+ assertThat(ByteStreams.toByteArray(data.get().getInputStream()), is("Hello\n".getBytes(StandardCharsets.UTF_8)));
+ }
+
+ @Test
+ public void clientGetRecognizesGetFailed() throws InterruptedException, ExecutionException, IOException {
+ Future<Optional<Data>> dataFuture = fcpClient.clientGet().identifier("test").uri("KSK@foo.txt");
+ connectNode();
+ List<String> lines = fcpServer.collectUntil(is("EndMessage"));
+ assertThat(lines, containsInAnyOrder(
+ "ClientGet",
+ "Identifier=test",
+ "ReturnType=direct",
+ "URI=KSK@foo.txt",
+ "EndMessage"
+ ));
+ fcpServer.writeLine(
+ "GetFailed",
+ "Identifier=test",
+ "Code=3",
+ "EndMessage"
+ );
+ Optional<Data> data = dataFuture.get();
+ assertThat(data.isPresent(), is(false));
+ }
+
+ @Test
+ public void clientGetRecognizesConnectionClosed() throws InterruptedException, ExecutionException, IOException {
+ Future<Optional<Data>> dataFuture = fcpClient.clientGet().identifier("test").uri("KSK@foo.txt");
+ connectNode();
+ List<String> lines = fcpServer.collectUntil(is("EndMessage"));
+ assertThat(lines, containsInAnyOrder(
+ "ClientGet",
+ "Identifier=test",
+ "ReturnType=direct",
+ "URI=KSK@foo.txt",
+ "EndMessage"
+ ));
+ fcpServer.close();
+ Optional<Data> data = dataFuture.get();
+ assertThat(data.isPresent(), is(false));
+ }
+
+ @Test
+ public void clientGetWithIgnoreDataStoreSettingSendsCorrectCommands() throws InterruptedException, ExecutionException, IOException {
+ fcpClient.clientGet().ignoreDataStore().identifier("test").uri("KSK@foo.txt");
+ connectNode();
+ List<String> lines = fcpServer.collectUntil(is("EndMessage"));
+ assertThat(lines, containsInAnyOrder(
+ "ClientGet",
+ "Identifier=test",
+ "ReturnType=direct",
+ "URI=KSK@foo.txt",
+ "IgnoreDS=true",
+ "EndMessage"
+ ));
+ }
+
+ @Test
+ public void clientGetWithDataStoreOnlySettingSendsCorrectCommands() throws InterruptedException, ExecutionException, IOException {
+ fcpClient.clientGet().dataStoreOnly().identifier("test").uri("KSK@foo.txt");
+ connectNode();
+ List<String> lines = fcpServer.collectUntil(is("EndMessage"));
+ assertThat(lines, containsInAnyOrder(
+ "ClientGet",
+ "Identifier=test",
+ "ReturnType=direct",
+ "URI=KSK@foo.txt",
+ "DSonly=true",
+ "EndMessage"
+ ));
+ }
+
+ @Test
+ public void clientGetWithMaxSizeSettingSendsCorrectCommands() throws InterruptedException, ExecutionException, IOException {
+ fcpClient.clientGet().maxSize(1048576).identifier("test").uri("KSK@foo.txt");
+ connectNode();
+ List<String> lines = fcpServer.collectUntil(is("EndMessage"));
+ assertThat(lines, containsInAnyOrder(
+ "ClientGet",
+ "Identifier=test",
+ "ReturnType=direct",
+ "URI=KSK@foo.txt",
+ "MaxSize=1048576",
+ "EndMessage"
+ ));
+ }
+
+ @Test
+ public void clientGetWithPrioritySettingSendsCorrectCommands() throws InterruptedException, ExecutionException, IOException {
+ fcpClient.clientGet().priority(Priority.interactive).identifier("test").uri("KSK@foo.txt");
+ connectNode();
+ List<String> lines = fcpServer.collectUntil(is("EndMessage"));
+ assertThat(lines, containsInAnyOrder(
+ "ClientGet",
+ "Identifier=test",
+ "ReturnType=direct",
+ "URI=KSK@foo.txt",
+ "PriorityClass=1",
+ "EndMessage"
+ ));
+ }
+
+ @Test
+ public void clientGetWithRealTimeSettingSendsCorrectCommands() throws InterruptedException, ExecutionException, IOException {
+ fcpClient.clientGet().realTime().identifier("test").uri("KSK@foo.txt");
+ connectNode();
+ List<String> lines = fcpServer.collectUntil(is("EndMessage"));
+ assertThat(lines, containsInAnyOrder(
+ "ClientGet",
+ "Identifier=test",
+ "ReturnType=direct",
+ "URI=KSK@foo.txt",
+ "RealTimeFlag=true",
+ "EndMessage"
+ ));
+ }
+
+ @Test
+ public void clientGetWithGlobalSettingSendsCorrectCommands() throws InterruptedException, ExecutionException, IOException {
+ fcpClient.clientGet().global().identifier("test").uri("KSK@foo.txt");
+ connectNode();
+ List<String> lines = fcpServer.collectUntil(is("EndMessage"));
+ assertThat(lines, containsInAnyOrder(
+ "ClientGet",
+ "Identifier=test",
+ "ReturnType=direct",
+ "URI=KSK@foo.txt",
+ "Global=true",
+ "EndMessage"
+ ));
}
}
projects / jFCPlib.git / blobdiff