/*
 * CDDL HEADER START
 *
 * The contents of this file are subject to the terms of the
 * Common Development and Distribution License (the "License").
 * You may not use this file except in compliance with the License.
 *
 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
 * or http://www.opensolaris.org/os/licensing.
 * See the License for the specific language governing permissions
 * and limitations under the License.
 *
 * When distributing Covered Code, include this CDDL HEADER in each
 * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
 * If applicable, add the following below this CDDL HEADER, with the
 * fields enclosed by brackets "[]" replaced with your own identifying
 * information: Portions Copyright [yyyy] [name of copyright owner]
 *
 * CDDL HEADER END
 */

/*
 * Copyright 2008 Sun Microsystems, Inc. All rights reserved.
 * Use is subject to license terms.
 */
#ifdef HAVE_CONFIG_H
#include <config.h>
#endif

#include <sys/types.h>
#include <unistd.h>
#include <stdio.h>
#include <strings.h>
#include <string.h>
#include <errno.h>

#include <glib.h>
#include <glib/gi18n.h>

#include "fsexam.h"
#include "fsexam-error.h"
#include "fsexam-helper.h"
#include "file-filter.h"
#include "fsexam-header.h"
#include "fsexam-ui.h"

#define CMD_NAME                "/usr/bin/find"
#define FSEXAM_REFRESH_TIMEOUT  50000

static gchar **
filter_compose_argv (const gchar *params)
{
    gchar *full_cmd = NULL;
    gchar **argv = NULL;

    if (params == NULL) {
        return NULL;
    }

    full_cmd = g_strdup_printf ("%s %s", CMD_NAME, params);
    argv = g_strsplit (full_cmd, " ", -1);
    g_free (full_cmd);

    return argv;
}

/*
 * Run find(1) with given params, and return the result
 */
GList *
filter_cmd_run (const gchar *params)
{
    FILE    *fp = NULL;
    gchar   **argv = NULL;
    gchar   *buf = NULL;
    GList   *list = NULL;
    GError  *error = NULL;
    gint    child_stdout;

    argv = filter_compose_argv (params);
    if (argv == NULL) {
        g_print (_("Parameters of find(1) is empty.\n"));
        return NULL;
    }

    /* create pipe */
    if (!g_spawn_async_with_pipes (NULL, argv,
                NULL,       /* envp */
                0,      /* GSpawnFlags */
                NULL, NULL,
                NULL,   /* pid */
                NULL,
                &child_stdout,
                NULL, 
                &error)) {
        g_print (error->message);
        g_error_free (error);
        g_strfreev (argv);

        return NULL;
    }

    /* create FILE pointer from subprocess's stdout */
    if ((fp = fdopen (child_stdout, "r")) == NULL) {
        g_print (_("Can't open pipe file descriptor.\n"));
        g_strfreev (argv);
        return NULL;
    }
        
    buf = (gchar *) g_malloc (PATH_MAX);
    g_print (_("Searching..."));
    g_print ("\n");

    while (fgets (buf, PATH_MAX, fp) != NULL) {
        gint  len = strlen (buf);

        if (buf[len - 1] == '\n')
            buf[len - 1] = '\0';

        list = g_list_prepend (list, g_strdup (buf));
    }

    g_print (_("Search finished"));
    g_print ("\n");

    g_free (buf);
    g_strfreev (argv);
    fclose (fp);

    return list;
}

/*
 * Run file(1) and append searched files into search result treeview 
 */
