// --------------------------------------------------------------------------------------------------------------------
//
// This file is part of the HandBrake source code - It may be used under the terms of the GNU General Public License.
//
//
// The Preview View Model
//
// --------------------------------------------------------------------------------------------------------------------
namespace HandBrakeWPF.ViewModels
{
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.ComponentModel;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Runtime.CompilerServices;
using System.Windows;
using Caliburn.Micro;
using HandBrakeWPF.EventArgs;
using HandBrakeWPF.Extensions;
using HandBrakeWPF.Properties;
using HandBrakeWPF.Services.Interfaces;
using HandBrakeWPF.Services.Queue.Interfaces;
using HandBrakeWPF.Services.Queue.Model;
using HandBrakeWPF.Utilities;
using HandBrakeWPF.ViewModels.Interfaces;
using Microsoft.Win32;
using EncodeCompletedEventArgs = Services.Encode.EventArgs.EncodeCompletedEventArgs;
using EncodeProgressEventArgs = Services.Encode.EventArgs.EncodeProgressEventArgs;
///
/// The Preview View Model
///
public class QueueViewModel : ViewModelBase, IQueueViewModel
{
#region Constants and Fields
private readonly IErrorService errorService;
private readonly IUserSettingService userSettingService;
private readonly IQueueProcessor queueProcessor;
private string jobStatus;
private string jobsPending;
private string whenDoneAction;
private QueueTask selectedTask;
private bool isQueueRunning;
private double progressValue;
private bool intermediateProgress;
private bool showEncodeProgress;
#endregion
#region Constructors and Destructors
///
/// Initializes a new instance of the class.
///
///
/// The user Setting Service.
///
///
/// The Queue Processor Service
///
///
/// The Error Service
///
public QueueViewModel(IUserSettingService userSettingService, IQueueProcessor queueProcessor, IErrorService errorService)
{
this.userSettingService = userSettingService;
this.queueProcessor = queueProcessor;
this.errorService = errorService;
this.Title = Resources.QueueViewModel_Queue;
this.JobsPending = Resources.QueueViewModel_NoEncodesPending;
this.JobStatus = string.Empty;
this.SelectedItems = new BindingList();
this.DisplayName = "Queue";
this.IsQueueRunning = false;
this.WhenDoneAction = this.userSettingService.GetUserSetting(UserSettingConstants.WhenCompleteAction);
}
#endregion
#region Properties
///
/// Gets or sets a value indicating whether the Queue is paused or not..
///
public bool IsQueueRunning
{
get
{
return this.isQueueRunning;
}
set
{
if (value == this.isQueueRunning) return;
this.isQueueRunning = value;
this.NotifyOfPropertyChange(() => this.IsQueueRunning);
}
}
///
/// Gets or sets JobStatus.
///
public string JobStatus
{
get
{
return this.jobStatus;
}
set
{
this.jobStatus = value;
this.NotifyOfPropertyChange(() => this.JobStatus);
this.NotifyOfPropertyChange(() => this.IsJobStatusVisible);
}
}
public bool IsJobStatusVisible => !string.IsNullOrEmpty(this.JobStatus) && this.SelectedTask?.Status == QueueItemStatus.InProgress;
///
/// Gets or sets JobsPending.
///
public string JobsPending
{
get
{
return this.jobsPending;
}
set
{
this.jobsPending = value;
this.NotifyOfPropertyChange(() => this.JobsPending);
}
}
///
/// Gets or sets WhenDoneAction.
///
public string WhenDoneAction
{
get
{
return this.whenDoneAction;
}
set
{
this.whenDoneAction = value;
this.NotifyOfPropertyChange(() => this.WhenDoneAction);
}
}
///
/// Gets the queue tasks.
///
public ObservableCollection QueueTasks
{
get
{
return this.queueProcessor.Queue;
}
}
///
/// Gets or sets the selected items.
///
public BindingList SelectedItems { get; set; }
public QueueTask SelectedTask
{
get
{
return this.selectedTask;
}
set
{
if (Equals(value, this.selectedTask)) return;
this.selectedTask = value;
this.NotifyOfPropertyChange(() => this.SelectedTask);
this.HandleLogData();
this.NotifyOfPropertyChange(() => this.CanRetryJob);
this.NotifyOfPropertyChange(() => this.CanEditJob);
this.NotifyOfPropertyChange(() => this.CanRemoveJob);
this.NotifyOfPropertyChange(() => this.CanPerformActionOnSource);
this.NotifyOfPropertyChange(() => this.CanPlayFile);
this.NotifyOfPropertyChange(() => this.StatsVisible);
}
}
public string ActivityLog { get; private set; }
public bool CanRetryJob => this.SelectedTask != null && this.SelectedTask.Status != QueueItemStatus.Waiting && this.SelectedTask.Status != QueueItemStatus.InProgress;
public bool CanEditJob => this.SelectedTask != null;
public bool CanRemoveJob => this.SelectedTask != null;
public bool CanPerformActionOnSource => this.SelectedTask != null;
public bool CanPlayFile =>
this.SelectedTask != null && this.SelectedTask.Task.Destination != null &&
this.SelectedTask.Status == QueueItemStatus.Completed && File.Exists(this.SelectedTask.Task.Destination);
public double ProgressValue
{
get => this.progressValue;
set
{
if (value == this.progressValue) return;
this.progressValue = value;
this.NotifyOfPropertyChange(() => this.ProgressValue);
}
}
public bool IntermediateProgress
{
get => this.intermediateProgress;
set
{
if (value == this.intermediateProgress) return;
this.intermediateProgress = value;
this.NotifyOfPropertyChange(() => this.IntermediateProgress);
}
}
public bool ShowEncodeProgress
{
get => this.showEncodeProgress;
set
{
if (value == this.showEncodeProgress) return;
this.showEncodeProgress = value;
this.NotifyOfPropertyChange(() => this.ShowEncodeProgress);
}
}
public bool IsInline { get; set; }
public bool StatsVisible
{
get
{
if (this.SelectedTask != null &&
(this.selectedTask.Status == QueueItemStatus.Completed || this.selectedTask.Status == QueueItemStatus.Error))
{
return true;
}
return false;
}
}
#endregion
#region Public Methods
///
/// Update the When Done Setting
///
///
/// The action.
///
public void WhenDone(string action)
{
this.WhenDone(action, true);
}
///
/// Update the When Done Setting
///
///
/// The action.
///
///
/// Save the change to the setting. Use false when updating UI.
///
public void WhenDone(string action, bool saveChange)
{
this.WhenDoneAction = action;
if (saveChange)
{
this.userSettingService.SetUserSetting(UserSettingConstants.WhenCompleteAction, action);
}
IOptionsViewModel ovm = IoC.Get();
ovm.UpdateSettings();
}
///
/// Clear the Queue
///
public void Clear()
{
MessageBoxResult result = this.errorService.ShowMessageBox(
Resources.QueueViewModel_ClearQueueConfrimation, Resources.Confirm, MessageBoxButton.YesNo, MessageBoxImage.Warning);
if (result == MessageBoxResult.Yes)
{
this.queueProcessor.Clear();
}
}
///
/// Clear Completed Items
///
public void ClearCompleted()
{
this.queueProcessor.ClearCompleted();
}
///
/// Close this window.
///
public void Close()
{
this.TryClose();
}
///
/// Handle the On Window Load
///
public override void OnLoad()
{
// Setup the window to the correct state.
this.IsQueueRunning = this.queueProcessor.EncodeService.IsEncoding;
this.JobsPending = string.Format(Resources.QueueViewModel_JobsPending, this.queueProcessor.Count);
base.OnLoad();
}
///
/// Can Pause the Queue.
/// Used by Caliburn Micro to enable/disable the context menu item.
///
///
/// True when we can pause the queue.
///
public bool CanPauseQueue()
{
return this.IsQueueRunning;
}
///
/// Pause the Queue
///
public void PauseQueue()
{
this.queueProcessor.Pause();
this.JobsPending = string.Format(Resources.QueueViewModel_JobsPending, this.queueProcessor.Count);
this.IsQueueRunning = false;
this.errorService.ShowMessageBox(Resources.QueueViewModel_QueuePauseNotice, Resources.QueueViewModel_Queue,
MessageBoxButton.OK, MessageBoxImage.Information);
}
///
/// Pause the Queue
///
///
/// Prevents evaluation of CanPauseQueue
///
public void PauseQueueToolbar()
{
this.PauseQueue();
}
///
/// The remove selected jobs.
///
public void RemoveSelectedJobs()
{
MessageBoxResult result =
this.errorService.ShowMessageBox(
Resources.QueueViewModel_DelSelectedJobConfirmation,
Resources.Question,
MessageBoxButton.YesNo,
MessageBoxImage.Question);
if (result == MessageBoxResult.No)
{
return;
}
List tasksToRemove = this.SelectedItems.ToList();
foreach (QueueTask job in tasksToRemove)
{
this.RemoveJob(job);
}
}
///
/// Remove a Job from the queue
///
///
/// The Job to remove from the queue
///
public void RemoveJob(object queueTask)
{
QueueTask task = queueTask as QueueTask;
if (task == null)
{
return;
}
bool removed = false;
int index = this.QueueTasks.IndexOf(task);
if (task.Status == QueueItemStatus.InProgress)
{
MessageBoxResult result =
this.errorService.ShowMessageBox(
Resources.QueueViewModel_JobCurrentlyRunningWarning,
Resources.Warning,
MessageBoxButton.YesNo,
MessageBoxImage.Question);
if (result == MessageBoxResult.Yes)
{
this.queueProcessor.EncodeService.Stop();
this.queueProcessor.Remove(task);
removed = true;
}
}
else
{
this.queueProcessor.Remove(task);
removed = true;
}
if (this.QueueTasks.Any() && removed)
{
this.SelectedTask = index > 1 ? this.QueueTasks[index - 1] : this.QueueTasks.FirstOrDefault();
}
}
///
/// Reset the job state to waiting.
///
///
/// The task.
///
public void RetryJob(QueueTask task)
{
task.Status = QueueItemStatus.Waiting;
this.queueProcessor.BackupQueue(null);
this.JobsPending = string.Format(Resources.QueueViewModel_JobsPending, this.queueProcessor.Count);
this.NotifyOfPropertyChange(() => this.CanRetryJob);
}
///
/// Start Encode
///
public void StartQueue()
{
if (!this.QueueTasks.Any(a => a.Status == QueueItemStatus.Waiting || a.Status == QueueItemStatus.InProgress))
{
this.errorService.ShowMessageBox(
Resources.QueueViewModel_NoPendingJobs, Resources.Error, MessageBoxButton.OK, MessageBoxImage.Error);
return;
}
var firstOrDefault = this.QueueTasks.FirstOrDefault(s => s.Status == QueueItemStatus.Waiting);
if (firstOrDefault != null && !DriveUtilities.HasMinimumDiskSpace(firstOrDefault.Task.Destination,
this.userSettingService.GetUserSetting(UserSettingConstants.PauseOnLowDiskspaceLevel)))
{
this.errorService.ShowMessageBox(Resources.Main_LowDiskspace, Resources.Error, MessageBoxButton.OK, MessageBoxImage.Error);
return;
}
this.JobsPending = string.Format(Resources.QueueViewModel_JobsPending, this.queueProcessor.Count);
this.IsQueueRunning = true;
this.queueProcessor.Start(userSettingService.GetUserSetting(UserSettingConstants.ClearCompletedFromQueue));
}
///
/// Export the Queue to a file.
///
public void Export()
{
SaveFileDialog dialog = new SaveFileDialog
{
Filter = "Json (*.json)|*.json",
OverwritePrompt = true,
DefaultExt = ".json",
AddExtension = true
};
if (dialog.ShowDialog() == true)
{
this.queueProcessor.ExportJson(dialog.FileName);
}
}
///
/// Import a saved queue
///
public void Import()
{
OpenFileDialog dialog = new OpenFileDialog { Filter = "Json (*.json)|*.json", CheckFileExists = true };
if (dialog.ShowDialog() == true)
{
this.queueProcessor.ImportJson(dialog.FileName);
}
}
///
/// Edit this Job
///
///
/// The task.
///
public void EditJob(QueueTask task)
{
MessageBoxResult result = this.errorService.ShowMessageBox(
Resources.QueueViewModel_EditConfrimation,
"Modify Job?",
MessageBoxButton.YesNo,
MessageBoxImage.Question);
if (result != MessageBoxResult.Yes)
{
return;
}
// Remove the job if it is not already encoding. Let the user decide if they want to cancel or not.
this.RemoveJob(task);
// Pass a copy of the job back to the Main Screen
IMainViewModel mvm = IoC.Get();
mvm.EditQueueJob(task);
}
public void OpenSourceDir()
{
this.OpenSourceDirectory(this.SelectedTask);
}
public void OpenDestDir()
{
this.OpenDestinationDirectory(this.SelectedTask);
}
public void OpenSourceDirectory(QueueTask task)
{
if (task != null)
{
this.OpenDirectory(task.ScannedSourcePath);
}
}
public void OpenDestinationDirectory(QueueTask task)
{
if (task != null)
{
this.OpenDirectory(task.Task.Destination);
}
}
public void ResetSelectedJobs()
{
foreach (var task in this.SelectedItems)
{
if (task.Status == QueueItemStatus.Completed || task.Status == QueueItemStatus.Error)
{
this.RetryJob(task);
}
}
}
public void ResetAllJobs()
{
foreach (var task in this.QueueTasks)
{
if (task.Status == QueueItemStatus.Completed || task.Status == QueueItemStatus.Error)
{
this.RetryJob(task);
}
}
}
public void ResetFailed()
{
foreach (var task in this.QueueTasks)
{
if (task.Status == QueueItemStatus.Error)
{
this.RetryJob(task);
}
}
}
public void PlayFile()
{
if (this.SelectedTask != null && this.SelectedTask.Task != null && File.Exists(this.SelectedTask.Task.Destination))
{
Process.Start(this.SelectedTask.Task.Destination);
}
}
public void MoveUp()
{
Dictionary tasks = new Dictionary();
foreach (var item in this.SelectedItems)
{
tasks.Add(this.QueueTasks.IndexOf(item), item);
}
foreach (var item in tasks.OrderBy(s => s.Key))
{
this.QueueTasks.MoveUp(item.Value);
}
}
public void MoveDown()
{
Dictionary tasks = new Dictionary();
foreach (var item in this.SelectedItems)
{
tasks.Add(this.QueueTasks.IndexOf(item), item);
}
foreach (var item in tasks.OrderByDescending(s => s.Key))
{
this.QueueTasks.MoveDown(item.Value);
}
}
#endregion
#region Methods
public void Activate()
{
this.OnActivate();
}
public void Deactivate()
{
this.OnDeactivate(false);
}
///
/// Override the OnActive to run the Screen Loading code in the view model base.
///
protected override void OnActivate()
{
this.Load();
this.queueProcessor.QueueCompleted += this.queueProcessor_QueueCompleted;
this.queueProcessor.QueueChanged += this.QueueManager_QueueChanged;
this.queueProcessor.EncodeService.EncodeStatusChanged += this.EncodeService_EncodeStatusChanged;
this.queueProcessor.EncodeService.EncodeCompleted += this.EncodeService_EncodeCompleted;
this.queueProcessor.JobProcessingStarted += this.QueueProcessorJobProcessingStarted;
this.queueProcessor.QueuePaused += this.QueueProcessor_QueuePaused;
this.JobsPending = string.Format(Resources.QueueViewModel_JobsPending, this.queueProcessor.Count);
base.OnActivate();
}
///
/// Override the Deactivate
///
///
/// The close.
///
protected override void OnDeactivate(bool close)
{
this.queueProcessor.QueueCompleted -= this.queueProcessor_QueueCompleted;
this.queueProcessor.QueueChanged -= this.QueueManager_QueueChanged;
this.queueProcessor.EncodeService.EncodeStatusChanged -= this.EncodeService_EncodeStatusChanged;
this.queueProcessor.EncodeService.EncodeCompleted -= this.EncodeService_EncodeCompleted;
this.queueProcessor.JobProcessingStarted -= this.QueueProcessorJobProcessingStarted;
this.queueProcessor.QueuePaused -= this.QueueProcessor_QueuePaused;
base.OnDeactivate(close);
}
private void OpenDirectory(string directory)
{
try
{
if (!string.IsNullOrEmpty(directory))
{
if (!File.Exists(directory) && !directory.EndsWith("\\"))
{
directory = directory + "\\";
}
directory = Path.GetDirectoryName(directory);
if (directory != null && Directory.Exists(directory))
{
Process.Start(directory);
}
}
}
catch (Exception exc)
{
this.errorService.ShowError(Resources.MainViewModel_UnableToLaunchDestDir, Resources.MainViewModel_UnableToLaunchDestDirSolution, exc);
}
}
///
/// Open the Log file directory
///
public void OpenLogDirectory()
{
string logDir = DirectoryUtilities.GetLogDirectory();
string windir = Environment.GetEnvironmentVariable("WINDIR");
Process prc = new Process { StartInfo = { FileName = windir + @"\explorer.exe", Arguments = logDir } };
prc.Start();
}
///
/// Copy the log file to the system clipboard
///
public void CopyLog()
{
try
{
Clipboard.SetDataObject(this.ActivityLog, true);
}
catch (Exception exc)
{
this.errorService.ShowError(Resources.Clipboard_Unavailable, Resources.Clipboard_Unavailable_Solution, exc);
}
}
private void HandleLogData()
{
if (this.SelectedTask == null || this.SelectedTask.Status == QueueItemStatus.InProgress || this.SelectedTask.Status == QueueItemStatus.Waiting)
{
this.ActivityLog = Resources.QueueView_LogNotAvailableYet;
}
else
{
try
{
// TODO full log path
if (!string.IsNullOrEmpty(this.SelectedTask.Statistics.CompletedActivityLogPath)
&& File.Exists(this.SelectedTask.Statistics.CompletedActivityLogPath))
{
using (StreamReader logReader = new StreamReader(this.SelectedTask.Statistics.CompletedActivityLogPath))
{
string logContent = logReader.ReadToEnd();
this.ActivityLog = logContent;
}
}
else
{
this.ActivityLog = string.Empty;
}
}
catch (Exception exc)
{
Debug.WriteLine(exc);
this.ActivityLog = exc.ToString();
}
}
this.NotifyOfPropertyChange(() => this.ActivityLog);
}
///
/// Handle the Encode Status Changed Event.
///
///
/// The sender.
///
///
/// The EncodeProgressEventArgs.
///
private void EncodeService_EncodeStatusChanged(object sender, EncodeProgressEventArgs e)
{
Execute.OnUIThread(() =>
{
this.IntermediateProgress = false;
if (e.IsSubtitleScan)
{
this.JobStatus = string.Format(Resources.MainViewModel_EncodeStatusChanged_SubScan_StatusLabel,
e.Task,
e.TaskCount,
e.PercentComplete,
e.EstimatedTimeLeft,
e.ElapsedTime,
null);
this.ProgressValue = e.PercentComplete;
}
else if (e.IsMuxing)
{
this.JobStatus = Resources.MainView_Muxing;
this.IntermediateProgress = true;
}
else if (e.IsSearching)
{
this.JobStatus = string.Format(Resources.MainView_ProgressStatusWithTask, Resources.MainView_Searching, e.PercentComplete, e.EstimatedTimeLeft, null);
this.ProgressValue = e.PercentComplete;
}
else
{
this.JobStatus =
string.Format(Resources.QueueViewModel_EncodeStatusChanged_StatusLabel,
e.Task,
e.TaskCount,
e.PercentComplete,
e.CurrentFrameRate,
e.AverageFrameRate,
e.EstimatedTimeLeft,
e.ElapsedTime,
null);
this.ProgressValue = e.PercentComplete;
}
});
}
///
/// Handle the Queue Changed Event.
///
///
/// The sender.
///
///
/// The e.
///
private void QueueManager_QueueChanged(object sender, EventArgs e)
{
this.JobsPending = string.Format(Resources.QueueViewModel_JobsPending, this.queueProcessor.Count);
if (!queueProcessor.IsProcessing)
{
this.IsQueueRunning = false;
}
this.NotifyOfPropertyChange(() => this.CanRetryJob);
this.NotifyOfPropertyChange(() => this.CanEditJob);
this.NotifyOfPropertyChange(() => this.CanRemoveJob);
this.NotifyOfPropertyChange(() => this.CanPerformActionOnSource);
this.NotifyOfPropertyChange(() => this.CanPlayFile);
this.NotifyOfPropertyChange(() => this.StatsVisible);
this.HandleLogData();
}
///
/// Handle the Queue Completed Event
///
///
/// The sender.
///
///
/// The EventArgs.
///
private void queueProcessor_QueueCompleted(object sender, EventArgs e)
{
this.JobsPending = string.Format(Resources.QueueViewModel_JobsPending, this.queueProcessor.Count);
this.IsQueueRunning = false;
this.NotifyOfPropertyChange(() => this.SelectedTask);
this.NotifyOfPropertyChange(() => this.StatsVisible);
this.NotifyOfPropertyChange(() => this.CanRetryJob);
this.JobStatus = string.Empty;
}
///
/// The encode service_ encode completed.
///
///
/// The sender.
///
///
/// The e.
///
private void EncodeService_EncodeCompleted(object sender, EncodeCompletedEventArgs e)
{
if (!this.queueProcessor.IsProcessing)
{
this.JobStatus = string.Empty;
}
}
///
/// The queue processor job processing started.
///
///
/// The sender.
///
///
/// The QueueProgressEventArgs.
///
private void QueueProcessorJobProcessingStarted(object sender, QueueProgressEventArgs e)
{
this.JobStatus = Resources.QueueViewModel_QueueStarted;
this.JobsPending = string.Format(Resources.QueueViewModel_JobsPending, this.queueProcessor.Count);
this.IsQueueRunning = true;
}
private void QueueProcessor_QueuePaused(object sender, EventArgs e)
{
this.JobStatus = Resources.QueueViewModel_QueuePaused;
this.JobsPending = string.Format(Resources.QueueViewModel_JobsPending, this.queueProcessor.Count);
this.IsQueueRunning = false;
}
#endregion
}
}