From 92056c4d3d409590b23996eef2795419d4b9617b Mon Sep 17 00:00:00 2001
From: LukePulverenti Luke Pulverenti luke pulverenti
 <LukePulverenti Luke Pulverenti luke.pulverenti@gmail.com>
Date: Fri, 10 Aug 2012 11:17:52 -0400
Subject: Added audio transcoding

---
 MediaBrowser.Api/Transcoding/TranscodingJob.cs | 102 +++++++++++++++++++++++++
 1 file changed, 102 insertions(+)
 create mode 100644 MediaBrowser.Api/Transcoding/TranscodingJob.cs

(limited to 'MediaBrowser.Api/Transcoding/TranscodingJob.cs')

diff --git a/MediaBrowser.Api/Transcoding/TranscodingJob.cs b/MediaBrowser.Api/Transcoding/TranscodingJob.cs
new file mode 100644
index 000000000..e504fec09
--- /dev/null
+++ b/MediaBrowser.Api/Transcoding/TranscodingJob.cs
@@ -0,0 +1,102 @@
+using System;
+using System.Diagnostics;
+using System.IO;
+using System.Threading;
+using MediaBrowser.Common.Logging;
+
+namespace MediaBrowser.Api.Transcoding
+{
+    /// <summary>
+    /// Represents an active transcoding job
+    /// </summary>
+    public class TranscodingJob
+    {
+        public string InputFile { get; set; }
+        public string OutputFile { get; set; }
+        public string TranscoderPath { get; set; }
+        public string Arguments { get; set; }
+
+        public TranscoderJobStatus Status { get; private set; }
+
+        /// <summary>
+        /// Starts the job
+        /// </summary>
+        public void Start()
+        {
+            ApiService.AddTranscodingJob(this);
+            
+            ProcessStartInfo startInfo = new ProcessStartInfo();
+
+            startInfo.CreateNoWindow = true;
+
+            startInfo.UseShellExecute = false;
+
+            startInfo.FileName = TranscoderPath;
+            startInfo.WorkingDirectory = Path.GetDirectoryName(TranscoderPath);
+            startInfo.Arguments = Arguments;
+
+            Logger.LogInfo("TranscodingJob.Start: " + TranscoderPath + " " + Arguments);
+
+            Process process = new Process();
+
+            process.StartInfo = startInfo;
+
+            process.EnableRaisingEvents = true;
+
+            process.Start();
+
+            process.Exited += process_Exited;
+        }
+
+        void process_Exited(object sender, EventArgs e)
+        {
+            ApiService.RemoveTranscodingJob(this);
+            
+            Process process = sender as Process;
+
+            // If it terminated with an error
+            if (process.ExitCode != 0)
+            {
+                Status = TranscoderJobStatus.Error;
+
+                // Delete this since it won't be valid
+                if (File.Exists(OutputFile))
+                {
+                    File.Delete(OutputFile);
+                }
+            }
+            else
+            {
+                Status = TranscoderJobStatus.Completed;
+            }
+
+            process.Dispose();
+        }
+
+        /// <summary>
+        /// Provides a helper to wait for the job to exit
+        /// </summary>
+        public void WaitForExit()
+        {
+            while (true)
+            {
+                TranscoderJobStatus status = Status;
+
+                if (status == TranscoderJobStatus.Completed || status == TranscoderJobStatus.Error)
+                {
+                    break;
+                }
+
+                Thread.Sleep(500);
+            }
+        }
+    }
+
+    public enum TranscoderJobStatus
+    {
+        Queued,
+        Started,
+        Completed,
+        Error
+    }
+}
-- 
cgit v1.2.3