feat(Reactive): delete file observation

johnnymillergh · Oct 20, 2020 · e9ea525 · e9ea525
1 parent bd7c695
commit e9ea525
Show file tree

Hide file tree

Showing 3 changed files with 21 additions and 7 deletions.
diff --git a/...a/com/jmframework/boot/mediastreamingspringbootautoconfigure/configuration/Bootstrap.java b/...a/com/jmframework/boot/mediastreamingspringbootautoconfigure/configuration/Bootstrap.java
@@ -40,7 +40,7 @@ public void afterInitialization() {
         fileWatcher.setFileWatcherHandler(new FileWatcherHandler() {
             @Override
             public void onCreated(Path file) {
-                log.info("onCreated: {}", file);
+                log.debug("Created file observed: {}", file);
                 Video video = new Video();
                 video.setName(file.getFileName().toString());
                 video.setLocation(file);
@@ -49,12 +49,13 @@ public void onCreated(Path file) {
 
             @Override
             public void onDeleted(Path file) {
-                log.info("onDeleted: {}", file);
+                log.debug("Deleted file observed: {}", file);
+                Mono.just(file).then(videoRepository.deleteVideoByPath(file)).subscribe();
             }
 
             @Override
             public void onModified(Path file) {
-                log.info("onModified: {}", file);
+                log.info("Modified file observed: {}", file);
                 Video video = new Video();
                 video.setName(file.getFileName().toString());
                 video.setLocation(file);

diff --git a/...om/jmframework/boot/mediastreamingspringbootautoconfigure/repository/VideoRepository.java b/...om/jmframework/boot/mediastreamingspringbootautoconfigure/repository/VideoRepository.java
@@ -4,6 +4,8 @@
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
+import java.nio.file.Path;
+
 /**
  * Description: VideoRepository, change description here.
  *
@@ -33,6 +35,14 @@ public interface VideoRepository {
      */
     Mono<Video> addVideo(Video video);
 
+    /**
+     * Delete video by path mono.
+     *
+     * @param path the path
+     * @return the mono
+     */
+    Mono<Video> deleteVideoByPath(Path path);
+
     /**
      * Delete video by name mono.
      *

diff --git a/...streamingspringbootautoconfigure/repository/impl/InMemoryVideoOnFileSystemRepository.java b/...streamingspringbootautoconfigure/repository/impl/InMemoryVideoOnFileSystemRepository.java
@@ -7,6 +7,7 @@
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
+import java.nio.file.Path;
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
 
@@ -39,10 +40,12 @@ public Flux<Video> getAllVideos() {
 
     @Override
     public Mono<Video> addVideo(Video video) {
-        return Mono.fromCallable(() -> {
-            log.debug(VIDEO_CACHE.toString());
-            return VIDEO_CACHE.put(video.getName(), video);
-        });
+        return Mono.fromCallable(() -> VIDEO_CACHE.put(video.getName(), video));
+    }
+
+    @Override
+    public Mono<Video> deleteVideoByPath(Path path) {
+        return this.deleteVideoByName(path.getFileName().toString());
     }
 
     @Override