using System; using System.Collections.Generic; using System.IO; using System.Linq; using System.Net; using System.Net.Http; using System.Net.Http.Headers; using System.Threading.Tasks; using BTCPayServer.Configuration; using BTCPayServer.Contracts; using Microsoft.AspNetCore.Builder; using Microsoft.AspNetCore.Http; using Microsoft.Extensions.DependencyInjection; using Newtonsoft.Json; namespace BTCPayServer.Plugins { public class PluginService { private readonly BTCPayServerOptions _btcPayServerOptions; private readonly HttpClient _githubClient; public PluginService(IEnumerable btcPayServerPlugins, IHttpClientFactory httpClientFactory, BTCPayServerOptions btcPayServerOptions) { LoadedPlugins = btcPayServerPlugins; _githubClient = httpClientFactory.CreateClient(); _githubClient.DefaultRequestHeaders.UserAgent.Add(new ProductInfoHeaderValue("btcpayserver", "1")); _btcPayServerOptions = btcPayServerOptions; } public IEnumerable LoadedPlugins { get; } public async Task> GetRemotePlugins(string remote) { var resp = await _githubClient .GetStringAsync(new Uri($"https://api.github.com/repos/{remote}/contents")); var files = JsonConvert.DeserializeObject(resp); return await Task.WhenAll(files.Where(file => file.Name.EndsWith($"{PluginManager.BTCPayPluginSuffix}.json", StringComparison.InvariantCulture)).Select(async file => { return await _githubClient.GetStringAsync(file.DownloadUrl).ContinueWith( task => JsonConvert.DeserializeObject(task.Result), TaskScheduler.Current); })); } public async Task DownloadRemotePlugin(string remote, string plugin) { var dest = _btcPayServerOptions.PluginDir; var resp = await _githubClient .GetStringAsync(new Uri($"https://api.github.com/repos/{remote}/contents")); var files = JsonConvert.DeserializeObject(resp); var ext = files.SingleOrDefault(file => file.Name == $"{plugin}{PluginManager.BTCPayPluginSuffix}"); if (ext is null) { throw new Exception("Plugin not found on remote"); } var filedest = Path.Combine(dest, ext.Name); Directory.CreateDirectory(Path.GetDirectoryName(filedest)); new WebClient().DownloadFile(new Uri(ext.DownloadUrl), filedest); } public void InstallPlugin(string plugin) { var dest = _btcPayServerOptions.PluginDir; UninstallPlugin(plugin); PluginManager.QueueCommands(dest, ("install", plugin)); } public async Task UploadPlugin(IFormFile plugin) { var dest = _btcPayServerOptions.PluginDir; var filedest = Path.Combine(dest, plugin.FileName); Directory.CreateDirectory(Path.GetDirectoryName(filedest)); if (Path.GetExtension(filedest) == PluginManager.BTCPayPluginSuffix) { await using var stream = new FileStream(filedest, FileMode.Create); await plugin.CopyToAsync(stream); } } public void UninstallPlugin(string plugin) { var dest = _btcPayServerOptions.PluginDir; PluginManager.QueueCommands(dest, ("delete", plugin)); } public class AvailablePlugin : IBTCPayServerPlugin { public string Identifier { get; set; } public string Name { get; set; } public Version Version { get; set; } public string Description { get; set; } public bool SystemPlugin { get; set; } = false; public string[] Dependencies { get; } = Array.Empty(); public void Execute(IApplicationBuilder applicationBuilder, IServiceProvider applicationBuilderApplicationServices) { } public void Execute(IServiceCollection applicationBuilder) { } } class GithubFile { [JsonProperty("name")] public string Name { get; set; } [JsonProperty("sha")] public string Sha { get; set; } [JsonProperty("download_url")] public string DownloadUrl { get; set; } } public (string command, string plugin)[] GetPendingCommands() { return PluginManager.GetPendingCommands(_btcPayServerOptions.PluginDir); } public void CancelCommands(string plugin) { PluginManager.CancelCommands(_btcPayServerOptions.PluginDir, plugin); } } }