implement routes for MediaFile, MediaVideo and MediaLofi

kontor-spring/build.gradle

@@ -64,6 +64,7 @@ dependencies {
     implementation libs.jackson
     implementation libs.gson
     implementation libs.json
+    implementation libs.jsoup
     implementation 'org.hibernate.orm:hibernate-community-dialects'
     testImplementation('org.springframework.boot:spring-boot-starter-test') {
         exclude group: 'org.junit.vintage', module: 'junit-vintage-engine'

kontor-spring/gradle/libs.versions.toml

@@ -20,6 +20,7 @@ lombok = "8.11"
 gson = "2.9.0"
 jackson = "2.16.1"
 json_simple = "1.1.1"
+jsoup = "1.23.1"
 mail = "1.6.2"
 hypersistence = "3.9.10"
 jolokia = "2.6.1"
@@ -36,6 +37,7 @@ picocli = { module = "info.picocli:picocli", version.ref = "picoli" }
 slf4j = { module = "org.slf4j:slf4j-api", version.ref = "slf4j" }
 hsqldb = { module = "org.hsqldb:hsqldb", version.ref = "hsqldb" }
 gson = { module = "com.google.code.gson:gson", version.ref = "gson" }
+jsoup = { module = "org.jsoup:jsoup", version.ref = "jsoup" }
 jackson = { module = "com.fasterxml.jackson.core:jackson-databind", version.ref = "jackson" }
 json = { module = "com.googlecode.json-simple:json-simple", version.ref ="json_simple" }
 mail = { module = "com.sun.mail:javax.mail", version.ref  ="mail" }

kontor-spring/src/integrationTest/java/de/thpeetz/kontor/views/tysc/CardSetViewTest.java

@@ -14,8 +14,6 @@ import org.springframework.boot.test.context.SpringBootTest;
 import com.vaadin.flow.component.grid.Grid;
 
 import de.thpeetz.kontor.data.tysc.CardSet;
-import de.thpeetz.kontor.views.tysc.CardSetForm;
-import de.thpeetz.kontor.views.tysc.CardSetView;
 
 @SpringBootTest
 class CardSetViewTest {

kontor-spring/src/integrationTest/java/de/thpeetz/kontor/views/tysc/CardViewTest.java

@@ -14,8 +14,6 @@ import org.springframework.boot.test.context.SpringBootTest;
 import com.vaadin.flow.component.grid.Grid;
 
 import de.thpeetz.kontor.data.tysc.Card;
-import de.thpeetz.kontor.views.tysc.CardForm;
-import de.thpeetz.kontor.views.tysc.CardView;
 
 @SpringBootTest
 class CardViewTest {

kontor-spring/src/integrationTest/java/de/thpeetz/kontor/views/tysc/FieldPositionViewTest.java

@@ -14,8 +14,6 @@ import org.springframework.boot.test.context.SpringBootTest;
 import com.vaadin.flow.component.grid.Grid;
 
 import de.thpeetz.kontor.data.tysc.FieldPosition;
-import de.thpeetz.kontor.views.tysc.PositionForm;
-import de.thpeetz.kontor.views.tysc.PositionView;
 
 @SpringBootTest
 class FieldPositionViewTest {

kontor-spring/src/integrationTest/java/de/thpeetz/kontor/views/tysc/PlayerViewTest.java

@@ -14,8 +14,6 @@ import org.springframework.boot.test.context.SpringBootTest;
 import com.vaadin.flow.component.grid.Grid;
 
 import de.thpeetz.kontor.data.tysc.Player;
-import de.thpeetz.kontor.views.tysc.PlayerForm;
-import de.thpeetz.kontor.views.tysc.PlayerView;
 
 @SpringBootTest
 class PlayerViewTest {

kontor-spring/src/integrationTest/java/de/thpeetz/kontor/views/tysc/RoosterViewTest.java

@@ -14,8 +14,6 @@ import org.springframework.boot.test.context.SpringBootTest;
 import com.vaadin.flow.component.grid.Grid;
 
 import de.thpeetz.kontor.data.tysc.Rooster;
-import de.thpeetz.kontor.views.tysc.RoosterForm;
-import de.thpeetz.kontor.views.tysc.RoosterView;
 
 @SpringBootTest
 class RoosterViewTest {

kontor-spring/src/integrationTest/java/de/thpeetz/kontor/views/tysc/SportViewTest.java

@@ -14,8 +14,6 @@ import org.springframework.boot.test.context.SpringBootTest;
 import com.vaadin.flow.component.grid.Grid;
 
 import de.thpeetz.kontor.data.tysc.Sport;
-import de.thpeetz.kontor.views.tysc.SportForm;
-import de.thpeetz.kontor.views.tysc.SportView;
 
 @SpringBootTest
 class SportViewTest {

kontor-spring/src/integrationTest/java/de/thpeetz/kontor/views/tysc/TeamViewTest.java

@@ -14,8 +14,6 @@ import org.springframework.boot.test.context.SpringBootTest;
 import com.vaadin.flow.component.grid.Grid;
 
 import de.thpeetz.kontor.data.tysc.Team;
-import de.thpeetz.kontor.views.tysc.TeamForm;
-import de.thpeetz.kontor.views.tysc.TeamView;
 
 @SpringBootTest
 class TeamViewTest {

kontor-spring/src/integrationTest/java/de/thpeetz/kontor/views/tysc/VendorViewTest.java

@@ -14,8 +14,6 @@ import org.springframework.boot.test.context.SpringBootTest;
 import com.vaadin.flow.component.grid.Grid;
 
 import de.thpeetz.kontor.data.tysc.Vendor;
-import de.thpeetz.kontor.views.tysc.VendorForm;
-import de.thpeetz.kontor.views.tysc.VendorView;
 
 @SpringBootTest
 class VendorViewTest {

kontor-spring/src/main/java/de/thpeetz/kontor/constants/MediaConstants.java

@@ -25,6 +25,12 @@ public class MediaConstants {
     private static final String MEDIAARTICLE = "Media Article";
     private static final String MEDIAACTOR = "Media Actor";
 
+    public static final String URL = "url";
+    public static final String LINKTITLE = "linkTitle";
+    public static final String LOFI_ID = "lofi_id";
+    public static final String FILE_ID = "file_id";
+    public static final String VIDEO_ID = "video_id";
+
     public static SideNavItem getMediaNavigation(ArrayList<String> roles) {
         SideNavItem media = new SideNavItem(MEDIA, MEDIAFILE_ROUTE, VaadinIcon.VIMEO.create());
         media.addItem(new SideNavItem(MEDIAVIDEO, MediaVideoView.class));

kontor-spring/src/main/java/de/thpeetz/kontor/data/media/MediaLofi.java

@@ -0,0 +1,32 @@
+package de.thpeetz.kontor.data.media;
+
+import de.thpeetz.kontor.data.common.AbstractEntity;
+import jakarta.annotation.Nullable;
+import jakarta.persistence.Entity;
+import jakarta.persistence.Table;
+import jakarta.persistence.UniqueConstraint;
+import lombok.EqualsAndHashCode;
+import lombok.Getter;
+import lombok.Setter;
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+@Getter
+@Setter
+@EqualsAndHashCode(callSuper = false)
+@Entity
+@Table(uniqueConstraints = { @UniqueConstraint(columnNames = { "url" }) })
+public class MediaLofi extends AbstractEntity {
+
+    private String url;
+
+    private boolean review;
+
+    private boolean shouldDownload;
+
+    @Nullable
+    private String title;
+
+    @Nullable
+    private String fileName;
+}

kontor-spring/src/main/java/de/thpeetz/kontor/integration/routes/QueueMediaLink.java

@@ -4,6 +4,7 @@ import org.apache.camel.builder.RouteBuilder;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
+import de.thpeetz.kontor.constants.MediaConstants;
 import de.thpeetz.kontor.integration.services.CheckLinkProcessor;
 import de.thpeetz.kontor.services.MediaFileService;
 
@@ -32,10 +33,7 @@ public class QueueMediaLink extends RouteBuilder {
                 .trace(true)
                 .process(new CheckLinkProcessor(mediaFileService))
                 .choice()
-                .when(exchangeProperty("linkId").isNotNull())
+                .when(header(MediaConstants.FILE_ID).isNotNull()).to("jms:queue:media.link.duplicate")
-                .to("jms:queue:media.link.add")
+                .otherwise().to("jms:queue:media.link.add");
-                .otherwise()
-                .to("jms:queue:DLQ")
-                .to("jms:queue:media.link.processed");
     }
 }

kontor-spring/src/main/java/de/thpeetz/kontor/integration/routes/QueueMediaLinkAdd.java

@@ -1,9 +1,11 @@
 package de.thpeetz.kontor.integration.routes;
+
 import org.apache.camel.builder.RouteBuilder;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 import de.thpeetz.kontor.integration.services.AddLinkProcessor;
+import de.thpeetz.kontor.integration.services.UrlTitleProcessor;
 import de.thpeetz.kontor.services.MediaFileService;
 
 @Component
@@ -20,11 +22,11 @@ public class QueueMediaLinkAdd extends RouteBuilder {
     @Override
     public void configure() throws Exception {
         from("jms:queue:media.link.add")
-                .routeId("read-queue-media-link-add")
+                .routeId("media.link.add")
                 .log("${body}")
                 .trace(true)
+                .process(new UrlTitleProcessor())
                 .process(new AddLinkProcessor(mediaFileService))
-                .to("jms:queue:media.link.update_title")
                 .to("jms:queue:media.link.add.processed");
     }
 }

kontor-spring/src/main/java/de/thpeetz/kontor/integration/routes/QueueMediaLoFi.java

@@ -4,18 +4,19 @@ import org.apache.camel.builder.RouteBuilder;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
+import de.thpeetz.kontor.constants.MediaConstants;
 import de.thpeetz.kontor.integration.services.CheckLoFiProcessor;
-import de.thpeetz.kontor.services.MediaFileService;
+import de.thpeetz.kontor.services.MediaLofiService;
 
 @Component
 public class QueueMediaLoFi extends RouteBuilder {
 
     @Autowired
-    private final MediaFileService mediaFileService;
+    private final MediaLofiService mediaLofiService;
 
     @Autowired
-    public QueueMediaLoFi(MediaFileService mediaFileService) {
+    public QueueMediaLoFi(MediaLofiService mediaLofiService) {
-        this.mediaFileService = mediaFileService;
+        this.mediaLofiService = mediaLofiService;
     }
 
     @Override
@@ -30,12 +31,10 @@ public class QueueMediaLoFi extends RouteBuilder {
                 .routeId("media.lofi")
                 .log("${body}")
                 .trace(true)
-                .process(new CheckLoFiProcessor(mediaFileService))
+                .process(new CheckLoFiProcessor(mediaLofiService))
+                .to("jms:queue:media.lofi.processed")
                 .choice()
-                .when(exchangeProperty("linkId").isNotNull())
+                .when(header(MediaConstants.LOFI_ID).isNotNull()).to("jms:queue:media.lofi.duplicate")
-                .to("jms:queue:media.lofi.add")
+                .otherwise().to("jms:queue:media.lofi.add");
-                .otherwise()
-                .to("jms:queue:DLQ")
-                .to("jms:queue:media.lofi.processed");
     }
 }

kontor-spring/src/main/java/de/thpeetz/kontor/integration/routes/QueueMediaLoFiAdd.java

@@ -4,24 +4,28 @@ import org.apache.camel.builder.RouteBuilder;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
-import de.thpeetz.kontor.services.MediaFileService;
+import de.thpeetz.kontor.integration.services.AddLofiProcessor;
+import de.thpeetz.kontor.integration.services.UrlTitleProcessor;
+import de.thpeetz.kontor.services.MediaLofiService;
 
 @Component
 public class QueueMediaLoFiAdd extends RouteBuilder {
 
     @Autowired
-    private final MediaFileService mediaFileService;
+    private final MediaLofiService mediaLofiService;
 
     @Autowired
-    public QueueMediaLoFiAdd(MediaFileService mediaFileService) {
+    public QueueMediaLoFiAdd(MediaLofiService mediaLofiService) {
-        this.mediaFileService = mediaFileService;
+        this.mediaLofiService = mediaLofiService;
     }
 
     @Override
     public void configure() throws Exception {
         from("jms:queue:media.lofi.add")
-                .routeId("read-queue-media-lofi-add")
+                .routeId("media.lofi.add")
                 .log("${body}")
+                .process(new UrlTitleProcessor())
+                .process(new AddLofiProcessor(mediaLofiService))
                 .to("jms:queue:media.lofi.add.processed");
     }
 }

kontor-spring/src/main/java/de/thpeetz/kontor/integration/routes/QueueMediaVideo.java

@@ -4,18 +4,19 @@ import org.apache.camel.builder.RouteBuilder;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
-import de.thpeetz.kontor.integration.services.CheckLoFiProcessor;
+import de.thpeetz.kontor.constants.MediaConstants;
-import de.thpeetz.kontor.services.MediaFileService;
+import de.thpeetz.kontor.integration.services.CheckVideoProcessor;
+import de.thpeetz.kontor.services.MediaVideoService;
 
 @Component
 public class QueueMediaVideo extends RouteBuilder {
 
     @Autowired
-    private final MediaFileService mediaFileService;
+    private final MediaVideoService mediaVideoService;
 
     @Autowired
-    public QueueMediaVideo(MediaFileService mediaFileService) {
+    public QueueMediaVideo(MediaVideoService mediaVideoService) {
-        this.mediaFileService = mediaFileService;
+        this.mediaVideoService = mediaVideoService;
     }
 
     @Override
@@ -30,12 +31,9 @@ public class QueueMediaVideo extends RouteBuilder {
                 .routeId("media.video")
                 .log("${body}")
                 .trace(true)
-                .process(new CheckLoFiProcessor(mediaFileService))
+                .process(new CheckVideoProcessor(mediaVideoService))
                 .choice()
-                .when(exchangeProperty("linkId").isNotNull())
+                .when(header(MediaConstants.VIDEO_ID).isNotNull()).to("jms:queue:media.video.duplicate")
-                .to("jms:queue:media.video.add")
+                .otherwise().to("jms:queue:media.video.add");
-                .otherwise()
-                .to("jms:queue:DLQ")
-                .to("jms:queue:media.video.processed");
     }
 }

kontor-spring/src/main/java/de/thpeetz/kontor/integration/routes/QueueMediaVideoAdd.java

@@ -4,24 +4,30 @@ import org.apache.camel.builder.RouteBuilder;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
-import de.thpeetz.kontor.services.MediaFileService;
+import de.thpeetz.kontor.integration.services.AddVideoProcessor;
+import de.thpeetz.kontor.integration.services.UrlTitleProcessor;
+import de.thpeetz.kontor.services.MediaVideoService;
 
 @Component
 public class QueueMediaVideoAdd extends RouteBuilder {
 
+    @SuppressWarnings("unused")
     @Autowired
-    private final MediaFileService mediaFileService;
+    private final MediaVideoService mediaVideoService;
 
     @Autowired
-    public QueueMediaVideoAdd(MediaFileService mediaFileService) {
+    public QueueMediaVideoAdd(MediaVideoService mediaVideoService) {
-        this.mediaFileService = mediaFileService;
+        this.mediaVideoService = mediaVideoService;
     }
 
     @Override
     public void configure() throws Exception {
         from("jms:queue:media.video.add")
-                .routeId("read-queue-media-video-add")
+                .routeId("media.video.add")
                 .log("${body}")
+                .trace(true)
+                .process(new UrlTitleProcessor())
+                .process(new AddVideoProcessor(mediaVideoService))
                 .to("jms:queue:media.video.add.processed");
     }
 }

kontor-spring/src/main/java/de/thpeetz/kontor/integration/services/AddLinkProcessor.java

@@ -1,16 +1,14 @@
 package de.thpeetz.kontor.integration.services;
 
-import com.fasterxml.jackson.core.type.TypeReference;
+import de.thpeetz.kontor.constants.MediaConstants;
-import com.fasterxml.jackson.databind.ObjectMapper;
-
 import de.thpeetz.kontor.data.media.MediaFile;
 import de.thpeetz.kontor.services.MediaFileService;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
-
+import org.json.simple.JSONObject;
-import java.util.HashMap;
+import org.json.simple.parser.JSONParser;
-import java.util.Map;
+import org.json.simple.parser.ParseException;
 
 @Slf4j
 public class AddLinkProcessor implements Processor {
@@ -23,32 +21,33 @@ public class AddLinkProcessor implements Processor {
 
     @Override
     public void process(Exchange exchange) throws Exception {
-        ObjectMapper objectMapper = new ObjectMapper();
+        String messageBody = exchange.getIn().getBody(String.class);
-        HashMap<String, String> myMap = objectMapper.readValue(exchange.getIn().getBody().toString(),
+        log.info("MediaFile URL to add: {}", messageBody);
-                new TypeReference<HashMap<String, String>>() {
+        String title = exchange.getIn().getHeader(MediaConstants.LINKTITLE).toString();
-                });
+
-        String url = myMap.get("url");
+        JSONParser parser = new JSONParser();
-        log.info("found url: {}", url);
+        try {
-        MediaFile mediaFile = mediaFileService.findAllMediaFilesByUrl(url);
+            JSONObject jsonObject = (JSONObject) parser.parse(messageBody);
-        if (mediaFile == null) {
+            String url = (String) jsonObject.get(MediaConstants.URL);
-            log.info("URL not found, create MediaFile");
+            MediaFile mediaFile = new MediaFile();
-            mediaFile = new MediaFile();
             mediaFile.setUrl(url);
             mediaFile.setPath("");
             mediaFile.setCloudLink("");
             mediaFile.setFileName("");
-            mediaFile.setTitle("");
+            mediaFile.setTitle(title);
             mediaFile.setReview(true);
             mediaFile.setShouldDownload(true);
             MediaFile mediaFileResult = mediaFileService.saveMediaFile(mediaFile);
-            log.info("created MediaFile with {}", mediaFileResult.getId());
+            if (mediaFileResult != null) {
-            exchange.getMessage().getHeaders().put("mediafile_id", mediaFileResult.getId());
+                log.info("MediaFile saved: {}", mediaFileResult.toString());
-        } else {
+                exchange.getIn().setHeader(MediaConstants.FILE_ID, mediaFileResult.getId());
-            log.info("found MediaFile with {}", mediaFile.getId());
+            } else {
-            exchange.getMessage().getHeaders().put("mediafile_id", mediaFile.getId());
+                log.info("MediaFile could not saved: {}", url);
+                exchange.getIn().setHeader(MediaConstants.FILE_ID, null);
+            }
+        } catch (ParseException pe) {
+            log.info("parse exception: {}", pe.toString());
+            exchange.getIn().setHeader(MediaConstants.FILE_ID, null);
         }
-        log.info("found MediaFile: {}", mediaFile);
-        Map<String, Object> map = exchange.getMessage().getHeaders();
-        log.info("Headers: {}", map);
     }
 }

kontor-spring/src/main/java/de/thpeetz/kontor/integration/services/AddLinkService.java

@@ -1,22 +0,0 @@
-package de.thpeetz.kontor.integration.services;
-
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.core.type.TypeReference;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Service;
-
-import java.util.HashMap;
-
-@Service
-@Slf4j
-public class AddLinkService {
-
-    public void fromQueue(String messageBody) throws JsonProcessingException {
-        log.info("get body: {}", messageBody);
-        ObjectMapper objectMapper = new ObjectMapper();
-        HashMap<String,String> myMap = objectMapper.readValue(messageBody, new TypeReference<HashMap<String,String>>() {});
-        String url = myMap.get("url");
-        log.info("found url: {}", url);
-    }
-}

kontor-spring/src/main/java/de/thpeetz/kontor/integration/services/AddLofiProcessor.java

@@ -0,0 +1,52 @@
+package de.thpeetz.kontor.integration.services;
+
+import org.apache.camel.Exchange;
+import org.apache.camel.Processor;
+import org.json.simple.JSONObject;
+import org.json.simple.parser.JSONParser;
+import org.json.simple.parser.ParseException;
+
+import de.thpeetz.kontor.constants.MediaConstants;
+import de.thpeetz.kontor.data.media.MediaLofi;
+import de.thpeetz.kontor.services.MediaLofiService;
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+public class AddLofiProcessor implements Processor {
+
+    private MediaLofiService mediaLofiService;
+
+    public AddLofiProcessor(MediaLofiService medialLofiService) {
+        this.mediaLofiService = medialLofiService;
+    }
+
+    @Override
+    public void process(Exchange exchange) throws Exception {
+        String messageBody = exchange.getIn().getBody(String.class);
+        log.info("LoFi URL to add: {}", messageBody);
+        String title = exchange.getIn().getHeader(MediaConstants.LINKTITLE).toString();
+
+        JSONParser parser = new JSONParser();
+        try {
+            JSONObject jsonObject = (JSONObject) parser.parse(messageBody);
+            String url = (String) jsonObject.get(MediaConstants.URL);
+            MediaLofi mediaLofi = new MediaLofi();
+            mediaLofi.setUrl(url);
+            mediaLofi.setTitle(title);
+            mediaLofi.setFileName("");
+            mediaLofi.setReview(false);
+            mediaLofi.setShouldDownload(false);
+            mediaLofi = this.mediaLofiService.saveMediaLofi(mediaLofi);
+            if (mediaLofi != null) {
+                log.info("MediaLofi saved: {}", mediaLofi.toString());
+                exchange.getIn().setHeader(MediaConstants.LOFI_ID, mediaLofi.getId());
+            } else {
+                log.info("MediaLofi could not saved: {}", url);
+                exchange.getIn().setHeader(MediaConstants.LOFI_ID, null);
+            }
+        } catch (ParseException pe) {
+            log.info("parse exception: {}", pe.toString());
+            exchange.getIn().setHeader(MediaConstants.LOFI_ID, null);
+        }
+    }
+}

kontor-spring/src/main/java/de/thpeetz/kontor/integration/services/AddVideoProcessor.java

@@ -0,0 +1,54 @@
+package de.thpeetz.kontor.integration.services;
+
+import org.apache.camel.Exchange;
+import org.apache.camel.Processor;
+import org.json.simple.JSONObject;
+import org.json.simple.parser.JSONParser;
+import org.json.simple.parser.ParseException;
+
+import de.thpeetz.kontor.constants.MediaConstants;
+import de.thpeetz.kontor.data.media.MediaVideo;
+import de.thpeetz.kontor.services.MediaVideoService;
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+public class AddVideoProcessor implements Processor {
+
+    private final MediaVideoService mediaVideoService;
+
+    public AddVideoProcessor(MediaVideoService mediaVideoService) {
+        this.mediaVideoService = mediaVideoService;
+    }
+
+    @Override
+    public void process(Exchange exchange) throws Exception {
+        String messageBody = exchange.getIn().getBody(String.class);
+        log.info("MediaVideo URL to add: {}", messageBody);
+        String title = exchange.getIn().getHeader(MediaConstants.LINKTITLE).toString();
+
+        JSONParser parser = new JSONParser();
+        try {
+            JSONObject jsonObject = (JSONObject) parser.parse(messageBody);
+            String url = (String) jsonObject.get(MediaConstants.URL);
+            MediaVideo mediaVideo = new MediaVideo();
+            mediaVideo.setUrl(url);
+            mediaVideo.setPath("");
+            mediaVideo.setCloudLink("");
+            mediaVideo.setFileName("");
+            mediaVideo.setTitle(title);
+            mediaVideo.setReview(true);
+            mediaVideo.setShouldDownload(true);
+            MediaVideo mediaVideoResult = mediaVideoService.saveMediaVideo(mediaVideo);
+            if (mediaVideoResult != null) {
+                log.info("MediaVideo saved: {}", mediaVideoResult.toString());
+                exchange.getIn().setHeader(MediaConstants.VIDEO_ID, mediaVideoResult.getId());
+            } else {
+                log.info("MediaFile could not saved: {}", url);
+                exchange.getIn().setHeader(MediaConstants.VIDEO_ID, null);
+            }
+        } catch (ParseException pe) {
+            log.info("parse exception: {}", pe.toString());
+            exchange.getIn().setHeader(MediaConstants.VIDEO_ID, null);
+        }
+    }
+}

kontor-spring/src/main/java/de/thpeetz/kontor/integration/services/CheckLinkProcessor.java

@@ -1,17 +1,13 @@
 package de.thpeetz.kontor.integration.services;
 
-// import java.nio.charset.StandardCharsets;
-// import java.util.HashMap;
-
 import org.apache.camel.Exchange;
 import org.apache.camel.Processor;
 import org.json.simple.JSONObject;
 import org.json.simple.parser.JSONParser;
 import org.json.simple.parser.ParseException;
 
-// import com.fasterxml.jackson.core.type.TypeReference;
+import de.thpeetz.kontor.constants.MediaConstants;
-// import com.fasterxml.jackson.databind.ObjectMapper;
+import de.thpeetz.kontor.data.media.MediaFile;
-
 import de.thpeetz.kontor.services.MediaFileService;
 import lombok.extern.slf4j.Slf4j;
 
@@ -29,22 +25,21 @@ public class CheckLinkProcessor implements Processor {
         String messageBody = exchange.getIn().getBody(String.class);
         log.info("message body: {}", messageBody);
 
-        // ObjectMapper objectMapper = new ObjectMapper();
-        // HashMap<String, String> myMap = objectMapper.readValue(messageBody, new TypeReference<HashMap<String, String>>() {});
-        // String url = myMap.get("url");
-        // log.info("found url: {}", url);
-        // exchange.getIn().setHeader("linkId", null);
-        // exchange.setProperty("linkId", null);
-
         JSONParser parser = new JSONParser();
         try {
             JSONObject jsonObject = (JSONObject) parser.parse(messageBody);
-            String url = (String)jsonObject.get("url");
+            String url = (String) jsonObject.get(MediaConstants.URL);
-            log.info("found url: {}", url);
+            MediaFile mediaFile = mediaFileService.findAllMediaFilesByUrl(url);
-            exchange.getIn().setHeader("linkId", null);
+            if (mediaFile != null) {
+                log.info("found url: {}", url);
+                exchange.getIn().setHeader(MediaConstants.FILE_ID, mediaFile.getId());
+            } else {
+                log.info("url not found: {}", url);
+                exchange.getIn().setHeader(MediaConstants.FILE_ID, null);
+            }
         } catch (ParseException pe) {
             log.info("parse exception: {}", pe.toString());
-            exchange.getIn().setHeader("linkId", null);
+            exchange.getIn().setHeader(MediaConstants.FILE_ID, null);
         }
     }
 }

kontor-spring/src/main/java/de/thpeetz/kontor/integration/services/CheckLoFiProcessor.java

@@ -6,16 +6,18 @@ import org.json.simple.JSONObject;
 import org.json.simple.parser.JSONParser;
 import org.json.simple.parser.ParseException;
 
-import de.thpeetz.kontor.services.MediaFileService;
+import de.thpeetz.kontor.constants.MediaConstants;
+import de.thpeetz.kontor.data.media.MediaLofi;
+import de.thpeetz.kontor.services.MediaLofiService;
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
 public class CheckLoFiProcessor implements Processor {
 
-    private final MediaFileService mediaFileService;
+    private final MediaLofiService medialLofiService;
 
-    public CheckLoFiProcessor(MediaFileService mediaFileService) {
+    public CheckLoFiProcessor(MediaLofiService medialLofiService) {
-        this.mediaFileService = mediaFileService;
+        this.medialLofiService = medialLofiService;
     }
 
     @Override
@@ -26,12 +28,18 @@ public class CheckLoFiProcessor implements Processor {
         JSONParser parser = new JSONParser();
         try {
             JSONObject jsonObject = (JSONObject) parser.parse(messageBody);
-            String url = (String) jsonObject.get("url");
+            String url = (String) jsonObject.get(MediaConstants.URL);
-            log.info("found url: {}", url);
+            MediaLofi mediaLofi = medialLofiService.findAllMediaLofiByUrl(url);
-            exchange.getIn().setHeader("linkId", null);
+            if (mediaLofi != null) {
+                log.info("found url: {}", url);
+                exchange.getIn().setHeader(MediaConstants.LOFI_ID, mediaLofi.getId());
+            } else {
+                log.info("url not found: {}", url);
+                exchange.getIn().setHeader(MediaConstants.LOFI_ID, null);
+            }
         } catch (ParseException pe) {
             log.info("parse exception: {}", pe.toString());
-            exchange.getIn().setHeader("linkId", null);
+            exchange.getIn().setHeader(MediaConstants.LOFI_ID, null);
         }
     }
 }

kontor-spring/src/main/java/de/thpeetz/kontor/integration/services/CheckVideoProcessor.java

@@ -6,16 +6,17 @@ import org.json.simple.JSONObject;
 import org.json.simple.parser.JSONParser;
 import org.json.simple.parser.ParseException;
 
-import de.thpeetz.kontor.services.MediaFileService;
+import de.thpeetz.kontor.services.MediaVideoService;
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
 public class CheckVideoProcessor implements Processor {
 
-    private final MediaFileService mediaFileService;
+    @SuppressWarnings("unused")
+    private final MediaVideoService mediaVideoService;
 
-    public CheckVideoProcessor(MediaFileService mediaFileService) {
+    public CheckVideoProcessor(MediaVideoService mediaVideoService) {
-        this.mediaFileService = mediaFileService;
+        this.mediaVideoService = mediaVideoService;
     }
 
     @Override

kontor-spring/src/main/java/de/thpeetz/kontor/integration/services/UrlTitleProcessor.java

@@ -0,0 +1,40 @@
+package de.thpeetz.kontor.integration.services;
+
+import java.io.IOException;
+
+import org.apache.camel.Exchange;
+import org.apache.camel.Processor;
+import org.json.simple.JSONObject;
+import org.json.simple.parser.JSONParser;
+import org.json.simple.parser.ParseException;
+import org.jsoup.Jsoup;
+import org.jsoup.nodes.Document;
+
+import de.thpeetz.kontor.constants.MediaConstants;
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+public class UrlTitleProcessor implements Processor {
+
+    @Override
+    public void process(Exchange exchange) throws Exception {
+        String messageBody = exchange.getIn().getBody(String.class);
+        log.info("URL to check: {}", messageBody);
+
+        JSONParser parser = new JSONParser();
+        try {
+            JSONObject jsonObject = (JSONObject) parser.parse(messageBody);
+            String url = (String) jsonObject.get(MediaConstants.URL);
+            Document doc = Jsoup.connect(url).get();
+            String title = doc.title();
+            log.info("URL Title: {}", title);
+            exchange.getIn().setHeader(MediaConstants.LINKTITLE, title);
+        } catch (IOException io) {
+            log.info("IOException: {}", io.toString());
+            exchange.getIn().setHeader(MediaConstants.LINKTITLE, "");
+        } catch (ParseException pe) {
+            log.info("parse exception: {}", pe.toString());
+            exchange.getIn().setHeader(MediaConstants.LINKTITLE, "");
+        }
+    }
+}

kontor-spring/src/main/java/de/thpeetz/kontor/repository/media/MediaLofiRepository.java

@@ -0,0 +1,33 @@
+package de.thpeetz.kontor.repository.media;
+
+import java.util.List;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+
+import de.thpeetz.kontor.data.media.MediaLofi;
+
+public interface MediaLofiRepository extends JpaRepository<MediaLofi, String> {
+
+    @Query("select m from MediaLofi m " +
+            "where lower(m.url) like lower(concat('%', :searchTerm, '%')) or lower(m.title) like lower(concat('%', :searchTerm, '%'))")
+    List<MediaLofi> search(@Param("searchTerm") String searchTerm);
+
+    List<MediaLofi> findByShouldDownload(Boolean shouldDownload);
+
+    List<MediaLofi> findByReview(Boolean review);
+
+    List<MediaLofi> findByReviewAndShouldDownload(Boolean review, Boolean shouldDownload);
+
+    MediaLofi findByUrl(String url);
+
+    @Query("select m from MediaLofi m " +
+            "where lower(m.url) like lower(concat('%', :searchTerm, '%')) or lower(m.title) like lower(concat('%', :searchTerm, '%')) "
+            +
+            "AND m.review=:review AND m.shouldDownload=:download")
+    List<MediaLofi> search(
+            @Param("searchTerm") String searchTerm,
+            @Param("review") boolean searchReview,
+            @Param("download") boolean searchDownload);
+}

kontor-spring/src/main/java/de/thpeetz/kontor/services/MediaLofiService.java

@@ -0,0 +1,86 @@
+package de.thpeetz.kontor.services;
+
+import java.util.List;
+
+import org.springframework.stereotype.Service;
+
+import de.thpeetz.kontor.data.media.MediaLofi;
+import de.thpeetz.kontor.repository.media.MediaLofiRepository;
+import de.thpeetz.kontor.views.common.SearchFilter;
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+@Service
+public class MediaLofiService {
+
+    private final MediaLofiRepository mediaLofiRepository;
+
+    public MediaLofiService(MediaLofiRepository mediaLofiRepository) {
+        this.mediaLofiRepository = mediaLofiRepository;
+    }
+
+    public List<MediaLofi> findAllMediaLofisByString(String stringFilter) {
+        List<MediaLofi> results;
+        if (stringFilter == null || stringFilter.isEmpty()) {
+            results = mediaLofiRepository.findAll();
+        } else {
+            results = mediaLofiRepository.search(stringFilter);
+        }
+        log.debug("Found " + results.size() + " entries");
+        return results;
+    }
+
+    public MediaLofi findAllMediaLofiByUrl(String url) {
+        return mediaLofiRepository.findByUrl(url);
+    }
+
+    public List<MediaLofi> findAllMediaLofis(SearchFilter searchFilter) {
+        if (searchFilter == null) {
+            return mediaLofiRepository.findAll();
+        } else {
+            if (searchFilter.getSearchTerm() != null && searchFilter.getFilterOptions().isEmpty()) {
+                log.info("find MediaFiles by using searchTerm: {}", searchFilter.getSearchTerm());
+                List<MediaLofi> results = mediaLofiRepository.search(searchFilter.getSearchTerm());
+                log.info("found {} entries", results.size());
+                return results;
+            }
+            if (searchFilter.getFilterOptions().size() == 1) {
+                log.info("using searchFilter: {}", searchFilter);
+                String filter = searchFilter.getFilterOptions().get(0).getName();
+                Boolean filterValue = searchFilter.getFilterOptions().get(0).getValue();
+                if (filter == "Überprüfung") {
+                    List<MediaLofi> results = mediaLofiRepository.findByReview(filterValue);
+                    log.info("found {} entries", results.size());
+                    return results;
+                }
+                if (filter == "Download") {
+                    List<MediaLofi> results = mediaLofiRepository.findByShouldDownload(filterValue);
+                    log.info("found {} entries", results.size());
+                    return results;
+                }
+            }
+            if (searchFilter.getFilterOptions().size() == 2) {
+                log.info("using searchFilter: {}", searchFilter);
+                List<MediaLofi> results = mediaLofiRepository.search(searchFilter.getSearchTerm(),
+                        searchFilter.getFilterOptions().get(0).getValue(),
+                        searchFilter.getFilterOptions().get(1).getValue());
+                log.info("found {} entries", results.size());
+                return results;
+            }
+        }
+        log.info("noch filter used");
+        return mediaLofiRepository.findAll();
+    }
+
+    public MediaLofi saveMediaLofi(MediaLofi mediaLofi) {
+        if (mediaLofi == null) {
+            log.warn("MediaLofi is null. Are you sure you have connected your form to the application?");
+            return null;
+        }
+        return mediaLofiRepository.save(mediaLofi);
+    }
+
+    public void deleteMediaLofi(MediaLofi mediaLofi) {
+        mediaLofiRepository.delete(mediaLofi);
+    }
+}

kontor-spring/src/main/java/de/thpeetz/kontor/services/MediaVideoService.java

@@ -25,12 +25,12 @@ public class MediaVideoService {
         }
     }
 
-    public void saveMediaVideo(MediaVideo mediaVideo) {
+    public MediaVideo saveMediaVideo(MediaVideo mediaVideo) {
         if (mediaVideo == null) {
             log.warn("MediaFile is null. Are you sure you have connected your form to the application?");
-            return;
+            return null;
         }
-        mediaVideoRepository.save(mediaVideo);
+        return mediaVideoRepository.save(mediaVideo);
     }
 
     public void deleteMediaVideo(MediaVideo mediaVideo) {

kontor-spring/src/main/java/de/thpeetz/kontor/views/admin/UserProfileView.java

@@ -19,13 +19,15 @@ import jakarta.annotation.security.PermitAll;
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
-@Route(value="user/profile", layout = MainLayout.class)
+@Route(value = "user/profile", layout = MainLayout.class)
 @PermitAll
 @PageTitle("Profile | User | Kontor")
 public class UserProfileView extends VerticalLayout {
 
+    @SuppressWarnings("unused")
     private SecurityService securityService;
 
+    @SuppressWarnings("unused")
     private AdminService adminService;
 
     TextField firstName = new TextField("First name");

kontor-spring/src/main/java/de/thpeetz/kontor/views/comics/ArtistForm.java

@@ -22,12 +22,12 @@ import lombok.extern.slf4j.Slf4j;
 @Slf4j
 public class ArtistForm extends FormLayout {
 
-    TextField name = new TextField("Name");
+    public TextField name = new TextField("Name");
     TextField weblink = new TextField("Link");
     Grid<ComicWork> comicWorks = new Grid<>(ComicWork.class);
 
-    Button save = new Button("Save");
+    public Button save = new Button("Save");
-    Button delete = new Button("Delete");
+    public Button delete = new Button("Delete");
     Button close = new Button("Cancel");
 
     Binder<Artist> binder = new BeanValidationBinder<>(Artist.class);

kontor-spring/src/main/java/de/thpeetz/kontor/views/comics/ComicForm.java

@@ -28,7 +28,7 @@ public class ComicForm extends FormLayout {
 
     private static final Logger log = LoggerFactory.getLogger(ComicForm.class);
 
-    TextField title = new TextField("Title");
+    public TextField title = new TextField("Title");
     ComboBox<Publisher> publisher = new ComboBox<>("Publisher");
     TextField weblink = new TextField("Link");
     Checkbox currentOrder = new Checkbox("Current order");

kontor-spring/src/main/java/de/thpeetz/kontor/views/comics/ComicLayout.java

@@ -18,10 +18,13 @@ import org.springframework.boot.info.BuildProperties;
 @Slf4j
 public class ComicLayout extends AppLayout {
 
+    @SuppressWarnings("unused")
     private final AdminService adminService;
 
+    @SuppressWarnings("unused")
     private final SecurityService securityService;
 
+    @SuppressWarnings("unused")
     private final BuildProperties buildProperties;
 
     public ComicLayout(AdminService adminService, SecurityService securityService, BuildProperties buildProperties) {
@@ -44,4 +47,3 @@ public class ComicLayout extends AppLayout {
         return navigation;
     }
 }
-

kontor-spring/src/main/java/de/thpeetz/kontor/views/comics/ComicWorkForm.java

@@ -19,7 +19,7 @@ import de.thpeetz.kontor.data.comics.ComicWork;
 import de.thpeetz.kontor.data.comics.Worktype;
 
 public class ComicWorkForm extends FormLayout {
-    ComboBox<Comic> comic = new ComboBox<>("Comic");
+    public ComboBox<Comic> comic = new ComboBox<>("Comic");
     ComboBox<Artist> artist = new ComboBox<>("Artist");
     ComboBox<Worktype> workType = new ComboBox<>("Worktype");
 

kontor-spring/src/main/java/de/thpeetz/kontor/views/comics/IssueForm.java

@@ -29,7 +29,7 @@ public class IssueForm extends FormLayout {
 
     ComboBox<Comic> comic = new ComboBox<>("Comic");
     ComboBox<Volume> volume = new ComboBox<>("Volume");
-    TextField issueNumber = new TextField("Issue number");
+    public TextField issueNumber = new TextField("Issue number");
     TextField title = new TextField("Full Title");
     YearMonthField publishedOn = new YearMonthField();
     Checkbox isRead = new Checkbox("Read");
@@ -61,7 +61,7 @@ public class IssueForm extends FormLayout {
         issueWorks.getColumnByKey("workType.name").setHeader("Work type");
         issueWorks.getColumnByKey("artist.name").setHeader("Artist");
         issueWorks.getColumns().forEach(col -> col.setAutoWidth(true));
-        add(comic, volume, issueNumber, title, publishedOn, isRead, inStock,issueWorks, createButtonsLayout());
+        add(comic, volume, issueNumber, title, publishedOn, isRead, inStock, issueWorks, createButtonsLayout());
     }
 
     private HorizontalLayout createButtonsLayout() {

kontor-spring/src/main/java/de/thpeetz/kontor/views/comics/IssueView.java

@@ -20,8 +20,6 @@ import de.thpeetz.kontor.constants.ComicConstants;
 import de.thpeetz.kontor.data.comics.Comic;
 import de.thpeetz.kontor.data.comics.Issue;
 import de.thpeetz.kontor.services.ComicService;
-import de.thpeetz.kontor.views.comics.IssueForm.DeleteEvent;
-import de.thpeetz.kontor.views.comics.IssueForm.SaveEvent;
 import de.thpeetz.kontor.views.common.ColumnToggleContextMenu;
 import de.thpeetz.kontor.views.common.MainLayout;
 import de.thpeetz.kontor.views.common.StatusIcon;
@@ -43,27 +41,28 @@ public class IssueView extends VerticalLayout {
     @Getter
     Grid<Issue> grid = new Grid<>(Issue.class, false);
     Grid.Column<Issue> idColumn = grid.addColumn(Issue::getId)
-        .setHeader("ID").setResizable(true).setSortable(true);
+            .setHeader("ID").setResizable(true).setSortable(true);
     Grid.Column<Issue> createdColumn = grid.addColumn(Issue::getCreatedDate)
-        .setHeader("Erstellt").setResizable(true).setSortable(true);
+            .setHeader("Erstellt").setResizable(true).setSortable(true);
     Grid.Column<Issue> modifiedColumn = grid.addColumn(Issue::getLastModifiedDate)
-        .setHeader("Geändert").setResizable(true).setSortable(true);
+            .setHeader("Geändert").setResizable(true).setSortable(true);
     Grid.Column<Issue> versionColumn = grid.addColumn(Issue::getVersion)
-        .setHeader("Version").setResizable(true).setSortable(true);
+            .setHeader("Version").setResizable(true).setSortable(true);
     Grid.Column<Issue> titleColumn = grid.addColumn(Issue::getComicTitle)
-        .setHeader("Comic").setResizable(true).setSortable(true);
+            .setHeader("Comic").setResizable(true).setSortable(true);
     Grid.Column<Issue> volumeColumn = grid.addColumn(Issue::getVolumeName)
             .setHeader("Volume").setResizable(true).setSortable(true);
     Grid.Column<Issue> issueNumberColumn = grid.addColumn(Issue::getIssueNumber)
-        .setHeader("Heft Nummer").setResizable(true).setSortable(true);
+            .setHeader("Heft Nummer").setResizable(true).setSortable(true);
     Grid.Column<Issue> issueTitleColumn = grid.addColumn(Issue::getTitle)
             .setHeader("Full Title").setResizable(true).setSortable(true);
     Grid.Column<Issue> publishedOncolumn = grid.addColumn(Issue::getPublishedOn)
             .setHeader("Published").setResizable(true).setSortable(true);
     Grid.Column<Issue> isReadColumn = grid.addComponentColumn(issueColumn -> StatusIcon.create(issueColumn.getIsRead()))
-        .setHeader("Gelesen?").setWidth("6rem").setSortable(true);
+            .setHeader("Gelesen?").setWidth("6rem").setSortable(true);
-    Grid.Column<Issue> inStockColumn = grid.addComponentColumn(issueColumn -> StatusIcon.create(issueColumn.getInStock()))
+    Grid.Column<Issue> inStockColumn = grid
-        .setHeader("Im Bestand?").setWidth("6rem").setSortable(true);
+            .addComponentColumn(issueColumn -> StatusIcon.create(issueColumn.getInStock()))
+            .setHeader("Im Bestand?").setWidth("6rem").setSortable(true);
     ComboBox<Comic> comicFilter = new ComboBox<>("Comic");
     @Getter
     IssueForm form;

kontor-spring/src/main/java/de/thpeetz/kontor/views/comics/StoryArcForm.java

@@ -20,7 +20,7 @@ import java.util.List;
 public class StoryArcForm extends FormLayout {
 
     ComboBox<Comic> comic = new ComboBox<>("Comic");
-    TextField name = new TextField("Story Arc Name");
+    public TextField name = new TextField("Story Arc Name");
 
     Button save = new Button("Save");
     Button delete = new Button("Delete");

kontor-spring/src/main/java/de/thpeetz/kontor/views/comics/StoryArcView.java

@@ -44,7 +44,7 @@ public class StoryArcView extends VerticalLayout {
         updateList();
     }
 
-    StoryArcForm getForm() {
+    public StoryArcForm getForm() {
         return form;
     }
 

kontor-spring/src/main/java/de/thpeetz/kontor/views/comics/TradePaperBackForm.java

@@ -18,7 +18,7 @@ import de.thpeetz.kontor.data.comics.Comic;
 import de.thpeetz.kontor.data.comics.TradePaperback;
 
 public class TradePaperBackForm extends FormLayout {
-    TextField name = new TextField("Name");
+    public TextField name = new TextField("Name");
     ComboBox<Comic> comic = new ComboBox<>("Comic");
     TextField issueStart = new TextField("Issue Start");
     TextField issueEnd = new TextField("Issue End");

kontor-spring/src/main/java/de/thpeetz/kontor/views/comics/VolumeView.java

@@ -44,7 +44,7 @@ public class VolumeView extends VerticalLayout {
         updateList();
     }
 
-    VolumeForm getForm() {
+    public VolumeForm getForm() {
         return form;
     }
 

kontor-spring/src/main/java/de/thpeetz/kontor/views/comics/WorktypeForm.java

@@ -24,7 +24,7 @@ public class WorktypeForm extends FormLayout {
 
     private static final Logger log = LoggerFactory.getLogger(WorktypeForm.class);
 
-    TextField name = new TextField("Name");
+    public TextField name = new TextField("Name");
     Grid<ComicWork> comicWorks = new Grid<>(ComicWork.class);
 
     Button save = new Button("Save");