module mastodon;

// import std.net.curl:HTTP, post, get, patch, del, No;
import std.net.curl;
import std.json:JSONValue, parseJSON;
import std.conv:to;

///
ClientConfig createApp(in string url, in string clientName, in string scopes, in string redirectUris = "urn:ietf:wg:oauth:2.0:oob"){
    auto res = post(url ~ "/api/v1/apps", [ "client_name"   : clientName,
                                            "redirect_uris" : redirectUris,
                                            "scope"         : scopes]).parseJSON;
    auto result = ClientConfig();
    result.url = url;
    result.id = res["client_id"].str;
    result.secret = res["client_secret"].str;
    return result;
}

///
JSONValue signIn(in string url, in string clientId, in string clientIdSeclet, in string email, in string password, in string scopes = "read write follow"){
    string[string] option = ["client_id" : clientId, 
                   "client_secret" : clientIdSeclet, 
                   "grant_type" : "password", 
                   "username" : email, 
                   "password" : password,
                   "scope" : scopes];
    auto response = post(url ~ "/oauth/token", option).parseJSON;
    return response;
}

///
JSONValue signIn(in JSONValue clientConfig, in string email, in string password){
    import std.algorithm:filter;
    import std.array:array;
    return signIn(clientConfig["url"].str.filter!(e => e!='\\').to!string, clientConfig["client_id"].str, clientConfig["client_secret"].str, email, password);
}

JSONValue signIn(in ClientConfig clientConfig, in string email, in string password){
    return signIn(clientConfig.url, clientConfig.id, clientConfig.secret, email, password);
}

/++
+/
struct ClientConfig {
    public{
        this(in string url, in string id, in string secret){
            this.url    = url;
            this.id     = id;
            this.secret = secret;
        }
        this(JSONValue v){
            url    = v["url"].str;
            id     = v["client_id"].str;
            secret = v["client_secret"].str;
        }
        string url;
        string id;
        string secret;
    }//public

    private{
    }//private
}//struct ClientConfig

/++
+/
enum StreamingType {
    User   = "user",
    Public = "public",
    Hashta = "hashtag"
}//enum StreamingType

