// OpenTween - Client of Twitter
// Copyright (c) 2007-2011 kiri_feather (@kiri_feather) <kiri.feather@gmail.com>
//           (c) 2008-2011 Moz (@syo68k)
//           (c) 2008-2011 takeshik (@takeshik) <http://www.takeshik.org/>
//           (c) 2010-2011 anis774 (@anis774) <http://d.hatena.ne.jp/anis774/>
//           (c) 2010-2011 fantasticswallow (@f_swallow) <http://twitter.com/f_swallow>
//           (c) 2011      kim_upsilon (@kim_upsilon) <https://upsilo.net/~upsilon/>
// All rights reserved.
// 
// This file is part of OpenTween.
// 
// This program is free software; you can redistribute it and/or modify it
// under the terms of the GNU General public License as published by the Free
// Software Foundation; either version 3 of the License, or (at your option)
// any later version.
// 
// This program is distributed in the hope that it will be useful, but
// WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
// or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General public License
// for more details. 
// 
// You should have received a copy of the GNU General public License along
// with this program. If not, see <http://www.gnu.org/licenses/>, or write to
// the Free Software Foundation, Inc., 51 Franklin Street - Fifth Floor,
// Boston, MA 02110-1301, USA.

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

namespace OpenTween
{
    public class HttpTwitter : ICloneable
    {
        //OAuth関連
        ///<summary>
        ///OAuthのアクセストークン取得先URI
        ///</summary>
        private const string AccessTokenUrlXAuth = "https://api.twitter.com/oauth/access_token";
        private const string RequestTokenUrl = "https://api.twitter.com/oauth/request_token";
        private const string AuthorizeUrl = "https://api.twitter.com/oauth/authorize";
        private const string AccessTokenUrl = "https://api.twitter.com/oauth/access_token";

        private const string PostMethod = "POST";
        private const string GetMethod = "GET";

        private IHttpConnection httpCon; //HttpConnectionApi or HttpConnectionOAuth

        private enum AuthMethod
        {
            OAuth,
            Basic,
        }
        private AuthMethod connectionType = AuthMethod.Basic;

        private string requestToken;

        private static string tk = "";
        private static string tks = "";
        private static string un = "";

        public void Initialize(string accessToken,
                                        string accessTokenSecret,
                                        string username,
                                        long userId)
        {
            //for OAuth
            HttpOAuthApiProxy con = new HttpOAuthApiProxy();
            if (tk != accessToken || tks != accessTokenSecret ||
                    un != username || connectionType != AuthMethod.OAuth)
            {
                // 以前の認証状態よりひとつでも変化があったらhttpヘッダより読み取ったカウントは初期化
                tk = accessToken;
                tks = accessTokenSecret;
                un = username;
            }
            con.Initialize(ApplicationSettings.TwitterConsumerKey, ApplicationSettings.TwitterConsumerSecret, accessToken, accessTokenSecret, username, userId, "screen_name", "user_id");
            con.CacheEnabled = false;
            httpCon = con;
            connectionType = AuthMethod.OAuth;
            requestToken = "";
        }

        public string AccessToken
        {
            get
            {
                return ((HttpConnectionOAuth)httpCon)?.AccessToken ?? "";
            }
        }

        public string AccessTokenSecret
        {
            get
            {
                return ((HttpConnectionOAuth)httpCon)?.AccessTokenSecret ?? "";
            }
        }

        public string AuthenticatedUsername
        {
            get
            {
                return httpCon?.AuthUsername ?? "";
            }
        }

        public long AuthenticatedUserId
        {
            get
            {
                return httpCon?.AuthUserId ?? 0;
            }
            set
            {
                if (httpCon != null)
                    httpCon.AuthUserId = value;
            }
        }

        public string Password
        {
            get
            {
                return "";
            }
        }

        public bool AuthGetRequestToken(ref string content)
        {
            Uri authUri = null;
            bool result = ((HttpOAuthApiProxy)httpCon).AuthenticatePinFlowRequest(RequestTokenUrl, AuthorizeUrl, ref requestToken, ref authUri);
            content = authUri.AbsoluteUri;
            return result;
        }

