From d39c14cd9a10583f2d7e5fcf5f40e699691e6d4b Mon Sep 17 00:00:00 2001 From: Thomas Peetz Date: Wed, 22 Jul 2026 19:00:39 +0200 Subject: [PATCH] change creation of MediaFile --- .../integration/services/AddLinkProcessor.java | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/kontor-spring/src/main/java/de/thpeetz/kontor/integration/services/AddLinkProcessor.java b/kontor-spring/src/main/java/de/thpeetz/kontor/integration/services/AddLinkProcessor.java index dde2673..6f326a4 100644 --- a/kontor-spring/src/main/java/de/thpeetz/kontor/integration/services/AddLinkProcessor.java +++ b/kontor-spring/src/main/java/de/thpeetz/kontor/integration/services/AddLinkProcessor.java @@ -7,7 +7,6 @@ import de.thpeetz.kontor.media.services.MediaFileService; import lombok.extern.slf4j.Slf4j; import org.apache.camel.Exchange; import org.apache.camel.Processor; -import org.springframework.beans.factory.annotation.Autowired; import java.util.HashMap; import java.util.Map; @@ -24,7 +23,9 @@ public class AddLinkProcessor implements Processor { @Override public void process(Exchange exchange) throws Exception { ObjectMapper objectMapper = new ObjectMapper(); - HashMap myMap = objectMapper.readValue(exchange.getIn().getBody().toString(), new TypeReference>() {}); + HashMap myMap = objectMapper.readValue(exchange.getIn().getBody().toString(), + new TypeReference>() { + }); String url = myMap.get("url"); log.info("found url: {}", url); MediaFile mediaFile = mediaFileService.findAllMediaFilesByUrl(url); @@ -32,11 +33,18 @@ public class AddLinkProcessor implements Processor { log.info("URL not found, create MediaFile"); mediaFile = new MediaFile(); mediaFile.setUrl(url); + mediaFile.setPath(""); + mediaFile.setCloudLink(""); + mediaFile.setFileName(""); + mediaFile.setTitle(""); mediaFile.setReview(true); mediaFile.setShouldDownload(true); MediaFile mediaFileResult = mediaFileService.saveMediaFile(mediaFile); log.info("created MediaFile with {}", mediaFileResult.getId()); exchange.getMessage().getHeaders().put("mediafile_id", mediaFileResult.getId()); + } else { + log.info("found MediaFile with {}", mediaFile.getId()); + exchange.getMessage().getHeaders().put("mediafile_id", mediaFile.getId()); } log.info("found MediaFile: {}", mediaFile); Map map = exchange.getMessage().getHeaders();