jellyfin/Emby.Server.Implementations/HttpServer/HttpListenerHost.cs

712 lines
24 KiB
C#
Raw Normal View History

2013-12-07 15:52:38 +00:00
using System;
using System.Collections.Generic;
using System.Diagnostics;
2013-12-07 15:52:38 +00:00
using System.IO;
using System.Linq;
using System.Net.Sockets;
2013-12-07 15:52:38 +00:00
using System.Reflection;
2017-05-22 04:54:02 +00:00
using System.Threading;
2013-12-07 15:52:38 +00:00
using System.Threading.Tasks;
2019-08-05 23:25:18 +00:00
using Emby.Server.Implementations.Configuration;
using Emby.Server.Implementations.Net;
2017-02-13 01:07:48 +00:00
using Emby.Server.Implementations.Services;
using MediaBrowser.Common.Extensions;
2015-12-14 14:45:42 +00:00
using MediaBrowser.Common.Net;
2016-10-26 06:01:42 +00:00
using MediaBrowser.Controller;
using MediaBrowser.Controller.Configuration;
using MediaBrowser.Controller.Net;
using MediaBrowser.Model.Events;
2016-03-18 03:40:15 +00:00
using MediaBrowser.Model.Extensions;
2016-11-10 14:41:24 +00:00
using MediaBrowser.Model.Serialization;
2016-10-25 19:02:04 +00:00
using MediaBrowser.Model.Services;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Http.Internal;
2019-02-27 11:40:18 +00:00
using Microsoft.AspNetCore.WebUtilities;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Logging;
using ServiceStack.Text.Jsv;
2013-12-07 15:52:38 +00:00
2016-11-11 03:29:51 +00:00
namespace Emby.Server.Implementations.HttpServer
2013-12-07 15:52:38 +00:00
{
2017-02-13 02:06:54 +00:00
public class HttpListenerHost : IHttpServer, IDisposable
2013-12-07 15:52:38 +00:00
{
private readonly ILogger _logger;
2015-06-13 04:14:48 +00:00
private readonly IServerConfigurationManager _config;
2015-12-14 14:45:42 +00:00
private readonly INetworkManager _networkManager;
2016-10-26 06:01:42 +00:00
private readonly IServerApplicationHost _appHost;
2016-11-10 14:41:24 +00:00
private readonly IJsonSerializer _jsonSerializer;
private readonly IXmlSerializer _xmlSerializer;
private readonly IHttpListener _socketListener;
2016-11-11 03:29:51 +00:00
private readonly Func<Type, Func<string, object>> _funcParseFn;
private readonly string _defaultRedirectPath;
2017-02-13 02:06:54 +00:00
private readonly Dictionary<Type, Type> ServiceOperationsMap = new Dictionary<Type, Type>();
2018-09-12 17:26:21 +00:00
private IWebSocketListener[] _webSocketListeners = Array.Empty<IWebSocketListener>();
private readonly List<IWebSocketConnection> _webSocketConnections = new List<IWebSocketConnection>();
private bool _disposed = false;
2018-09-12 17:26:21 +00:00
2019-01-06 19:35:36 +00:00
public HttpListenerHost(
IServerApplicationHost applicationHost,
ILogger<HttpListenerHost> logger,
2015-06-13 04:14:48 +00:00
IServerConfigurationManager config,
IConfiguration configuration,
2019-01-06 19:35:36 +00:00
INetworkManager networkManager,
IJsonSerializer jsonSerializer,
IXmlSerializer xmlSerializer,
IHttpListener socketListener)
2013-12-07 15:52:38 +00:00
{
2016-10-26 06:01:42 +00:00
_appHost = applicationHost;
_logger = logger;
2019-01-06 19:35:36 +00:00
_config = config;
_defaultRedirectPath = configuration["HttpListenerHost:DefaultRedirectPath"];
2015-12-14 14:45:42 +00:00
_networkManager = networkManager;
2016-11-10 14:41:24 +00:00
_jsonSerializer = jsonSerializer;
_xmlSerializer = xmlSerializer;
_socketListener = socketListener;
_socketListener.WebSocketConnected = OnWebSocketConnected;
2019-02-26 18:37:39 +00:00
_funcParseFn = t => s => JsvReader.GetParseFn(t)(s);
2017-02-13 01:07:48 +00:00
2019-01-06 19:35:36 +00:00
Instance = this;
ResponseFilters = Array.Empty<Action<IRequest, HttpResponse, object>>();
2013-12-07 15:52:38 +00:00
}
public Action<IRequest, HttpResponse, object>[] ResponseFilters { get; set; }
public static HttpListenerHost Instance { get; protected set; }
public string[] UrlPrefixes { get; private set; }
2015-09-13 23:07:54 +00:00
public string GlobalResponse { get; set; }
2015-10-30 17:00:33 +00:00
public ServiceController ServiceController { get; private set; }
public event EventHandler<GenericEventArgs<IWebSocketConnection>> WebSocketConnected;
2016-11-08 18:44:23 +00:00
2017-02-13 02:06:54 +00:00
public object CreateInstance(Type type)
2016-11-10 14:41:24 +00:00
{
2017-02-13 01:07:48 +00:00
return _appHost.CreateInstance(type);
2016-11-10 14:41:24 +00:00
}
2017-02-13 01:07:48 +00:00
/// <summary>
2019-01-07 23:27:46 +00:00
/// Applies the request filters. Returns whether or not the request has been handled
2017-02-13 01:07:48 +00:00
/// and no more processing should be done.
/// </summary>
/// <returns></returns>
public void ApplyRequestFilters(IRequest req, HttpResponse res, object requestDto)
2016-11-11 01:37:20 +00:00
{
2017-02-13 01:07:48 +00:00
//Exec all RequestFilter attributes with Priority < 0
var attributes = GetRequestFilterAttributes(requestDto.GetType());
2017-08-30 18:52:29 +00:00
2019-01-06 19:35:36 +00:00
int count = attributes.Count;
int i = 0;
2017-08-30 18:52:29 +00:00
for (; i < count && attributes[i].Priority < 0; i++)
2017-02-13 01:07:48 +00:00
{
var attribute = attributes[i];
attribute.RequestFilter(req, res, requestDto);
}
//Exec remaining RequestFilter attributes with Priority >= 0
2017-08-30 18:52:29 +00:00
for (; i < count && attributes[i].Priority >= 0; i++)
2017-02-13 01:07:48 +00:00
{
var attribute = attributes[i];
attribute.RequestFilter(req, res, requestDto);
}
2013-12-07 15:52:38 +00:00
}
2017-02-13 01:07:48 +00:00
public Type GetServiceTypeByRequest(Type requestType)
2013-12-07 15:52:38 +00:00
{
ServiceOperationsMap.TryGetValue(requestType, out var serviceType);
2017-02-13 01:07:48 +00:00
return serviceType;
}
2013-12-07 15:52:38 +00:00
2017-08-19 19:43:35 +00:00
public void AddServiceInfo(Type serviceType, Type requestType)
2017-02-13 01:07:48 +00:00
{
ServiceOperationsMap[requestType] = serviceType;
2013-12-07 15:52:38 +00:00
}
2017-08-30 18:52:29 +00:00
private List<IHasRequestFilter> GetRequestFilterAttributes(Type requestDtoType)
2013-12-07 15:52:38 +00:00
{
2019-03-26 18:20:40 +00:00
var attributes = requestDtoType.GetCustomAttributes(true).OfType<IHasRequestFilter>().ToList();
2017-02-13 01:07:48 +00:00
var serviceType = GetServiceTypeByRequest(requestDtoType);
if (serviceType != null)
{
2019-03-26 18:20:40 +00:00
attributes.AddRange(serviceType.GetCustomAttributes(true).OfType<IHasRequestFilter>());
2017-02-13 01:07:48 +00:00
}
attributes.Sort((x, y) => x.Priority - y.Priority);
2017-08-30 18:52:29 +00:00
return attributes;
2014-07-09 00:46:11 +00:00
}
2013-12-07 15:52:38 +00:00
2018-09-12 17:26:21 +00:00
private void OnWebSocketConnected(WebSocketConnectEventArgs e)
2015-03-08 19:48:30 +00:00
{
2016-04-22 16:12:20 +00:00
if (_disposed)
{
return;
}
var connection = new WebSocketConnection(e.WebSocket, e.Endpoint, _jsonSerializer, _logger)
2015-03-08 19:48:30 +00:00
{
2018-09-12 17:26:21 +00:00
OnReceive = ProcessWebSocketMessageReceived,
Url = e.Url,
QueryString = e.QueryString ?? new QueryCollection()
2018-09-12 17:26:21 +00:00
};
2015-03-08 19:48:30 +00:00
2019-03-26 18:20:40 +00:00
connection.Closed += OnConnectionClosed;
2018-09-12 17:26:21 +00:00
lock (_webSocketConnections)
2016-04-22 16:12:20 +00:00
{
2018-09-12 17:26:21 +00:00
_webSocketConnections.Add(connection);
2016-04-22 16:12:20 +00:00
}
2019-01-06 19:35:36 +00:00
WebSocketConnected?.Invoke(this, new GenericEventArgs<IWebSocketConnection>(connection));
2018-09-12 17:26:21 +00:00
}
2019-03-26 18:20:40 +00:00
private void OnConnectionClosed(object sender, EventArgs e)
2018-09-12 17:26:21 +00:00
{
lock (_webSocketConnections)
{
_webSocketConnections.Remove((IWebSocketConnection)sender);
2014-07-09 00:46:11 +00:00
}
2013-12-07 15:52:38 +00:00
}
private static Exception GetActualException(Exception ex)
2017-07-22 22:58:03 +00:00
{
if (ex is AggregateException agg)
2017-07-22 22:58:03 +00:00
{
var inner = agg.InnerException;
if (inner != null)
{
return GetActualException(inner);
}
else
{
var inners = agg.InnerExceptions;
if (inners != null && inners.Count > 0)
{
return GetActualException(inners[0]);
}
}
}
return ex;
}
2016-12-27 07:24:44 +00:00
private int GetStatusCode(Exception ex)
{
2019-01-06 19:35:36 +00:00
switch (ex)
2016-12-27 07:24:44 +00:00
{
2019-01-18 16:04:01 +00:00
case ArgumentException _: return 400;
case SecurityException _: return 401;
2019-01-06 19:35:36 +00:00
case DirectoryNotFoundException _:
case FileNotFoundException _:
2019-01-18 16:04:01 +00:00
case ResourceNotFoundException _: return 404;
case MethodNotAllowedException _: return 405;
2019-01-06 19:35:36 +00:00
case RemoteServiceUnavailableException _: return 502;
2019-01-18 16:04:01 +00:00
default: return 500;
2016-12-27 07:24:44 +00:00
}
}
2018-09-12 17:26:21 +00:00
private async Task ErrorHandler(Exception ex, IRequest httpReq, bool logExceptionStackTrace, bool logExceptionMessage)
2013-12-07 15:52:38 +00:00
{
try
{
2017-07-22 22:58:03 +00:00
ex = GetActualException(ex);
2018-09-12 17:26:21 +00:00
if (logExceptionStackTrace)
2016-12-26 17:38:12 +00:00
{
_logger.LogError(ex, "Error processing request");
2016-12-26 17:38:12 +00:00
}
2018-09-12 17:26:21 +00:00
else if (logExceptionMessage)
{
_logger.LogError(ex.Message);
2018-09-12 17:26:21 +00:00
}
2016-11-10 14:41:24 +00:00
2013-12-07 15:52:38 +00:00
var httpRes = httpReq.Response;
if (httpRes.HasStarted)
{
return;
}
2015-01-17 19:30:23 +00:00
2016-12-27 07:24:44 +00:00
var statusCode = GetStatusCode(ex);
2016-11-12 06:58:50 +00:00
httpRes.StatusCode = statusCode;
2013-12-07 15:52:38 +00:00
2016-11-10 14:41:24 +00:00
httpRes.ContentType = "text/html";
await httpRes.WriteAsync(NormalizeExceptionMessage(ex.Message)).ConfigureAwait(false);
2013-12-07 15:52:38 +00:00
}
2018-12-20 12:11:26 +00:00
catch (Exception errorEx)
2013-12-07 15:52:38 +00:00
{
_logger.LogError(errorEx, "Error this.ProcessRequest(context)(Exception while writing error to the response)");
2013-12-07 15:52:38 +00:00
}
}
2018-09-12 17:26:21 +00:00
private string NormalizeExceptionMessage(string msg)
{
if (msg == null)
{
return string.Empty;
}
// Strip any information we don't want to reveal
msg = msg.Replace(_config.ApplicationPaths.ProgramSystemPath, string.Empty, StringComparison.OrdinalIgnoreCase);
msg = msg.Replace(_config.ApplicationPaths.ProgramDataPath, string.Empty, StringComparison.OrdinalIgnoreCase);
return msg;
}
2013-12-07 15:52:38 +00:00
/// <summary>
/// Shut down the Web Service
/// </summary>
public void Stop()
{
2018-09-12 17:26:21 +00:00
List<IWebSocketConnection> connections;
lock (_webSocketConnections)
{
connections = _webSocketConnections.ToList();
_webSocketConnections.Clear();
}
foreach (var connection in connections)
{
try
{
connection.Dispose();
}
catch
{
}
}
2013-12-07 15:52:38 +00:00
}
2016-03-15 19:11:53 +00: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
2019-02-27 11:40:18 +00:00
var newQueryString = QueryHelpers.ParseQuery(uri.Query);
2016-03-15 19:11:53 +00:00
2016-11-11 03:29:51 +00:00
var originalCount = newQueryString.Count;
if (originalCount == 0)
2016-03-15 19:11:53 +00:00
{
return url;
}
// this removes the key if exists
newQueryString.Remove(key);
2016-11-11 03:29:51 +00:00
if (originalCount == newQueryString.Count)
{
return url;
}
2016-03-15 19:11:53 +00:00
// this gets the page path from root without QueryString
2016-11-11 03:29:51 +00:00
string pagePathWithoutQueryString = url.Split(new[] { '?' }, StringSplitOptions.RemoveEmptyEntries)[0];
2016-03-15 19:11:53 +00:00
return newQueryString.Count > 0
2019-03-04 19:08:54 +00:00
? QueryHelpers.AddQueryString(pagePathWithoutQueryString, newQueryString.ToDictionary(kv => kv.Key, kv => kv.Value.ToString()))
2016-03-15 19:11:53 +00:00
: pagePathWithoutQueryString;
}
private static string GetUrlToLog(string url)
2016-03-15 19:11:53 +00:00
{
url = RemoveQueryStringByKey(url, "api_key");
return url;
}
private static string NormalizeConfiguredLocalAddress(string address)
{
2019-03-26 18:20:40 +00:00
var add = address.AsSpan().Trim('/');
int index = add.IndexOf('/');
if (index != -1)
{
2019-03-26 18:20:40 +00:00
add = add.Slice(index + 1);
}
2019-03-26 18:20:40 +00:00
return add.TrimStart('/').ToString();
}
2017-09-03 07:28:58 +00:00
private bool ValidateHost(string host)
{
var hosts = _config
.Configuration
.LocalNetworkAddresses
.Select(NormalizeConfiguredLocalAddress)
.ToList();
if (hosts.Count == 0)
{
return true;
}
2017-09-03 07:28:58 +00:00
host = host ?? string.Empty;
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;
}
2018-09-12 17:26:21 +00:00
private bool ValidateRequest(string remoteIp, bool isLocal)
{
if (isLocal)
{
return true;
}
if (_config.Configuration.EnableRemoteAccess)
{
var addressFilter = _config.Configuration.RemoteIPFilter.Where(i => !string.IsNullOrWhiteSpace(i)).ToArray();
if (addressFilter.Length > 0 && !_networkManager.IsInLocalNetwork(remoteIp))
{
if (_config.Configuration.IsRemoteIPFilterBlacklist)
{
return !_networkManager.IsAddressInSubnets(remoteIp, addressFilter);
}
else
{
return _networkManager.IsAddressInSubnets(remoteIp, addressFilter);
}
}
}
else
{
if (!_networkManager.IsInLocalNetwork(remoteIp))
{
return false;
}
}
return true;
}
2017-09-30 17:40:42 +00:00
private bool ValidateSsl(string remoteIp, string urlString)
{
2018-09-12 17:26:21 +00:00
if (_config.Configuration.RequireHttps && _appHost.EnableHttps && !_config.Configuration.IsBehindProxy)
{
2017-09-30 17:40:42 +00:00
if (urlString.IndexOf("https://", StringComparison.OrdinalIgnoreCase) == -1)
{
2018-09-12 17:26:21 +00:00
// These are hacks, but if these ever occur on ipv6 in the local network they could be incorrectly redirected
2019-03-26 18:20:40 +00:00
if (urlString.IndexOf("system/ping", StringComparison.OrdinalIgnoreCase) != -1
|| urlString.IndexOf("dlna/", StringComparison.OrdinalIgnoreCase) != -1)
2018-09-12 17:26:21 +00:00
{
return true;
}
2017-09-30 17:40:42 +00:00
if (!_networkManager.IsInLocalNetwork(remoteIp))
{
return false;
}
}
}
return true;
}
2013-12-07 15:52:38 +00:00
/// <summary>
/// Overridable method that can be used to implement a custom hnandler
/// </summary>
2019-02-25 22:34:32 +00:00
public async Task RequestHandler(IHttpRequest httpReq, string urlString, string host, string localPath, CancellationToken cancellationToken)
2013-12-07 15:52:38 +00:00
{
var stopWatch = new Stopwatch();
stopWatch.Start();
2014-07-18 22:14:59 +00:00
var httpRes = httpReq.Response;
2016-11-08 18:44:23 +00:00
string urlToLog = null;
2018-09-12 17:26:21 +00:00
string remoteIp = httpReq.RemoteIp;
2014-07-09 00:46:11 +00:00
2016-11-08 18:44:23 +00:00
try
2016-04-22 16:12:20 +00:00
{
2016-11-08 18:44:23 +00:00
if (_disposed)
{
httpRes.StatusCode = 503;
2016-11-13 21:04:21 +00:00
httpRes.ContentType = "text/plain";
await httpRes.WriteAsync("Server shutting down", cancellationToken).ConfigureAwait(false);
2016-11-08 18:44:23 +00:00
return;
}
2016-04-22 16:12:20 +00:00
2017-09-03 07:28:58 +00:00
if (!ValidateHost(host))
2016-11-08 18:44:23 +00:00
{
httpRes.StatusCode = 400;
httpRes.ContentType = "text/plain";
await httpRes.WriteAsync("Invalid host", cancellationToken).ConfigureAwait(false);
2016-11-08 18:44:23 +00:00
return;
}
2018-09-12 17:26:21 +00:00
if (!ValidateRequest(remoteIp, httpReq.IsLocal))
{
2018-09-12 17:26:21 +00:00
httpRes.StatusCode = 403;
httpRes.ContentType = "text/plain";
await httpRes.WriteAsync("Forbidden", cancellationToken).ConfigureAwait(false);
2018-09-12 17:26:21 +00:00
return;
}
2017-09-30 17:40:42 +00:00
2018-09-12 17:26:21 +00:00
if (!ValidateSsl(httpReq.RemoteIp, urlString))
{
RedirectToSecureUrl(httpReq, httpRes, urlString);
return;
}
2016-11-08 18:44:23 +00:00
if (string.Equals(httpReq.Verb, "OPTIONS", StringComparison.OrdinalIgnoreCase))
{
httpRes.StatusCode = 200;
httpRes.Headers.Add("Access-Control-Allow-Origin", "*");
httpRes.Headers.Add("Access-Control-Allow-Methods", "GET, POST, PUT, DELETE, PATCH, OPTIONS");
httpRes.Headers.Add("Access-Control-Allow-Headers", "Content-Type, Authorization, Range, X-MediaBrowser-Token, X-Emby-Authorization");
httpRes.ContentType = "text/plain";
await httpRes.WriteAsync(string.Empty, cancellationToken).ConfigureAwait(false);
2016-11-08 18:44:23 +00:00
return;
}
urlToLog = GetUrlToLog(urlString);
2016-01-23 03:10:21 +00:00
2019-08-05 23:25:18 +00:00
if (string.Equals(localPath, "/" + _config.Configuration.BaseUrl + "/", StringComparison.OrdinalIgnoreCase)
|| string.Equals(localPath, "/" + _config.Configuration.BaseUrl, StringComparison.OrdinalIgnoreCase))
2016-11-08 18:44:23 +00:00
{
2019-08-05 23:25:18 +00:00
httpRes.Redirect("/" + _config.Configuration.BaseUrl + "/" + _defaultRedirectPath);
2016-11-08 18:44:23 +00:00
return;
}
2016-03-18 03:40:15 +00:00
2016-11-08 18:44:23 +00:00
if (string.Equals(localPath, "/", StringComparison.OrdinalIgnoreCase))
{
httpRes.Redirect(_defaultRedirectPath);
2016-11-08 18:44:23 +00:00
return;
}
2016-11-08 18:44:23 +00:00
if (string.IsNullOrEmpty(localPath))
{
httpRes.Redirect("/" + _defaultRedirectPath);
2016-11-08 18:44:23 +00:00
return;
}
2016-03-18 03:40:15 +00:00
2018-09-12 17:26:21 +00:00
if (!string.IsNullOrEmpty(GlobalResponse))
2016-11-08 18:44:23 +00:00
{
2018-09-12 17:26:21 +00:00
// We don't want the address pings in ApplicationHost to fail
if (localPath.IndexOf("system/ping", StringComparison.OrdinalIgnoreCase) == -1)
{
httpRes.StatusCode = 503;
httpRes.ContentType = "text/html";
await httpRes.WriteAsync(GlobalResponse, cancellationToken).ConfigureAwait(false);
2018-09-12 17:26:21 +00:00
return;
}
2016-03-25 17:48:18 +00:00
}
2016-03-18 06:36:58 +00:00
2017-02-13 01:07:48 +00:00
var handler = GetServiceHandler(httpReq);
2016-11-08 18:44:23 +00:00
if (handler != null)
{
await handler.ProcessRequestAsync(this, httpReq, httpRes, _logger, cancellationToken).ConfigureAwait(false);
2016-11-08 18:44:23 +00:00
}
2016-11-12 06:58:50 +00:00
else
{
2018-09-12 17:26:21 +00:00
await ErrorHandler(new FileNotFoundException(), httpReq, false, false).ConfigureAwait(false);
2016-11-12 06:58:50 +00:00
}
2016-02-21 06:25:25 +00:00
}
catch (Exception ex) when (ex is SocketException || ex is IOException || ex is OperationCanceledException)
2018-09-12 17:26:21 +00:00
{
await ErrorHandler(ex, httpReq, false, false).ConfigureAwait(false);
}
catch (SecurityException ex)
{
await ErrorHandler(ex, httpReq, false, true).ConfigureAwait(false);
2016-12-26 17:38:12 +00:00
}
2016-11-08 18:44:23 +00:00
catch (Exception ex)
2015-09-13 23:07:54 +00:00
{
var logException = !string.Equals(ex.GetType().Name, "SocketException", StringComparison.OrdinalIgnoreCase);
2018-09-12 17:26:21 +00:00
await ErrorHandler(ex, httpReq, logException, false).ConfigureAwait(false);
2015-09-13 23:07:54 +00:00
}
2016-11-08 18:44:23 +00:00
finally
2013-12-07 15:52:38 +00:00
{
stopWatch.Stop();
var elapsed = stopWatch.Elapsed;
2019-02-26 18:37:39 +00:00
if (elapsed.TotalMilliseconds > 500)
2014-07-09 00:46:11 +00:00
{
_logger.LogWarning("HTTP Response {StatusCode} to {RemoteIp}. Time (slow): {Elapsed:g}. {Url}", httpRes.StatusCode, remoteIp, elapsed, urlToLog);
2016-07-14 19:13:52 +00:00
}
2013-12-07 15:52:38 +00:00
}
}
2017-02-13 01:07:48 +00:00
// Entry point for HttpListener
public ServiceHandler GetServiceHandler(IHttpRequest httpReq)
{
var pathInfo = httpReq.PathInfo;
2019-03-26 18:20:40 +00:00
pathInfo = ServiceHandler.GetSanitizedPathInfo(pathInfo, out string contentType);
var restPath = ServiceController.GetRestPathForRequest(httpReq.HttpMethod, pathInfo);
2017-02-13 01:07:48 +00:00
if (restPath != null)
{
2019-03-26 18:20:40 +00:00
return new ServiceHandler(restPath, contentType);
2017-02-13 01:07:48 +00:00
}
_logger.LogError("Could not find handler for {PathInfo}", pathInfo);
2017-02-13 01:07:48 +00:00
return null;
}
private void RedirectToSecureUrl(IHttpRequest httpReq, HttpResponse httpRes, string url)
2018-09-12 17:26:21 +00:00
{
2019-01-06 19:35:36 +00:00
if (Uri.TryCreate(url, UriKind.Absolute, out Uri uri))
2018-09-12 17:26:21 +00:00
{
2019-01-06 19:35:36 +00:00
var builder = new UriBuilder(uri)
{
Port = _config.Configuration.PublicHttpsPort,
Scheme = "https"
};
2018-09-12 17:26:21 +00:00
url = builder.Uri.ToString();
}
2016-11-12 07:14:04 +00:00
httpRes.Redirect(url);
2016-11-08 18:44:23 +00:00
}
2013-12-07 15:52:38 +00:00
/// <summary>
/// Adds the rest handlers.
/// </summary>
/// <param name="services">The services.</param>
2019-03-07 21:49:41 +00:00
/// <param name="listeners"></param>
/// <param name="urlPrefixes"></param>
public void Init(IEnumerable<IService> services, IEnumerable<IWebSocketListener> listeners, IEnumerable<string> urlPrefixes)
2013-12-07 15:52:38 +00:00
{
2018-09-12 17:26:21 +00:00
_webSocketListeners = listeners.ToArray();
2019-03-07 21:49:41 +00:00
UrlPrefixes = urlPrefixes.ToArray();
ServiceController = new ServiceController();
2013-12-07 15:52:38 +00:00
2019-03-26 18:20:40 +00:00
var types = services.Select(r => r.GetType());
ServiceController.Init(this, types);
2017-02-13 01:07:48 +00:00
ResponseFilters = new Action<IRequest, HttpResponse, object>[]
2017-08-30 18:52:29 +00:00
{
new ResponseFilter(_logger).FilterResponse
2017-08-30 18:52:29 +00:00
};
2013-12-07 15:52:38 +00:00
}
2017-02-13 02:06:54 +00:00
public RouteAttribute[] GetRouteAttributes(Type requestType)
2015-01-17 19:30:23 +00:00
{
2017-02-13 02:06:54 +00:00
var routes = requestType.GetTypeInfo().GetCustomAttributes<RouteAttribute>(true).ToList();
2015-01-17 19:30:23 +00:00
var clone = routes.ToList();
foreach (var route in clone)
{
2019-08-05 23:25:18 +00:00
routes.Add(new RouteAttribute(NormalizeCustomRoutePath(_config.Configuration.BaseUrl, route.Path), route.Verbs)
2017-10-07 06:13:26 +00:00
{
Notes = route.Notes,
Priority = route.Priority,
Summary = route.Summary
});
2019-08-05 23:27:10 +00:00
routes.Add(new RouteAttribute(NormalizeOldRoutePath(route.Path), route.Verbs)
{
Notes = route.Notes,
Priority = route.Priority,
Summary = route.Summary
});
2015-01-17 19:30:23 +00:00
}
2018-12-28 15:48:26 +00:00
return routes.ToArray();
2015-01-17 19:30:23 +00:00
}
2017-02-13 02:06:54 +00:00
public Func<string, object> GetParseFn(Type propertyType)
2016-11-11 01:37:20 +00:00
{
2016-11-11 03:29:51 +00:00
return _funcParseFn(propertyType);
2016-11-11 01:37:20 +00:00
}
2017-02-13 02:06:54 +00:00
public void SerializeToJson(object o, Stream stream)
2016-11-10 14:41:24 +00:00
{
_jsonSerializer.SerializeToStream(o, stream);
}
2017-02-13 02:06:54 +00:00
public void SerializeToXml(object o, Stream stream)
2016-11-10 14:41:24 +00:00
{
_xmlSerializer.SerializeToStream(o, stream);
}
2018-09-12 17:26:21 +00:00
public Task<object> DeserializeXml(Type type, Stream stream)
2016-11-10 14:41:24 +00:00
{
2018-09-12 17:26:21 +00:00
return Task.FromResult(_xmlSerializer.DeserializeFromStream(type, stream));
2016-11-10 14:41:24 +00:00
}
2018-09-12 17:26:21 +00:00
public Task<object> DeserializeJson(Type type, Stream stream)
2016-11-10 14:41:24 +00:00
{
2018-09-12 17:26:21 +00:00
return _jsonSerializer.DeserializeFromStreamAsync(stream, type);
2016-11-10 14:41:24 +00:00
}
public Task ProcessWebSocketRequest(HttpContext context)
{
return _socketListener.ProcessWebSocketRequest(context);
}
2019-08-05 23:27:10 +00:00
// this method was left for compatibility with third party clients
private static string NormalizeOldRoutePath(string path)
{
if (path.StartsWith("/", StringComparison.OrdinalIgnoreCase))
{
return "/emby" + path;
}
return "emby/" + path;
}
2019-08-05 23:25:18 +00:00
private static string NormalizeCustomRoutePath(string baseUrl, string path)
2015-04-11 21:34:05 +00:00
{
if (path.StartsWith("/", StringComparison.OrdinalIgnoreCase))
{
2019-08-05 23:25:18 +00:00
return "/" + baseUrl + path;
2015-04-11 21:34:05 +00:00
}
2019-08-05 23:25:18 +00:00
return baseUrl + "/" + path;
2015-04-11 21:34:05 +00:00
}
/// <inheritdoc />
public void Dispose()
{
Dispose(true);
GC.SuppressFinalize(this);
}
2013-12-07 15:52:38 +00:00
protected virtual void Dispose(bool disposing)
{
if (_disposed) return;
2016-12-28 06:08:18 +00:00
if (disposing)
2013-12-07 15:52:38 +00:00
{
Stop();
2013-12-07 15:52:38 +00:00
}
_disposed = true;
2013-12-07 15:52:38 +00:00
}
2018-09-12 17:26:21 +00:00
/// <summary>
/// Processes the web socket message received.
/// </summary>
/// <param name="result">The result.</param>
private Task ProcessWebSocketMessageReceived(WebSocketMessageInfo result)
{
if (_disposed)
{
return Task.CompletedTask;
}
_logger.LogDebug("Websocket message received: {0}", result.MessageType);
2018-09-12 17:26:21 +00:00
2019-02-24 02:16:19 +00:00
IEnumerable<Task> GetTasks()
2018-09-12 17:26:21 +00:00
{
2019-02-24 02:16:19 +00:00
foreach (var x in _webSocketListeners)
2018-09-12 17:26:21 +00:00
{
2019-02-24 02:16:19 +00:00
yield return x.ProcessMessageAsync(result);
2018-09-12 17:26:21 +00:00
}
2019-02-24 02:16:19 +00:00
}
2018-09-12 17:26:21 +00:00
2019-02-24 02:16:19 +00:00
return Task.WhenAll(GetTasks());
2018-09-12 17:26:21 +00:00
}
2013-12-07 15:52:38 +00:00
}
2018-12-28 15:48:26 +00:00
}