        public HttpStatusCode AuthGetAccessToken(string pin)
        {
            return ((HttpOAuthApiProxy)httpCon).AuthenticatePinFlow(AccessTokenUrl, requestToken, pin);
        }

        public HttpStatusCode AuthUserAndPass(string username, string password, ref string content)
        {
            return httpCon.Authenticate(new Uri(AccessTokenUrlXAuth), username, password, ref content);
        }

        public void ClearAuthInfo()
        {
            this.Initialize("", "", "", 0);
        }

        public HttpStatusCode UploadMedia(IMediaItem item, ref string content)
        {
            //画像投稿専用エンドポイント
            var binary = new List<KeyValuePair<string, IMediaItem>>();
            binary.Add(new KeyValuePair<string, IMediaItem>("media", item));

            return httpCon.GetContent(PostMethod,
                this.CreateTwitterUploadUri("/1.1/media/upload.json"),
                null,
                binary,
                ref content,
                null,
                null);
        }

        public HttpStatusCode RetweetStatus(long id, ref string content)
        {
            Dictionary<string, string> param = new Dictionary<string, string>();
            param.Add("include_entities", "true");
            param.Add("include_ext_alt_text", "true");

            return httpCon.GetContent(PostMethod,
                this.CreateTwitterUri("/1.1/statuses/retweet/" + id + ".json"),
                param,
                ref content,
                null,
                null);
        }

        public HttpStatusCode ShowStatuses(long id, ref string content)
        {
            Dictionary<string, string> param = new Dictionary<string, string>();
            param.Add("include_entities", "true");
            param.Add("include_ext_alt_text", "true");
            return httpCon.GetContent(GetMethod,
                this.CreateTwitterUri("/1.1/statuses/show/" + id + ".json"),
                param,
                ref content,
                this.CreateRatelimitHeadersDict(),
                this.CreateApiCalllback("/statuses/show/:id"));
        }

        public HttpStatusCode HomeTimeline(int? count, long? max_id, long? since_id, ref string content)
        {
            Dictionary<string, string> param = new Dictionary<string, string>();
            if (count != null)
                param.Add("count", count.ToString());
            if (max_id != null)
                param.Add("max_id", max_id.ToString());
            if (since_id != null)
                param.Add("since_id", since_id.ToString());

            param.Add("include_entities", "true");
            param.Add("include_ext_alt_text", "true");

            return httpCon.GetContent(GetMethod,
                this.CreateTwitterUri("/1.1/statuses/home_timeline.json"),
                param,
                ref content,
                this.CreateRatelimitHeadersDict(),
                this.CreateApiCalllback("/statuses/home_timeline"));
        }

        public HttpStatusCode UserTimeline(long? user_id, string screen_name, int? count, long? max_id, long? since_id, ref string content)
        {
            Dictionary<string, string> param = new Dictionary<string, string>();

            if ((user_id == null && string.IsNullOrEmpty(screen_name)) ||
                (user_id != null && !string.IsNullOrEmpty(screen_name))) return HttpStatusCode.BadRequest;

            if (user_id != null)
                param.Add("user_id", user_id.ToString());
            if (!string.IsNullOrEmpty(screen_name))
                param.Add("screen_name", screen_name);
            if (count != null)
                param.Add("count", count.ToString());
            if (max_id != null)
                param.Add("max_id", max_id.ToString());
            if (since_id != null)
                param.Add("since_id", since_id.ToString());

            param.Add("include_rts", "true");
            param.Add("include_entities", "true");
            param.Add("include_ext_alt_text", "true");

            return httpCon.GetContent(GetMethod,
                this.CreateTwitterUri("/1.1/statuses/user_timeline.json"),
                param,
                ref content,
                this.CreateRatelimitHeadersDict(),
                this.CreateApiCalllback("/statuses/user_timeline"));
        }

