RequestStateForTask.cs

using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using System.Text;
using System.Threading.Tasks;

namespace SlackAPI
{
    public class RequestStateForTask<K>
        where K : Response
    {
        public HttpWebRequest request;
        Tuple<string, string>[] Post;
        public bool Success;

        public RequestStateForTask(HttpWebRequest requestData, Tuple<string, string>[] postParameters)
        {
            request = requestData;
            Post = postParameters;
        }

        internal Task<K> Execute()
        {
            if (Post.Length == 0)
            {
                request.Method = "GET";
                return this.ExecuteResult();
            }
            else
            {
                return this.ExecutePost();
            }
        }

        private async Task<K> ExecuteResult()
        {
            HttpWebResponse response = null;
            try
            {
                response = (HttpWebResponse)await this.request.GetResponseAsync();
                Success = true;
            }
            catch (WebException we)
            {
                //Anything that doesn't return error 200 throws an exception.  Sucks.  :l
                response = (HttpWebResponse)we.Response;
                //TODO: Handle timeouts, etc?
            }

            K responseObj;

            using (Stream responseReading = response.GetResponseStream())
            {
                using (StreamReader reader = new StreamReader(responseReading))
                {
                    string responseData = reader.ReadToEnd();
                    responseObj = JsonConvert.DeserializeObject<K>(responseData, new JavascriptDateTimeConverter());
                }
            }

            return responseObj;
        }

        private async Task<K> ExecutePost()
        {
            request.Method = "POST";
            using (Stream requestStream = await request.GetRequestStreamAsync())
            {
                if (Post.Length > 0)
                {
                    using (StreamWriter writer = new StreamWriter(requestStream))
                    {
                        bool first = true;
                        foreach (Tuple<string, string> postEntry in Post)
                        {
                            if (!first)
                                writer.Write(',');

                            await writer.WriteAsync(string.Format("{0}={1}", Uri.EscapeDataString(postEntry.Item1), Uri.EscapeDataString(postEntry.Item2)));

                            first = false;
                        }
                    }
                }
            }

            return await this.ExecuteResult();
        }
    }
}