/*
* Copyright (c) 2017-2020 Alecaddd (https://alecaddd.com)
*
* 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 2 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, write to the
* Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
* Boston, MA 02110-1301 USA
*
* Authored by: Alessandro "Alecaddd" Castellani <castellani.ale@gmail.com>
*/

public class Sequeler.Layouts.Library : Gtk.Grid {
    public weak Sequeler.Window window { get; construct; }

    GLib.File? file;
    Gtk.TextBuffer buffer;

    private Gtk.Grid title;
    private Gtk.Revealer motion_revealer;
    public Gtk.ListBox item_box;
    public Gtk.ScrolledWindow scroll;
    public Sequeler.Partials.HeaderBarButton delete_all;

    public Gee.HashMap<string, string> real_data;
    public Gtk.Spinner real_spinner;
    public Gtk.ModelButton real_button;
    public Sequeler.Services.ConnectionManager connection_manager;

    public signal void edit_dialog (Gee.HashMap data);

    // Datatype restrictions on DnD (Gtk.TargetFlags).
    public const Gtk.TargetEntry[] TARGET_ENTRIES_LABEL = {
        { "LIBRARYITEM", Gtk.TargetFlags.SAME_APP, 0 }
    };

    public Library (Sequeler.Window main_window) {
        Object (
            orientation: Gtk.Orientation.VERTICAL,
            window: main_window,
            width_request: 260,
            column_homogeneous: true
        );
    }

    construct {
        var motion_grid = new Gtk.Grid ();
        motion_grid.margin = 6;
        motion_grid.get_style_context ().add_class ("grid-motion");
        motion_grid.height_request = 18;

        motion_revealer = new Gtk.Revealer ();
        motion_revealer.transition_type = Gtk.RevealerTransitionType.SLIDE_DOWN;
        motion_revealer.add (motion_grid);

        var titlebar = new Sequeler.Partials.TitleBar (_("SAVED CONNECTIONS"));

        title = new Gtk.Grid ();
        title.attach (titlebar, 0, 0);
        title.attach (motion_revealer, 0, 1);

        var toolbar = new Gtk.Grid ();
        toolbar.get_style_context ().add_class ("library-toolbar");

        delete_all = new Sequeler.Partials.HeaderBarButton ("user-trash-symbolic", _("Delete All"));
        delete_all.halign = Gtk.Align.END;
        delete_all.hexpand = true;
        delete_all.clicked.connect (() => {
            confirm_delete_all ();
        });

        var reload_btn = new Sequeler.Partials.HeaderBarButton ("view-refresh-symbolic", _("Reload Library"));
        reload_btn.clicked.connect (() => reload_library.begin ());

        var export_btn = new Sequeler.Partials.HeaderBarButton ("document-save-symbolic", _("Export Library"));
        export_btn.clicked.connect (export_library);

        toolbar.attach (reload_btn, 0, 0, 1, 1);
        toolbar.attach (new Gtk.Separator (Gtk.Orientation.VERTICAL), 1, 0, 1, 1);
        toolbar.attach (export_btn, 2, 0, 1, 1);
        toolbar.attach (new Gtk.Separator (Gtk.Orientation.VERTICAL), 3, 0, 1, 1);
        toolbar.attach (delete_all, 4, 0, 1, 1);

        scroll = new Gtk.ScrolledWindow (null, null);
        scroll.hscrollbar_policy = Gtk.PolicyType.AUTOMATIC;
        scroll.vscrollbar_policy = Gtk.PolicyType.AUTOMATIC;

        item_box = new Gtk.ListBox ();
        item_box.get_style_context ().add_class ("library-box");
        item_box.set_activate_on_single_click (false);
        item_box.selection_mode = Gtk.SelectionMode.SINGLE;
        item_box.valign = Gtk.Align.FILL;
        item_box.expand = true;

        scroll.add (item_box);

        foreach (var conn in settings.saved_connections) {
            add_item (settings.arraify_data (conn));
        }

        if (settings.saved_connections.length > 0) {
            delete_all.sensitive = true;
        }

        item_box.row_activated.connect ((row) => {
            var item = row as Sequeler.Partials.LibraryItem;
            item.spinner.start ();
            item.connect_button.sensitive = false;
            window.data_manager.data = item.data;
            init_connection_begin (item.data, item.spinner, item.connect_button, false);
        });

        attach (title, 0, 0, 1, 1);
        scroll.expand = true;
        attach (scroll, 0, 1, 1, 2);
        attach (toolbar, 0, 3, 1, 1);

        build_drag_and_drop ();
    }

