HttpResult.cs 1.8 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061
  1. using System.Collections.Generic;
  2. using System.IO;
  3. using System.Net;
  4. using System.Threading;
  5. using System.Threading.Tasks;
  6. using MediaBrowser.Model.Services;
  7. namespace Emby.Server.Implementations.Services
  8. {
  9. public class HttpResult
  10. : IHttpResult, IAsyncStreamWriter
  11. {
  12. public object Response { get; set; }
  13. public HttpResult(object response, string contentType, HttpStatusCode statusCode)
  14. {
  15. this.Headers = new Dictionary<string, string>();
  16. this.Response = response;
  17. this.ContentType = contentType;
  18. this.StatusCode = statusCode;
  19. }
  20. public string ContentType { get; set; }
  21. public IDictionary<string, string> Headers { get; private set; }
  22. public int Status { get; set; }
  23. public HttpStatusCode StatusCode
  24. {
  25. get => (HttpStatusCode)Status;
  26. set => Status = (int)value;
  27. }
  28. public IRequest RequestContext { get; set; }
  29. public async Task WriteToAsync(Stream responseStream, CancellationToken cancellationToken)
  30. {
  31. var response = RequestContext == null ? null : RequestContext.Response;
  32. if (this.Response is byte[] bytesResponse)
  33. {
  34. var contentLength = bytesResponse.Length;
  35. if (response != null)
  36. {
  37. response.SetContentLength(contentLength);
  38. }
  39. if (contentLength > 0)
  40. {
  41. await responseStream.WriteAsync(bytesResponse, 0, contentLength).ConfigureAwait(false);
  42. }
  43. return;
  44. }
  45. await ResponseHelper.WriteObject(this.RequestContext, this.Response, response).ConfigureAwait(false);
  46. }
  47. }
  48. }