Welcome to mirror list, hosted at ThFree Co, Russian Federation.

FileStreamResult.cs « src « Http.Results « Http « src - github.com/dotnet/aspnetcore.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
blob: ed4202cb5cd12052249abd0503ba7a422a848d0c (plain)
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
// Licensed to the .NET Foundation under one or more agreements.
// The .NET Foundation licenses this file to you under the MIT license.

using Microsoft.AspNetCore.Internal;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;

namespace Microsoft.AspNetCore.Http.Result;

/// <summary>
/// Represents an <see cref="FileResult"/> that when executed will
/// write a file from a stream to the response.
/// </summary>
internal sealed class FileStreamResult : FileResult, IResult
{
    /// <summary>
    /// Creates a new <see cref="FileStreamResult"/> instance with
    /// the provided <paramref name="fileStream"/> and the
    /// provided <paramref name="contentType"/>.
    /// </summary>
    /// <param name="fileStream">The stream with the file.</param>
    /// <param name="contentType">The Content-Type header of the response.</param>
    public FileStreamResult(Stream fileStream, string? contentType)
        : base(contentType)
    {
        if (fileStream == null)
        {
            throw new ArgumentNullException(nameof(fileStream));
        }

        FileStream = fileStream;
    }

    /// <summary>
    /// Gets or sets the stream with the file that will be sent back as the response.
    /// </summary>
    public Stream FileStream { get; }

    public async Task ExecuteAsync(HttpContext httpContext)
    {
        var logger = httpContext.RequestServices.GetRequiredService<ILogger<FileStreamResult>>();
        await using (FileStream)
        {
            Log.ExecutingFileResult(logger, this);

            long? fileLength = null;
            if (FileStream.CanSeek)
            {
                fileLength = FileStream.Length;
            }

            var fileResultInfo = new FileResultInfo
            {
                ContentType = ContentType,
                EnableRangeProcessing = EnableRangeProcessing,
                EntityTag = EntityTag,
                FileDownloadName = FileDownloadName,
            };

            var (range, rangeLength, serveBody) = FileResultHelper.SetHeadersAndLog(
                httpContext,
                fileResultInfo,
                fileLength,
                EnableRangeProcessing,
                LastModified,
                EntityTag,
                logger);

            if (!serveBody)
            {
                return;
            }

            if (range != null && rangeLength == 0)
            {
                return;
            }

            if (range != null)
            {
                FileResultHelper.Log.WritingRangeToBody(logger);
            }

            await FileResultHelper.WriteFileAsync(httpContext, FileStream, range, rangeLength);
        }
    }
}