You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
115 lines
3.3 KiB
115 lines
3.3 KiB
using Apewer.Network;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Net;
|
|
using System.Reflection;
|
|
|
|
namespace Apewer.Web
|
|
{
|
|
|
|
/// <summary>API 调用器。</summary>
|
|
public sealed class ApiInvoker
|
|
{
|
|
|
|
#region default
|
|
|
|
private static ApiInvoker _default = new ApiInvoker();
|
|
|
|
/// <summary>默认调用器实例。</summary>
|
|
public static ApiInvoker Default { get => _default; }
|
|
|
|
#endregion
|
|
|
|
#region 配置
|
|
|
|
/// <summary>获取或设置要使用的 API 入口。</summary>
|
|
public ApiEntries Entries { get; set; }
|
|
|
|
/// <summary>获取或设置 Logger。</summary>
|
|
public Logger Logger { get; set; }
|
|
|
|
/// <summary>获取或设置选项。</summary>
|
|
public ApiOptions Options { get; set; }
|
|
|
|
/// <summary>异常捕获程序。</summary>
|
|
public Action<ApiCatch> Catcher { get; set; }
|
|
|
|
/// <summary>输出前的检查。</summary>
|
|
public ApiPreOutput PreOutput { get; set; }
|
|
|
|
#endregion
|
|
|
|
#region 中间件
|
|
|
|
private List<ApiMiddleware> _middlewares = new List<ApiMiddleware>();
|
|
|
|
/// <summary>中间件。</summary>
|
|
internal ApiMiddleware[] Middlewares { get => _middlewares.ToArray(); }
|
|
|
|
/// <summary>添加中间件。</summary>
|
|
public void AddMiddleware<T>() where T : class, IApiMiddleware, new()
|
|
{
|
|
var middleware = new ApiMiddleware(typeof(T));
|
|
_middlewares.Add(middleware);
|
|
}
|
|
|
|
/// <summary>添加中间件。</summary>
|
|
/// <exception cref="ArgumentNullException" />
|
|
public void AddMiddleware(Action<ApiContext, Action> callback)
|
|
{
|
|
if (callback == null) throw new ArgumentNullException(nameof(callback));
|
|
_middlewares.Add(new ApiMiddleware(callback));
|
|
}
|
|
|
|
#endregion
|
|
|
|
#region 初始化
|
|
|
|
object _locker = new object();
|
|
bool _initialized = false;
|
|
|
|
/// <summary>执行初始化程序,每个 ApiInvoker 实例仅执行一次初始化。</summary>
|
|
public void Initialize(Action action)
|
|
{
|
|
if (action == null) return;
|
|
lock (_locker)
|
|
{
|
|
if (_initialized) return;
|
|
action.Invoke();
|
|
_initialized = true;
|
|
}
|
|
}
|
|
|
|
#endregion
|
|
|
|
#region 调用
|
|
|
|
/// <summary>发起调用。</summary>
|
|
/// <exception cref="ArgumentNullException" />
|
|
public void Invoke(ApiProvider provider)
|
|
{
|
|
if (provider == null) throw new ArgumentNullException(nameof(provider));
|
|
|
|
var entries = Entries;
|
|
if (entries == null) entries = ApiEntries.AppDomain();
|
|
Entries = entries;
|
|
Invoke(provider, entries);
|
|
}
|
|
|
|
/// <summary>发起调用。</summary>
|
|
/// <exception cref="ArgumentNullException" />
|
|
public void Invoke(ApiProvider provider, ApiEntries entries)
|
|
{
|
|
if (provider == null) throw new ArgumentNullException(nameof(provider));
|
|
if (entries == null) throw new ArgumentNullException(nameof(entries));
|
|
|
|
var context = new ApiContext(this, provider, entries);
|
|
var processor = new ApiProcessor(context);
|
|
processor.Run();
|
|
}
|
|
|
|
#endregion
|
|
|
|
}
|
|
|
|
}
|
|
|