mirror of
https://github.com/jellyfin/jellyfin.git
synced 2024-09-08 20:38:24 +02:00
166 lines
No EOL
6.4 KiB
C#
166 lines
No EOL
6.4 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Linq.Expressions;
|
|
using System.Reflection;
|
|
using System.Threading.Tasks;
|
|
using MediaBrowser.Model.Services;
|
|
using MediaBrowser.Model.Extensions;
|
|
|
|
namespace Emby.Server.Implementations.Services
|
|
{
|
|
public static class ServiceExecExtensions
|
|
{
|
|
public static HashSet<string> AllVerbs = new HashSet<string>(new[] {
|
|
"OPTIONS", "GET", "HEAD", "POST", "PUT", "DELETE", "TRACE", "CONNECT", // RFC 2616
|
|
"PROPFIND", "PROPPATCH", "MKCOL", "COPY", "MOVE", "LOCK", "UNLOCK", // RFC 2518
|
|
"VERSION-CONTROL", "REPORT", "CHECKOUT", "CHECKIN", "UNCHECKOUT",
|
|
"MKWORKSPACE", "UPDATE", "LABEL", "MERGE", "BASELINE-CONTROL", "MKACTIVITY", // RFC 3253
|
|
"ORDERPATCH", // RFC 3648
|
|
"ACL", // RFC 3744
|
|
"PATCH", // https://datatracker.ietf.org/doc/draft-dusseault-http-patch/
|
|
"SEARCH", // https://datatracker.ietf.org/doc/draft-reschke-webdav-search/
|
|
"BCOPY", "BDELETE", "BMOVE", "BPROPFIND", "BPROPPATCH", "NOTIFY",
|
|
"POLL", "SUBSCRIBE", "UNSUBSCRIBE"
|
|
});
|
|
|
|
public static IEnumerable<MethodInfo> GetActions(this Type serviceType)
|
|
{
|
|
foreach (var mi in serviceType.GetRuntimeMethods().Where(i => i.IsPublic && !i.IsStatic))
|
|
{
|
|
if (mi.GetParameters().Length != 1)
|
|
continue;
|
|
|
|
var actionName = mi.Name;
|
|
if (!AllVerbs.Contains(actionName, StringComparer.OrdinalIgnoreCase) && !string.Equals(actionName, ServiceMethod.AnyAction, StringComparison.OrdinalIgnoreCase))
|
|
continue;
|
|
|
|
yield return mi;
|
|
}
|
|
}
|
|
}
|
|
|
|
internal static class ServiceExecGeneral
|
|
{
|
|
public static Dictionary<string, ServiceMethod> execMap = new Dictionary<string, ServiceMethod>();
|
|
|
|
public static void CreateServiceRunnersFor(Type requestType, List<ServiceMethod> actions)
|
|
{
|
|
foreach (var actionCtx in actions)
|
|
{
|
|
if (execMap.ContainsKey(actionCtx.Id)) continue;
|
|
|
|
execMap[actionCtx.Id] = actionCtx;
|
|
}
|
|
}
|
|
|
|
public static async Task<object> Execute(Type serviceType, IRequest request, object instance, object requestDto, string requestName)
|
|
{
|
|
var actionName = request.Verb ?? "POST";
|
|
|
|
ServiceMethod actionContext;
|
|
if (ServiceExecGeneral.execMap.TryGetValue(ServiceMethod.Key(serviceType, actionName, requestName), out actionContext)
|
|
|| ServiceExecGeneral.execMap.TryGetValue(ServiceMethod.AnyKey(serviceType, requestName), out actionContext))
|
|
{
|
|
if (actionContext.RequestFilters != null)
|
|
{
|
|
foreach (var requestFilter in actionContext.RequestFilters)
|
|
{
|
|
requestFilter.RequestFilter(request, request.Response, requestDto);
|
|
if (request.Response.IsClosed) return null;
|
|
}
|
|
}
|
|
|
|
var response = actionContext.ServiceAction(instance, requestDto);
|
|
|
|
var taskResponse = response as Task;
|
|
if (taskResponse != null)
|
|
{
|
|
await taskResponse.ConfigureAwait(false);
|
|
response = ServiceHandler.GetTaskResult(taskResponse);
|
|
}
|
|
|
|
return response;
|
|
}
|
|
|
|
var expectedMethodName = actionName.Substring(0, 1) + actionName.Substring(1).ToLower();
|
|
throw new NotImplementedException(string.Format("Could not find method named {1}({0}) or Any({0}) on Service {2}", requestDto.GetType().GetMethodName(), expectedMethodName, serviceType.GetMethodName()));
|
|
}
|
|
|
|
public static List<ServiceMethod> Reset(Type serviceType)
|
|
{
|
|
var actions = new List<ServiceMethod>();
|
|
|
|
foreach (var mi in serviceType.GetActions())
|
|
{
|
|
var actionName = mi.Name;
|
|
var args = mi.GetParameters();
|
|
|
|
var requestType = args[0].ParameterType;
|
|
var actionCtx = new ServiceMethod
|
|
{
|
|
Id = ServiceMethod.Key(serviceType, actionName, requestType.GetMethodName())
|
|
};
|
|
|
|
try
|
|
{
|
|
actionCtx.ServiceAction = CreateExecFn(serviceType, requestType, mi);
|
|
}
|
|
catch
|
|
{
|
|
//Potential problems with MONO, using reflection for fallback
|
|
actionCtx.ServiceAction = (service, request) =>
|
|
mi.Invoke(service, new[] { request });
|
|
}
|
|
|
|
var reqFilters = new List<IHasRequestFilter>();
|
|
|
|
foreach (var attr in mi.GetCustomAttributes(true))
|
|
{
|
|
var hasReqFilter = attr as IHasRequestFilter;
|
|
|
|
if (hasReqFilter != null)
|
|
reqFilters.Add(hasReqFilter);
|
|
}
|
|
|
|
if (reqFilters.Count > 0)
|
|
actionCtx.RequestFilters = reqFilters.OrderBy(i => i.Priority).ToArray(reqFilters.Count);
|
|
|
|
actions.Add(actionCtx);
|
|
}
|
|
|
|
return actions;
|
|
}
|
|
|
|
private static ActionInvokerFn CreateExecFn(Type serviceType, Type requestType, MethodInfo mi)
|
|
{
|
|
var serviceParam = Expression.Parameter(typeof(object), "serviceObj");
|
|
var serviceStrong = Expression.Convert(serviceParam, serviceType);
|
|
|
|
var requestDtoParam = Expression.Parameter(typeof(object), "requestDto");
|
|
var requestDtoStrong = Expression.Convert(requestDtoParam, requestType);
|
|
|
|
Expression callExecute = Expression.Call(
|
|
serviceStrong, mi, requestDtoStrong);
|
|
|
|
if (mi.ReturnType != typeof(void))
|
|
{
|
|
var executeFunc = Expression.Lambda<ActionInvokerFn>
|
|
(callExecute, serviceParam, requestDtoParam).Compile();
|
|
|
|
return executeFunc;
|
|
}
|
|
else
|
|
{
|
|
var executeFunc = Expression.Lambda<VoidActionInvokerFn>
|
|
(callExecute, serviceParam, requestDtoParam).Compile();
|
|
|
|
return (service, request) =>
|
|
{
|
|
executeFunc(service, request);
|
|
return null;
|
|
};
|
|
}
|
|
}
|
|
}
|
|
} |