in client/src/testFixtures/java/org/apache/cassandra/sidecar/client/SidecarClientTest.java [510:541]
void testUploadSSTableWithChecksum(@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",
"15a69dc6501aa5ae17af037fe053f610",
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()))
.isEqualTo("15a69dc6501aa5ae17af037fe053f610");
assertThat(request.getHeader(HttpHeaderNames.CONTENT_LENGTH.toString())).isEqualTo("80");
assertThat(request.getBodySize()).isEqualTo(80);
}
}