-
Notifications
You must be signed in to change notification settings - Fork 19
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
4 changed files
with
96 additions
and
22 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,68 @@ | ||
| module FsCodec.Core.Tests.DeflateTests | ||
|
|
||
| open System | ||
| open Swensen.Unquote | ||
| open Xunit | ||
|
|
||
| let inline roundtrip (sut : FsCodec.IEventCodec<_, _, _>) value = | ||
| let encoded = sut.Encode(context = None, value = value) | ||
| let loaded = FsCodec.Core.TimelineEvent.Create(-1L, encoded.EventType, encoded.Data) | ||
| sut.TryDecode loaded | ||
|
|
||
| (* Base Fixture Round-trips a String encoded as ReadOnlyMemory<byte> UTF-8 blob *) | ||
|
|
||
| module StringUtf8 = | ||
|
|
||
| let eventType = "n/a" | ||
| let enc (s : string) : ReadOnlyMemory<byte> = System.Text.Encoding.UTF8.GetBytes s |> ReadOnlyMemory | ||
| let dec (b : ReadOnlySpan<byte>) : string = System.Text.Encoding.UTF8.GetString b | ||
| let stringUtf8Encoder = | ||
| let encode e = eventType, enc e | ||
| let tryDecode (s, b : ReadOnlyMemory<byte>) = if s = eventType then Some (dec b.Span) else invalidOp "Invalid eventType value" | ||
| FsCodec.Codec.Create(encode, tryDecode) | ||
|
|
||
| let sut = stringUtf8Encoder | ||
|
|
||
| let [<Fact>] roundtrips () = | ||
| let value = "TestValue" | ||
| let res' = roundtrip sut value | ||
| res' =! Some value | ||
|
|
||
| module WithTryDeflate = | ||
|
|
||
| let sut = FsCodec.DeflateHelpers.EncodeWithTryDeflate(StringUtf8.sut) | ||
|
|
||
| let compressibleValue = String('x', 5000) | ||
|
|
||
| let [<Fact>] roundtrips () = | ||
| let res' = roundtrip sut compressibleValue | ||
| res' =! Some compressibleValue | ||
|
|
||
| let [<Fact>] ``compresses when possible`` () = | ||
| let encoded = sut.Encode(context = None, value = compressibleValue) | ||
| let struct (encoding, encodedValue) = encoded.Data | ||
| encodedValue.Length <! compressibleValue.Length | ||
|
|
||
| let [<Fact>] ``uses raw value where compression not possible`` () = | ||
| let value = "NotCompressible" | ||
| let directResult = StringUtf8.sut.Encode(None, value).Data | ||
| let encoded = sut.Encode(context = None, value = value) | ||
| let struct (_encoding, result) = encoded.Data | ||
| true =! directResult.Span.SequenceEqual(result.Span) | ||
|
|
||
| module WithoutCompression = | ||
|
|
||
| let sut = FsCodec.DeflateHelpers.EncodeUncompressed(StringUtf8.sut) | ||
|
|
||
| // Borrow a demonstrably compressible value | ||
| let value = WithTryDeflate.compressibleValue | ||
|
|
||
| let [<Fact>] roundtrips () = | ||
| let res' = roundtrip sut value | ||
| res' =! Some value | ||
|
|
||
| let [<Fact>] ``does not compress, even if it was possible to`` () = | ||
| let directResult = StringUtf8.sut.Encode(None, value).Data | ||
| let encoded = sut.Encode(context = None, value = value) | ||
| let struct (_encoding, result) = encoded.Data | ||
| true =! directResult.Span.SequenceEqual(result.Span) |