Added extra check for the Watcher to make sure the file has finished transferring before it is sent for encoding.

The "stability check" interval can be configured in Global Options -> Advanced.

Author: RandomEngy

VidCoder/Extensions/WatchedFileStatusExtensions.cs

@@ -14,6 +14,8 @@ public static WatchedFileStatusLive ToLive(this WatchedFileStatus status)
 	{
 		switch (status)
 		{
+			case WatchedFileStatus.Found:
+				return WatchedFileStatusLive.Found;
 			case WatchedFileStatus.Planned:
 				return WatchedFileStatusLive.Planned;
 			case WatchedFileStatus.Canceled:

VidCoder/Model/Config/Config.cs

@@ -91,6 +91,7 @@ private static void Initialize(SQLiteConnection connection)
 			cache.Add("EnableDirectXDecoding", DatabaseConfig.Get("EnableDirectXDecoding", true, connection));
 			cache.Add("WatcherMode", DatabaseConfig.Get("WatcherMode", "FileSystemWatcher", connection));
 			cache.Add("WatcherPollIntervalSeconds", DatabaseConfig.Get("WatcherPollIntervalSeconds", 5, connection));
+			cache.Add("WatcherStabilityCheckIntervalSeconds", DatabaseConfig.Get("WatcherStabilityCheckIntervalSeconds", 1.0, connection));
 			cache.Add("WorkerProcessPriority", DatabaseConfig.Get("WorkerProcessPriority", "BelowNormal", connection));
 			cache.Add("LogVerbosity", DatabaseConfig.Get("LogVerbosity", 1, connection));
 			cache.Add("CopyLogToOutputFolder", DatabaseConfig.Get("CopyLogToOutputFolder", false, connection));
@@ -482,6 +483,11 @@ public static int WatcherPollIntervalSeconds
 			get { return (int)cache["WatcherPollIntervalSeconds"]; }
 			set { Set("WatcherPollIntervalSeconds", value); }
 		}
+		public static double WatcherStabilityCheckIntervalSeconds
+		{
+			get { return (double)cache["WatcherStabilityCheckIntervalSeconds"]; }
+			set { Set("WatcherStabilityCheckIntervalSeconds", value); }
+		}
 		public static string WorkerProcessPriority
 		{
 			get { return (string)cache["WorkerProcessPriority"]; }
@@ -810,6 +816,7 @@ public static class Observables
 			public static IObservable<bool> EnableDirectXDecoding => GetObservable<bool>("EnableDirectXDecoding");
 			public static IObservable<string> WatcherMode => GetObservable<string>("WatcherMode");
 			public static IObservable<int> WatcherPollIntervalSeconds => GetObservable<int>("WatcherPollIntervalSeconds");
+			public static IObservable<double> WatcherStabilityCheckIntervalSeconds => GetObservable<double>("WatcherStabilityCheckIntervalSeconds");
 			public static IObservable<string> WorkerProcessPriority => GetObservable<string>("WorkerProcessPriority");
 			public static IObservable<int> LogVerbosity => GetObservable<int>("LogVerbosity");
 			public static IObservable<bool> CopyLogToOutputFolder => GetObservable<bool>("CopyLogToOutputFolder");

VidCoder/Model/Config/Config.txt

@@ -74,6 +74,7 @@ EnableDirectXDecoding|bool|true
 
 WatcherMode|string|"FileSystemWatcher"
 WatcherPollIntervalSeconds|int|5
+WatcherStabilityCheckIntervalSeconds|double|1.0
 WorkerProcessPriority|string|"BelowNormal"
 LogVerbosity|int|1
 CopyLogToOutputFolder|bool|false

VidCoder/Model/WatchedFileStatusLive.cs

@@ -11,6 +11,11 @@ namespace VidCoder.Model;
 /// </summary>
 public enum WatchedFileStatusLive
 {
+	/// <summary>
+	/// VidCoder has found the file, but is waiting for it to be fully written before trying to encode it.
+	/// </summary>
+	Found,
+
 	/// <summary>
 	/// VidCoder has planned to encode this file but it has not yet been added to the queue. It should only be in this state as long as it takes to scan the item.
 	/// </summary>

VidCoder/Resources/EnumsRes.Designer.cs

@@ -408,4 +408,7 @@
   <data name="WhenFileExists_Skip" xml:space="preserve">
     <value>Skip</value>
   </data>
+  <data name="WatchedFileStatusLive_Found" xml:space="preserve">
+    <value>Found</value>
+  </data>
 </root>

VidCoder/Resources/EnumsRes.resx

@@ -478,4 +478,7 @@ Polling: Periodically checks the contents of the folders. Uses significant CPU a
   <data name="EnableQuickSyncHyperEncodeToolTip" xml:space="preserve">
     <value>Use multiple media engines to speed up a single encode where supported. Disable to allow load balancing multiple parallel encodes across media engines.</value>
   </data>
+  <data name="WatcherStabilityIntervalLabel" xml:space="preserve">
+    <value>File stability wait interval (seconds):</value>
+  </data>
 </root>

VidCoder/Resources/OptionsRes.Designer.cs

@@ -37,7 +37,7 @@ public void Start()
 		SQLiteConnection connection = Database.Connection;
 
 		// Queue up anything that hasn't been encoded yet
-		Dictionary<string, WatchedFile> plannedFiles = WatcherStorage.GetPlannedFiles(connection);
+		Dictionary<string, WatchedFile> plannedFiles = WatcherStorage.GetFilesWithStatus(connection, WatchedFileStatus.Planned);
 		this.logger.LogDebug($"Starting WatchedFileStatusTracker. Found {plannedFiles.Count} planned files.");
 
 		foreach (var job in this.processingService.EncodeQueue.Items)

VidCoder/Resources/OptionsRes.resx

@@ -632,9 +632,29 @@
 										ItemsSource="{Binding WatcherModeChoices}"
 										SelectedValue="{Binding WatcherMode}"
 										SelectedValuePath="Value" />
+								</StackPanel>
+
+								<StackPanel Margin="12 6 0 0" Orientation="Vertical">
+
+
+									<StackPanel Margin="0 0 0 0" Orientation="Horizontal">
+										<TextBlock
+											Name="watcherStabilityIntervalLabel"
+											VerticalAlignment="Center"
+											Text="{x:Static res:OptionsRes.WatcherStabilityIntervalLabel}" />
+
+										<controls:NumberBox
+											Width="45"
+											Height="20"
+											Margin="6 0 0 0"
+											AllowEmpty="False"
+											Maximum="3600"
+											Minimum="0.5"
+											Number="{Binding WatcherStabilityIntervalSeconds, Mode=TwoWay}" />
+									</StackPanel>
 
 									<StackPanel
-										Margin="10 0 0 0"
+										Margin="0 6 0 0"
 										Orientation="Horizontal"
 										Visibility="{Binding WatcherMode, Converter={StaticResource EnumVisibilityConverter}, ConverterParameter={x:Static commonModel:WatcherMode.Polling}}">
 										<TextBlock
@@ -650,9 +670,9 @@
 											Minimum="1"
 											Number="{Binding WatcherPollIntervalSeconds, Mode=TwoWay}" />
 									</StackPanel>
-
 								</StackPanel>
 
+
 								<!--  Part file naming  -->
 								<StackPanel Margin="0 6 0 0" Orientation="Horizontal">
 									<TextBlock