diff options
Diffstat (limited to 'MediaBrowser.Controller/Net')
| -rw-r--r-- | MediaBrowser.Controller/Net/CollectionExtensions.cs | 14 | ||||
| -rw-r--r-- | MediaBrowser.Controller/Net/HttpServer.cs | 47 | ||||
| -rw-r--r-- | MediaBrowser.Controller/Net/Request.cs | 18 | ||||
| -rw-r--r-- | MediaBrowser.Controller/Net/RequestContext.cs | 37 | ||||
| -rw-r--r-- | MediaBrowser.Controller/Net/Response.cs | 49 | ||||
| -rw-r--r-- | MediaBrowser.Controller/Net/StreamExtensions.cs | 20 |
6 files changed, 0 insertions, 185 deletions
diff --git a/MediaBrowser.Controller/Net/CollectionExtensions.cs b/MediaBrowser.Controller/Net/CollectionExtensions.cs deleted file mode 100644 index 137fbe50b..000000000 --- a/MediaBrowser.Controller/Net/CollectionExtensions.cs +++ /dev/null @@ -1,14 +0,0 @@ -using System.Collections.Generic;
-using System.Collections.Specialized;
-using System.Linq;
-
-namespace MediaBrowser.Controller.Net
-{
- public static class CollectionExtensions
- {
- public static IDictionary<string, IEnumerable<string>> ToDictionary(this NameValueCollection source)
- {
- return source.AllKeys.ToDictionary<string, string, IEnumerable<string>>(key => key, source.GetValues);
- }
- }
-}
\ No newline at end of file diff --git a/MediaBrowser.Controller/Net/HttpServer.cs b/MediaBrowser.Controller/Net/HttpServer.cs deleted file mode 100644 index bb014ca5a..000000000 --- a/MediaBrowser.Controller/Net/HttpServer.cs +++ /dev/null @@ -1,47 +0,0 @@ -using System;
-using System.Net;
-using System.Reactive.Linq;
-
-namespace MediaBrowser.Controller.Net
-{
- public class HttpServer : IObservable<RequestContext>, IDisposable
- {
- private readonly HttpListener listener;
- private readonly IObservable<RequestContext> stream;
-
- public HttpServer(int port)
- : this("http://+:" + port + "/")
- {
- }
-
- public HttpServer(string url)
- {
- listener = new HttpListener();
- listener.Prefixes.Add(url);
- listener.Start();
- stream = ObservableHttpContext();
- }
-
- private IObservable<RequestContext> ObservableHttpContext()
- {
- return Observable.Create<RequestContext>(obs =>
- Observable.FromAsyncPattern<HttpListenerContext>(listener.BeginGetContext,
- listener.EndGetContext)()
- .Select(c => new RequestContext(c))
- .Subscribe(obs))
- .Repeat()
- .Retry()
- .Publish()
- .RefCount();
- }
- public void Dispose()
- {
- listener.Stop();
- }
-
- public IDisposable Subscribe(IObserver<RequestContext> observer)
- {
- return stream.Subscribe(observer);
- }
- }
-}
\ No newline at end of file diff --git a/MediaBrowser.Controller/Net/Request.cs b/MediaBrowser.Controller/Net/Request.cs deleted file mode 100644 index 751c1e384..000000000 --- a/MediaBrowser.Controller/Net/Request.cs +++ /dev/null @@ -1,18 +0,0 @@ -using System.Collections.Generic;
-using System.IO;
-using System.Linq;
-
-namespace MediaBrowser.Controller.Net
-{
- public class Request
- {
- public string HttpMethod { get; set; }
- public IDictionary<string, IEnumerable<string>> Headers { get; set; }
- public Stream InputStream { get; set; }
- public string RawUrl { get; set; }
- public int ContentLength
- {
- get { return int.Parse(Headers["Content-Length"].First()); }
- }
- }
-}
\ No newline at end of file diff --git a/MediaBrowser.Controller/Net/RequestContext.cs b/MediaBrowser.Controller/Net/RequestContext.cs deleted file mode 100644 index 531faab84..000000000 --- a/MediaBrowser.Controller/Net/RequestContext.cs +++ /dev/null @@ -1,37 +0,0 @@ -using System.Linq;
-using System.Net;
-using System.IO.Compression;
-
-namespace MediaBrowser.Controller.Net
-{
- public class RequestContext
- {
- public HttpListenerRequest Request { get; private set; }
- public HttpListenerResponse Response { get; private set; }
-
- public RequestContext(HttpListenerContext context)
- {
- Response = context.Response;
- Request = context.Request;
- }
-
- public void Respond(Response response)
- {
- Response.AddHeader("Access-Control-Allow-Origin", "*");
-
- foreach (var header in response.Headers)
- {
- Response.AddHeader(header.Key, header.Value);
- }
-
- Response.ContentType = response.ContentType;
- Response.StatusCode = response.StatusCode;
-
- Response.SendChunked = true;
-
- GZipStream gzipStream = new GZipStream(Response.OutputStream, CompressionMode.Compress, false);
-
- response.WriteStream(Response.OutputStream);
- }
- }
-}
\ No newline at end of file diff --git a/MediaBrowser.Controller/Net/Response.cs b/MediaBrowser.Controller/Net/Response.cs deleted file mode 100644 index a119198cb..000000000 --- a/MediaBrowser.Controller/Net/Response.cs +++ /dev/null @@ -1,49 +0,0 @@ -using System;
-using System.Collections.Generic;
-using System.IO;
-using System.Text;
-
-namespace MediaBrowser.Controller.Net
-{
- public class Response
- {
- protected RequestContext RequestContext { get; private set; }
-
- public Response(RequestContext ctx)
- {
- RequestContext = ctx;
-
- WriteStream = s => { };
- StatusCode = 200;
- Headers = new Dictionary<string, string>();
- CacheDuration = TimeSpan.FromTicks(0);
- ContentType = "text/html";
- }
-
- public int StatusCode { get; set; }
- public string ContentType { get; set; }
- public IDictionary<string, string> Headers { get; set; }
- public TimeSpan CacheDuration { get; set; }
- public Action<Stream> WriteStream { get; set; }
- }
-
- /*public class ByteResponse : Response
- {
- public ByteResponse(byte[] bytes)
- {
- WriteStream = async s =>
- {
- await s.WriteAsync(bytes, 0, bytes.Length);
- s.Close();
- };
- }
- }
-
- public class StringResponse : ByteResponse
- {
- public StringResponse(string message)
- : base(Encoding.UTF8.GetBytes(message))
- {
- }
- }*/
-}
\ No newline at end of file diff --git a/MediaBrowser.Controller/Net/StreamExtensions.cs b/MediaBrowser.Controller/Net/StreamExtensions.cs deleted file mode 100644 index 451a43acb..000000000 --- a/MediaBrowser.Controller/Net/StreamExtensions.cs +++ /dev/null @@ -1,20 +0,0 @@ -using System;
-using System.Collections.Generic;
-using System.IO;
-using System.Reactive.Linq;
-
-namespace MediaBrowser.Controller.Net
-{
- public static class StreamExtensions
- {
- public static IObservable<byte[]> ReadBytes(this Stream stream, int count)
- {
- var buffer = new byte[count];
- return Observable.FromAsyncPattern((cb, state) => stream.BeginRead(buffer, 0, count, cb, state), ar =>
- {
- stream.EndRead(ar);
- return buffer;
- })();
- }
- }
-}
\ No newline at end of file |
