2014-07-26 19:30:15 +02:00
|
|
|
|
using Funq;
|
2013-12-07 16:52:38 +01:00
|
|
|
|
using MediaBrowser.Common;
|
|
|
|
|
using MediaBrowser.Common.Extensions;
|
2015-06-13 06:14:48 +02:00
|
|
|
|
using MediaBrowser.Controller.Configuration;
|
2013-12-07 16:52:38 +01:00
|
|
|
|
using MediaBrowser.Controller.Net;
|
|
|
|
|
using MediaBrowser.Model.Logging;
|
2014-07-19 03:28:40 +02:00
|
|
|
|
using MediaBrowser.Server.Implementations.HttpServer.SocketSharp;
|
2013-12-07 16:52:38 +01:00
|
|
|
|
using ServiceStack;
|
|
|
|
|
using ServiceStack.Host;
|
|
|
|
|
using ServiceStack.Host.Handlers;
|
|
|
|
|
using ServiceStack.Web;
|
|
|
|
|
using System;
|
|
|
|
|
using System.Collections.Generic;
|
|
|
|
|
using System.IO;
|
|
|
|
|
using System.Linq;
|
2016-11-08 19:44:23 +01:00
|
|
|
|
using System.Net.Security;
|
|
|
|
|
using System.Net.Sockets;
|
2013-12-07 16:52:38 +01:00
|
|
|
|
using System.Reflection;
|
2016-11-08 19:44:23 +01:00
|
|
|
|
using System.Security.Cryptography.X509Certificates;
|
2013-12-07 16:52:38 +01:00
|
|
|
|
using System.Threading;
|
|
|
|
|
using System.Threading.Tasks;
|
2016-11-08 19:44:23 +01:00
|
|
|
|
using Emby.Common.Implementations.Net;
|
2016-11-04 02:18:51 +01:00
|
|
|
|
using Emby.Server.Implementations.HttpServer;
|
2016-11-05 03:17:18 +01:00
|
|
|
|
using Emby.Server.Implementations.HttpServer.SocketSharp;
|
2015-12-14 15:45:42 +01:00
|
|
|
|
using MediaBrowser.Common.Net;
|
2015-10-30 18:00:33 +01:00
|
|
|
|
using MediaBrowser.Common.Security;
|
2016-10-26 08:01:42 +02:00
|
|
|
|
using MediaBrowser.Controller;
|
2016-11-08 19:44:23 +01:00
|
|
|
|
using MediaBrowser.Model.Cryptography;
|
2016-03-18 04:40:15 +01:00
|
|
|
|
using MediaBrowser.Model.Extensions;
|
2016-10-23 21:14:57 +02:00
|
|
|
|
using MediaBrowser.Model.IO;
|
2016-11-08 19:44:23 +01:00
|
|
|
|
using MediaBrowser.Model.Net;
|
2016-10-25 21:02:04 +02:00
|
|
|
|
using MediaBrowser.Model.Services;
|
2016-11-08 19:44:23 +01:00
|
|
|
|
using MediaBrowser.Model.Text;
|
|
|
|
|
using SocketHttpListener.Net;
|
|
|
|
|
using SocketHttpListener.Primitives;
|
2013-12-07 16:52:38 +01:00
|
|
|
|
|
|
|
|
|
namespace MediaBrowser.Server.Implementations.HttpServer
|
|
|
|
|
{
|
|
|
|
|
public class HttpListenerHost : ServiceStackHost, IHttpServer
|
|
|
|
|
{
|
|
|
|
|
private string DefaultRedirectPath { get; set; }
|
|
|
|
|
|
|
|
|
|
private readonly ILogger _logger;
|
2014-01-09 05:44:51 +01:00
|
|
|
|
public IEnumerable<string> UrlPrefixes { get; private set; }
|
2013-12-07 16:52:38 +01:00
|
|
|
|
|
2016-10-26 08:01:42 +02:00
|
|
|
|
private readonly List<IService> _restServices = new List<IService>();
|
2013-12-07 16:52:38 +01:00
|
|
|
|
|
2014-07-19 00:14:59 +02:00
|
|
|
|
private IHttpListener _listener;
|
2013-12-07 16:52:38 +01:00
|
|
|
|
|
|
|
|
|
private readonly ContainerAdapter _containerAdapter;
|
|
|
|
|
|
|
|
|
|
public event EventHandler<WebSocketConnectEventArgs> WebSocketConnected;
|
2015-03-08 20:48:30 +01:00
|
|
|
|
public event EventHandler<WebSocketConnectingEventArgs> WebSocketConnecting;
|
2013-12-07 16:52:38 +01:00
|
|
|
|
|
2015-01-19 05:29:57 +01:00
|
|
|
|
public string CertificatePath { get; private set; }
|
2015-01-07 04:36:42 +01:00
|
|
|
|
|
2015-06-13 06:14:48 +02:00
|
|
|
|
private readonly IServerConfigurationManager _config;
|
2015-12-14 15:45:42 +01:00
|
|
|
|
private readonly INetworkManager _networkManager;
|
2016-11-08 19:44:23 +01:00
|
|
|
|
private readonly IMemoryStreamFactory _memoryStreamProvider;
|
2015-06-13 06:14:48 +02:00
|
|
|
|
|
2016-10-26 08:01:42 +02:00
|
|
|
|
private readonly IServerApplicationHost _appHost;
|
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
private readonly ITextEncoding _textEncoding;
|
|
|
|
|
private readonly ISocketFactory _socketFactory;
|
|
|
|
|
private readonly ICryptoProvider _cryptoProvider;
|
|
|
|
|
|
2016-10-26 08:01:42 +02:00
|
|
|
|
public HttpListenerHost(IServerApplicationHost applicationHost,
|
2015-10-30 18:00:33 +01:00
|
|
|
|
ILogManager logManager,
|
2015-06-13 06:14:48 +02:00
|
|
|
|
IServerConfigurationManager config,
|
2015-01-17 20:30:23 +01:00
|
|
|
|
string serviceName,
|
2016-11-08 19:44:23 +01:00
|
|
|
|
string defaultRedirectPath, INetworkManager networkManager, IMemoryStreamFactory memoryStreamProvider, ITextEncoding textEncoding, ISocketFactory socketFactory, ICryptoProvider cryptoProvider)
|
|
|
|
|
: base(serviceName, new Assembly[] { })
|
2013-12-07 16:52:38 +01:00
|
|
|
|
{
|
2016-10-26 08:01:42 +02:00
|
|
|
|
_appHost = applicationHost;
|
2013-12-07 16:52:38 +01:00
|
|
|
|
DefaultRedirectPath = defaultRedirectPath;
|
2015-12-14 15:45:42 +01:00
|
|
|
|
_networkManager = networkManager;
|
2016-10-06 20:55:01 +02:00
|
|
|
|
_memoryStreamProvider = memoryStreamProvider;
|
2016-11-08 19:44:23 +01:00
|
|
|
|
_textEncoding = textEncoding;
|
|
|
|
|
_socketFactory = socketFactory;
|
|
|
|
|
_cryptoProvider = cryptoProvider;
|
2015-06-13 06:14:48 +02:00
|
|
|
|
_config = config;
|
2013-12-07 16:52:38 +01:00
|
|
|
|
|
|
|
|
|
_logger = logManager.GetLogger("HttpServer");
|
|
|
|
|
|
|
|
|
|
_containerAdapter = new ContainerAdapter(applicationHost);
|
|
|
|
|
}
|
|
|
|
|
|
2015-09-14 01:07:54 +02:00
|
|
|
|
public string GlobalResponse { get; set; }
|
2015-10-30 18:00:33 +01:00
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
public override void Configure()
|
2013-12-07 16:52:38 +01:00
|
|
|
|
{
|
|
|
|
|
HostConfig.Instance.DefaultRedirectPath = DefaultRedirectPath;
|
|
|
|
|
|
|
|
|
|
HostConfig.Instance.MapExceptionToStatusCode = new Dictionary<Type, int>
|
|
|
|
|
{
|
2016-08-31 21:17:11 +02:00
|
|
|
|
{typeof (InvalidOperationException), 500},
|
|
|
|
|
{typeof (NotImplementedException), 500},
|
2013-12-07 16:52:38 +01:00
|
|
|
|
{typeof (ResourceNotFoundException), 404},
|
|
|
|
|
{typeof (FileNotFoundException), 404},
|
2014-07-22 03:29:06 +02:00
|
|
|
|
{typeof (DirectoryNotFoundException), 404},
|
2014-11-15 03:31:03 +01:00
|
|
|
|
{typeof (SecurityException), 401},
|
2015-10-30 18:00:33 +01:00
|
|
|
|
{typeof (PaymentRequiredException), 402},
|
|
|
|
|
{typeof (UnauthorizedAccessException), 500},
|
2016-08-31 21:17:11 +02:00
|
|
|
|
{typeof (ApplicationException), 500},
|
|
|
|
|
{typeof (PlatformNotSupportedException), 500},
|
|
|
|
|
{typeof (NotSupportedException), 500}
|
2013-12-07 16:52:38 +01:00
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
// The Markdown feature causes slow startup times (5 mins+) on cold boots for some users
|
|
|
|
|
// Custom format allows images
|
2016-10-08 07:57:38 +02:00
|
|
|
|
HostConfig.Instance.EnableFeatures = Feature.Html | Feature.Json | Feature.Xml | Feature.CustomFormat;
|
2013-12-07 16:52:38 +01:00
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
Container.Adapter = _containerAdapter;
|
2014-07-02 06:57:18 +02:00
|
|
|
|
|
2016-10-26 08:01:42 +02:00
|
|
|
|
var requestFilters = _appHost.GetExports<IRequestFilter>().ToList();
|
|
|
|
|
foreach (var filter in requestFilters)
|
|
|
|
|
{
|
|
|
|
|
HostContext.GlobalRequestFilters.Add(filter.Filter);
|
|
|
|
|
}
|
|
|
|
|
|
2016-05-29 23:04:49 +02:00
|
|
|
|
HostContext.GlobalResponseFilters.Add(new ResponseFilter(_logger).FilterResponse);
|
2013-12-07 16:52:38 +01:00
|
|
|
|
}
|
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
protected override ILogger Logger
|
|
|
|
|
{
|
|
|
|
|
get
|
|
|
|
|
{
|
|
|
|
|
return _logger;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
2013-12-07 16:52:38 +01:00
|
|
|
|
public override void OnConfigLoad()
|
|
|
|
|
{
|
|
|
|
|
base.OnConfigLoad();
|
|
|
|
|
|
2015-01-17 20:30:23 +01:00
|
|
|
|
Config.HandlerFactoryPath = null;
|
2013-12-07 16:52:38 +01:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
protected override ServiceController CreateServiceController(params Assembly[] assembliesWithServices)
|
|
|
|
|
{
|
|
|
|
|
var types = _restServices.Select(r => r.GetType()).ToArray();
|
|
|
|
|
|
|
|
|
|
return new ServiceController(this, () => types);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public override ServiceStackHost Start(string listeningAtUrlBase)
|
|
|
|
|
{
|
2014-07-19 00:14:59 +02:00
|
|
|
|
StartListener();
|
2013-12-07 16:52:38 +01:00
|
|
|
|
return this;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// Starts the Web Service
|
|
|
|
|
/// </summary>
|
2014-07-19 00:14:59 +02:00
|
|
|
|
private void StartListener()
|
2013-12-07 16:52:38 +01:00
|
|
|
|
{
|
2016-10-25 21:02:04 +02:00
|
|
|
|
HostContext.Config.HandlerFactoryPath = GetHandlerPathIfAny(UrlPrefixes.First());
|
2014-07-09 02:46:11 +02:00
|
|
|
|
|
2014-12-27 23:52:41 +01:00
|
|
|
|
_listener = GetListener();
|
2014-07-19 03:28:40 +02:00
|
|
|
|
|
2015-03-08 20:48:30 +01:00
|
|
|
|
_listener.WebSocketConnected = OnWebSocketConnected;
|
|
|
|
|
_listener.WebSocketConnecting = OnWebSocketConnecting;
|
2014-07-19 03:28:40 +02:00
|
|
|
|
_listener.ErrorHandler = ErrorHandler;
|
|
|
|
|
_listener.RequestHandler = RequestHandler;
|
2013-12-07 16:52:38 +01:00
|
|
|
|
|
2014-07-19 00:14:59 +02:00
|
|
|
|
_listener.Start(UrlPrefixes);
|
2014-07-09 02:46:11 +02:00
|
|
|
|
}
|
2013-12-07 16:52:38 +01:00
|
|
|
|
|
2016-10-25 21:02:04 +02:00
|
|
|
|
public static string GetHandlerPathIfAny(string listenerUrl)
|
|
|
|
|
{
|
|
|
|
|
if (listenerUrl == null) return null;
|
|
|
|
|
var pos = listenerUrl.IndexOf("://", StringComparison.OrdinalIgnoreCase);
|
|
|
|
|
if (pos == -1) return null;
|
|
|
|
|
var startHostUrl = listenerUrl.Substring(pos + "://".Length);
|
|
|
|
|
var endPos = startHostUrl.IndexOf('/');
|
|
|
|
|
if (endPos == -1) return null;
|
|
|
|
|
var endHostUrl = startHostUrl.Substring(endPos + 1);
|
|
|
|
|
return string.IsNullOrEmpty(endHostUrl) ? null : endHostUrl.TrimEnd('/');
|
|
|
|
|
}
|
|
|
|
|
|
2014-12-27 23:52:41 +01:00
|
|
|
|
private IHttpListener GetListener()
|
|
|
|
|
{
|
2016-11-08 19:44:23 +01:00
|
|
|
|
var cert = !string.IsNullOrWhiteSpace(CertificatePath) && File.Exists(CertificatePath)
|
|
|
|
|
? GetCert(CertificatePath) :
|
|
|
|
|
null;
|
|
|
|
|
|
2016-11-08 20:50:39 +01:00
|
|
|
|
var enableDualMode = Environment.OSVersion.Platform == PlatformID.Win32NT;
|
|
|
|
|
|
|
|
|
|
return new WebSocketSharpListener(_logger, cert, _memoryStreamProvider, _textEncoding, _networkManager, _socketFactory, _cryptoProvider, new StreamFactory(), enableDualMode, GetRequest);
|
2016-11-08 19:44:23 +01:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public static ICertificate GetCert(string certificateLocation)
|
|
|
|
|
{
|
|
|
|
|
X509Certificate2 localCert = new X509Certificate2(certificateLocation);
|
|
|
|
|
//localCert.PrivateKey = PrivateKey.CreateFromFile(pvk_file).RSA;
|
|
|
|
|
if (localCert.PrivateKey == null)
|
|
|
|
|
{
|
|
|
|
|
//throw new FileNotFoundException("Secure requested, no private key included", certificateLocation);
|
|
|
|
|
return null;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return new Certificate(localCert);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private IHttpRequest GetRequest(HttpListenerContext httpContext)
|
|
|
|
|
{
|
|
|
|
|
var operationName = httpContext.Request.GetOperationName();
|
|
|
|
|
|
|
|
|
|
var req = new WebSocketSharpRequest(httpContext, operationName, _logger, _memoryStreamProvider);
|
|
|
|
|
|
|
|
|
|
return req;
|
2014-12-27 23:52:41 +01:00
|
|
|
|
}
|
|
|
|
|
|
2015-03-08 20:48:30 +01:00
|
|
|
|
private void OnWebSocketConnecting(WebSocketConnectingEventArgs args)
|
|
|
|
|
{
|
2016-04-22 18:12:20 +02:00
|
|
|
|
if (_disposed)
|
|
|
|
|
{
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
2015-03-08 20:48:30 +01:00
|
|
|
|
if (WebSocketConnecting != null)
|
|
|
|
|
{
|
|
|
|
|
WebSocketConnecting(this, args);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private void OnWebSocketConnected(WebSocketConnectEventArgs args)
|
2014-07-09 02:46:11 +02:00
|
|
|
|
{
|
2016-04-22 18:12:20 +02:00
|
|
|
|
if (_disposed)
|
|
|
|
|
{
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
2014-07-19 00:14:59 +02:00
|
|
|
|
if (WebSocketConnected != null)
|
2014-07-09 02:46:11 +02:00
|
|
|
|
{
|
2014-07-19 00:14:59 +02:00
|
|
|
|
WebSocketConnected(this, args);
|
2014-07-09 02:46:11 +02:00
|
|
|
|
}
|
2013-12-07 16:52:38 +01:00
|
|
|
|
}
|
|
|
|
|
|
2014-07-19 00:14:59 +02:00
|
|
|
|
private void ErrorHandler(Exception ex, IRequest httpReq)
|
2013-12-07 16:52:38 +01:00
|
|
|
|
{
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
var httpRes = httpReq.Response;
|
2014-07-04 04:22:57 +02:00
|
|
|
|
|
|
|
|
|
if (httpRes.IsClosed)
|
|
|
|
|
{
|
|
|
|
|
return;
|
|
|
|
|
}
|
2015-01-17 20:30:23 +01:00
|
|
|
|
|
2014-07-09 02:46:11 +02:00
|
|
|
|
var errorResponse = new ErrorResponse
|
|
|
|
|
{
|
|
|
|
|
ResponseStatus = new ResponseStatus
|
|
|
|
|
{
|
|
|
|
|
ErrorCode = ex.GetType().GetOperationName(),
|
|
|
|
|
Message = ex.Message,
|
2014-10-29 00:17:55 +01:00
|
|
|
|
StackTrace = ex.StackTrace
|
2014-07-09 02:46:11 +02:00
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
|
2013-12-07 16:52:38 +01:00
|
|
|
|
var contentType = httpReq.ResponseContentType;
|
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
var serializer = ContentTypes.Instance.GetResponseSerializer(contentType);
|
2013-12-07 16:52:38 +01:00
|
|
|
|
if (serializer == null)
|
|
|
|
|
{
|
|
|
|
|
contentType = HostContext.Config.DefaultContentType;
|
2016-11-08 19:44:23 +01:00
|
|
|
|
serializer = ContentTypes.Instance.GetResponseSerializer(contentType);
|
2013-12-07 16:52:38 +01:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
var httpError = ex as IHttpError;
|
|
|
|
|
if (httpError != null)
|
|
|
|
|
{
|
|
|
|
|
httpRes.StatusCode = httpError.Status;
|
|
|
|
|
httpRes.StatusDescription = httpError.StatusDescription;
|
|
|
|
|
}
|
|
|
|
|
else
|
|
|
|
|
{
|
|
|
|
|
httpRes.StatusCode = 500;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
httpRes.ContentType = contentType;
|
|
|
|
|
|
|
|
|
|
serializer(httpReq, errorResponse, httpRes);
|
|
|
|
|
|
|
|
|
|
httpRes.Close();
|
|
|
|
|
}
|
2016-08-05 23:15:48 +02:00
|
|
|
|
catch
|
2013-12-07 16:52:38 +01:00
|
|
|
|
{
|
2016-02-04 19:04:04 +01:00
|
|
|
|
//_logger.ErrorException("Error this.ProcessRequest(context)(Exception while writing error to the response)", errorEx);
|
2013-12-07 16:52:38 +01:00
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// Shut down the Web Service
|
|
|
|
|
/// </summary>
|
|
|
|
|
public void Stop()
|
|
|
|
|
{
|
2014-07-19 00:14:59 +02:00
|
|
|
|
if (_listener != null)
|
2013-12-07 16:52:38 +01:00
|
|
|
|
{
|
2014-07-19 00:14:59 +02:00
|
|
|
|
_listener.Stop();
|
2013-12-07 16:52:38 +01:00
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
2016-01-23 04:10:21 +01:00
|
|
|
|
private readonly Dictionary<string, int> _skipLogExtensions = new Dictionary<string, int>(StringComparer.OrdinalIgnoreCase)
|
|
|
|
|
{
|
|
|
|
|
{".js", 0},
|
|
|
|
|
{".css", 0},
|
|
|
|
|
{".woff", 0},
|
|
|
|
|
{".woff2", 0},
|
|
|
|
|
{".ttf", 0},
|
|
|
|
|
{".html", 0}
|
|
|
|
|
};
|
|
|
|
|
|
2016-02-03 22:56:00 +01:00
|
|
|
|
private bool EnableLogging(string url, string localPath)
|
2016-01-23 04:10:21 +01:00
|
|
|
|
{
|
2016-02-01 20:54:49 +01:00
|
|
|
|
var extension = GetExtension(url);
|
2016-01-23 04:10:21 +01:00
|
|
|
|
|
2016-02-03 22:56:00 +01:00
|
|
|
|
if (string.IsNullOrWhiteSpace(extension) || !_skipLogExtensions.ContainsKey(extension))
|
|
|
|
|
{
|
|
|
|
|
if (string.IsNullOrWhiteSpace(localPath) || localPath.IndexOf("system/ping", StringComparison.OrdinalIgnoreCase) == -1)
|
|
|
|
|
{
|
|
|
|
|
return true;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return false;
|
2016-01-23 04:10:21 +01:00
|
|
|
|
}
|
|
|
|
|
|
2016-02-01 20:54:49 +01:00
|
|
|
|
private string GetExtension(string url)
|
|
|
|
|
{
|
|
|
|
|
var parts = url.Split(new[] { '?' }, 2);
|
|
|
|
|
|
|
|
|
|
return Path.GetExtension(parts[0]);
|
|
|
|
|
}
|
|
|
|
|
|
2016-03-15 20:11:53 +01:00
|
|
|
|
public static string RemoveQueryStringByKey(string url, string key)
|
|
|
|
|
{
|
|
|
|
|
var uri = new Uri(url);
|
|
|
|
|
|
|
|
|
|
// this gets all the query string key value pairs as a collection
|
|
|
|
|
var newQueryString = MyHttpUtility.ParseQueryString(uri.Query);
|
|
|
|
|
|
|
|
|
|
if (newQueryString.Count == 0)
|
|
|
|
|
{
|
|
|
|
|
return url;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// this removes the key if exists
|
|
|
|
|
newQueryString.Remove(key);
|
|
|
|
|
|
|
|
|
|
// this gets the page path from root without QueryString
|
|
|
|
|
string pagePathWithoutQueryString = uri.GetLeftPart(UriPartial.Path);
|
|
|
|
|
|
|
|
|
|
return newQueryString.Count > 0
|
|
|
|
|
? String.Format("{0}?{1}", pagePathWithoutQueryString, newQueryString)
|
|
|
|
|
: pagePathWithoutQueryString;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private string GetUrlToLog(string url)
|
|
|
|
|
{
|
|
|
|
|
url = RemoveQueryStringByKey(url, "api_key");
|
|
|
|
|
|
|
|
|
|
return url;
|
|
|
|
|
}
|
|
|
|
|
|
2016-08-18 08:26:47 +02:00
|
|
|
|
private string NormalizeConfiguredLocalAddress(string address)
|
|
|
|
|
{
|
|
|
|
|
var index = address.Trim('/').IndexOf('/');
|
|
|
|
|
|
|
|
|
|
if (index != -1)
|
|
|
|
|
{
|
|
|
|
|
address = address.Substring(index + 1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return address.Trim('/');
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private bool ValidateHost(Uri url)
|
|
|
|
|
{
|
|
|
|
|
var hosts = _config
|
|
|
|
|
.Configuration
|
|
|
|
|
.LocalNetworkAddresses
|
|
|
|
|
.Select(NormalizeConfiguredLocalAddress)
|
|
|
|
|
.ToList();
|
|
|
|
|
|
|
|
|
|
if (hosts.Count == 0)
|
|
|
|
|
{
|
|
|
|
|
return true;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
var host = url.Host ?? string.Empty;
|
|
|
|
|
|
|
|
|
|
_logger.Debug("Validating host {0}", host);
|
|
|
|
|
|
|
|
|
|
if (_networkManager.IsInPrivateAddressSpace(host))
|
|
|
|
|
{
|
|
|
|
|
hosts.Add("localhost");
|
|
|
|
|
hosts.Add("127.0.0.1");
|
|
|
|
|
|
|
|
|
|
return hosts.Any(i => host.IndexOf(i, StringComparison.OrdinalIgnoreCase) != -1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return true;
|
|
|
|
|
}
|
|
|
|
|
|
2013-12-07 16:52:38 +01:00
|
|
|
|
/// <summary>
|
|
|
|
|
/// Overridable method that can be used to implement a custom hnandler
|
|
|
|
|
/// </summary>
|
2014-07-19 00:14:59 +02:00
|
|
|
|
/// <param name="httpReq">The HTTP req.</param>
|
2014-07-19 03:28:40 +02:00
|
|
|
|
/// <param name="url">The URL.</param>
|
2014-07-19 00:14:59 +02:00
|
|
|
|
/// <returns>Task.</returns>
|
2016-07-14 21:13:52 +02:00
|
|
|
|
protected async Task RequestHandler(IHttpRequest httpReq, Uri url)
|
2013-12-07 16:52:38 +01:00
|
|
|
|
{
|
2014-07-19 00:14:59 +02:00
|
|
|
|
var date = DateTime.Now;
|
|
|
|
|
var httpRes = httpReq.Response;
|
2016-11-08 19:44:23 +01:00
|
|
|
|
bool enableLog = false;
|
|
|
|
|
string urlToLog = null;
|
|
|
|
|
string remoteIp = null;
|
2014-07-09 02:46:11 +02:00
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
try
|
2016-04-22 18:12:20 +02:00
|
|
|
|
{
|
2016-11-08 19:44:23 +01:00
|
|
|
|
if (_disposed)
|
|
|
|
|
{
|
|
|
|
|
httpRes.StatusCode = 503;
|
|
|
|
|
return;
|
|
|
|
|
}
|
2016-04-22 18:12:20 +02:00
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
if (!ValidateHost(url))
|
|
|
|
|
{
|
|
|
|
|
httpRes.StatusCode = 400;
|
|
|
|
|
httpRes.ContentType = "text/plain";
|
|
|
|
|
httpRes.Write("Invalid host");
|
|
|
|
|
return;
|
|
|
|
|
}
|
2016-08-18 08:26:47 +02:00
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
if (string.Equals(httpReq.Verb, "OPTIONS", StringComparison.OrdinalIgnoreCase))
|
|
|
|
|
{
|
|
|
|
|
httpRes.StatusCode = 200;
|
|
|
|
|
httpRes.AddHeader("Access-Control-Allow-Origin", "*");
|
|
|
|
|
httpRes.AddHeader("Access-Control-Allow-Methods", "GET, POST, PUT, DELETE, PATCH, OPTIONS");
|
|
|
|
|
httpRes.AddHeader("Access-Control-Allow-Headers",
|
|
|
|
|
"Content-Type, Authorization, Range, X-MediaBrowser-Token, X-Emby-Authorization");
|
|
|
|
|
httpRes.ContentType = "text/html";
|
|
|
|
|
return;
|
|
|
|
|
}
|
2016-08-18 08:26:47 +02:00
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
var operationName = httpReq.OperationName;
|
|
|
|
|
var localPath = url.LocalPath;
|
2016-09-01 18:36:11 +02:00
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
var urlString = url.OriginalString;
|
|
|
|
|
enableLog = EnableLogging(urlString, localPath);
|
|
|
|
|
urlToLog = urlString;
|
2016-09-01 18:36:11 +02:00
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
if (enableLog)
|
|
|
|
|
{
|
|
|
|
|
urlToLog = GetUrlToLog(urlString);
|
|
|
|
|
remoteIp = httpReq.RemoteIp;
|
2014-07-09 02:46:11 +02:00
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
LoggerUtils.LogRequest(_logger, urlToLog, httpReq.HttpMethod, httpReq.UserAgent);
|
|
|
|
|
}
|
2016-01-23 04:10:21 +01:00
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
if (string.Equals(localPath, "/emby/", StringComparison.OrdinalIgnoreCase) ||
|
|
|
|
|
string.Equals(localPath, "/mediabrowser/", StringComparison.OrdinalIgnoreCase))
|
|
|
|
|
{
|
|
|
|
|
RedirectToUrl(httpRes, DefaultRedirectPath);
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
if (string.Equals(localPath, "/emby", StringComparison.OrdinalIgnoreCase) ||
|
|
|
|
|
string.Equals(localPath, "/mediabrowser", StringComparison.OrdinalIgnoreCase))
|
|
|
|
|
{
|
|
|
|
|
RedirectToUrl(httpRes, "emby/" + DefaultRedirectPath);
|
|
|
|
|
return;
|
|
|
|
|
}
|
2016-03-18 04:40:15 +01:00
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
if (string.Equals(localPath, "/mediabrowser/", StringComparison.OrdinalIgnoreCase) ||
|
|
|
|
|
string.Equals(localPath, "/mediabrowser", StringComparison.OrdinalIgnoreCase) ||
|
|
|
|
|
localPath.IndexOf("mediabrowser/web", StringComparison.OrdinalIgnoreCase) != -1)
|
|
|
|
|
{
|
|
|
|
|
httpRes.StatusCode = 200;
|
|
|
|
|
httpRes.ContentType = "text/html";
|
|
|
|
|
var newUrl = urlString.Replace("mediabrowser", "emby", StringComparison.OrdinalIgnoreCase)
|
|
|
|
|
.Replace("/dashboard/", "/web/", StringComparison.OrdinalIgnoreCase);
|
2016-04-06 04:18:56 +02:00
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
if (!string.Equals(newUrl, urlString, StringComparison.OrdinalIgnoreCase))
|
|
|
|
|
{
|
|
|
|
|
httpRes.Write(
|
|
|
|
|
"<!doctype html><html><head><title>Emby</title></head><body>Please update your Emby bookmark to <a href=\"" +
|
|
|
|
|
newUrl + "\">" + newUrl + "</a></body></html>");
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
}
|
2016-08-22 20:28:24 +02:00
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
if (localPath.IndexOf("dashboard/", StringComparison.OrdinalIgnoreCase) != -1 &&
|
|
|
|
|
localPath.IndexOf("web/dashboard", StringComparison.OrdinalIgnoreCase) == -1)
|
2016-08-22 20:28:24 +02:00
|
|
|
|
{
|
2016-11-08 19:44:23 +01:00
|
|
|
|
httpRes.StatusCode = 200;
|
|
|
|
|
httpRes.ContentType = "text/html";
|
|
|
|
|
var newUrl = urlString.Replace("mediabrowser", "emby", StringComparison.OrdinalIgnoreCase)
|
|
|
|
|
.Replace("/dashboard/", "/web/", StringComparison.OrdinalIgnoreCase);
|
2016-08-22 20:28:24 +02:00
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
if (!string.Equals(newUrl, urlString, StringComparison.OrdinalIgnoreCase))
|
|
|
|
|
{
|
|
|
|
|
httpRes.Write(
|
|
|
|
|
"<!doctype html><html><head><title>Emby</title></head><body>Please update your Emby bookmark to <a href=\"" +
|
|
|
|
|
newUrl + "\">" + newUrl + "</a></body></html>");
|
|
|
|
|
return;
|
|
|
|
|
}
|
2016-08-22 20:28:24 +02:00
|
|
|
|
}
|
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
if (string.Equals(localPath, "/web", StringComparison.OrdinalIgnoreCase))
|
|
|
|
|
{
|
|
|
|
|
RedirectToUrl(httpRes, DefaultRedirectPath);
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
if (string.Equals(localPath, "/web/", StringComparison.OrdinalIgnoreCase))
|
|
|
|
|
{
|
|
|
|
|
RedirectToUrl(httpRes, "../" + DefaultRedirectPath);
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
if (string.Equals(localPath, "/", StringComparison.OrdinalIgnoreCase))
|
|
|
|
|
{
|
|
|
|
|
RedirectToUrl(httpRes, DefaultRedirectPath);
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
if (string.IsNullOrEmpty(localPath))
|
|
|
|
|
{
|
|
|
|
|
RedirectToUrl(httpRes, "/" + DefaultRedirectPath);
|
|
|
|
|
return;
|
|
|
|
|
}
|
2016-03-18 04:40:15 +01:00
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
if (string.Equals(localPath, "/emby/pin", StringComparison.OrdinalIgnoreCase))
|
2016-03-25 18:48:18 +01:00
|
|
|
|
{
|
2016-11-08 19:44:23 +01:00
|
|
|
|
RedirectToUrl(httpRes, "web/pin.html");
|
|
|
|
|
return;
|
|
|
|
|
}
|
2016-03-18 04:40:15 +01:00
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
if (!string.IsNullOrWhiteSpace(GlobalResponse))
|
|
|
|
|
{
|
|
|
|
|
httpRes.StatusCode = 503;
|
|
|
|
|
httpRes.ContentType = "text/html";
|
|
|
|
|
httpRes.Write(GlobalResponse);
|
2016-07-14 21:13:52 +02:00
|
|
|
|
return;
|
2016-03-25 18:48:18 +01:00
|
|
|
|
}
|
2016-03-18 07:36:58 +01:00
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
var handler = HttpHandlerFactory.GetHandler(httpReq);
|
2014-07-09 02:46:11 +02:00
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
if (handler != null)
|
|
|
|
|
{
|
|
|
|
|
await handler.ProcessRequestAsync(httpReq, httpRes, operationName).ConfigureAwait(false);
|
|
|
|
|
}
|
2016-02-21 07:25:25 +01:00
|
|
|
|
}
|
2016-11-08 19:44:23 +01:00
|
|
|
|
catch (Exception ex)
|
2015-09-14 01:07:54 +02:00
|
|
|
|
{
|
2016-11-08 19:44:23 +01:00
|
|
|
|
ErrorHandler(ex, httpReq);
|
2015-09-14 01:07:54 +02:00
|
|
|
|
}
|
2016-11-08 19:44:23 +01:00
|
|
|
|
finally
|
2013-12-07 16:52:38 +01:00
|
|
|
|
{
|
2016-11-08 19:44:23 +01:00
|
|
|
|
httpRes.Close();
|
2013-12-07 16:52:38 +01:00
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
if (enableLog)
|
2014-07-09 02:46:11 +02:00
|
|
|
|
{
|
2014-07-19 03:28:40 +02:00
|
|
|
|
var statusCode = httpRes.StatusCode;
|
|
|
|
|
|
2014-07-09 02:46:11 +02:00
|
|
|
|
var duration = DateTime.Now - date;
|
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
LoggerUtils.LogResponse(_logger, statusCode, urlToLog, remoteIp, duration);
|
2016-07-14 21:13:52 +02:00
|
|
|
|
}
|
2013-12-07 16:52:38 +01:00
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
2016-11-08 19:44:23 +01:00
|
|
|
|
public static void RedirectToUrl(IResponse httpRes, string url)
|
|
|
|
|
{
|
|
|
|
|
httpRes.StatusCode = 302;
|
|
|
|
|
httpRes.AddHeader(HttpHeaders.Location, url);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
2013-12-07 16:52:38 +01:00
|
|
|
|
/// <summary>
|
|
|
|
|
/// Adds the rest handlers.
|
|
|
|
|
/// </summary>
|
|
|
|
|
/// <param name="services">The services.</param>
|
2016-10-26 08:01:42 +02:00
|
|
|
|
public void Init(IEnumerable<IService> services)
|
2013-12-07 16:52:38 +01:00
|
|
|
|
{
|
|
|
|
|
_restServices.AddRange(services);
|
|
|
|
|
|
|
|
|
|
ServiceController = CreateServiceController();
|
|
|
|
|
|
|
|
|
|
_logger.Info("Calling ServiceStack AppHost.Init");
|
2013-12-09 03:24:48 +01:00
|
|
|
|
|
|
|
|
|
base.Init();
|
2013-12-07 16:52:38 +01:00
|
|
|
|
}
|
|
|
|
|
|
2016-10-25 21:02:04 +02:00
|
|
|
|
public override Model.Services.RouteAttribute[] GetRouteAttributes(Type requestType)
|
2015-01-17 20:30:23 +01:00
|
|
|
|
{
|
|
|
|
|
var routes = base.GetRouteAttributes(requestType).ToList();
|
|
|
|
|
var clone = routes.ToList();
|
|
|
|
|
|
|
|
|
|
foreach (var route in clone)
|
|
|
|
|
{
|
2016-10-25 21:02:04 +02:00
|
|
|
|
routes.Add(new Model.Services.RouteAttribute(NormalizeEmbyRoutePath(route.Path), route.Verbs)
|
2015-04-11 23:34:05 +02:00
|
|
|
|
{
|
|
|
|
|
Notes = route.Notes,
|
|
|
|
|
Priority = route.Priority,
|
|
|
|
|
Summary = route.Summary
|
|
|
|
|
});
|
2016-03-18 04:40:15 +01:00
|
|
|
|
|
2016-10-25 21:02:04 +02:00
|
|
|
|
routes.Add(new Model.Services.RouteAttribute(NormalizeRoutePath(route.Path), route.Verbs)
|
2015-01-17 20:30:23 +01:00
|
|
|
|
{
|
|
|
|
|
Notes = route.Notes,
|
|
|
|
|
Priority = route.Priority,
|
|
|
|
|
Summary = route.Summary
|
|
|
|
|
});
|
2015-02-19 05:37:44 +01:00
|
|
|
|
|
2016-10-25 21:02:04 +02:00
|
|
|
|
routes.Add(new Model.Services.RouteAttribute(DoubleNormalizeEmbyRoutePath(route.Path), route.Verbs)
|
2015-04-11 23:34:05 +02:00
|
|
|
|
{
|
|
|
|
|
Notes = route.Notes,
|
|
|
|
|
Priority = route.Priority,
|
|
|
|
|
Summary = route.Summary
|
|
|
|
|
});
|
2015-01-17 20:30:23 +01:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return routes.ToArray();
|
|
|
|
|
}
|
|
|
|
|
|
2015-04-11 23:34:05 +02:00
|
|
|
|
private string NormalizeEmbyRoutePath(string path)
|
|
|
|
|
{
|
|
|
|
|
if (path.StartsWith("/", StringComparison.OrdinalIgnoreCase))
|
|
|
|
|
{
|
|
|
|
|
return "/emby" + path;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return "emby/" + path;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private string DoubleNormalizeEmbyRoutePath(string path)
|
|
|
|
|
{
|
|
|
|
|
if (path.StartsWith("/", StringComparison.OrdinalIgnoreCase))
|
|
|
|
|
{
|
|
|
|
|
return "/emby/emby" + path;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return "emby/emby/" + path;
|
|
|
|
|
}
|
|
|
|
|
|
2015-01-17 20:30:23 +01:00
|
|
|
|
private string NormalizeRoutePath(string path)
|
|
|
|
|
{
|
|
|
|
|
if (path.StartsWith("/", StringComparison.OrdinalIgnoreCase))
|
|
|
|
|
{
|
|
|
|
|
return "/mediabrowser" + path;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return "mediabrowser/" + path;
|
|
|
|
|
}
|
2014-07-09 02:46:11 +02:00
|
|
|
|
|
2013-12-07 16:52:38 +01:00
|
|
|
|
private bool _disposed;
|
|
|
|
|
private readonly object _disposeLock = new object();
|
|
|
|
|
protected virtual void Dispose(bool disposing)
|
|
|
|
|
{
|
|
|
|
|
if (_disposed) return;
|
|
|
|
|
base.Dispose();
|
|
|
|
|
|
|
|
|
|
lock (_disposeLock)
|
|
|
|
|
{
|
|
|
|
|
if (_disposed) return;
|
|
|
|
|
|
|
|
|
|
if (disposing)
|
|
|
|
|
{
|
|
|
|
|
Stop();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//release unmanaged resources here...
|
|
|
|
|
_disposed = true;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public override void Dispose()
|
|
|
|
|
{
|
|
|
|
|
Dispose(true);
|
|
|
|
|
GC.SuppressFinalize(this);
|
|
|
|
|
}
|
|
|
|
|
|
2015-01-07 04:36:42 +01:00
|
|
|
|
public void StartServer(IEnumerable<string> urlPrefixes, string certificatePath)
|
2013-12-07 16:52:38 +01:00
|
|
|
|
{
|
2015-01-19 05:29:57 +01:00
|
|
|
|
CertificatePath = certificatePath;
|
2014-01-09 05:44:51 +01:00
|
|
|
|
UrlPrefixes = urlPrefixes.ToList();
|
|
|
|
|
Start(UrlPrefixes.First());
|
2013-12-07 16:52:38 +01:00
|
|
|
|
}
|
|
|
|
|
}
|
2016-11-08 19:44:23 +01:00
|
|
|
|
|
|
|
|
|
public class StreamFactory : IStreamFactory
|
|
|
|
|
{
|
|
|
|
|
public Stream CreateNetworkStream(ISocket socket, bool ownsSocket)
|
|
|
|
|
{
|
|
|
|
|
var netSocket = (NetSocket)socket;
|
|
|
|
|
|
|
|
|
|
return new NetworkStream(netSocket.Socket, ownsSocket);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public Task AuthenticateSslStreamAsServer(Stream stream, ICertificate certificate)
|
|
|
|
|
{
|
|
|
|
|
var sslStream = (SslStream)stream;
|
|
|
|
|
var cert = (Certificate)certificate;
|
|
|
|
|
|
|
|
|
|
return sslStream.AuthenticateAsServerAsync(cert.X509Certificate);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public Stream CreateSslStream(Stream innerStream, bool leaveInnerStreamOpen)
|
|
|
|
|
{
|
|
|
|
|
return new SslStream(innerStream, leaveInnerStreamOpen);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public class Certificate : ICertificate
|
|
|
|
|
{
|
|
|
|
|
public Certificate(X509Certificate x509Certificate)
|
|
|
|
|
{
|
|
|
|
|
X509Certificate = x509Certificate;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public X509Certificate X509Certificate { get; private set; }
|
|
|
|
|
}
|
2013-12-07 16:52:38 +01:00
|
|
|
|
}
|