        public HttpStatusCode Mentions(int? count, long? max_id, long? since_id, ref string content)
        {
            Dictionary<string, string> param = new Dictionary<string, string>();
            if (count != null)
                param.Add("count", count.ToString());
            if (max_id != null)
                param.Add("max_id", max_id.ToString());
            if (since_id != null)
                param.Add("since_id", since_id.ToString());

            param.Add("include_entities", "true");
            param.Add("include_ext_alt_text", "true");

            return httpCon.GetContent(GetMethod,
                this.CreateTwitterUri("/1.1/statuses/mentions_timeline.json"),
                param,
                ref content,
                this.CreateRatelimitHeadersDict(),
                this.CreateApiCalllback("/statuses/mentions_timeline"));
        }

        public HttpStatusCode DirectMessages(int? count, long? max_id, long? since_id, ref string content)
        {
            Dictionary<string, string> param = new Dictionary<string, string>();
            if (count != null)
                param.Add("count", count.ToString());
            if (max_id != null)
                param.Add("max_id", max_id.ToString());
            if (since_id != null)
                param.Add("since_id", since_id.ToString());
            param.Add("full_text", "true");
            param.Add("include_entities", "true");
            param.Add("include_ext_alt_text", "true");

            return httpCon.GetContent(GetMethod,
                this.CreateTwitterUri("/1.1/direct_messages.json"),
                param,
                ref content,
                this.CreateRatelimitHeadersDict(),
                this.CreateApiCalllback("/direct_messages"));
        }

        public HttpStatusCode DirectMessagesSent(int? count, long? max_id, long? since_id, ref string content)
        {
            Dictionary<string, string> param = new Dictionary<string, string>();
            if (count != null)
                param.Add("count", count.ToString());
            if (max_id != null)
                param.Add("max_id", max_id.ToString());
            if (since_id != null)
                param.Add("since_id", since_id.ToString());
            param.Add("full_text", "true");
            param.Add("include_entities", "true");
            param.Add("include_ext_alt_text", "true");

            return httpCon.GetContent(GetMethod,
                this.CreateTwitterUri("/1.1/direct_messages/sent.json"),
                param,
                ref content,
                this.CreateRatelimitHeadersDict(),
                this.CreateApiCalllback("/direct_messages/sent"));
        }

        public HttpStatusCode Favorites(int? count, ref string content)
        {
            Dictionary<string, string> param = new Dictionary<string, string>();
            if (count != null)
                param.Add("count", count.ToString());
            param.Add("include_entities", "true");
            param.Add("include_ext_alt_text", "true");

            return httpCon.GetContent(GetMethod,
                this.CreateTwitterUri("/1.1/favorites/list.json"),
                param,
                ref content,
                this.CreateRatelimitHeadersDict(),
                this.CreateApiCalllback("/favorites/list"));
        }

        public HttpStatusCode Search(string words, string lang, int? count, long? maxId, long? sinceId, ref string content)
        {
            Dictionary<string, string> param = new Dictionary<string, string>();
            if (!string.IsNullOrEmpty(words)) param.Add("q", words);
            if (!string.IsNullOrEmpty(lang)) param.Add("lang", lang);
            if (count != null) param.Add("count", count.ToString());
            if (maxId != null) param.Add("max_id", maxId.ToString());
            if (sinceId != null) param.Add("since_id", sinceId.ToString());

            if (param.Count == 0) return HttpStatusCode.BadRequest;

            param.Add("result_type", "recent");
            param.Add("include_entities", "true");
            param.Add("include_ext_alt_text", "true");
            return httpCon.GetContent(GetMethod,
                this.CreateTwitterUri("/1.1/search/tweets.json"),
                param,
                ref content,
                this.CreateRatelimitHeadersDict(),
                this.CreateApiCalllback("/search/tweets"));
        }

        public HttpStatusCode SavedSearches(ref string content)
        {
            return httpCon.GetContent(GetMethod,
                this.CreateTwitterUri("/1.1/saved_searches/list.json"),
                null,
                ref content,
                this.CreateRatelimitHeadersDict(),
                this.CreateApiCalllback("/saved_searches/list"));
        }

