connectNode();
List<String> lines = fcpServer.collectUntil(is("Hello"));
String identifier = extractIdentifier(lines);
- fcpServer.writeLine(
- "URIGenerated",
- "Identifier=" + identifier,
- "URI=KSK@foo.txt",
- "EndMessage"
- );
+ replyWithGeneratedUri();
replyWithPutSuccessful(identifier);
assertThat(key.get().get().getKey(), is("KSK@foo.txt"));
assertThat(generatedKeys, contains("KSK@foo.txt"));
);
}
+ private void replyWithGeneratedUri() throws IOException {
+ fcpServer.writeLine(
+ "URIGenerated",
+ "Identifier=" + identifier,
+ "URI=KSK@foo.txt",
+ "EndMessage"
+ );
+ }
+
private void replyWithSimpleProgress(
int total, int required, int failed, int fatallyFailed, int succeeded, int lastProgress,
boolean finalizedTotal, int minSuccessFetchBlocks) throws IOException {