From d75876a772da470153996ef81e11c1e159b679bf Mon Sep 17 00:00:00 2001 From: LittleSheep Date: Fri, 26 Sep 2025 22:11:52 +0800 Subject: [PATCH] :bug: Proper file upload retries --- DysonNetwork.Drive/Startup/BroadcastEventHandler.cs | 6 ++++-- DysonNetwork.Drive/Storage/FileService.cs | 2 +- 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/DysonNetwork.Drive/Startup/BroadcastEventHandler.cs b/DysonNetwork.Drive/Startup/BroadcastEventHandler.cs index 5654a16..805be3b 100644 --- a/DysonNetwork.Drive/Startup/BroadcastEventHandler.cs +++ b/DysonNetwork.Drive/Startup/BroadcastEventHandler.cs @@ -27,7 +27,9 @@ public class BroadcastEventHandler( private static readonly string[] AnimatedImageExtensions = [".gif", ".apng", ".avif"]; - + + + protected override async Task ExecuteAsync(CancellationToken stoppingToken) { var js = nats.CreateJetStreamContext(); @@ -291,4 +293,4 @@ public class BroadcastEventHandler( await fs._PurgeCacheAsync(fileId); } } -} \ No newline at end of file +} diff --git a/DysonNetwork.Drive/Storage/FileService.cs b/DysonNetwork.Drive/Storage/FileService.cs index 3890556..1048af4 100644 --- a/DysonNetwork.Drive/Storage/FileService.cs +++ b/DysonNetwork.Drive/Storage/FileService.cs @@ -346,7 +346,7 @@ public class FileService( if (selfDestruct) File.Delete(filePath); } - public async Task UploadFileToRemoteAsync( + private async Task UploadFileToRemoteAsync( string storageId, Guid targetRemote, Stream stream,