248 lines
9.5 KiB
C#
248 lines
9.5 KiB
C#
/* This file is part of OpenSubtitles Handler
|
|
A library that handle OpenSubtitles.org XML-RPC methods.
|
|
|
|
Copyright © Ala Ibrahim Hadid 2013
|
|
|
|
This program is free software: you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License as published by
|
|
the Free Software Foundation, either version 3 of the License, or
|
|
(at your option) any later version.
|
|
|
|
This program is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
*/
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.IO;
|
|
using System.IO.Compression;
|
|
using System.Net;
|
|
using System.Security.Cryptography;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
using MediaBrowser.Common.Net;
|
|
|
|
namespace OpenSubtitlesHandler
|
|
{
|
|
/// <summary>
|
|
/// Include helper methods. All member are statics.
|
|
/// </summary>
|
|
public sealed class Utilities
|
|
{
|
|
private const string XML_RPC_SERVER = "http://api.opensubtitles.org/xml-rpc";
|
|
|
|
/// <summary>
|
|
/// Compute movie hash
|
|
/// </summary>
|
|
/// <param name="fileName">The complete media file path</param>
|
|
/// <returns>The hash as Hexadecimal string</returns>
|
|
public static string ComputeHash(string fileName)
|
|
{
|
|
byte[] hash = MovieHasher.ComputeMovieHash(File.OpenRead(fileName));
|
|
return MovieHasher.ToHexadecimal(hash);
|
|
}
|
|
/// <summary>
|
|
/// Compute md5 for a file
|
|
/// </summary>
|
|
/// <param name="filename">The complete file path</param>
|
|
/// <returns>MD5 of the file</returns>
|
|
public static string ComputeMd5(string filename)
|
|
{
|
|
var md5 = MD5.Create();
|
|
var sb = new StringBuilder();
|
|
Stream str = new FileStream(filename, FileMode.Open, FileAccess.Read);
|
|
|
|
foreach (var b in md5.ComputeHash(str))
|
|
sb.Append(b.ToString("x2").ToLower());
|
|
str.Close();
|
|
return sb.ToString();
|
|
}
|
|
/// <summary>
|
|
/// Decompress data using GZip
|
|
/// </summary>
|
|
/// <param name="dataToDecompress">The stream that hold the data</param>
|
|
/// <returns>Bytes array of decompressed data</returns>
|
|
public static byte[] Decompress(Stream dataToDecompress)
|
|
{
|
|
MemoryStream target = new MemoryStream();
|
|
|
|
using (System.IO.Compression.GZipStream decompressionStream = new System.IO.Compression.GZipStream(dataToDecompress,
|
|
System.IO.Compression.CompressionMode.Decompress))
|
|
{
|
|
decompressionStream.CopyTo(target);
|
|
}
|
|
return target.GetBuffer();
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
/// Compress data using GZip (the retunred buffer will be WITHOUT HEADER)
|
|
/// </summary>
|
|
/// <param name="dataToCompress">The stream that hold the data</param>
|
|
/// <returns>Bytes array of compressed data WITHOUT HEADER bytes</returns>
|
|
public static byte[] Compress(Stream dataToCompress)
|
|
{
|
|
/*using (var compressed = new MemoryStream())
|
|
{
|
|
using (var compressor = new System.IO.Compression.GZipStream(compressed,
|
|
System.IO.Compression.CompressionMode.Compress))
|
|
{
|
|
dataToCompress.CopyTo(compressor);
|
|
}
|
|
// Get the compressed bytes only after closing the GZipStream
|
|
return compressed.ToArray();
|
|
}*/
|
|
//using (var compressedOutput = new MemoryStream())
|
|
//{
|
|
// using (var compressedStream = new ZlibStream(compressedOutput,
|
|
// Ionic.Zlib.CompressionMode.Compress,
|
|
// CompressionLevel.Default, false))
|
|
// {
|
|
// var buffer = new byte[4096];
|
|
// int byteCount;
|
|
// do
|
|
// {
|
|
// byteCount = dataToCompress.Read(buffer, 0, buffer.Length);
|
|
|
|
// if (byteCount > 0)
|
|
// {
|
|
// compressedStream.Write(buffer, 0, byteCount);
|
|
// }
|
|
// } while (byteCount > 0);
|
|
// }
|
|
// return compressedOutput.ToArray();
|
|
//}
|
|
|
|
throw new NotImplementedException();
|
|
}
|
|
|
|
/// <summary>
|
|
/// Handle server response stream and decode it as given encoding string.
|
|
/// </summary>
|
|
/// <param name="responseStream">The response stream. Expects a stream that doesn't support seek.</param>
|
|
/// <param name="encoding">The encoding that should be used to decode buffer</param>
|
|
/// <returns>The string of the stream after decode using given encoding</returns>
|
|
public static string GetStreamString(Stream responseStream, Encoding encoding)
|
|
{
|
|
// Handle response, should be XML text.
|
|
List<byte> data = new List<byte>();
|
|
while (true)
|
|
{
|
|
int r = responseStream.ReadByte();
|
|
if (r < 0)
|
|
break;
|
|
data.Add((byte)r);
|
|
}
|
|
responseStream.Close();
|
|
return encoding.GetString(data.ToArray());
|
|
}
|
|
/// <summary>
|
|
/// Handle server response stream and decode it as ASCII encoding string.
|
|
/// </summary>
|
|
/// <param name="responseStream">The response stream. Expects a stream that doesn't support seek.</param>
|
|
/// <returns>The string of the stream after decode using ASCII encoding</returns>
|
|
public static string GetStreamString(Stream responseStream)
|
|
{
|
|
return GetStreamString(responseStream, Encoding.ASCII);
|
|
}
|
|
|
|
public static IHttpClient HttpClient { get; set; }
|
|
|
|
/// <summary>
|
|
/// Send a request to the server
|
|
/// </summary>
|
|
/// <param name="request">The request buffer to send as bytes array.</param>
|
|
/// <param name="userAgent">The user agent value.</param>
|
|
/// <returns>Response of the server or stream of error message as string started with 'ERROR:' keyword.</returns>
|
|
public static Stream SendRequest(byte[] request, string userAgent)
|
|
{
|
|
return SendRequestAsync(request, userAgent, CancellationToken.None).Result;
|
|
|
|
//HttpWebRequest req = (HttpWebRequest)WebRequest.Create(XML_RPC_SERVER);
|
|
//req.ContentType = "text/xml";
|
|
//req.Host = "api.opensubtitles.org:80";
|
|
//req.Method = "POST";
|
|
//req.UserAgent = "xmlrpc-epi-php/0.2 (PHP)";
|
|
//req.ContentLength = request.Length;
|
|
//ServicePointManager.Expect100Continue = false;
|
|
//try
|
|
//{
|
|
// using (Stream stm = req.GetRequestStream())
|
|
// {
|
|
// stm.Write(request, 0, request.Length);
|
|
// }
|
|
|
|
// WebResponse response = req.GetResponse();
|
|
// return response.GetResponseStream();
|
|
//}
|
|
//catch (Exception ex)
|
|
//{
|
|
// Stream errorStream = new MemoryStream();
|
|
// byte[] dd = Encoding.ASCII.GetBytes("ERROR: " + ex.Message);
|
|
// errorStream.Write(dd, 0, dd.Length);
|
|
// errorStream.Position = 0;
|
|
// return errorStream;
|
|
//}
|
|
}
|
|
|
|
public static async Task<Stream> SendRequestAsync(byte[] request, string userAgent, CancellationToken cancellationToken)
|
|
{
|
|
var options = new HttpRequestOptions
|
|
{
|
|
RequestContentBytes = request,
|
|
RequestContentType = "text/xml",
|
|
UserAgent = userAgent,
|
|
Host = "api.opensubtitles.org:80",
|
|
Url = XML_RPC_SERVER,
|
|
|
|
// Response parsing will fail with this enabled
|
|
EnableHttpCompression = false,
|
|
|
|
CancellationToken = cancellationToken
|
|
};
|
|
|
|
if (string.IsNullOrEmpty(options.UserAgent))
|
|
{
|
|
options.UserAgent = "xmlrpc-epi-php/0.2 (PHP)";
|
|
}
|
|
|
|
var result = await HttpClient.Post(options).ConfigureAwait(false);
|
|
|
|
return result.Content;
|
|
|
|
//HttpWebRequest req = (HttpWebRequest)WebRequest.Create(XML_RPC_SERVER);
|
|
//req.ContentType = "text/xml";
|
|
//req.Host = "api.opensubtitles.org:80";
|
|
//req.Method = "POST";
|
|
//req.UserAgent = "xmlrpc-epi-php/0.2 (PHP)";
|
|
//req.ContentLength = request.Length;
|
|
//ServicePointManager.Expect100Continue = false;
|
|
//try
|
|
//{
|
|
// using (Stream stm = req.GetRequestStream())
|
|
// {
|
|
// stm.Write(request, 0, request.Length);
|
|
// }
|
|
|
|
// WebResponse response = req.GetResponse();
|
|
// return response.GetResponseStream();
|
|
//}
|
|
//catch (Exception ex)
|
|
//{
|
|
// Stream errorStream = new MemoryStream();
|
|
// byte[] dd = Encoding.ASCII.GetBytes("ERROR: " + ex.Message);
|
|
// errorStream.Write(dd, 0, dd.Length);
|
|
// errorStream.Position = 0;
|
|
// return errorStream;
|
|
//}
|
|
}
|
|
|
|
}
|
|
}
|