        public HttpStatusCode FollowerIds(long cursor, ref string content)
        {
            Dictionary<string, string> param = new Dictionary<string, string>();
            param.Add("cursor", cursor.ToString());

            return httpCon.GetContent(GetMethod,
                this.CreateTwitterUri("/1.1/followers/ids.json"),
                param,
                ref content,
                this.CreateRatelimitHeadersDict(),
                this.CreateApiCalllback("/followers/ids"));
        }

        public HttpStatusCode NoRetweetIds(ref string content)
        {
            return httpCon.GetContent(GetMethod,
                this.CreateTwitterUri("/1.1/friendships/no_retweets/ids.json"),
                null,
                ref content,
                this.CreateRatelimitHeadersDict(),
                this.CreateApiCalllback("/friendships/no_retweets/ids"));
        }

        public HttpStatusCode RateLimitStatus(ref string content)
        {
            return httpCon.GetContent(GetMethod,
                this.CreateTwitterUri("/1.1/application/rate_limit_status.json"),
                null,
                ref content,
                this.CreateRatelimitHeadersDict(),
                this.CreateApiCalllback("/application/rate_limit_status"));
        }

        #region Lists
        public HttpStatusCode GetLists(string user, ref string content)
        {
            Dictionary<string, string> param = new Dictionary<string, string>();
            param.Add("screen_name", user);

            return httpCon.GetContent(GetMethod,
                this.CreateTwitterUri("/1.1/lists/list.json"),
                param,
                ref content,
                this.CreateRatelimitHeadersDict(),
                this.CreateApiCalllback("/lists/list"));
        }

        public HttpStatusCode UpdateListID(string user, string list_id, string name, Boolean isPrivate, string description, ref string content)
        {
            string mode = "public";
            if (isPrivate)
                mode = "private";

            Dictionary<string, string> param = new Dictionary<string, string>();
            param.Add("screen_name", user);
            param.Add("list_id", list_id);
            if (name != null) param.Add("name", name);
            if (mode != null) param.Add("mode", mode);
            if (description != null) param.Add("description", description);

            return httpCon.GetContent(PostMethod,
                this.CreateTwitterUri("/1.1/lists/update.json"),
                param,
                ref content,
                null,
                null);
        }

        public HttpStatusCode DeleteListID(string user, string list_id, ref string content)
        {
            Dictionary<string, string> param = new Dictionary<string, string>();
            param.Add("screen_name", user);
            param.Add("list_id", list_id);

            return httpCon.GetContent(PostMethod,
                this.CreateTwitterUri("/1.1/lists/destroy.json"),
                param,
                ref content,
                null,
                null);
        }

        public HttpStatusCode GetListsSubscriptions(string user, ref string content)
        {
            Dictionary<string, string> param = new Dictionary<string, string>();
            param.Add("screen_name", user);

            return httpCon.GetContent(GetMethod,
                this.CreateTwitterUri("/1.1/lists/subscriptions.json"),
                param,
                ref content,
                this.CreateRatelimitHeadersDict(),
                this.CreateApiCalllback("/lists/subscriptions"));
        }

        public HttpStatusCode GetListsStatuses(long userId, long list_id, int? per_page, long? max_id, long? since_id, Boolean isRTinclude, ref string content)
        {
            //認証なくても取得できるが、protectedユーザー分が抜ける
            Dictionary<string, string> param = new Dictionary<string, string>();
            param.Add("user_id", userId.ToString());
            param.Add("list_id", list_id.ToString());
            param.Add("include_rts", isRTinclude ? "true" : "false");
            if (per_page != null)
                param.Add("count", per_page.ToString());
            if (max_id != null)
                param.Add("max_id", max_id.ToString());
            if (since_id != null)
                param.Add("since_id", since_id.ToString());
            param.Add("include_entities", "true");
            param.Add("include_ext_alt_text", "true");

            return httpCon.GetContent(GetMethod,
                this.CreateTwitterUri("/1.1/lists/statuses.json"),
                param,
                ref content,
                this.CreateRatelimitHeadersDict(),
                this.CreateApiCalllback("/lists/statuses"));
        }

