[Milky] Fix some streams are not closed, causing memory leaks

Author: NoirHare

Lagrange.Milky/Api/Handler/File/UploadGroupFileHandler.cs

@@ -13,7 +13,7 @@ public class UploadGroupFileHandler(BotContext bot, ResourceResolver resolver) :
 
     public async Task<UploadGroupFileResult> HandleAsync(UploadGroupFileParameter parameter, CancellationToken token)
     {
-        var stream = await _resolver.ToMemoryStreamAsync(parameter.FileUri, token);
+        using var stream = await _resolver.ToMemoryStreamAsync(parameter.FileUri, token);
         var id = await _bot.SendGroupFile(parameter.GroupId, stream, parameter.FileName, parameter.ParentFolderId);
 
         return new UploadGroupFileResult(id);

Lagrange.Milky/Api/Handler/File/UploadPrivateFileHandler.cs

@@ -13,7 +13,7 @@ public class UploadPrivateFileHandler(BotContext bot, ResourceResolver resolver)
 
     public async Task<UploadPrivateFileResult> HandleAsync(UploadPrivateFileParameter parameter, CancellationToken token)
     {
-        var stream = await _resolver.ToMemoryStreamAsync(parameter.FileUri, token);
+        using var stream = await _resolver.ToMemoryStreamAsync(parameter.FileUri, token);
         (int _, _) = await _bot.SendFriendFile(parameter.UserId, stream, parameter.FileName);
 
         // TODO: The URL cannot be located at this time

Lagrange.Milky/Utility/EntityConvert.Segment.cs

@@ -99,12 +99,17 @@ await _resolver.ToMemoryStreamAsync(image.Data.Uri, token),
                 "normal" => 0,
                 "sticker" => 1,
                 _ => throw new NotSupportedException(),
-            }
+            },
+            disposeOnCompletion: true
+        ),
+        RecordOutgoingSegment record => new RecordEntity(
+            await _resolver.ToMemoryStreamAsync(record.Data.Uri, token),
+            disposeOnCompletion: true
         ),
-        RecordOutgoingSegment record => new RecordEntity(await _resolver.ToMemoryStreamAsync(record.Data.Uri, token)),
         VideoOutgoingSegment video => new VideoEntity(
             await _resolver.ToMemoryStreamAsync(video.Data.Uri, token),
-            video.Data.ThumbUri != null ? await _resolver.ToMemoryStreamAsync(video.Data.ThumbUri, token) : null
+            video.Data.ThumbUri != null ? await _resolver.ToMemoryStreamAsync(video.Data.ThumbUri, token) : null,
+            disposeOnCompletion: true
         ),
         // TODO: ForwardOutgoingSegment
         _ => throw new NotSupportedException(),