CSharpFunctionalExtensions.HttpResults/CSharpFunctionalExtensions.HttpResults.Tests/ResultExtensions/ToFileStreamHttpResultStream.cs at 8aca180e17bb04eaf22bfd12a88baec6eb066010 · co-IT/CSharpFunctionalExtensions.HttpResults · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
using System.Net.Mime;
using CSharpFunctionalExtensions.HttpResults.ResultExtensions;
using FluentAssertions;
using Microsoft.AspNetCore.Http.HttpResults;
using Microsoft.Net.Http.Headers;

namespace CSharpFunctionalExtensions.HttpResults.Tests.ResultExtensions;

public class ToFileStreamHttpResultStream
{
  [Fact]
  public void ResultStream_Success_can_be_mapped_to_FileStreamHttpResult()
  {
    var value = "foo"u8.ToArray();
    using var sourceStream = new MemoryStream();
    sourceStream.Write(value);
    var contentType = MediaTypeNames.Text.Plain;
    var fileDownloadName = "foo.txt";
    var lastModified = DateTimeOffset.Now;
    var entityTag = new EntityTagHeaderValue("\"fooETag\"");
    var enableRangeProcessing = true;

    var result =
      Result
        .Success(sourceStream)
        .ToFileStreamHttpResult(contentType, fileDownloadName, lastModified, entityTag, enableRangeProcessing)
        .Result as FileStreamHttpResult;

    using var resultStream = new MemoryStream();
    result!.FileStream.Position = 0;
    result!.FileStream.CopyTo(resultStream);
    resultStream.ToArray().Should().BeEquivalentTo(value);
    result!.LastModified.Should().Be(lastModified);
    result!.FileDownloadName.Should().Be(fileDownloadName);
    result!.FileLength.Should().Be(value.Length);
    result!.ContentType.Should().Be(contentType);
    result!.EnableRangeProcessing.Should().Be(enableRangeProcessing);
    result!.EntityTag.Should().Be(entityTag);
  }

  [Fact]
  public async Task ResultStream_Success_can_be_mapped_to_FileStreamHttpResult_Async()
  {
    var value = "foo"u8.ToArray();
    await using var sourceStream = new MemoryStream();
    sourceStream.Write(value);
    var contentType = MediaTypeNames.Text.Plain;
    var fileDownloadName = "foo.txt";
    var lastModified = DateTimeOffset.Now;
    var entityTag = new EntityTagHeaderValue("\"fooETag\"");
    var enableRangeProcessing = true;

    var result =
      (
        await Task.FromResult(Result.Success(sourceStream))
          .ToFileStreamHttpResult(contentType, fileDownloadName, lastModified, entityTag, enableRangeProcessing)
      ).Result as FileStreamHttpResult;

    await using var resultStream = new MemoryStream();
    result!.FileStream.Position = 0;
    await result!.FileStream.CopyToAsync(resultStream);
    resultStream.ToArray().Should().BeEquivalentTo(value);
    result!.LastModified.Should().Be(lastModified);
    result!.FileDownloadName.Should().Be(fileDownloadName);
    result!.FileLength.Should().Be(value.Length);
    result!.ContentType.Should().Be(contentType);
    result!.EnableRangeProcessing.Should().Be(enableRangeProcessing);
    result!.EntityTag.Should().Be(entityTag);
  }

  [Fact]
  public void ResultStream_Failure_can_be_mapped_to_FileStreamHttpResult()
  {
    var error = "Error";

    var result = Result.Failure<Stream>(error).ToFileStreamHttpResult().Result as ProblemHttpResult;

    result!.StatusCode.Should().Be(400);
    result!.ProblemDetails.Status.Should().Be(400);
    result!.ProblemDetails.Detail.Should().Be(error);
  }

  [Fact]
  public async Task ResultStream_Failure_can_be_mapped_to_FileStreamHttpResult_Async()
  {
    var error = "Error";

    var result =
      (await Task.FromResult(Result.Failure<Stream>(error)).ToFileStreamHttpResult()).Result as ProblemHttpResult;

    result!.StatusCode.Should().Be(400);
    result!.ProblemDetails.Status.Should().Be(400);
    result!.ProblemDetails.Detail.Should().Be(error);
  }

  [Fact]
  public void ResultStream_Failure_StatusCode_can_be_changed()
  {
    var statusCode = 418;
    var error = "Error";

    var result =
      Result.Failure<Stream>(error).ToFileStreamHttpResult(failureStatusCode: statusCode).Result as ProblemHttpResult;

    result!.StatusCode.Should().Be(statusCode);
    result!.ProblemDetails.Status.Should().Be(statusCode);
    result!.ProblemDetails.Detail.Should().Be(error);
  }

  [Fact]
  public async Task ResultStream_Failure_StatusCode_can_be_changed_Async()
  {
    var statusCode = 418;
    var error = "Error";

    var result =
      (
        await Task.FromResult(Result.Failure<Stream>(error)).ToFileStreamHttpResult(failureStatusCode: statusCode)
      ).Result as ProblemHttpResult;

    result!.StatusCode.Should().Be(statusCode);
    result!.ProblemDetails.Status.Should().Be(statusCode);
    result!.ProblemDetails.Detail.Should().Be(error);
  }

  [Fact]
  public void ResultStream_Failure_ProblemDetails_can_be_customized()
  {
    var error = "Error";
    var customTitle = "Custom Title";

    var result =
      Result
        .Failure<Stream>(error)
        .ToFileStreamHttpResult(customizeProblemDetails: problemDetails => problemDetails.Title = customTitle)
        .Result as ProblemHttpResult;

    result!.ProblemDetails.Title.Should().Be(customTitle);
  }

  [Fact]
  public async Task ResultStream_Failure_ProblemDetails_can_be_customized_Async()
  {
    var error = "Error";
    var customTitle = "Custom Title";

    var result =
      (
        await Task.FromResult(Result.Failure<Stream>(error))
          .ToFileStreamHttpResult(customizeProblemDetails: problemDetails => problemDetails.Title = customTitle)
      ).Result as ProblemHttpResult;

    result!.ProblemDetails.Title.Should().Be(customTitle);
  }
}