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<String,String> myMap = objectMapper.readValue(exchange.getIn().getBody().toString(), new TypeReference<HashMap<String,String>>() {});
+        HashMap<String, String> myMap = objectMapper.readValue(exchange.getIn().getBody().toString(),
+                new TypeReference<HashMap<String, String>>() {
+                });
         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<String, Object> map = exchange.getMessage().getHeaders();