fcpClient.loadPlugin().officialFromFreenet("superPlugin").execute();
connectAndAssert(() -> createMatcherForOfficialSource("freenet"));
assertThat(lines, not(contains(startsWith("Store="))));
- replyWithPluginInfo(identifier);
+ replyWithPluginInfo();
verifyPluginInfo(pluginInfo);
}
fcpClient.loadPlugin().addToConfig().officialFromFreenet("superPlugin").execute();
connectAndAssert(() -> createMatcherForOfficialSource("freenet"));
assertThat(lines, hasItem("Store=true"));
- replyWithPluginInfo(identifier);
+ replyWithPluginInfo();
verifyPluginInfo(pluginInfo);
}
Future<Optional<PluginInfo>> pluginInfo =
fcpClient.loadPlugin().officialFromHttps("superPlugin").execute();
connectAndAssert(() -> createMatcherForOfficialSource("https"));
- replyWithPluginInfo(identifier);
+ replyWithPluginInfo();
verifyPluginInfo(pluginInfo);
}
public void fromFile() throws ExecutionException, InterruptedException, IOException {
Future<Optional<PluginInfo>> pluginInfo = fcpClient.loadPlugin().fromFile(FILE_PATH).execute();
connectAndAssert(() -> createMatcher("file", FILE_PATH));
- replyWithPluginInfo(identifier);
+ replyWithPluginInfo();
verifyPluginInfo(pluginInfo);
}
public void fromUrl() throws ExecutionException, InterruptedException, IOException {
Future<Optional<PluginInfo>> pluginInfo = fcpClient.loadPlugin().fromUrl(URL).execute();
connectAndAssert(() -> createMatcher("url", URL));
- replyWithPluginInfo(identifier);
+ replyWithPluginInfo();
verifyPluginInfo(pluginInfo);
}
public void fromFreenet() throws ExecutionException, InterruptedException, IOException {
Future<Optional<PluginInfo>> pluginInfo = fcpClient.loadPlugin().fromFreenet(KEY).execute();
connectAndAssert(() -> createMatcher("freenet", KEY));
- replyWithPluginInfo(identifier);
+ replyWithPluginInfo();
verifyPluginInfo(pluginInfo);
}
}
- private void replyWithPluginInfo(String identifier) throws IOException {
+ private void replyWithPluginInfo() throws IOException {
fcpServer.writeLine(
"PluginInfo",
"Identifier=" + identifier,