blob: 0afbc223918f67957e5e15566ca7e7bf1b29e168 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
|
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using Impostor.Api.Plugins;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Microsoft.Extensions.Logging;
namespace Impostor.Server.Plugins
{
public class PluginLoaderService : IHostedService
{
private readonly ILogger<PluginLoaderService> _logger;
private readonly IServiceProvider _serviceProvider;
private readonly List<PluginInformation> _plugins;
public PluginLoaderService(ILogger<PluginLoaderService> logger, IServiceProvider serviceProvider, List<PluginInformation> plugins)
{
_logger = logger;
_serviceProvider = serviceProvider;
_plugins = plugins;
}
public async Task StartAsync(CancellationToken cancellationToken)
{
_logger.LogInformation("Loading plugins.");
foreach (var plugin in _plugins)
{
_logger.LogInformation("Enabling plugin {0}.", plugin);
// Create instance and inject services.
plugin.Instance = (IPlugin) ActivatorUtilities.CreateInstance(_serviceProvider, plugin.PluginType);
// Enable plugin.
await plugin.Instance.EnableAsync();
}
_logger.LogInformation(
_plugins.Count == 1
? "Loaded {0} plugin."
: "Loaded {0} plugins.", _plugins.Count);
}
public async Task StopAsync(CancellationToken cancellationToken)
{
// Disable all plugins with a valid instance set.
// In the case of a failed startup, some can be null.
foreach (var plugin in _plugins.Where(plugin => plugin.Instance != null))
{
_logger.LogInformation("Disabling plugin {0}.", plugin);
// Disable plugin.
await plugin.Instance.DisableAsync();
}
}
}
}
|