        public HttpStatusCode CreateLists(string listname, Boolean isPrivate, string description, ref string content)
        {
            string mode = "public";
            if (isPrivate)
                mode = "private";

            Dictionary<string, string> param = new Dictionary<string, string>();
            param.Add("name", listname);
            param.Add("mode", mode);
            if (!string.IsNullOrEmpty(description))
                param.Add("description", description);

            return httpCon.GetContent(PostMethod,
                this.CreateTwitterUri("/1.1/lists/create.json"),
                param,
                ref content,
                null,
                null);
        }

        public HttpStatusCode GetListMembers(string user, string list_id, long cursor, ref string content)
        {
            Dictionary<string, string> param = new Dictionary<string, string>();
            param.Add("screen_name", user);
            param.Add("list_id", list_id);
            param.Add("cursor", cursor.ToString());
            return httpCon.GetContent(GetMethod,
                this.CreateTwitterUri("/1.1/lists/members.json"),
                param,
                ref content,
                this.CreateRatelimitHeadersDict(),
                this.CreateApiCalllback("/lists/members"));
        }

        public HttpStatusCode CreateListMembers(string list_id, string memberName, ref string content)
        {
            Dictionary<string, string> param = new Dictionary<string, string>();
            param.Add("list_id", list_id);
            param.Add("screen_name", memberName);
            return httpCon.GetContent(PostMethod,
                this.CreateTwitterUri("/1.1/lists/members/create.json"),
                param,
                ref content,
                null,
                null);
        }

        public HttpStatusCode DeleteListMembers(string list_id, string memberName, ref string content)
        {
            Dictionary<string, string> param = new Dictionary<string, string>();
            param.Add("screen_name", memberName);
            param.Add("list_id", list_id);
            return httpCon.GetContent(PostMethod,
                this.CreateTwitterUri("/1.1/lists/members/destroy.json"),
                param,
                ref content,
                null,
                null);
        }

        public HttpStatusCode ShowListMember(string list_id, string memberName, ref string content)
        {
            Dictionary<string, string> param = new Dictionary<string, string>();
            param.Add("screen_name", memberName);
            param.Add("list_id", list_id);
            return httpCon.GetContent(GetMethod,
                this.CreateTwitterUri("/1.1/lists/members/show.json"),
                param,
                ref content,
                this.CreateRatelimitHeadersDict(),
                this.CreateApiCalllback("/lists/members/show"));
        }
        #endregion

        public HttpStatusCode Statusid_retweeted_by_ids(long statusid, int? count, int? page, ref string content)
        {
            Dictionary<string, string> param = new Dictionary<string, string>();
            if (count != null)
                param.Add("count", count.ToString());
            if (page != null)
                param.Add("page", page.ToString());

            param.Add("id", statusid.ToString());

            return httpCon.GetContent(GetMethod,
                this.CreateTwitterUri("/1.1/statuses/retweeters/ids.json"),
                param,
                ref content,
                this.CreateRatelimitHeadersDict(),
                this.CreateApiCalllback("/statuses/retweeters/ids"));
        }

        public HttpStatusCode GetBlockUserIds(ref string content, long? cursor)
        {
            var param = new Dictionary<string, string>();

            if (cursor != null)
                param.Add("cursor", cursor.ToString());

            return httpCon.GetContent(GetMethod,
                this.CreateTwitterUri("/1.1/blocks/ids.json"),
                param,
                ref content,
                this.CreateRatelimitHeadersDict(),
                this.CreateApiCalllback("/blocks/ids"));
        }

        public HttpStatusCode GetMuteUserIds(ref string content, long? cursor)
        {
            var param = new Dictionary<string, string>();

            if (cursor != null)
                param.Add("cursor", cursor.ToString());

            return httpCon.GetContent(GetMethod,
                this.CreateTwitterUri("/1.1/mutes/users/ids.json"),
                param,
                ref content,
                this.CreateRatelimitHeadersDict(),
                this.CreateApiCalllback("/mutes/users/ids"));
        }

        public HttpStatusCode GetConfiguration(ref string content)
        {
            return httpCon.GetContent(GetMethod,
                this.CreateTwitterUri("/1.1/help/configuration.json"),
                null,
                ref content,
                this.CreateRatelimitHeadersDict(),
                this.CreateApiCalllback("/help/configuration"));
        }

