aboutsummaryrefslogtreecommitdiff
path: root/Jellyfin.Server/Middleware/ExceptionMiddleware.cs
diff options
context:
space:
mode:
Diffstat (limited to 'Jellyfin.Server/Middleware/ExceptionMiddleware.cs')
-rw-r--r--Jellyfin.Server/Middleware/ExceptionMiddleware.cs151
1 files changed, 0 insertions, 151 deletions
diff --git a/Jellyfin.Server/Middleware/ExceptionMiddleware.cs b/Jellyfin.Server/Middleware/ExceptionMiddleware.cs
deleted file mode 100644
index db7877c31..000000000
--- a/Jellyfin.Server/Middleware/ExceptionMiddleware.cs
+++ /dev/null
@@ -1,151 +0,0 @@
-using System;
-using System.IO;
-using System.Net.Mime;
-using System.Net.Sockets;
-using System.Threading.Tasks;
-using MediaBrowser.Common.Extensions;
-using MediaBrowser.Controller.Authentication;
-using MediaBrowser.Controller.Configuration;
-using MediaBrowser.Controller.Net;
-using Microsoft.AspNetCore.Hosting;
-using Microsoft.AspNetCore.Http;
-using Microsoft.Extensions.Hosting;
-using Microsoft.Extensions.Logging;
-
-namespace Jellyfin.Server.Middleware
-{
- /// <summary>
- /// Exception Middleware.
- /// </summary>
- public class ExceptionMiddleware
- {
- private readonly RequestDelegate _next;
- private readonly ILogger<ExceptionMiddleware> _logger;
- private readonly IServerConfigurationManager _configuration;
- private readonly IWebHostEnvironment _hostEnvironment;
-
- /// <summary>
- /// Initializes a new instance of the <see cref="ExceptionMiddleware"/> class.
- /// </summary>
- /// <param name="next">Next request delegate.</param>
- /// <param name="logger">Instance of the <see cref="ILogger{ExceptionMiddleware}"/> interface.</param>
- /// <param name="serverConfigurationManager">Instance of the <see cref="IServerConfigurationManager"/> interface.</param>
- /// <param name="hostEnvironment">Instance of the <see cref="IWebHostEnvironment"/> interface.</param>
- public ExceptionMiddleware(
- RequestDelegate next,
- ILogger<ExceptionMiddleware> logger,
- IServerConfigurationManager serverConfigurationManager,
- IWebHostEnvironment hostEnvironment)
- {
- _next = next;
- _logger = logger;
- _configuration = serverConfigurationManager;
- _hostEnvironment = hostEnvironment;
- }
-
- /// <summary>
- /// Invoke request.
- /// </summary>
- /// <param name="context">Request context.</param>
- /// <returns>Task.</returns>
- public async Task Invoke(HttpContext context)
- {
- try
- {
- await _next(context).ConfigureAwait(false);
- }
- catch (Exception ex)
- {
- if (context.Response.HasStarted)
- {
- _logger.LogWarning("The response has already started, the exception middleware will not be executed.");
- throw;
- }
-
- ex = GetActualException(ex);
-
- bool ignoreStackTrace =
- ex is SocketException
- || ex is IOException
- || ex is OperationCanceledException
- || ex is SecurityException
- || ex is AuthenticationException
- || ex is FileNotFoundException;
-
- if (ignoreStackTrace)
- {
- _logger.LogError(
- "Error processing request: {ExceptionMessage}. URL {Method} {Url}.",
- ex.Message.TrimEnd('.'),
- context.Request.Method,
- context.Request.Path);
- }
- else
- {
- _logger.LogError(
- ex,
- "Error processing request. URL {Method} {Url}.",
- context.Request.Method,
- context.Request.Path);
- }
-
- context.Response.StatusCode = GetStatusCode(ex);
- context.Response.ContentType = MediaTypeNames.Text.Plain;
-
- // Don't send exception unless the server is in a Development environment
- var errorContent = _hostEnvironment.IsDevelopment()
- ? NormalizeExceptionMessage(ex.Message)
- : "Error processing request.";
- await context.Response.WriteAsync(errorContent).ConfigureAwait(false);
- }
- }
-
- private static Exception GetActualException(Exception ex)
- {
- if (ex is AggregateException agg)
- {
- var inner = agg.InnerException;
- if (inner != null)
- {
- return GetActualException(inner);
- }
-
- var inners = agg.InnerExceptions;
- if (inners.Count > 0)
- {
- return GetActualException(inners[0]);
- }
- }
-
- return ex;
- }
-
- private static int GetStatusCode(Exception ex)
- {
- switch (ex)
- {
- case ArgumentException _: return StatusCodes.Status400BadRequest;
- case AuthenticationException _: return StatusCodes.Status401Unauthorized;
- case SecurityException _: return StatusCodes.Status403Forbidden;
- case DirectoryNotFoundException _:
- case FileNotFoundException _:
- case ResourceNotFoundException _: return StatusCodes.Status404NotFound;
- case MethodNotAllowedException _: return StatusCodes.Status405MethodNotAllowed;
- default: return StatusCodes.Status500InternalServerError;
- }
- }
-
- private string NormalizeExceptionMessage(string msg)
- {
- // Strip any information we don't want to reveal
- return msg.Replace(
- _configuration.ApplicationPaths.ProgramSystemPath,
- string.Empty,
- StringComparison.OrdinalIgnoreCase)
- .Replace(
- _configuration.ApplicationPaths.ProgramDataPath,
- string.Empty,
- StringComparison.OrdinalIgnoreCase);
- }
- }
-}