TwitterAPIClient for UnityWebRequest (beta)

JsonHelper.cs

using System.Collections;
using System.Collections.Generic;
using System;
using UnityEngine;

public class JsonHelper {

	public static string ArrayToObject (string arrayString) {
		if (arrayString.StartsWith ("[")) {
			arrayString = "{\"items\":" + arrayString + "}";
			return arrayString;
		} else {
			return arrayString;
		}
	}
}

ResponseJson.cs

using System;
using System.Collections.Generic;
using UnityEngine;

namespace twitter {

	// ==============================
	// Response Class
	// ==============================
	[Serializable]
	public class TweetResponse {
		public int id;
		public string text;
		public string created_at;
		public UserResponse user;
		public int retweet_count;
	}

	[Serializable]
	public class UserResponse {
		public int id;
		public string name;
		public string screen_name;
		public string profile_image_url;
		public string location;
		public string description;
		public string url;
	}

	[Serializable]
	public class SearchTweetsResponse {
		public TweetResponse[] statuses; 
	}

	[Serializable]
	public class StatusesUserTimelineResponse {
		public TweetResponse[] items;
	}
	[Serializable]
	public class StatusesHomeTimelineResponse {
		public TweetResponse[] items;
	}

	[Serializable]
	public class FollowersListResponse {
		public UserResponse[] users;
	}

	[Serializable]
	public class FriendsListResponse {
		public UserResponse[] users;
	}

}

Sample.cs

using System.Collections;
using System.Collections.Generic;
using UnityEngine;
using UnityEngine.UI;
using UnityEngine.Networking;
using twitter;

public class Sample : MonoBehaviour {
	void Start () {
		twitter.Client.consumerKey = "...";
		twitter.Client.consumerSecret = "...";
		twitter.Client.accessToken = "...";
		twitter.Client.accessTokenSecret = "...";

		Dictionary<string, string> parameters = new Dictionary<string, string>();
    parameters ["status"] = "テスト";
    StartCoroutine (twitter.Client.Post ("statuses/update", parameters1, new twitter.GetCallback (this.PostCallback))); 
	}

	void PostCallback(bool success, string response) {
		if (success) {
			TweetResponse tweet = JsonUtility.FromJson<TweetResponse> (response);
			Debug.Log (tweet.user.name + ":" + tweet.text);
		} else {
			Debug.Log (response);
		}
	}


}

TwitterRequest.cs

using System;
using System.IO;
using System.Net;
using System.Xml;
using System.Globalization;
using System.Collections;
using System.Collections.Generic;
using System.Security.Cryptography;
using System.Text;
using System.Text.RegularExpressions;
using UnityEngine;
using UnityEngine.UI;
using UnityEngine.Networking;
using twitter;

namespace twitter {


	public delegate void GetCallback(bool success, string response);

	public class Client {

		// ==============================
		// Tokens
		// ==============================
		public static string consumerKey        {get; set;}
		public static string consumerSecret     {get; set;}
		public static string accessToken        {get; set;}
		public static string accessTokenSecret  {get; set;}

		// ==============================
		// REST APIs
		// ==============================
		public static IEnumerator Get(string APIPath, Dictionary<string, string> APIParams, GetCallback callback)
		{
			string REQUEST_URL = "https://api.twitter.com/1.1/" + APIPath + ".json";

			SortedDictionary<string, string> parameters = new SortedDictionary<string, string> ();
			SetAPIParams (parameters, APIParams);

			string requestURL = REQUEST_URL + "?" + GenerateRequestparams(parameters);
			UnityWebRequest request = UnityWebRequest.Get (requestURL);

			yield return SendRequest (request, parameters, "GET", REQUEST_URL, consumerKey, consumerSecret, accessToken, accessTokenSecret, callback);
		}

		public static IEnumerator Post(string APIPath, Dictionary<string, string> APIParams, GetCallback callback)
		{
			string REQUEST_URL = "https://api.twitter.com/1.1/" + APIPath + ".json";

			SortedDictionary<string, string> parameters = new SortedDictionary<string, string> ();
			SetAPIParams (parameters, APIParams);

			WWWForm form = new WWWForm ();
			string paramsString = "";
			foreach (KeyValuePair<string, string> parameter in APIParams) {
				form.AddField (parameter.Key, parameter.Value);
				paramsString += String.Format ("{0}={1},", parameter.Key, parameter.Value); 
			}
			paramsString = paramsString.Remove (paramsString.Length - 1);
			Debug.Log (paramsString);

			UnityWebRequest request = UnityWebRequest.Post(REQUEST_URL, form); 
			yield return SendRequest (request, parameters, "POST", REQUEST_URL, consumerKey, consumerSecret, accessToken, accessTokenSecret, callback);

		}

		// ==============================
		// RequestHelperMethods
		// ==============================
		private static void SetAPIParams(SortedDictionary<string, string> parameters, Dictionary<string, string> APIParams)
		{
			foreach (KeyValuePair<string, string> APIParam in APIParams) {
				parameters.Add (APIParam.Key, APIParam.Value);
			}
		}

