using MareSynchronosShared.Metrics; using MareSynchronosShared.Services; using MareSynchronosStaticFilesServer.Utils; using System.Collections.Concurrent; using System.Net.Http.Headers; using MareSynchronosShared.Utils; using MareSynchronos.API.Routes; namespace MareSynchronosStaticFilesServer.Services; public class CachedFileProvider { private readonly ILogger _logger; private readonly FileStatisticsService _fileStatisticsService; private readonly MareMetrics _metrics; private readonly ServerTokenGenerator _generator; private readonly Uri _remoteCacheSourceUri; private readonly string _basePath; private readonly ConcurrentDictionary _currentTransfers = new(StringComparer.Ordinal); private readonly HttpClient _httpClient; private bool IsMainServer => _remoteCacheSourceUri == null; public CachedFileProvider(IConfigurationService configuration, ILogger logger, FileStatisticsService fileStatisticsService, MareMetrics metrics, ServerTokenGenerator generator) { _logger = logger; _fileStatisticsService = fileStatisticsService; _metrics = metrics; _generator = generator; _remoteCacheSourceUri = configuration.GetValueOrDefault(nameof(StaticFilesServerConfiguration.RemoteCacheSourceUri), null); _basePath = configuration.GetValue(nameof(StaticFilesServerConfiguration.CacheDirectory)); _httpClient = new HttpClient(); } private async Task DownloadTask(string hash) { // download file from remote var downloadUrl = MareFiles.ServerFilesGetFullPath(_remoteCacheSourceUri, hash); _logger.LogInformation("Did not find {hash}, downloading from {server}", hash, downloadUrl); using var requestMessage = new HttpRequestMessage(HttpMethod.Get, downloadUrl); requestMessage.Headers.Authorization = new AuthenticationHeaderValue("Bearer", _generator.Token); var response = await _httpClient.SendAsync(requestMessage).ConfigureAwait(false); try { response.EnsureSuccessStatusCode(); } catch (Exception ex) { _logger.LogWarning(ex, "Failed to download {url}", downloadUrl); return; } var fileName = FilePathUtil.GetFilePath(_basePath, hash); using var fileStream = new FileStream(fileName, FileMode.OpenOrCreate, FileAccess.ReadWrite); var bufferSize = response.Content.Headers.ContentLength > 1024 * 1024 ? 4096 : 1024; var buffer = new byte[bufferSize]; var bytesRead = 0; while ((bytesRead = await (await response.Content.ReadAsStreamAsync().ConfigureAwait(false)).ReadAsync(buffer).ConfigureAwait(false)) > 0) { await fileStream.WriteAsync(buffer.AsMemory(0, bytesRead)).ConfigureAwait(false); } _metrics.IncGauge(MetricsAPI.GaugeFilesTotal); _metrics.IncGauge(MetricsAPI.GaugeFilesTotalSize, FilePathUtil.GetFileInfoForHash(_basePath, hash).Length); } public void DownloadFileWhenRequired(string hash) { var fi = FilePathUtil.GetFileInfoForHash(_basePath, hash); if (fi == null && IsMainServer) return; if (fi == null && !_currentTransfers.ContainsKey(hash)) { _currentTransfers[hash] = Task.Run(async () => { await DownloadTask(hash).ConfigureAwait(false); _currentTransfers.Remove(hash, out _); }); } } public FileStream? GetLocalFileStream(string hash) { var fi = FilePathUtil.GetFileInfoForHash(_basePath, hash); if (fi == null) return null; _fileStatisticsService.LogFile(hash, fi.Length); return new FileStream(fi.FullName, FileMode.Open, FileAccess.Read, FileShare.Inheritable | FileShare.Read); } public async Task GetAndDownloadFileStream(string hash) { DownloadFileWhenRequired(hash); if (_currentTransfers.TryGetValue(hash, out var downloadTask)) { await downloadTask.ConfigureAwait(false); } return GetLocalFileStream(hash); } }