        public HttpStatusCode VerifyCredentials(ref string content)
        {
            return httpCon.GetContent(GetMethod,
                this.CreateTwitterUri("/1.1/account/verify_credentials.json"),
                null,
                ref content,
                this.CreateRatelimitHeadersDict(),
                this.CreateApiCalllback("/account/verify_credentials"));
        }

        #region Proxy API
        private static string _twitterUrl = "api.twitter.com";
        private static string _twitterUserStreamUrl = "userstream.twitter.com";
        private static string _twitterStreamUrl = "stream.twitter.com";
        private static string _twitterUploadUrl = "upload.twitter.com";

        private Uri CreateTwitterUri(string path)
        {
            return new Uri(string.Format("{0}{1}{2}", "https://", _twitterUrl, path));
        }

        private Uri CreateTwitterUserStreamUri(string path)
        {
            return new Uri(string.Format("{0}{1}{2}", "https://", _twitterUserStreamUrl, path));
        }

        private Uri CreateTwitterStreamUri(string path)
        {
            return new Uri(string.Format("{0}{1}{2}", "http://", _twitterStreamUrl, path));
        }

        private Uri CreateTwitterUploadUri(string path)
        {
            return new Uri(string.Format("{0}{1}{2}", "https://", _twitterUploadUrl, path));
        }

        public static string TwitterUrl
        {
            get { return _twitterUrl; }
            set
            {
                _twitterUrl = value;
                HttpOAuthApiProxy.ProxyHost = value;
            }
        }
        #endregion

        private Dictionary<string, string> CreateRatelimitHeadersDict()
        {
            return new Dictionary<string, string>(StringComparer.OrdinalIgnoreCase)
            {
                ["X-Access-Level"] = "",
                ["X-RateLimit-Limit"] = "",
                ["X-RateLimit-Remaining"] = "",
                ["X-RateLimit-Reset"] = "",
                ["X-Rate-Limit-Limit"] = "",
                ["X-Rate-Limit-Remaining"] = "",
                ["X-Rate-Limit-Reset"] = "",
                ["X-MediaRateLimit-Limit"] = "",
                ["X-MediaRateLimit-Remaining"] = "",
                ["X-MediaRateLimit-Reset"] = "",
            };
        }

        private CallbackDelegate CreateApiCalllback(string endpointName)
        {
            return (sender, code, headerInfo, content) =>
            {
                if (code < HttpStatusCode.InternalServerError)
                    MyCommon.TwitterApiInfo.UpdateFromHeader(headerInfo, endpointName);
            };
        }

        public HttpStatusCode UserStream(ref Stream content,
                                         bool allAtReplies,
                                         string trackwords,
                                         string userAgent)
        {
            Dictionary<string, string> param = new Dictionary<string, string>();

            if (allAtReplies)
                param.Add("replies", "all");

            if (!string.IsNullOrEmpty(trackwords))
                param.Add("track", trackwords);

            return httpCon.GetContent(GetMethod,
                this.CreateTwitterUserStreamUri("/1.1/user.json"),
                param,
                ref content,
                userAgent);
        }

        public HttpStatusCode FilterStream(ref Stream content,
                                           string trackwords,
                                           string userAgent)
        {
            //文中の日本語キーワードに反応せず、使えない（スペースで分かち書きしてないと反応しない）
            Dictionary<string, string> param = new Dictionary<string, string>();

            if (!string.IsNullOrEmpty(trackwords))
                param.Add("track", string.Join(",", trackwords.Split(" ".ToCharArray())));

            return httpCon.GetContent(PostMethod,
                this.CreateTwitterStreamUri("/1.1/statuses/filter.json"),
                param,
                ref content,
                userAgent);
        }

        public void RequestAbort()
        {
            httpCon.RequestAbort();
        }

        public object Clone()
        {
            HttpTwitter myCopy = new HttpTwitter();
            myCopy.Initialize(this.AccessToken, this.AccessTokenSecret, this.AuthenticatedUsername, this.AuthenticatedUserId);
            return myCopy;
        }
    }
}