		private static string GenerateRequestparams(SortedDictionary<string, string> parameters)
		{
			string requestParams = "";
			foreach(KeyValuePair<string, string> param in parameters) {
				requestParams += UrlEncode (param.Key) + "=" + UrlEncode (param.Value) + "&";
			}
			requestParams = requestParams.Remove (requestParams.Length - 1);
			return requestParams;
		}

		private static IEnumerator SendRequest(UnityWebRequest request, SortedDictionary<string, string> parameters, string method, string requestURL, string consumerKey, string consumerSecret, string accessToken, string accessTokenSecret, GetCallback callback)
		{
			request.SetRequestHeader ("ContentType", "application/x-www-form-urlencoded");
			request.SetRequestHeader ("Authorization", GenerateHeaderWithAccessToken(parameters, method, requestURL, consumerKey, consumerSecret, accessToken, accessTokenSecret));
			yield return request.Send();

			if (request.isError) {
				callback (false, JsonHelper.ArrayToObject(request.error));
			} else {
				if (request.responseCode == 200) {
					callback (true, JsonHelper.ArrayToObject(request.downloadHandler.text));
				} else {
					Debug.Log (request.responseCode);
					callback (false, JsonHelper.ArrayToObject(request.downloadHandler.text));
				}
			}
		}


		// ==============================
		// OAuthHelperMethods
		// ==============================
		private static string GenerateHeaderWithAccessToken(SortedDictionary<string, string> parameters, string requestMethod, string requestURL, string consumerKey, string consumerSecret, string accessToken, string accessTokenSecret)
		{
			string signature = GenerateSignatureWithAccessToken(parameters, requestMethod, requestURL, consumerKey, consumerSecret, accessToken, accessTokenSecret);

			string requestParamsString = "";
			foreach (KeyValuePair<string, string> param in parameters) {
				requestParamsString += String.Format ("{0}=\"{1}\",", UrlEncode (param.Key), UrlEncode (param.Value));
			}

			string authHeader = "OAuth realm=\"Twitter API\",";
			string requestSignature = String.Format ("oauth_signature=\"{0}\"", UrlEncode (signature));
			authHeader += requestParamsString + requestSignature;
			return authHeader;
		}

		private static string GenerateSignatureWithAccessToken(SortedDictionary<string, string> parameters, string requestMethod, string requestURL, string consumerKey, string consumerSecret, string accessToken, string accessTokenSecret)
		{
			AddDefaultOauthParams (parameters, consumerKey);
			parameters.Add ("oauth_token", accessToken);

			string paramsString = "";
			foreach (KeyValuePair<string, string> param in parameters) {
				paramsString += UrlEncode(param.Key) + "=" + UrlEncode(param.Value) + "&";
			}
			paramsString = paramsString.Remove (paramsString.Length - 1); // Remove "&" at the last of string
			paramsString = UrlEncode (paramsString);

			string requestHeader = UrlEncode (requestMethod) + "&" + UrlEncode (requestURL);
			string signatureData = requestHeader + "&" + paramsString;

			string signatureKey = UrlEncode (consumerSecret) + "&" + UrlEncode (accessTokenSecret);
			HMACSHA1 hmacsha1 = new HMACSHA1 (Encoding.ASCII.GetBytes(signatureKey));
			byte[] signatureBytes = hmacsha1.ComputeHash (Encoding.ASCII.GetBytes (signatureData));
			return Convert.ToBase64String (signatureBytes);
		}

		private static void AddDefaultOauthParams(SortedDictionary<string, string> parameters, string consumerKey) {
			parameters.Add ("oauth_consumer_key", consumerKey);
			parameters.Add ("oauth_signature_method", "HMAC-SHA1");
			parameters.Add ("oauth_timestamp", GenerateTimeStamp());
			parameters.Add ("oauth_nonce", GenerateNonce());
			parameters.Add ("oauth_version", "1.0");
		}

		private static string GenerateTimeStamp()
		{
			TimeSpan ts = DateTime.UtcNow - new DateTime(1970, 1, 1, 0, 0, 0, 0);
			return Convert.ToInt64(ts.TotalSeconds).ToString();
		}

		private static string GenerateNonce()
		{
			return new System.Random().Next(123400, int.MaxValue).ToString("X");
		}

		private static string UrlEncode(string value)
		{
			if (string.IsNullOrEmpty(value))
			{
				return string.Empty;
			}

			value = Uri.EscapeDataString(value);
			value = Regex.Replace(value, "(%[0-9a-f][0-9a-f])", c => c.Value.ToUpper());
			value = value
				.Replace("(", "%28")
				.Replace(")", "%29")
				.Replace("$", "%24")
				.Replace("!", "%21")
				.Replace("*", "%2A")
				.Replace("'", "%27");
			value = value.Replace("%7E", "~");
			return value;

		}
	}

}