    private void build_drag_and_drop () {
        Gtk.drag_dest_set (item_box, Gtk.DestDefaults.ALL, TARGET_ENTRIES_LABEL, Gdk.DragAction.MOVE);
        item_box.drag_data_received.connect (on_drag_data_received);

        Gtk.drag_dest_set (title, Gtk.DestDefaults.ALL, TARGET_ENTRIES_LABEL, Gdk.DragAction.MOVE);
        title.drag_data_received.connect (on_drag_item_received);
        title.drag_motion.connect (on_drag_motion);
        title.drag_leave.connect (on_drag_leave);
    }

    private void on_drag_data_received (Gdk.DragContext context, int x, int y,
        Gtk.SelectionData selection_data, uint target_type, uint time) {
        int new_pos;
        var target = (Partials.LibraryItem) item_box.get_row_at_y (y);

        var row = ((Gtk.Widget[]) selection_data.get_data ())[0];
        var source = (Partials.LibraryItem) row;

        int last_index = (int) item_box.get_children ().length ();

        if (target == null) {
            new_pos = last_index - 1;
        } else {
            new_pos = source.get_index () < target.get_index ()
                ? target.get_index ()
                : target.get_index () + 1;
        }

        settings.reorder_connection (source.data, new_pos);
        reload_library.begin ();
    }

    private void on_drag_item_received (Gdk.DragContext context, int x, int y,
        Gtk.SelectionData selection_data, uint target_type, uint time) {
        var row = ((Gtk.Widget[]) selection_data.get_data ())[0];
        var source = (Partials.LibraryItem) row;

        settings.reorder_connection (source.data, 0);
        reload_library.begin ();
    }

    public bool on_drag_motion (Gdk.DragContext context, int x, int y, uint time) {
        motion_revealer.reveal_child = true;
        return true;
    }

    public void on_drag_leave (Gdk.DragContext context, uint time) {
        motion_revealer.reveal_child = false;
    }

    public void add_item (Gee.HashMap<string, string> data) {
        var item = new Sequeler.Partials.LibraryItem (data);
        item.scrolled = scroll;
        item_box.add (item);

        item.confirm_delete.connect ((item, data) => {
            confirm_delete (item, data);
        });

        item.edit_dialog.connect ((data) => {
            window.data_manager.data = data;

            if (window.connection_dialog == null) {
                window.connection_dialog = new Sequeler.Widgets.ConnectionDialog (window);
                window.connection_dialog.show_all ();

                window.connection_dialog.destroy.connect (() => {
                    window.connection_dialog = null;
                });
            }

            window.connection_dialog.present ();
        });

        item.duplicate_connection.connect ((data) => {
            duplicate_connection.begin (data);
        });

        item.connect_to.connect ((data, spinner, connect_button) => {
            window.data_manager.data = data;
            init_connection_begin (data, spinner, connect_button);
        });
    }

    public void confirm_delete (Gtk.ListBoxRow item, Gee.HashMap<string, string> data) {
        var message_dialog = new Granite.MessageDialog.with_image_from_icon_name (_("Are you sure you want to proceed?"), _("By deleting this connection you won’t be able to recover this data."), "dialog-warning", Gtk.ButtonsType.CANCEL);
        message_dialog.transient_for = window;

        var suggested_button = new Gtk.Button.with_label (_("Yes, Delete!"));
        suggested_button.get_style_context ().add_class (Gtk.STYLE_CLASS_DESTRUCTIVE_ACTION);
        message_dialog.add_action_widget (suggested_button, Gtk.ResponseType.ACCEPT);

        message_dialog.show_all ();
        if (message_dialog.run () == Gtk.ResponseType.ACCEPT) {
            settings.delete_connection (data);
            item_box.remove (item);
            reload_library.begin ();
        }

        message_dialog.destroy ();
    }

