in client/src/testFixtures/java/org/apache/cassandra/sidecar/client/SidecarClientTest.java [477:507]
void testUploadSSTableWithoutChecksum(@TempDir Path tempDirectory) throws Exception
{
Path fileToUpload = prepareFile(tempDirectory);
try (MockWebServer server = new MockWebServer())
{
server.enqueue(new MockResponse().setResponseCode(OK.code()));
SidecarInstanceImpl sidecarInstance = RequestExecutorTest.newSidecarInstance(server);
client.uploadSSTableRequest(sidecarInstance,
"cycling",
"cyclist_name",
"0000-0000",
"nb-1-big-TOC.txt",
null,
fileToUpload.toString())
.get(30, TimeUnit.SECONDS);
assertThat(server.getRequestCount()).isEqualTo(1);
RecordedRequest request = server.takeRequest();
assertThat(request.getPath())
.isEqualTo(ApiEndpointsV1.SSTABLE_UPLOAD_ROUTE
.replaceAll(ApiEndpointsV1.UPLOAD_ID_PATH_PARAM, "0000-0000")
.replaceAll(ApiEndpointsV1.KEYSPACE_PATH_PARAM, "cycling")
.replaceAll(ApiEndpointsV1.TABLE_PATH_PARAM, "cyclist_name")
.replaceAll(ApiEndpointsV1.COMPONENT_PATH_PARAM, "nb-1-big-TOC.txt"));
assertThat(request.getMethod()).isEqualTo("PUT");
assertThat(request.getHeader(HttpHeaderNames.CONTENT_MD5.toString())).isNull();
assertThat(request.getHeader(HttpHeaderNames.CONTENT_LENGTH.toString())).isEqualTo("80");
assertThat(request.getBodySize()).isEqualTo(80);
}
}