1 files changed, 36 insertions, 0 deletions
diff --git a/extra/admin-api/Interop/Spacebar.Interop.Cdn.Abstractions/ProxyFileSource.cs b/extra/admin-api/Interop/Spacebar.Interop.Cdn.Abstractions/ProxyFileSource.cs
new file mode 100644
index 00000000..af7cecf2
--- /dev/null
+++ b/extra/admin-api/Interop/Spacebar.Interop.Cdn.Abstractions/ProxyFileSource.cs
@@ -0,0 +1,36 @@
+using ArcaneLibs;
+
+namespace Spacebar.Interop.Cdn.Abstractions;
+
+public class ProxyFileSource(string baseUrl) : IFileSource {
+    private static LruFileCache _cache = new(100 * 1024 * 1024); // 100 MB
+
+    private readonly StreamingHttpClient _httpClient = new() {
+        BaseAddress = new Uri(baseUrl)
+    };
+
+    public string BaseUrl => baseUrl;
+
+    public async Task<FileInfo> GetFile(string path, CancellationToken? cancellationToken = null) {
+        var res = await _cache.GetOrAdd(path, async () => {
+            var res = await _httpClient.SendUnhandledAsync(new(HttpMethod.Get, path), cancellationToken);
+            res.EnsureSuccessStatusCode();
+            var ms = new MemoryStream();
+            await res.Content.CopyToAsync(ms);
+            return new LruFileCache.Entry {
+                Data = ms.ToArray(),
+                MimeType = res.Content.Headers.ContentType?.MediaType ?? "application/octet-stream"
+            };
+        });
+
+        return new() {
+            Stream = new MemoryStream(res.Data),
+            MimeType = res.MimeType
+        };
+    }
+
+    public async Task<bool> FileExists(string path, CancellationToken? cancellationToken = null) {
+        var res = await _httpClient.SendUnhandledAsync(new(HttpMethod.Head, path), cancellationToken);
+        return res.IsSuccessStatusCode;
+    }
+}
\ No newline at end of file