From ea281c9e3fc5504457aa6a9c1921aa0a8d43cd1f Mon Sep 17 00:00:00 2001 From: Brage Date: Sun, 30 Jul 2023 21:12:43 +0200 Subject: [PATCH] Updated file watcher --- .../content/reader/fileWatcher/FileWatcher.kt | 18 +++++++++++++++++- 1 file changed, 17 insertions(+), 1 deletion(-) diff --git a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/fileWatcher/FileWatcher.kt b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/fileWatcher/FileWatcher.kt index 59d4bbd3..c4ff099a 100644 --- a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/fileWatcher/FileWatcher.kt +++ b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/fileWatcher/FileWatcher.kt @@ -41,7 +41,14 @@ class FileWatcher: FileWatcherEvents { } KWatchEvent.Kind.Created, KWatchEvent.Kind.Initialized -> { - queue.addToQueue(it.file, this@FileWatcher::onFilePending, this@FileWatcher::onFileAvailable) + if (validVideoFiles().contains(it.file.extension)) { + queue.addToQueue(it.file, this@FileWatcher::onFilePending, this@FileWatcher::onFileAvailable) + } else if (it.file.isFile) { + logger.warn { "${it.file.name} is not a valid file type" } + } else if (it.file.isDirectory) { + val valid = it.file.walkTopDown().filter { f -> f.isFile && f.extension in validVideoFiles() } + logger.warn { "${it.file.name} ignoring directory" } + } } else -> { @@ -69,6 +76,15 @@ class FileWatcher: FileWatcherEvents { } } + fun validVideoFiles(): List = listOf( + "mkv", + "avi", + "mp4", + "wmv", + "webm", + "mov" + ) + override fun onFileAvailable(file: PendingFile) { logger.debug { "onFileAvailable har mottatt pendingFile ${file.file.name}" }