danvics/rdt-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Cleanup, fixed failing build.

Browse source
This commit is contained in:
Roger Far 2026-04-27 21:04:26 -06:00
parent 5d09053327
commit 7f60f9de5a
3 changed files with 10 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
server/RdtClient.Service.Test/Regression/TorrentDownloadRaceTests.cs
View file

@ -132,6 +132,8 @@ public class TorrentDownloadRaceTests : IAsyncLifetime
public Task DisposeAsync()
{
SqliteConnection.ClearAllPools();
if (File.Exists(_databasePath))
{
File.Delete(_databasePath);
@ -160,7 +162,7 @@ public class TorrentDownloadRaceTests : IAsyncLifetime
var torrentId = Guid.NewGuid();
await using var context = CreateContext();
context.Torrents.Add(new Torrent
context.Torrents.Add(new()
{
TorrentId = torrentId,
Hash = Guid.NewGuid().ToString("N"),

7
server/RdtClient.Service/Services/Torrents.cs
View file

@ -3,6 +3,7 @@ using System.IO.Abstractions;
using System.Security.Cryptography;
using System.Text;
using System.Text.Json;
using System.Text.Json.Serialization;
using System.Xml;
using System.Xml.Linq;
using Microsoft.Extensions.Logging;
@ -37,6 +38,11 @@ public class Torrents(
private static readonly SemaphoreSlim TorrentResetLock = new(1, 1);
private static readonly JsonSerializerOptions JsonSerializerOptions = new()
{
ReferenceHandler = ReferenceHandler.IgnoreCycles
};
private IDebridClient DebridClient
{
get
@ -609,7 +615,6 @@ public class Torrents(
return unrestrictedLink;
}
/// <inheritdoc />
public async Task<String> RetrieveFileName(Guid downloadId)
{
var download = await downloads.GetById(downloadId) ?? throw new($"Download with ID {downloadId} not found");

2
server/RdtClient.Web/Controllers/TorrentsController.cs
View file

@ -388,7 +388,7 @@ public class TorrentsController(ILogger<TorrentsController> logger, Torrents tor
private static async Task<Byte[]> ReadFormFileBytes(IFormFile file)
{
await using var fileStream = file.OpenReadStream();
await using var memoryStream = file.Length > 0 && file.Length <= Int32.MaxValue ? new MemoryStream((Int32)file.Length) : new MemoryStream();
await using var memoryStream = file.Length is > 0 and <= Int32.MaxValue ? new((Int32)file.Length) : new MemoryStream();
await fileStream.CopyToAsync(memoryStream);