.uri("KSK@foo.txt")
.execute();
connectNode();
- List<String> lines = fcpServer.collectUntil(is("Hello"));
- String identifier = extractIdentifier(lines);
+ readMessage("Hello", this::matchesDirectClientPut);
replyWithGeneratedUri();
replyWithPutSuccessful(identifier);
assertThat(key.get().get().getKey(), is("KSK@foo.txt"));
connectAndAssert(() -> matchesClientPutDiskDir("Verbosity=1"));
replyWithSimpleProgress(1, 2, 3, 4, 5, 6, true, 8);
replyWithSimpleProgress(11, 12, 13, 14, 15, 16, false, 18);
- fcpServer.writeLine("PutSuccessful", "Identifier=" + identifier, "URI=CHK@abc", "EndMessage");
- assertThat(key.get().get().getKey(), is("CHK@abc"));
+ replyWithPutSuccessful(identifier);
+ assertThat(key.get().get().getKey(), is("KSK@foo.txt"));
assertThat(requestProgress, contains(
isRequestProgress(1, 2, 3, 4, 5, 6, true, 8),
isRequestProgress(11, 12, 13, 14, 15, 16, false, 18)