jellyfin/Emby.Server.Implementations/Services/HttpResult.cs

65 lines
1.8 KiB
C#
Raw Normal View History

#pragma warning disable CS1591
2016-11-11 14:55:12 -05:00
using System.Collections.Generic;
using System.IO;
using System.Net;
using System.Threading;
using System.Threading.Tasks;
using MediaBrowser.Model.Services;
2017-02-12 20:07:48 -05:00
namespace Emby.Server.Implementations.Services
2016-11-11 14:55:12 -05:00
{
public class HttpResult
: IHttpResult, IAsyncStreamWriter
{
public HttpResult(object response, string contentType, HttpStatusCode statusCode)
{
this.Headers = new Dictionary<string, string>();
this.Response = response;
this.ContentType = contentType;
this.StatusCode = statusCode;
}
public object Response { get; set; }
2016-11-11 14:55:12 -05:00
public string ContentType { get; set; }
public IDictionary<string, string> Headers { get; private set; }
public int Status { get; set; }
public HttpStatusCode StatusCode
{
get => (HttpStatusCode)Status;
set => Status = (int)value;
2016-11-11 14:55:12 -05:00
}
2016-11-12 01:58:50 -05:00
public IRequest RequestContext { get; set; }
2016-11-11 14:55:12 -05:00
public async Task WriteToAsync(Stream responseStream, CancellationToken cancellationToken)
{
var response = RequestContext?.Response;
2016-11-11 14:55:12 -05:00
2019-01-06 14:35:36 -05:00
if (this.Response is byte[] bytesResponse)
2016-11-11 14:55:12 -05:00
{
2017-09-03 03:28:58 -04:00
var contentLength = bytesResponse.Length;
if (response != null)
{
response.ContentLength = contentLength;
}
2017-09-03 03:28:58 -04:00
if (contentLength > 0)
{
2019-02-26 15:08:30 -05:00
await responseStream.WriteAsync(bytesResponse, 0, contentLength, cancellationToken).ConfigureAwait(false);
2017-09-03 03:28:58 -04:00
}
2016-11-11 14:55:12 -05:00
return;
}
2017-02-12 20:07:48 -05:00
await ResponseHelper.WriteObject(this.RequestContext, this.Response, response).ConfigureAwait(false);
2016-11-11 14:55:12 -05:00
}
}
}