// --------------------------------------------------------------------------------------------------------------------
//
// This file is part of the HandBrake source code - It may be used under the terms of the GNU General Public License.
//
//
// LibHB Implementation of IEncode
//
// --------------------------------------------------------------------------------------------------------------------
namespace HandBrakeWPF.Services.Encode
{
using System;
using System.Diagnostics;
using HandBrake.ApplicationServices.Interop;
using HandBrake.ApplicationServices.Interop.EventArgs;
using HandBrake.ApplicationServices.Interop.Interfaces;
using HandBrake.ApplicationServices.Model;
using HandBrake.ApplicationServices.Services.Logging;
using HandBrake.ApplicationServices.Services.Logging.Interfaces;
using HandBrake.ApplicationServices.Services.Logging.Model;
using HandBrakeWPF.Exceptions;
using HandBrakeWPF.Services.Encode.Factories;
using EncodeTask = HandBrakeWPF.Services.Encode.Model.EncodeTask;
using IEncode = HandBrakeWPF.Services.Encode.Interfaces.IEncode;
///
/// LibHB Implementation of IEncode
///
public class LibEncode : HandBrakeWPF.Services.Encode.EncodeBase, IEncode
{
#region Private Variables
private ILog log = LogService.GetLogger();
private IHandBrakeInstance instance;
private DateTime startTime;
private EncodeTask currentTask;
private HBConfiguration currentConfiguration;
private bool isPreviewInstance;
#endregion
///
/// Gets a value indicating whether is pasued.
///
public bool IsPasued { get; private set; }
///
/// Start with a LibHb EncodeJob Object
///
///
/// The task.
///
///
/// The configuration.
///
public void Start(EncodeTask task, HBConfiguration configuration)
{
try
{
// Sanity Checking and Setup
if (this.IsEncoding)
{
throw new GeneralApplicationException("HandBrake is already encoding a file.", "Please stop the current encode. If the problem persists, please restart HandBrake.", null);
}
// Setup
this.startTime = DateTime.Now;
this.currentTask = task;
this.currentConfiguration = configuration;
// Create a new HandBrake instance
// Setup the HandBrake Instance
this.log.Reset(); // Reset so we have a clean log for the start of the encode.
this.ServiceLogMessage("Starting Encode ...");
HandBrakeUtils.SetDvdNav(!configuration.IsDvdNavDisabled);
this.instance = task.IsPreviewEncode ? HandBrakeInstanceManager.GetPreviewInstance(configuration.Verbosity) : HandBrakeInstanceManager.GetEncodeInstance(configuration.Verbosity);
this.instance.EncodeCompleted += this.InstanceEncodeCompleted;
this.instance.EncodeProgress += this.InstanceEncodeProgress;
this.IsEncoding = true;
this.isPreviewInstance = task.IsPreviewEncode;
// Verify the Destination Path Exists, and if not, create it.
this.VerifyEncodeDestinationPath(task);
// Get an EncodeJob object for the Interop Library
this.instance.StartEncode(EncodeFactory.Create(task, configuration));
// Fire the Encode Started Event
this.InvokeEncodeStarted(System.EventArgs.Empty);
}
catch (Exception exc)
{
this.IsEncoding = false;
this.ServiceLogMessage("Failed to start encoding ..." + Environment.NewLine + exc);
this.InvokeEncodeCompleted(new EventArgs.EncodeCompletedEventArgs(false, exc, "Unable to start encoding", task.Source));
}
}
///
/// Pause the currently running encode.
///
public void Pause()
{
if (this.instance != null)
{
this.instance.PauseEncode();
this.ServiceLogMessage("Encode Paused");
this.IsPasued = true;
}
}
///
/// Resume the currently running encode.
///
public void Resume()
{
if (this.instance != null)
{
this.instance.ResumeEncode();
this.ServiceLogMessage("Encode Resumed");
this.IsPasued = false;
}
}
///
/// Kill the process
///
public void Stop()
{
try
{
this.IsEncoding = false;
if (this.instance != null)
{
this.instance.StopEncode();
this.ServiceLogMessage("Encode Stopped");
}
}
catch (Exception exc)
{
Debug.WriteLine(exc);
}
}
#region HandBrakeInstance Event Handlers.
///
/// Encode Progress Event Handler
///
///
/// The sender.
///
///
/// The Interop.EncodeProgressEventArgs.
///
private void InstanceEncodeProgress(object sender, EncodeProgressEventArgs e)
{
EventArgs.EncodeProgressEventArgs args = new EventArgs.EncodeProgressEventArgs
{
AverageFrameRate = e.AverageFrameRate,
CurrentFrameRate = e.CurrentFrameRate,
EstimatedTimeLeft = e.EstimatedTimeLeft,
PercentComplete = e.FractionComplete * 100,
Task = e.Pass,
TaskCount = e.PassCount,
ElapsedTime = DateTime.Now - this.startTime,
PassId = e.PassId
};
this.InvokeEncodeStatusChanged(args);
}
///
/// Encode Completed Event Handler
///
///
/// The sender.
///
///
/// The e.
///
private void InstanceEncodeCompleted(object sender, EncodeCompletedEventArgs e)
{
this.IsEncoding = false;
this.ServiceLogMessage("Encode Completed ...");
// Handling Log Data
this.ProcessLogs(this.currentTask.Destination, this.isPreviewInstance, this.currentConfiguration);
// Raise the Encode Completed EVent.
this.InvokeEncodeCompleted(
e.Error
? new EventArgs.EncodeCompletedEventArgs(false, null, string.Empty, this.currentTask.Destination)
: new EventArgs.EncodeCompletedEventArgs(true, null, string.Empty, this.currentTask.Destination));
}
///
/// Service Log Message.
///
/// Log message content
protected void ServiceLogMessage(string message)
{
this.log.LogMessage(string.Format("{0}# {1}{0}", Environment.NewLine, message), LogMessageType.ScanOrEncode, LogLevel.Info);
}
#endregion
}
}