    public void confirm_delete_all () {
        var message_dialog = new Granite.MessageDialog.with_image_from_icon_name (_("Are you sure you want to proceed?"), _("All the data will be deleted and you won’t be able to recover it."), "dialog-warning", Gtk.ButtonsType.CANCEL);
        message_dialog.transient_for = window;

        var suggested_button = new Gtk.Button.with_label (_("Yes, Delete All!"));
        suggested_button.get_style_context ().add_class (Gtk.STYLE_CLASS_DESTRUCTIVE_ACTION);
        message_dialog.add_action_widget (suggested_button, Gtk.ResponseType.ACCEPT);

        message_dialog.show_all ();
        if (message_dialog.run () == Gtk.ResponseType.ACCEPT) {
            settings.clear_connections ();
            item_box.forall ((item) => item_box.remove (item));
            reload_library.begin ();
        }

        message_dialog.destroy ();
    }

    public async void reload_library () {
        item_box.@foreach ((item) => item_box.remove (item));

        foreach (var new_conn in settings.saved_connections) {
            var array = settings.arraify_data (new_conn);
            add_item (array);
        }
        item_box.show_all ();

        delete_all.sensitive = (settings.saved_connections.length > 0);
    }

    public async void check_add_item (Gee.HashMap<string, string> data) {
        bool result = false;

        SourceFunc callback = check_add_item.callback;
        new Thread<void*> ("check-add-item", () => {
            result = update_existing_connection (data);

            Idle.add ((owned) callback);
            Thread.exit (null);

            return null;
        });

        yield;

        if (!result) {
            settings.add_connection (data);
        }

        yield reload_library ();
    }

    private bool update_existing_connection (Gee.HashMap<string, string> data) {
        foreach (var conn in settings.saved_connections) {
            var check = settings.arraify_data (conn);

            if (check["id"] == data["id"]) {
                settings.edit_connection (data, conn);
                return true;
            }
        }

        return false;
    }

    public void check_open_sqlite_file (string path, string name) {
        foreach (var conn in settings.saved_connections) {
            var check = settings.arraify_data (conn);
            if (check["file_path"] == path) {
                settings.edit_connection (check, conn);
                reload_library.begin ((obj, res) => {
                    item_box.get_row_at_index (0).activate ();
                });
                return;
            }
        }

        var data = new Gee.HashMap<string, string> ();

        data.set ("id", settings.tot_connections.to_string ());
        data.set ("title", name);
        data.set ("color", "rgb(222,222,222)");
        data.set ("type", "SQLite");
        data.set ("host", "");
        data.set ("name", "");
        data.set ("file_path", path);
        data.set ("username", "");
        data.set ("password", "");
        data.set ("port", "");

        settings.add_connection (data);

        reload_library.begin ((obj, res) => {
            item_box.get_row_at_index (0).activate ();
        });
    }

    private void init_connection_begin (Gee.HashMap<string, string> data, Gtk.Spinner spinner, Gtk.ModelButton button, bool update = true) {
        connection_manager = new Sequeler.Services.ConnectionManager (window, data);

        if (data["type"] != "SQLite" && data["username"] == "") {
            spinner.stop ();
            button.sensitive = true;
            connection_warning (_("A username is required in order to connect!"), data["name"]);
            return;
        }

        if (data["has_ssh"] == "true") {
            real_data = data;
            real_spinner = spinner;
            real_button = button;
            connection_manager.ssh_tunnel_ready.connect (() =>
                init_real_connection_begin (real_data, real_spinner, real_button, update)
            );

            new Thread<void*> (null, () => {
                var result = new Gee.HashMap<string, string> ();
                try {
                    connection_manager.ssh_tunnel_init (true);
                } catch (Error e) {
                    result["status"] = "false";
                    result["message"] = e.message;
                }

                Idle.add (() => {
                    if (result["status"] == "false") {
                        spinner.stop ();
                        button.sensitive = true;
                        connection_warning (result["message"], data["name"]);
                    }
                    return false;
                });

                return null;
            });
        } else {
            init_real_connection_begin (data, spinner, button, update);
        }
    }