/++
+/
class Client {
    private alias This = typeof(this);
    /++
        +/
    private enum Method {
        GET, POST, DELETE, PATCH
    }//enum Method
    public{
        this(in ClientConfig clientToken){
            _clientToken = clientToken;
        }

        This signIn(in string email, in string password){
            _userToken = _clientToken.signIn(email, password);
            return this;
        };

        JSONValue request(Method M, T)(in string endPoint, T arg = null){
            auto http = HTTP(_clientToken.url);
            http.addRequestHeader("Authorization", "Bearer " ~ _userToken["access_token"].str);
            // http.handle.set(CurlOption.ssl_verifypeer, false);
            string url = _clientToken.url ~ endPoint;
            JSONValue response;

            static if(M == Method.GET){
                response = get(url, http).parseJSON;
            }
            static if(M == Method.POST){
                response = post(url, arg, http).parseJSON;
            }
            static if(M == Method.PATCH){
                response = patch(url, arg, http).parseJSON;
            }
            static if(M == Method.DELETE){
                del(url, http);
            }
        
            return response;
        }

        ///
        JSONValue account(in uint id){
            return request!(Method.GET)("/api/v1/accounts/" ~ id.to!string);
        }

        JSONValue verifyAccountCredentials(){
            return request!(Method.GET)("/api/v1/accounts/verify_credentials");
        }

        JSONValue updateAccountCredentials(in string arg){
        // TODO doesn't work
            return request!(Method.PATCH)("/api/v1/accounts/update_credentials", arg);
        }

        ///
        JSONValue accountFollowers(in uint id){
            return request!(Method.GET)("/api/v1/accounts/" ~ id.to!string ~ "/followers");
        }

        /// 
        JSONValue accountFollowing(in uint id){
            return request!(Method.GET)("/api/v1/accounts/" ~ id.to!string ~ "/following");
        }

        ///
        JSONValue accountStatuses(in uint id){
            return request!(Method.GET)("/api/v1/accounts/" ~ id.to!string ~ "/statuses");
        }

        ///
        JSONValue followAccount(in uint id){
            return request!(Method.POST)("/api/v1/accounts/" ~ id.to!string ~ "/follow");
        }

        ///
        JSONValue unfollowAccount(in uint id){
            return request!(Method.POST)("/api/v1/accounts/" ~ id.to!string ~ "/unfollow");
        }

        ///
        // GET /api/v1/accounts/:id/block
        JSONValue blockAccount(in uint id){
            return request!(Method.POST)("/api/v1/accounts/" ~ id.to!string ~ "/block");
        }

        ///
        JSONValue unblockAccount(in uint id){
            return request!(Method.POST)("/api/v1/accounts/" ~ id.to!string ~ "/unblock");
        }

        ///
        JSONValue muteAccount(in uint id){
            return request!(Method.POST)("/api/v1/accounts/" ~ id.to!string ~ "/mute");
        }

        ///
        JSONValue unmuteAccount(in uint id){
            return request!(Method.POST)("/api/v1/accounts/" ~ id.to!string ~ "/unmute");
        }

        /// 
        JSONValue accountRelationships(in uint[] id...){
            return accountRelationships(id);
        }

        ///
        JSONValue accountRelationships(in uint[] arr){
            import std.algorithm:map;
            import std.string:join;
            string qArray = arr.map!(e => "id[]=" ~ e.to!string).join("&");
            return request!(Method.GET)("/api/v1/accounts/relationships/?" ~ qArray);
        }

        ///
        JSONValue searchAccount(in string q, in uint limit = 40){
            return request!(Method.GET)("/api/v1/accounts/search/?q="~q~"&limit"~limit.to!string);
        }

        ///
        JSONValue blocks(){
            return request!(Method.GET)("/api/v1/blocks");
        }

        ///
        JSONValue favourites(){
            return request!(Method.GET)("/api/v1/favourites");
        }

        ///
        JSONValue followRequests(){
            return request!(Method.GET)("/api/v1/follow_requests");
        }

        ///
        JSONValue authorizeFollowRequest(in uint id){
            return request!(Method.POST)("/api/v1/follow_requests/authorize", ["id":id.to!string]);
        }

        ///
        JSONValue rejectFollowRequest(in uint id){
            return request!(Method.POST)("/api/v1/follow_requests/reject", ["id":id.to!string]);
        }

        ///
        JSONValue followRemoteUser(in string uri){
            return request!(Method.POST)("/api/v1/follows", ["uri":uri.to!string]);
        }

        ///
        JSONValue instance(){
            return request!(Method.GET)("/api/v1/instance");
        }

        /// TODO
        // POST /api/v1/media

        ///
        JSONValue mutes(){
            return request!(Method.GET)("/api/v1/mutes");
        }

        ///
        JSONValue notifications(){
            return request!(Method.GET)("/api/v1/notifications");
        }

        ///
        JSONValue notifications(in uint id){
            return request!(Method.GET)("/api/v1/notifications/" ~ id.to!string);
        }

        ///
        JSONValue clearNotifications(){
            return request!(Method.GET)("/api/v1/notifications/clear");
        }

        ///
        JSONValue reports(){
            return request!(Method.GET)("/api/v1/reports");
        }

        /// TODO
        // POST /api/v1/reports

        /// TODO
        // GET /api/v1/search
        // JSONValue search(in string q, bool resolve = false){
        //     import std.conv:to;
        //     string qArray = "q="~q ~ resolve?"&resolve":"";
        //     return request!(Method.GET)("/api/v1/search/?" ~ qArray);
        // }

        ///
        JSONValue status(in uint id){
            return request!(Method.GET)("/api/v1/statuses/" ~ id.to!string);
        }

        ///
        JSONValue statusContext(in uint id){
            return request!(Method.GET)("/api/v1/statuses/" ~ id.to!string ~ "/context");
        }

        ///
        JSONValue statusCard(in uint id){
            return request!(Method.GET)("/api/v1/statuses/" ~ id.to!string ~ "/card");
        }

        ///
        JSONValue rebloggedBy(in uint id){
            return request!(Method.GET)("/api/v1/statuses/" ~ id.to!string ~ "/reblogged_by");
        }


        ///
        JSONValue favouritedBy(in uint id){
            return request!(Method.GET)("/api/v1/statuses/" ~ id.to!string ~ "/favourited_by");
        }

        /// TODO add params
        JSONValue postStatus(in string status){
            string[string] arg = ["status" : status];
            return request!(Method.POST)("/api/v1/statuses", arg);
        }

        ///
        JSONValue deleteStatus(in uint statusId){
            return request!(Method.DELETE)("/api/v1/statuses/"~statusId.to!string);
        }

        ///
        JSONValue reblog(in uint statusId){
            return request!(Method.POST)("/api/v1/statuses/"~statusId.to!string~"/reblog");
        }

        ///
        JSONValue unreblog(in uint statusId){
            return request!(Method.POST)("/api/v1/statuses/"~statusId.to!string~"/unreblog");
        }

        ///
        JSONValue favourite(in uint statusId){
            return request!(Method.POST)("/api/v1/statuses/"~statusId.to!string~"/favourite");
        }

        ///
        JSONValue unfavourite(in uint statusId){
            return request!(Method.POST)("/api/v1/statuses/"~statusId.to!string~"/unfavourite");
        }

        ///
        JSONValue timelineHome(){
            return request!(Method.GET)("/api/v1/timelines/home");
        }

        ///
        JSONValue timelinePublic(){
            return request!(Method.GET)("/api/v1/timelines/public");
        }

        ///
        JSONValue timelineHashtag(in string tag){
            return request!(Method.GET)("/api/v1/timelines/tag/" ~ tag);
        }

        ///
        auto stream(in StreamingType type){
            import std.net.curl;
            auto http = HTTP(_clientToken.url);
            http.addRequestHeader("Authorization", "Bearer " ~ _userToken["access_token"].str);
            http.method = HTTP.Method.get;
            string url = _clientToken.url ~ "/api/v1/streaming/" ~ type;
            auto stream = byLineAsync(
                    url, 
                    No.keepTerminator,
                    '\x0a', 
                    10, 
                    http
                    ); 

            import std.algorithm:filter, map;
            string lastLineType;
            string lastEventType;
            foreach (e; stream.filter!"a.length != 0") {
                import std.json;
                import std.stdio;
                if(e[0..6] == "event:"){
                    lastLineType = "event";
                    lastEventType = e[7..$].to!string;
                }else{
                    if(lastLineType == "event"){
                        switch (lastEventType){
                            case "update":
                                "################".writeln;
                                e[6..$].parseJSON(JSONOptions.none)["content"].writeln;
                                "################".writeln;
                                break;
                            case "delete":
                                //TODO
                                break;
                            case "notification":
                                //TODO
                                break;
                            default:
                                //TODO
                                break;
                        }
                    }
                    lastLineType = "data";
                }
            }
            // return stream;
        }

        ///
        // void startStreaming(in StreamingType type){
        //     string url = _clientToken.url ~ "/api/v1/streaming/" ~ type;
        //     import std.stdio;
        //     url.writeln;
        //     _streams[type] = new Stream(url, _userToken["access_token"].str);
        //     // _streams[type].addRequestHeader("Authorization", "Bearer " ~ _userToken["access_token"].str);
        //     // _streams[type].method = HTTP.Method.get;
        //
        //     // return request!(Method.GET)("/api/v1/streaming/user");
        // }

        ///
        // JSONValue[] streaming(in StreamingType type){
        // }
    }//public

