wjones
3e5d29225a
- Removed unused classes and files related to SQLite database provider, including SqliteDesignTimeJellyfinDbFactory, ModelBuilderExtensions, PragmaConnectionInterceptor, AssemblyInfo, SqliteDatabaseProvider, DateTimeKindValueConverter. - Updated tests to remove dependencies on removed classes and adjusted mocking for configuration sections. - Added Microsoft.EntityFrameworkCore.Sqlite package reference to test project. - Improved string handling in tests for better consistency and clarity. - Refactored logging methods in JellyfinApplicationFactory for better readability and maintainability.
76 lines
3.1 KiB
C#
76 lines
3.1 KiB
C#
// <copyright file="WebSocketConnectionTests.cs" company="PlaceholderCompany">
|
|
// Copyright (c) PlaceholderCompany. All rights reserved.
|
|
// </copyright>
|
|
|
|
#pragma warning disable CA1517 // Do not use overloads of StartsWith/EndsWith with char when multiple characters are expected
|
|
|
|
namespace Jellyfin.Server.Implementations.Tests.HttpServer
|
|
{
|
|
using System;
|
|
using System.Buffers;
|
|
using System.IO;
|
|
using System.Text.Json;
|
|
using Emby.Server.Implementations.HttpServer;
|
|
using Microsoft.Extensions.Logging.Abstractions;
|
|
using Xunit;
|
|
|
|
public class WebSocketConnectionTests
|
|
{
|
|
[Fact]
|
|
public void DeserializeWebSocketMessage_SingleSegment_Success()
|
|
{
|
|
var con = new WebSocketConnection(new NullLogger<WebSocketConnection>(), null!, null!, null!);
|
|
var bytes = File.ReadAllBytes("Test Data/HttpServer/ForceKeepAlive.json");
|
|
con.DeserializeWebSocketMessage(new ReadOnlySequence<byte>(bytes), out var bytesConsumed);
|
|
Assert.Equal(109, bytesConsumed);
|
|
}
|
|
|
|
[Fact]
|
|
public void DeserializeWebSocketMessage_MultipleSegments_Success()
|
|
{
|
|
const int SplitPos = 64;
|
|
var con = new WebSocketConnection(new NullLogger<WebSocketConnection>(), null!, null!, null!);
|
|
var bytes = File.ReadAllBytes("Test Data/HttpServer/ForceKeepAlive.json");
|
|
var seg1 = new BufferSegment(new Memory<byte>(bytes, 0, SplitPos));
|
|
var seg2 = seg1.Append(new Memory<byte>(bytes, SplitPos, bytes.Length - SplitPos));
|
|
con.DeserializeWebSocketMessage(new ReadOnlySequence<byte>(seg1, 0, seg2, seg2.Memory.Length - 1), out var bytesConsumed);
|
|
Assert.Equal(109, bytesConsumed);
|
|
}
|
|
|
|
[Fact]
|
|
public void DeserializeWebSocketMessage_ValidPartial_Success()
|
|
{
|
|
var con = new WebSocketConnection(new NullLogger<WebSocketConnection>(), null!, null!, null!);
|
|
var bytes = File.ReadAllBytes("Test Data/HttpServer/ValidPartial.json");
|
|
con.DeserializeWebSocketMessage(new ReadOnlySequence<byte>(bytes), out var bytesConsumed);
|
|
Assert.Equal(109, bytesConsumed);
|
|
}
|
|
|
|
[Fact]
|
|
public void DeserializeWebSocketMessage_Partial_ThrowJsonException()
|
|
{
|
|
var con = new WebSocketConnection(new NullLogger<WebSocketConnection>(), null!, null!, null!);
|
|
var bytes = File.ReadAllBytes("Test Data/HttpServer/Partial.json");
|
|
Assert.Throws<JsonException>(() => con.DeserializeWebSocketMessage(new ReadOnlySequence<byte>(bytes), out var bytesConsumed));
|
|
}
|
|
|
|
internal sealed class BufferSegment : ReadOnlySequenceSegment<byte>
|
|
{
|
|
public BufferSegment(ReadOnlyMemory<byte> memory)
|
|
{
|
|
Memory = memory;
|
|
}
|
|
|
|
public BufferSegment Append(Memory<byte> memory)
|
|
{
|
|
var segment = new BufferSegment(memory)
|
|
{
|
|
RunningIndex = RunningIndex + Memory.Length
|
|
};
|
|
Next = segment;
|
|
return segment;
|
|
}
|
|
}
|
|
}
|
|
}
|