AsyncWebRequest.cs

using System;
using System.Net;
using System.IO;
using System.Text;
using System.Threading;

namespace Oxide
{
    /// <summary>
    /// An asynchronous web request
    /// </summary>
    public class AsyncWebRequest
    {
        private WebRequest request;
        private string url;
        private string postdata;
        private bool ispost;

        private Thread thread;

        public bool Complete { get; private set; }
        public int ResponseCode { get; private set; }
        public string Response { get; private set; }

        private bool handled;

        public event Action<AsyncWebRequest> OnResponse;

        public AsyncWebRequest(string url)
        {
            this.url = url;
            this.postdata = null;
            this.ispost = false;
            thread = new Thread(Worker);
            thread.Start();
            //Main.Log("Worker thread started...");
        }

        public AsyncWebRequest(string url, string postdata)
        {
            this.url = url;
            this.postdata = postdata;
            this.ispost = true;
            thread = new Thread(Worker);
            thread.Start();
        }

        private void Worker()
        {
            try
            {
                //Main.Log("Creating request...");
                request = WebRequest.Create(url);
                request.Credentials = CredentialCache.DefaultCredentials;
                //30 Second timeout instead of 2 minutes before.
                request.Timeout = 30000;
                //Main.Log("Waiting for response...");

                if (this.ispost == true && this.postdata != null)
                {
                    request.Method = "POST";
                    byte[] bytePostData = Encoding.UTF8.GetBytes(postdata);

                    request.ContentType = "application/x-www-form-urlencoded";
                    request.ContentLength = bytePostData.Length;

                    Stream postStream = request.GetRequestStream();
                    postStream.Write(bytePostData, 0, bytePostData.Length);
                    postStream.Close();
                }

                HttpWebResponse response = request.GetResponse() as HttpWebResponse;
                if (response == null)
                {
                    // Uhh panic what do we do
                    Logger.Error("AsyncWebRequest panic: Response is null!");
                    return;
                }
                //Main.Log("Reading response stream...");
                Stream strm = response.GetResponseStream();
                StreamReader rdr = new StreamReader(strm);
                Response = rdr.ReadToEnd();
                ResponseCode = (int)response.StatusCode;
                rdr.Close();
                strm.Close();
                response.Close();
                //Main.Log("Web request complete.");
            }
            catch (WebException webex)
            {
                var response = webex.Response as HttpWebResponse;
                Response = webex.Message;
                ResponseCode = (int)response.StatusCode;
            }
            catch (Exception ex)
            {
                Response = ex.ToString();
                ResponseCode = -1;
                Logger.Error(ex.ToString());
            }
            finally
            {
                Complete = true;
            }
            
        }

        /// <summary>
        /// Updates this request
        /// </summary>
        public void Update()
        {
            if (Complete && !handled)
            {
                handled = true;
                if (OnResponse != null)
                {
                    //Main.Log("Firing web request callback...");
                    OnResponse(this);
                }
            }
        }

    }
}