Skip to content

Commit 814a39b

Browse files
committed
fix(presign): remove baseUri from reports and jfr-datasource, send full presigned URLs
1 parent 7cb4d26 commit 814a39b

File tree

6 files changed

+5
-14
lines changed

6 files changed

+5
-14
lines changed

compose/jfr-datasource.yml

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,6 @@ services:
2727
-Dcom.sun.management.jmxremote.authenticate=false
2828
-Dcom.sun.management.jmxremote.ssl=false
2929
-Dcom.sun.management.jmxremote.local.only=false
30-
CRYOSTAT_STORAGE_BASE_URI: ${S3_ENDPOINT_ARCHIVES_BUCKET:-http://s3:8333}
3130
healthcheck:
3231
test: curl --fail http://localhost:8080/ || exit 1
3332
retries: 3

compose/reports.yml

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,6 @@ services:
3030
-Dcom.sun.management.jmxremote.ssl=false
3131
-Dcom.sun.management.jmxremote.local.only=false
3232
QUARKUS_HTTP_PORT: 10001
33-
CRYOSTAT_STORAGE_BASE_URI: ${S3_ENDPOINT_ARCHIVES_BUCKET:-http://s3:8333}
3433
healthcheck:
3534
test: curl --fail http://localhost:10001/ || exit 1
3635
retries: 3

src/main/java/io/cryostat/recordings/RecordingHelper.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1486,7 +1486,7 @@ private Uni<String> uploadPresignedToJFRDatasource(String jvmId, String filename
14861486
throws URISyntaxException {
14871487
var uri = getPresignedPath(jvmId, filename);
14881488
return datasourceClient
1489-
.uploadPresigned(uri.getPath(), uri.getQuery())
1489+
.uploadPresigned(uri.toString())
14901490
.onItem()
14911491
.transform(
14921492
r -> {
@@ -1640,8 +1640,6 @@ Uni<Response> upload(
16401640
@POST
16411641
@jakarta.ws.rs.Path("/load_presigned")
16421642
@Consumes(MediaType.MULTIPART_FORM_DATA)
1643-
Uni<Response> uploadPresigned(
1644-
@RestForm("path") @PartType(MediaType.TEXT_PLAIN) String path,
1645-
@RestForm("query") @PartType(MediaType.TEXT_PLAIN) String query);
1643+
Uni<Response> uploadPresigned(@RestForm("uri") @PartType(MediaType.TEXT_PLAIN) String uri);
16461644
}
16471645
}

src/main/java/io/cryostat/reports/ReportSidecarService.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,6 @@ Uni<Map<String, AnalysisResult>> generate(
4848
@POST
4949
@Consumes(MediaType.MULTIPART_FORM_DATA)
5050
Uni<Map<String, AnalysisResult>> generatePresigned(
51-
@RestForm("path") @PartType(MediaType.TEXT_PLAIN) String path,
52-
@RestForm("query") @PartType(MediaType.TEXT_PLAIN) String query,
51+
@RestForm("uri") @PartType(MediaType.TEXT_PLAIN) String uri,
5352
@RestForm("filter") @PartType(MediaType.TEXT_PLAIN) String filter);
5453
}

src/main/java/io/cryostat/reports/ReportsServiceImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -118,7 +118,7 @@ public Uni<Map<String, AnalysisResult>> reportFor(
118118
logger.tracev(
119119
"sidecar reportFor presigned archived recording {0} {1}", jvmId, filename);
120120
var uri = getPresignedPath(jvmId, filename);
121-
return sidecar.generatePresigned(uri.getPath(), uri.getQuery(), filter);
121+
return sidecar.generatePresigned(uri.toString(), filter);
122122
} else {
123123
InputStream stream = helper.getArchivedRecordingStream(jvmId, filename);
124124
logger.tracev("sidecar reportFor archived recording {0} {1}", jvmId, filename);

src/test/java/io/cryostat/resources/ReportsSidecarResource.java

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -30,11 +30,7 @@ public class ReportsSidecarResource
3030
private static final int REPORTS_PORT = 10001;
3131
private static final String IMAGE_NAME = "quay.io/cryostat/cryostat-reports:latest";
3232
private static final Map<String, String> envMap =
33-
Map.of(
34-
"QUARKUS_HTTP_PORT", String.valueOf(REPORTS_PORT),
35-
// TODO localhost:8333 should be dynamically set to the host and port of the
36-
// S3StorageResource
37-
"CRYOSTAT_STORAGE_BASE_URI", String.format("http://%s:%d", "localhost", 8333));
33+
Map.of("QUARKUS_HTTP_PORT", String.valueOf(REPORTS_PORT));
3834

3935
private Optional<String> containerNetworkId;
4036
private GenericContainer<?> container;

0 commit comments

Comments
 (0)