    private void init_real_connection_begin (Gee.HashMap<string, string> data, Gtk.Spinner spinner, Gtk.ModelButton button, bool update) {
        var result = new Gee.HashMap<string, string> ();

        connection_manager.init_connection.begin ((obj, res) => {
            new Thread<void*> (null, () => {
                try {
                    result = connection_manager.init_connection.end (res);
                } catch (ThreadError e) {
                    connection_warning (e.message, data["name"]);
                    spinner.stop ();
                    button.sensitive = true;
                }

                Idle.add (() => {
                    spinner.stop ();
                    button.sensitive = true;

                    if (result["status"] == "true") {
                        if (settings.save_quick && update) {
                            check_add_item.begin (data);
                        }

                        window.main.connection_opened.begin (connection_manager);
                    } else {
                        connection_warning (result["msg"], data["name"]);
                    }
                    return false;
                });
                return null;
            });
        });
    }

    private void export_library () {
        file = null;
        buffer = new Gtk.TextBuffer (null);

        var save_dialog = new Gtk.FileChooserNative (_("Pick a file"),
                                                     window,
                                                     Gtk.FileChooserAction.SAVE,
                                                     _("_Save"),
                                                     _("_Cancel"));

        save_dialog.do_overwrite_confirmation = true;
        save_dialog.modal = true;
        save_dialog.response.connect ((dialog, response_id) => {
            switch (response_id) {
                case Gtk.ResponseType.ACCEPT:
                    file = save_dialog.get_file ();
                    save_to_file.begin ();
                    break;
                default:
                    break;
            }
            dialog.destroy ();
        });

        save_dialog.run ();
    }

    private async void save_to_file () {
        var buffer_content = "";
        var library = settings.saved_connections;

        foreach (var lib in library) {
            var array = settings.arraify_data (lib);

            try {
                array["password"] = yield password_mngr.get_password_async (array["id"]);
            } catch (Error e) {
                debug ("Unable to get the password from libsecret");
            }

            if (array["has_ssh"] == "true") {
                try {
                    array["ssh_password"] = yield password_mngr.get_password_async (array["id"] + "9999");
                } catch {
                    debug ("Unable to get the SSH password from libsecret");
                }
            }

            buffer_content += settings.stringify_data (array) + "---\n";
        }

        buffer.set_text (buffer_content);

        Gtk.TextIter start;
        Gtk.TextIter end;

        buffer.get_bounds (out start, out end);
        string current_contents = buffer.get_text (start, end, false);
        try {
            file.replace_contents (current_contents.data, null, false, GLib.FileCreateFlags.NONE, null, null);
        }
        catch (GLib.Error err) {
            export_warning (err.message);
        }
    }

    private void connection_warning (string message, string title) {
        var message_dialog = new Granite.MessageDialog.with_image_from_icon_name (_("Unable to Connect to %s").printf (title), message, "dialog-error", Gtk.ButtonsType.NONE);
        message_dialog.transient_for = window;

        var suggested_button = new Gtk.Button.with_label ("Close");
        message_dialog.add_action_widget (suggested_button, Gtk.ResponseType.ACCEPT);

        message_dialog.show_all ();
        if (message_dialog.run () == Gtk.ResponseType.ACCEPT) {}

        message_dialog.destroy ();
    }

    private void export_warning (string message) {
        var message_dialog = new Granite.MessageDialog.with_image_from_icon_name (_("Unable to Export Library "), message, "dialog-error", Gtk.ButtonsType.NONE);
        message_dialog.transient_for = window;

        var suggested_button = new Gtk.Button.with_label ("Close");
        message_dialog.add_action_widget (suggested_button, Gtk.ResponseType.ACCEPT);

        message_dialog.show_all ();
        if (message_dialog.run () == Gtk.ResponseType.ACCEPT) {}

        message_dialog.destroy ();
    }

    private async void duplicate_connection (Gee.HashMap<string, string> data) {
        if (data["type"] != "SQLite") {
            try {
                data["password"] = yield password_mngr.get_password_async (data["id"]);
            } catch (Error e) {
                debug ("Unable to get the password from libsecret");
            }
        }

        if (data["has_ssh"] == "true") {
            try {
                data["ssh_password"] = yield password_mngr.get_password_async (data["id"] + "9999");
            } catch {
                debug ("Unable to get the SSH password from libsecret");
            }
        }

        yield settings.duplicate_connection (data);
        yield reload_library ();
    }
}