void
filter_gui_run (const gchar *folder, const gchar *params)
{
    FILE    *fp = NULL;
    gchar   **argv = NULL;
    GError  *error = NULL;
    gint    child_stdout;
    gint    file_count = 0;
    gchar   *buf = NULL;
    gchar   *msg = NULL;
    GTimer  *timer = NULL;
    gulong  duration;
    GtkWidget *menu_stop = NULL;
    GtkWidget *menu_search = NULL;
    GtkWidget *menu_clear = NULL;
    GtkWidget *label_result = NULL;

    argv = filter_compose_argv (params);
    if (argv == NULL) {
        g_print (_("Parameters of find(1) is empty.\n"));
        return;
    }

    /* create pipe */
    if (!g_spawn_async_with_pipes (NULL, argv, 
                NULL,       /* envp */
                0,          /* GSpawnFlags */
                NULL, NULL, 
                &view->pid, 
                NULL,
                &child_stdout,
                NULL,
                &error)) {
        GtkWidget *dialog = NULL;

        dialog = gtk_message_dialog_new (GTK_WINDOW (view->mainwin),
                GTK_DIALOG_DESTROY_WITH_PARENT,
                GTK_MESSAGE_ERROR,
                GTK_BUTTONS_OK,
                _("Error occurs during executing the search command."));
        gtk_message_dialog_format_secondary_text (GTK_MESSAGE_DIALOG (dialog),
                error->message);

        gtk_dialog_run (GTK_DIALOG (dialog));
        
        gtk_widget_destroy (dialog);
        g_error_free (error);
        g_strfreev (argv);
        
        return;
    }

    /* create FILE pointer from subprocess's stdout */
    if ((fp = fdopen (child_stdout, "r")) == NULL) {
        GtkWidget *dialog = NULL;

        dialog = gtk_message_dialog_new (GTK_WINDOW (view->mainwin),
                GTK_DIALOG_DESTROY_WITH_PARENT,
                GTK_MESSAGE_ERROR,
                GTK_BUTTONS_OK,
                _("Error occurs when open fd."));
        gtk_message_dialog_format_secondary_text (GTK_MESSAGE_DIALOG (dialog),
                g_strerror (errno));

        gtk_dialog_run (GTK_DIALOG (dialog));
        
        gtk_widget_destroy (dialog);
        g_strfreev (argv);

        return;
    }

    /*
     * Prepare for searching 
     */
    menu_clear = g_object_get_data (G_OBJECT (view->mainwin), 
                                    "menu_clear_search");
    menu_search = g_object_get_data (G_OBJECT (view->mainwin), "menu_search");
    menu_stop = g_object_get_data (G_OBJECT (view->mainwin), 
                                    "menu_stop_search");
    gtk_widget_set_sensitive (menu_clear, FALSE);
    gtk_widget_hide (menu_search);
    gtk_widget_show (menu_stop);
    
    label_result = g_object_get_data (G_OBJECT (view->mainwin), "label_result");
    fsexam_statusbar_update (_("Searching..."));

    /* show result pane and clear previous result */
    fsexam_search_treeview_append_file (NULL, TRUE);
    g_free (view->basedir);

    /* resolve possible symlink in folder path */
    if (g_file_test (folder, G_FILE_TEST_IS_SYMLINK))
        view->basedir = get_abs_path_for_symlink_target (folder);
    else
        view->basedir = get_abs_path (folder);

    stop_search = FALSE;
    buf = (gchar *) g_malloc (PATH_MAX);
    memset (buf, 0, PATH_MAX);

    timer = g_timer_new ();
    g_timer_start (timer);

    /* Read data from child's stdout async */
    while (fgets (buf, PATH_MAX, fp) != NULL) {
        gint  len = strlen (buf);

        if (buf[len - 1] == '\n')
            buf[len - 1] = '\0';

        fsexam_search_treeview_append_file (buf, FALSE);
        file_count ++;

        g_timer_elapsed (timer, &duration);

        if (duration > FSEXAM_REFRESH_TIMEOUT) {
            msg = g_strdup_printf (_("%d files found"), file_count);
            gtk_label_set_text (GTK_LABEL (label_result), msg);
            g_free (msg);

            while (gtk_events_pending ()) {
                gtk_main_iteration ();
            }

            g_timer_reset (timer);
        }

        if (force_quit) /* user quit application */
            break;
    }

    g_timer_destroy (timer);

    if (!force_quit) {  /* Quit the whole app, mainwin has been destroyed */
        g_spawn_close_pid (view->pid);
        view->pid = -1;

        msg = g_strdup_printf (_("%d files found"), file_count);
        gtk_label_set_text (GTK_LABEL (label_result), msg);
        g_free (msg);

        if (file_count != 0)
            gtk_widget_set_sensitive (menu_clear, TRUE);

        gtk_widget_hide (menu_stop);
        gtk_widget_show (menu_search);
    
        fsexam_statusbar_update (stop_search ? _("Search stopped") 
                                             : _("Search finished"));
    }

    fclose (fp);
    g_free (buf);
    g_strfreev (argv);

    return;
}