aspnetcore/src/Microsoft.AspNet.PipelineCore/DefaultHttpResponse.cs

111 lines
3.5 KiB
C#

using System;
using System.Globalization;
using System.IO;
using System.Text;
using System.Threading.Tasks;
using Microsoft.AspNet.Abstractions;
using Microsoft.AspNet.Abstractions.Infrastructure;
using Microsoft.AspNet.FeatureModel;
using Microsoft.AspNet.HttpFeature;
using Microsoft.AspNet.PipelineCore.Collections;
using Microsoft.AspNet.PipelineCore.Infrastructure;
namespace Microsoft.AspNet.PipelineCore
{
public class DefaultHttpResponse : HttpResponse
{
private readonly DefaultHttpContext _context;
private readonly IFeatureCollection _features;
private FeatureReference<IHttpResponseInformation> _response = FeatureReference<IHttpResponseInformation>.Default;
private FeatureReference<ICanHasResponseCookies> _canHasCookies = FeatureReference<ICanHasResponseCookies>.Default;
public DefaultHttpResponse(DefaultHttpContext context, IFeatureCollection features)
{
_context = context;
_features = features;
}
private IHttpResponseInformation HttpResponseInformation
{
get { return _response.Fetch(_features); }
}
private ICanHasResponseCookies CanHasResponseCookies
{
get { return _canHasCookies.Fetch(_features) ?? _canHasCookies.Update(_features, new DefaultCanHasResponseCookies(_features)); }
}
public override HttpContext HttpContext { get { return _context; } }
public override int StatusCode
{
get { return HttpResponseInformation.StatusCode; }
set { HttpResponseInformation.StatusCode = value; }
}
public override IHeaderDictionary Headers
{
get { return new HeaderDictionary(HttpResponseInformation.Headers); }
}
public override Stream Body
{
get { return HttpResponseInformation.Body; }
set { HttpResponseInformation.Body = value; }
}
public override long? ContentLength
{
get
{
return ParsingHelpers.GetContentLength(Headers);
}
set
{
ParsingHelpers.SetContentLength(Headers, value);
}
}
public override string ContentType
{
get
{
var contentType = Headers[Constants.Headers.ContentType];
return contentType;
}
set
{
if (string.IsNullOrWhiteSpace(value))
{
HttpResponseInformation.Headers.Remove(Constants.Headers.ContentType);
}
else
{
HttpResponseInformation.Headers[Constants.Headers.ContentType] = new[] { value };
}
}
}
public override IResponseCookies Cookies
{
get { return CanHasResponseCookies.Cookies; }
}
public override void OnSendingHeaders(Action<object> callback, object state)
{
HttpResponseInformation.OnSendingHeaders(callback, state);
}
public override void Redirect(string location)
{
HttpResponseInformation.StatusCode = 302;
Headers.Set(Constants.Headers.Location, location);
}
public override Task WriteAsync(string data)
{
var bytes = Encoding.UTF8.GetBytes(data);
return Body.WriteAsync(bytes, 0, bytes.Length);
}
}
}