From c03c586fd91ef90fdafba58b80e5fd0dfa1d5e21 Mon Sep 17 00:00:00 2001 From: jmatsuok Date: Thu, 30 Jan 2025 18:30:33 -0500 Subject: [PATCH] Restore notification when expiry == null --- .../cryostat/recordings/RecordingHelper.java | 23 +++++++++++++++++++ 1 file changed, 23 insertions(+) diff --git a/src/main/java/io/cryostat/recordings/RecordingHelper.java b/src/main/java/io/cryostat/recordings/RecordingHelper.java index bd734245c..56dfe2bc4 100644 --- a/src/main/java/io/cryostat/recordings/RecordingHelper.java +++ b/src/main/java/io/cryostat/recordings/RecordingHelper.java @@ -18,6 +18,7 @@ import java.io.IOException; import java.io.InputStream; import java.net.MalformedURLException; +import java.net.URI; import java.net.URISyntaxException; import java.net.URL; import java.net.URLDecoder; @@ -914,6 +915,28 @@ public ArchivedRecording archiveRecording( // couldn't parse the response from Amazon S3. throw e; } + if (expiry == null) { + ArchivedRecording archivedRecording = + new ArchivedRecording( + recording.target.jvmId, + filename, + downloadUrl(recording.target.jvmId, filename), + reportUrl(recording.target.jvmId, filename), + recording.metadata, + accum, + now.getEpochSecond()); + + URI connectUrl = recording.target.connectUrl; + + var event = + new ArchivedRecordingEvent( + ActiveRecordings.RecordingEventCategory.ARCHIVED_CREATED, + ArchivedRecordingEvent.Payload.of(connectUrl, archivedRecording)); + bus.publish(event.category().category(), event.payload().recording()); + bus.publish( + MessagingServer.class.getName(), + new Notification(event.category().category(), event.payload())); + } return new ArchivedRecording( recording.target.jvmId, filename,