HTTP.cs

Siirry tämän tiedoston dokumentaatioon.

using System;
using System.Collections.Generic;
using System.Linq;
using System.IO;
using System.Net;

namespace Jypeli
{
    public abstract partial class FileManager : Updatable
    {
        public class AsyncOperation
        {
            public HttpWebRequest Request;
            public IAsyncResult Result;
            public TimeSpan Lifetime;
            public Action<StorageFile> Callback;

            public bool IsCompleted
            {
                get { return Result == null ? true : Result.IsCompleted; }
            }

            public AsyncOperation( HttpWebRequest req, Action<StorageFile> callback )
            {
                this.Request = req;
                this.Callback = callback;
                this.Lifetime = TimeSpan.FromSeconds( 15 );
            }

            public AsyncOperation( HttpWebRequest req, Action<StorageFile> callback, TimeSpan timeout )
            {
                this.Request = req;
                this.Callback = callback;
                this.Lifetime = timeout;
            }
        }

        private class AsyncTrigger
        {
            public List<AsyncOperation> ops;
            public Action onCompleted;
            public int triggered = 0;
            public int failed = 0;

            public AsyncTrigger( List<AsyncOperation> operations, Action endAction )
            {
                this.ops = operations;
                this.onCompleted = endAction;
            }

            public AsyncTrigger( List<AsyncOperation> operations, TimeSpan timeout, Action endAction )
            {
                this.ops = operations;
                this.onCompleted = endAction;
                foreach ( var op in ops ) op.Lifetime = timeout;
            }
        }
        
        SynchronousList<AsyncTrigger> triggers = new SynchronousList<AsyncTrigger>();

        public bool IsUpdated
        {
            get { return triggers.Count > 0; }
        }

        public void Update( Time time )
        {
            triggers.Update( time );

            foreach ( var trig in triggers )
            {
                foreach ( var op in trig.ops.FindAll( o => !o.IsCompleted ) )
                {
                    op.Lifetime -= time.SinceLastUpdate;

                    if ( op.Lifetime.TotalSeconds <= 0 )
                    {
                        //Game.Instance.MessageDisplay.Add( "!!ABORT" );
                        op.Request.Abort();
                        trig.failed++;
                    }
                }

                if ( trig.triggered + trig.failed >= trig.ops.Count )
                {
                    triggers.Remove( trig );
                    trig.onCompleted();
                }
            }
        }

        public AsyncOperation DoWith( string fileName, Action<StorageFile> callback )
        {
            using ( var f = Open( fileName, false ) )
            {
                callback( f );
            }

            return new AsyncOperation( null, callback );
        }

        public AsyncOperation DoWithURL( string url, Action<StorageFile> callback )
        {
            HttpWebRequest request = (HttpWebRequest)WebRequest.Create( url );
            AsyncOperation op = new AsyncOperation( request, callback );
            IAsyncResult result = request.BeginGetResponse( DoWithCallback, op );
            op.Result = result;
            return op;
        }

        public AsyncOperation DoWithURL( string url, TimeSpan timeout, Action<StorageFile> callback )
        {
            HttpWebRequest request = (HttpWebRequest)WebRequest.Create( url );
            AsyncOperation op = new AsyncOperation( request, callback, timeout );
            IAsyncResult result = request.BeginGetResponse( DoWithCallback, op );
            op.Result = result;
            return op;
        }

        private void DoWithCallback(IAsyncResult ar)
        {
            try
            {
                AsyncOperation op = (AsyncOperation)ar.AsyncState;
                WebResponse response = op.Request.EndGetResponse( ar );
                Stream resStream = response.GetResponseStream();
                MemoryStream memStream = new MemoryStream();
                resStream.CopyStreamTo( memStream );
                resStream.Close();
                response.Close();

                memStream.Seek( 0, SeekOrigin.Begin );
                op.Callback( new StorageFile( op.Request.RequestUri.AbsoluteUri, memStream ) );
                memStream.Close();

                foreach ( var trig in triggers.FindAll( t => t.ops.Any( o => o.Result == ar ) ) )
                    trig.triggered++;

            }
            catch ( WebException we )
            {
                // Return if aborted
                return;
            }
        }

        public void TriggerOnComplete( Action callback, params AsyncOperation[] actions )
        {
            triggers.Add( new AsyncTrigger( actions.ToList().FindAll( o => !o.IsCompleted ), callback ) );

#if JYPELI
            triggers.Update( Game.Time );
#else
            triggers.Update( Time.Zero );
#endif
        }

        public void TriggerOnComplete( Action callback, TimeSpan timeout, params AsyncOperation[] actions )
        {
            triggers.Add( new AsyncTrigger( actions.ToList().FindAll( o => !o.IsCompleted ), timeout, callback ) );
#if JYPELI
            triggers.Update( Game.Time );
#else
            triggers.Update( Time.Zero );
#endif
        }
    }
}