    private{
        ClientConfig _clientToken;
        JSONValue _userToken;
        Stream[StreamingType] _streams;

    }//private
}//class Client

/++
+/
private class Stream {
    // public{
    //     this(in string url, in string accessToken){
    //         auto http = HTTP(url);
    //         http.addRequestHeader("Authorization", "Bearer " ~ accessToken);
    //         http.method = HTTP.Method.get;
    //         _http = &http;
    //         _url = url;
    //         // _http.addRequestHeader("Authorization", "Bearer " ~ accessToken);
    //         // _http.method = HTTP.Method.get;
    //     }
    //
    //     start(){
    //         _stream = byLineAsync(_url); 
    //     }
    //
    //     JSONValue[] pop(){
    //         JSONValue[] events;
    //         foreach (e; _stream) {
    //             events = e.parseJSON;
    //         }
    //         _stream = [];
    //         return events;
    //     }
    // }//public
    //
    // private{
    //     HTTP* _http;
    //     string _url;
    //     char[] _stream;
    //
    // }//private
}//class Streamk

// /++
// +/
// struct Account {
//     // TODO
// }//struct Account
//
// /++
// +/
// struct Application {
//     // TODO
// }//struct Application
//
// /++
// +/
// struct Attachment {
//     // TODO
// }//struct Attachment
//
// /++
// +/
// struct Card {
//     // TODO
// }//struct Card
//
// /++
// +/
// struct Context {
//     // TODO
// }//struct Context
//
// /++
// +/
// struct Error {
//     // TODO
// }//struct Error
//
// /++
// +/
// struct Instance {
//     // TODO
// }//struct Instance
//
// /++
// +/
// struct Mention {
//     // TODO
// }//struct Mention
//
// /++
// +/
// struct Notification {
//     // TODO
// }//struct Notification
//
// /++
// +/
// struct Relationship {
//     // TODO
// }//struct Relationship
//
// /++
// +/
// struct Report {
//     // TODO
// }//struct Report
//
// /++
// +/
// struct Result {
//     // TODO
// }//struct Result
//
// /++
// +/
// struct Status {
//     // TODO
// }//struct Status
//
// /++
// +/
// struct Tag {
//     // TODO
// }//struct Tag