iktdev/MediaProcessing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Added meta timeout env

Browse Source
This commit is contained in:
Brage 2023-08-25 01:50:16 +02:00
parent 05d560bc2d
commit 4d75083817
3 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
Reader/src/main/kotlin/no/iktdev/streamit/content/reader/ReaderEnv.kt
View File

@ -4,6 +4,7 @@ import java.io.File
class ReaderEnv { class ReaderEnv {
companion object { companion object {
val metadataTimeOut: Long = System.getenv("TIMEOUT_READER_WAIT_FOR_METADATA").toLongOrNull() ?: 300000
val ffprobe: String = System.getenv("SUPPORTING_EXECUTABLE_FFPROBE") ?: "ffprobe" val ffprobe: String = System.getenv("SUPPORTING_EXECUTABLE_FFPROBE") ?: "ffprobe"
val encodePreference: File = File("/data/config/preference.json") val encodePreference: File = File("/data/config/preference.json")
} }

4
Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/contentDeterminator/ContentDeterminate.kt
View File

@ -10,6 +10,7 @@ import no.iktdev.streamit.content.common.dto.Metadata
import no.iktdev.streamit.content.common.dto.reader.EpisodeInfo import no.iktdev.streamit.content.common.dto.reader.EpisodeInfo
import no.iktdev.streamit.content.common.dto.reader.FileResult import no.iktdev.streamit.content.common.dto.reader.FileResult
import no.iktdev.streamit.content.common.dto.reader.MovieInfo import no.iktdev.streamit.content.common.dto.reader.MovieInfo
import no.iktdev.streamit.content.reader.ReaderEnv
import no.iktdev.streamit.library.kafka.KafkaEvents import no.iktdev.streamit.library.kafka.KafkaEvents
import no.iktdev.streamit.library.kafka.dto.Message import no.iktdev.streamit.library.kafka.dto.Message
import no.iktdev.streamit.library.kafka.dto.Status import no.iktdev.streamit.library.kafka.dto.Status
@ -30,7 +31,8 @@ class ContentDeterminate: DefaultKafkaReader("contentDeterminate"), ISequentialM
accept = KafkaEvents.EVENT_READER_RECEIVED_FILE.event, accept = KafkaEvents.EVENT_READER_RECEIVED_FILE.event,
subAccepts = listOf(KafkaEvents.EVENT_METADATA_OBTAINED.event), subAccepts = listOf(KafkaEvents.EVENT_METADATA_OBTAINED.event),
deserializers = loadDeserializers(), deserializers = loadDeserializers(),
listener = this listener = this,
validity = ReaderEnv.metadataTimeOut
) {} ) {}
init { init {

2
Reader/src/main/kotlin/no/iktdev/streamit/content/reader/fileWatcher/FileWatcher.kt
View File

@ -47,7 +47,7 @@ class FileWatcher: FileWatcherEvents {
logger.warn { "${it.file.name} is not a valid file type" } logger.warn { "${it.file.name} is not a valid file type" }
} else if (it.file.isDirectory) { } else if (it.file.isDirectory) {
val valid = it.file.walkTopDown().filter { f -> f.isFile && f.extension in validVideoFiles() } val valid = it.file.walkTopDown().filter { f -> f.isFile && f.extension in validVideoFiles() }
logger.warn { "${it.file.name} ignoring directory" } logger.warn { "Ignoring directory: ${it.file.name}" }
} }
} }