Adding ability to scan for changes in subdirectories

2 files changed, 27 insertions, 9 deletions

diff --git a/src/main/java/soundchan/BotListener/BotListener.java b/src/main/java/soundchan/BotListener/BotListener.java
index e3ac382..16ad2fc 100644
--- a/src/main/java/soundchan/BotListener/BotListener.java
+++ b/src/main/java/soundchan/BotListener/BotListener.java
@@ -73,7 +73,7 @@ public class BotListener extends ListenerAdapter{
                     public void onWatchEvent(WatchEvent event) {
                         localManager.UpdateUserAudio();
                     }
-                }, userAudioPath, "watchUserSoundFile");
+                }, userAudioPath, "watchUserSoundFile", false);
             }
         }
         else
@@ -85,7 +85,7 @@ public class BotListener extends ListenerAdapter{
                 public void onWatchEvent(WatchEvent event) {
                     localManager.UpdateFiles();
                 }
-            }, localFilePath, "watchLocalFilePath");
+            }, localFilePath, "watchLocalFilePath", true);
         }
 
     }
@@ -403,10 +403,11 @@ public class BotListener extends ListenerAdapter{
      * @param listener Listener that will get callback during watching of media
      * @param filepath Path to either directory or file
      * @param taskName Thing to name task as
+     * @param watchSubDirs Also watch any subdirectories in the given directory (doesn't do anything if watching a file)
      */
-    private void addWatcherTask(@NotNull MediaWatcherListener listener, String filepath, String taskName) {
+    private void addWatcherTask(@NotNull MediaWatcherListener listener, String filepath, String taskName, boolean watchSubDirs) {
         ExecutorService executorService = Executors.newSingleThreadExecutor();
-        MediaWatcher watcher = new MediaWatcher(listener, filepath);
+        MediaWatcher watcher = new MediaWatcher(listener, filepath, watchSubDirs);
         otherTasks.put(taskName, executorService.submit(watcher));
         executorService.shutdown();
     }
diff --git a/src/main/java/soundchan/BotListener/MediaWatcher.java b/src/main/java/soundchan/BotListener/MediaWatcher.java
index f9c7598..3e58d3f 100644
--- a/src/main/java/soundchan/BotListener/MediaWatcher.java
+++ b/src/main/java/soundchan/BotListener/MediaWatcher.java
@@ -3,6 +3,7 @@ package soundchan.BotListener;
 import java.io.File;
 import java.io.IOException;
 import java.nio.file.*;
+import java.nio.file.attribute.BasicFileAttributes;
 
 import static java.lang.Thread.sleep;
 import static java.nio.file.StandardWatchEventKinds.ENTRY_CREATE;
@@ -29,29 +30,31 @@ public class MediaWatcher implements Runnable {
      * Defaults to scanning every 5 seconds.
      * @param listener Object that will get a callback when there is a watch event
      * @param filepath Path to either directory or specific file
+     * @param watchSubDirs Also watch any subdirectories in the given directory (doesn't do anything if watching a file)
      */
-    public MediaWatcher(MediaWatcherListener listener, String filepath) {
+    public MediaWatcher(MediaWatcherListener listener, String filepath, boolean watchSubDirs) {
         this.listener = listener;
-        startWatchService(filepath);
+        startWatchService(filepath, watchSubDirs);
     }
 
     /**
      * Creates a MediaWatcher, which monitors changes to files either within a directory or for a specific file.
      * @param listener Object that will get a callback when there is a watch event
      * @param filepath Path to either directory or specific file
+     * @param watchSubDirs Also watch any subdirectories in the given directory (doesn't do anything if watching a file)
      * @param sleepTime How long to put the scanner thread to sleep between rescans (time in milliseconds)
      */
-    public MediaWatcher(MediaWatcherListener listener, String filepath, int sleepTime) {
+    public MediaWatcher(MediaWatcherListener listener, String filepath, boolean watchSubDirs, int sleepTime) {
         this.listener = listener;
         this.sleepTime = sleepTime;
-        startWatchService(filepath);
+        startWatchService(filepath, watchSubDirs);
     }
 
     /**
      * Sets up watch service for the file/directory
      * @param filepath Path to file or directory to be scanned
      */
-    private void startWatchService(String filepath) {
+    private void startWatchService(String filepath, boolean watchSubDirs) {
         File mediaFile = new File(filepath);
         this.mediaFilename = mediaFile.getName();
         if(mediaFile.isFile()) {
@@ -68,6 +71,20 @@ public class MediaWatcher implements Runnable {
         try {
             this.watchService = FileSystems.getDefault().newWatchService();
             this.watchKey = mediaDir.register(watchService, ENTRY_CREATE, ENTRY_DELETE, ENTRY_MODIFY);
+            if(isDirectory && watchSubDirs) {
+                Files.walkFileTree(mediaDir, new SimpleFileVisitor<Path>() {
+                    @Override
+                    public FileVisitResult preVisitDirectory(Path dir, BasicFileAttributes attrs) {
+                        try {
+                            dir.register(watchService, ENTRY_CREATE, ENTRY_DELETE, ENTRY_MODIFY);
+                            return FileVisitResult.CONTINUE;
+                        } catch (IOException e) {
+                            System.out.println("Error setting up watch service with sub dirs in " + filepath);
+                            return FileVisitResult.SKIP_SUBTREE;
+                        }
+                    }
+                });
+            }
         } catch (IOException e) {
             System.out.println("Error setting up watcher for " + filepath);
         }