Sylpheed

/*

 * Sylpheed -- a GTK+ based, lightweight, and fast e-mail client

 * Copyright (C) 1999-2009 Hiroyuki Yamamoto

 *

 * 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., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.

 */

#ifdef HAVE_CONFIG_H

#  include "config.h"

#endif

#include "defs.h"

#include <glib.h>

#include <glib/gi18n.h>

#include <gtk/gtkmain.h>

#include <gtk/gtkrc.h>

#include <gtk/gtkstock.h>

#include <gtk/gtkaccelmap.h>

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <ctype.h>

#include <unistd.h>

#include <time.h>

#include <sys/stat.h>

#include <sys/types.h>

#ifdef G_OS_UNIX

#  include <signal.h>

#endif

#if HAVE_LOCALE_H

#  include <locale.h>

#endif

#if USE_GPGME

#  include <gpgme.h>

#endif

#include "main.h"

#include "mainwindow.h"

#include "folderview.h"

#include "summaryview.h"

#include "prefs_common.h"

#include "prefs_account.h"

#include "prefs_actions.h"

#include "prefs_display_header.h"

#include "account.h"

#include "account_dialog.h"

#include "procmsg.h"

#include "filter.h"

#include "send_message.h"

#include "inc.h"

#include "import.h"

#include "manage_window.h"

#include "alertpanel.h"

#include "inputdialog.h"

#include "statusbar.h"

#include "addressbook.h"

#include "addrindex.h"

#include "compose.h"

#include "logwindow.h"

#include "folder.h"

#include "setup.h"

#include "sylmain.h"

#include "utils.h"

#include "gtkutils.h"

#include "socket.h"

#include "stock_pixmap.h"

#include "trayicon.h"

#include "plugin.h"

#include "plugin_manager.h"

#include "foldersel.h"

#include "update_check.h"

#if USE_GPGME

#  include "rfc2015.h"

#endif

#if USE_SSL

#  include "ssl.h"

#  include "sslmanager.h"

#endif

#ifdef G_OS_WIN32

#  include <windows.h>

#  include <pbt.h>

#  include <fcntl.h>

#  include <conio.h>

#endif

#include "version.h"

gchar *prog_version;

#ifdef G_OS_WIN32

static gboolean init_console_done = FALSE;

#endif

static gint lock_socket = -1;

static gint lock_socket_tag = 0;

static GIOChannel *lock_ch = NULL;

static struct RemoteCmd {

        gboolean receive;

        gboolean receive_all;

        gboolean compose;

        const gchar *compose_mailto;

        GPtrArray *attach_files;

        gboolean send;

        gboolean status;

        gboolean status_full;

        GPtrArray *status_folders;

        GPtrArray *status_full_folders;

        gchar *open_msg;

        gboolean configdir;

        gboolean exit;

#ifdef G_OS_WIN32

        gushort ipcport;

#endif

} cmd;

static void parse_cmd_opt                (int                 argc,

                                         char                *argv[]);

static void app_init                        (void);

static void parse_gtkrc_files                (void);

static void setup_rc_dir                (void);

static void check_gpg                        (void);

static void set_log_handlers                (gboolean         enable);

static void register_system_events        (void);

static void plugin_init                        (void);

static gchar *get_socket_name                (void);

static gint prohibit_duplicate_launch        (void);

static gint lock_socket_remove                (void);

static gboolean lock_socket_input_cb        (GIOChannel        *source,

                                         GIOCondition         condition,

                                         gpointer         data);

static void remote_command_exec                (void);

static void migrate_old_config                (void);

static void open_compose_new                (const gchar        *address,

                                         GPtrArray        *attach_files);

static void open_message                (const gchar        *path);

static void send_queue                        (void);

#define MAKE_DIR_IF_NOT_EXIST(dir)                                        \

{                                                                        \

        if (!is_dir_exist(dir)) {                                        \

                if (is_file_exist(dir)) {                                \

                        alertpanel_warning                                \

                                (_("File `%s' already exists.\n"        \

                                   "Can't create folder."),                \

                                 dir);                                        \

                        exit(1);                                        \

                }                                                        \

                if (make_dir(dir) < 0)                                        \

                        exit(1);                                        \

        }                                                                \

}

#define CHDIR_EXIT_IF_FAIL(dir, val)        \

{                                        \

        if (change_dir(dir) < 0)        \

                exit(val);                \

}

static void load_cb(GObject *obj, GModule *module, gpointer data)

{

        g_print("load_cb: %p (%s), %p\n", module, module ? g_module_name(module) : "(null)", data);

}

int main(int argc, char *argv[])

{

        MainWindow *mainwin;

        FolderView *folderview;

        GdkPixbuf *icon;

#ifdef G_OS_WIN32

        GList *iconlist = NULL;

#endif

        GObject *syl_app;

        app_init();

        parse_cmd_opt(argc, argv);

        /* check and create (unix domain) socket for remote operation */

        lock_socket = prohibit_duplicate_launch();

        if (lock_socket < 0) return 0;

        if (cmd.status || cmd.status_full) {

                puts("0 Sylpheed not running.");

                lock_socket_remove();

                return 0;

        }

        gtk_set_locale();

        gtk_init(&argc, &argv);

        syl_app = syl_app_create();

        gdk_rgb_init();

        gtk_widget_set_default_colormap(gdk_rgb_get_cmap());

        gtk_widget_set_default_visual(gdk_rgb_get_visual());

#if USE_THREADS || USE_LDAP

        if (!g_thread_supported())

                g_thread_init(NULL);

        if (!g_thread_supported())

                g_error(_("g_thread is not supported by glib.\n"));

#endif

        parse_gtkrc_files();

        setup_rc_dir();

        if (is_file_exist("sylpheed.log")) {

                if (rename_force("sylpheed.log", "sylpheed.log.bak") < 0)

                        FILE_OP_ERROR("sylpheed.log", "rename");

        }

        set_log_file("sylpheed.log");

        set_ui_update_func(gtkut_events_flush);

        set_progress_func(main_window_progress_show);

        set_input_query_password_func(input_dialog_query_password);

#if USE_SSL

        ssl_set_verify_func(ssl_manager_verify_cert);

#endif

        CHDIR_EXIT_IF_FAIL(get_home_dir(), 1);

        prefs_common_read_config();

        filter_read_config();

        prefs_actions_read_config();

        prefs_display_header_read_config();

#ifdef G_OS_WIN32

        {

                gchar *path;

                path = g_strconcat(get_rc_dir(), G_DIR_SEPARATOR_S, COMMON_RC,

                                   NULL);

                if (!is_file_exist(path) && conv_is_ja_locale()) {

                        const gchar *str;

                        debug_print("fixing prefs_common.textfont setting\n");

                        str = "MS Gothic 12";

                        if (!gtkut_font_can_load(str)) {

                                debug_print("font '%s' load failed\n", str);

                                str = "\xef\xbc\xad\xef\xbc\xb3 \xe3\x82\xb4\xe3\x82\xb7\xe3\x83\x83\xe3\x82\xaf 12";

                                if (!gtkut_font_can_load(str)) {

                                        debug_print("font '%s' load failed\n", str);

                                        str = NULL;

                                }

                        }

                        if (str) {

                                debug_print("font '%s' load ok\n", str);

                                g_free(prefs_common.textfont);

                                prefs_common.textfont = g_strdup(str);

                        }

                }

                g_free(path);

        }

#endif

        gtkut_stock_button_set_set_reverse(!prefs_common.comply_gnome_hig);

        check_gpg();

        sock_set_io_timeout(prefs_common.io_timeout_secs);

        gtkut_widget_init();

#ifdef G_OS_WIN32

        stock_pixbuf_gdk(NULL, STOCK_PIXMAP_SYLPHEED_32, &icon);

        iconlist = g_list_append(iconlist, icon);

        stock_pixbuf_gdk(NULL, STOCK_PIXMAP_SYLPHEED_SMALL, &icon);

        iconlist = g_list_append(iconlist, icon);

        gtk_window_set_default_icon_list(iconlist);

        g_list_free(iconlist);

#else

        stock_pixbuf_gdk(NULL, STOCK_PIXMAP_SYLPHEED, &icon);

        gtk_window_set_default_icon(icon);

#endif

        mainwin = main_window_create

                (prefs_common.sep_folder | prefs_common.sep_msg << 1);

        folderview = mainwin->folderview;

        /* register the callback of socket input */

        if (lock_socket > 0) {

                lock_ch = g_io_channel_unix_new(lock_socket);

                lock_socket_tag = g_io_add_watch(lock_ch,

                                                 G_IO_IN|G_IO_PRI|G_IO_ERR,

                                                 lock_socket_input_cb, mainwin);

        }

        set_log_handlers(TRUE);

        account_read_config_all();

        account_set_menu();

        main_window_reflect_prefs_all();

        if (folder_read_list() < 0) {

                setup(mainwin);

                folder_write_list();

        }

        if (!account_get_list()) {

                account_edit_open();

                account_add();

        }

        account_set_missing_folder();

        folder_set_missing_folders();

        folderview_set(folderview);

        addressbook_read_file();

        register_system_events();

        inc_autocheck_timer_init(mainwin);

        plugin_init();

        g_signal_emit_by_name(syl_app, "init-done");

        remote_command_exec();

        if (prefs_common.auto_update_check)

                update_check(FALSE);

        gtk_main();

        return 0;

}

static void init_console(void)

{

#ifdef G_OS_WIN32

        gint fd;

        FILE *fp;

        if (init_console_done)

                return;

        if (!AllocConsole()) {

                g_warning("AllocConsole() failed\n");

                return;

        }

        fd = _open_osfhandle((glong)GetStdHandle(STD_OUTPUT_HANDLE), _O_TEXT);

        _dup2(fd, 1);

        fp = _fdopen(fd, "w");

        *stdout = *fp;

        setvbuf(stdout, NULL, _IONBF, 0);

        fd = _open_osfhandle((glong)GetStdHandle(STD_ERROR_HANDLE), _O_TEXT);

        _dup2(fd, 2);

        fp = _fdopen(fd, "w");

        *stderr = *fp;

        setvbuf(stderr, NULL, _IONBF, 0);

        init_console_done = TRUE;

#endif

}

static void cleanup_console(void)

{

#ifdef G_OS_WIN32

        FreeConsole();

#endif

}

#ifdef G_OS_WIN32

static void read_ini_file(void)

{

        static gushort ipcport = REMOTE_CMD_PORT;

        static gchar *confdir = NULL;

        static PrefParam param[] = {

                {"ipcport", "50215", &ipcport, P_USHORT},

                {"configdir", NULL, &confdir, P_STRING},

                {NULL, NULL, NULL, P_OTHER}

        };

        gchar *file;

        file = g_strconcat(get_startup_dir(), G_DIR_SEPARATOR_S, "sylpheed.ini",

                           NULL);

        if (!is_file_exist(file)) {

                g_free(file);

                return;

        }

        prefs_read_config(param, "Sylpheed", file,

                          conv_get_locale_charset_str());

        g_free(file);

        cmd.ipcport = ipcport;

        if (confdir) {

                set_rc_dir(confdir);

                g_free(confdir);

                confdir = NULL;

                cmd.configdir = TRUE;

        }

}

#endif

static void parse_cmd_opt(int argc, char *argv[])

{

        gint i;

        for (i = 1; i < argc; i++) {

                if (!strncmp(argv[i], "--debug", 7)) {

                        init_console();

                        set_debug_mode(TRUE);

                } else if (!strncmp(argv[i], "--receive-all", 13))

                        cmd.receive_all = TRUE;

                else if (!strncmp(argv[i], "--receive", 9))

                        cmd.receive = TRUE;

                else if (!strncmp(argv[i], "--compose", 9)) {

                        const gchar *p = argv[i + 1];

                        cmd.compose = TRUE;

                        cmd.compose_mailto = NULL;

                        if (p && *p != '\0' && *p != '-') {

                                if (!strncmp(p, "mailto:", 7))

                                        cmd.compose_mailto = p + 7;

                                else

                                        cmd.compose_mailto = p;

                                i++;

                        }

                } else if (!strncmp(argv[i], "--attach", 8)) {

                        const gchar *p = argv[i + 1];

                        gchar *file;

                        while (p && *p != '\0' && *p != '-') {

                                if (!cmd.attach_files)

                                        cmd.attach_files = g_ptr_array_new();

                                if (!g_path_is_absolute(p))

                                        file = g_strconcat(get_startup_dir(),

                                                           G_DIR_SEPARATOR_S,

                                                           p, NULL);

                                else

                                        file = g_strdup(p);

                                g_ptr_array_add(cmd.attach_files, file);

                                i++;

                                p = argv[i + 1];

                        }

                } else if (!strncmp(argv[i], "--send", 6)) {

                        cmd.send = TRUE;

                } else if (!strncmp(argv[i], "--version", 9)) {

                        puts("Sylpheed version " VERSION);

                        exit(0);

                } else if (!strncmp(argv[i], "--status-full", 13)) {

                        const gchar *p = argv[i + 1];

                        cmd.status_full = TRUE;

                        while (p && *p != '\0' && *p != '-') {

                                if (!cmd.status_full_folders)

                                        cmd.status_full_folders =

                                                g_ptr_array_new();

                                g_ptr_array_add(cmd.status_full_folders,

                                                g_strdup(p));

                                i++;

                                p = argv[i + 1];

                        }

                } else if (!strncmp(argv[i], "--status", 8)) {

                        const gchar *p = argv[i + 1];

                        cmd.status = TRUE;

                        while (p && *p != '\0' && *p != '-') {

                                if (!cmd.status_folders)

                                        cmd.status_folders = g_ptr_array_new();

                                g_ptr_array_add(cmd.status_folders,

                                                g_strdup(p));

                                i++;

                                p = argv[i + 1];

                        }

                } else if (!strncmp(argv[i], "--open", 6)) {

                        const gchar *p = argv[i + 1];

                        if (p && *p != '\0' && *p != '-') {

                                cmd.open_msg = g_locale_to_utf8

                                        (p, -1, NULL, NULL, NULL);

                                i++;

                        }

                } else if (!strncmp(argv[i], "--configdir", 11)) {

                        const gchar *p = argv[i + 1];

                        if (p && *p != '\0' && *p != '-') {

                                /* this must only be done at startup */

#ifdef G_OS_WIN32

                                gchar *utf8dir;

                                utf8dir = g_locale_to_utf8

                                        (p, -1, NULL, NULL, NULL);

                                if (utf8dir) {

                                        set_rc_dir(utf8dir);

                                        g_free(utf8dir);

                                } else

                                        set_rc_dir(p);

#else

                                set_rc_dir(p);

#endif

                                cmd.configdir = TRUE;

                                i++;

                        }

#ifdef G_OS_WIN32

                } else if (!strncmp(argv[i], "--ipcport", 9)) {

                        if (argv[i + 1]) {

                                cmd.ipcport = atoi(argv[i + 1]);

                                i++;

                        }

#endif

                } else if (!strncmp(argv[i], "--exit", 6)) {

                        cmd.exit = TRUE;

                } else if (!strncmp(argv[i], "--help", 6)) {

                        init_console();

                        g_print(_("Usage: %s [OPTION]...\n"),

                                g_basename(argv[0]));

                        g_print("%s\n", _("  --compose [address]    open composition window"));

                        g_print("%s\n", _("  --attach file1 [file2]...\n"

                                "                         open composition window with specified files\n"

                                "                         attached"));

                        g_print("%s\n", _("  --receive              receive new messages"));

                        g_print("%s\n", _("  --receive-all          receive new messages of all accounts"));

                        g_print("%s\n", _("  --send                 send all queued messages"));

                        g_print("%s\n", _("  --status [folder]...   show the total number of messages"));

                        g_print("%s\n", _("  --status-full [folder]...\n"

                                "                         show the status of each folder"));

                        g_print("%s\n", _("  --open folderid/msgnum open message in new window"));

                        g_print("%s\n", _("  --configdir dirname    specify directory which stores configuration files"));

#ifdef G_OS_WIN32

                        g_print("%s\n", _("  --ipcport portnum      specify port for IPC remote commands"));

#endif

                        g_print("%s\n", _("  --exit                 exit Sylpheed"));

                        g_print("%s\n", _("  --debug                debug mode"));

                        g_print("%s\n", _("  --help                 display this help and exit"));

                        g_print("%s\n", _("  --version              output version information and exit"));

#ifdef G_OS_WIN32

                        g_print("\n");

                        g_print(_("Press any key..."));

                        _getch();

#endif

                        cleanup_console();

                        exit(1);

                }

        }

        if (cmd.attach_files && cmd.compose == FALSE) {

                cmd.compose = TRUE;

                cmd.compose_mailto = NULL;

        }

}

static gint get_queued_message_num(void)

{

        FolderItem *queue;

        queue = folder_get_default_queue();

        if (!queue) return -1;

        folder_item_scan(queue);

        return queue->total;

}

static void app_init(void)

{

        syl_init();

        prog_version = PROG_VERSION;

#ifdef G_OS_WIN32

        read_ini_file();

#endif

}

static void parse_gtkrc_files(void)

{

        gchar *userrc;

        /* parse gtkrc files */

        userrc = g_strconcat(get_home_dir(), G_DIR_SEPARATOR_S, ".gtkrc-2.0",

                             NULL);

        gtk_rc_parse(userrc);

        g_free(userrc);

        userrc = g_strconcat(get_home_dir(), G_DIR_SEPARATOR_S, ".gtk",

                             G_DIR_SEPARATOR_S, "gtkrc-2.0", NULL);

        gtk_rc_parse(userrc);

        g_free(userrc);

        userrc = g_strconcat(get_rc_dir(), G_DIR_SEPARATOR_S, "gtkrc", NULL);

        gtk_rc_parse(userrc);

        g_free(userrc);

        userrc = g_strconcat(get_rc_dir(), G_DIR_SEPARATOR_S, MENU_RC, NULL);

        gtk_accel_map_load(userrc);

        g_free(userrc);

}

static void setup_rc_dir(void)

{

#ifndef G_OS_WIN32

        CHDIR_EXIT_IF_FAIL(get_home_dir(), 1);

        /* backup if old rc file exists */

        if (!cmd.configdir && is_file_exist(RC_DIR)) {

                if (rename_force(RC_DIR, RC_DIR ".bak") < 0)

                        FILE_OP_ERROR(RC_DIR, "rename");

        }

        /* migration from ~/.sylpheed to ~/.sylpheed-2.0 */

        if (!cmd.configdir && !is_dir_exist(RC_DIR)) {

                const gchar *envstr;

                AlertValue val;

                /* check for filename encoding */

                if (conv_get_locale_charset() != C_UTF_8) {

                        envstr = g_getenv("G_FILENAME_ENCODING");

                        if (!envstr)

                                envstr = g_getenv("G_BROKEN_FILENAMES");

                        if (!envstr) {

                                val = alertpanel(_("Filename encoding"),

                                                 _("The locale encoding is not UTF-8, but the environmental variable G_FILENAME_ENCODING is not set.\n"

                                                   "If the locale encoding is used for file name or directory name, it will not work correctly.\n"

                                                   "In that case, you must set the following environmental variable (see README for detail):\n"

                                                   "\n"

                                                   "\tG_FILENAME_ENCODING=@locale\n"

                                                   "\n"

                                                   "Continue?"),

                                                 GTK_STOCK_OK, GTK_STOCK_QUIT,

                                                 NULL);

                                if (G_ALERTDEFAULT != val)

                                        exit(1);

                        }

                }

                if (make_dir(RC_DIR) < 0)

                        exit(1);

                if (is_dir_exist(OLD_RC_DIR))

                        migrate_old_config();

        }

#endif /* !G_OS_WIN32 */

        syl_setup_rc_dir();

}

void app_will_exit(gboolean force)

{

        MainWindow *mainwin;

        gchar *filename;

        static gboolean on_exit = FALSE;

        GList *cur;

        if (on_exit)

                return;

        on_exit = TRUE;

        mainwin = main_window_get();

        if (!force && compose_get_compose_list()) {

                if (alertpanel(_("Notice"),

                               _("Composing message exists. Really quit?"),

                               GTK_STOCK_OK, GTK_STOCK_CANCEL, NULL)

                    != G_ALERTDEFAULT) {

                        on_exit = FALSE;

                        return;

                }

                manage_window_focus_in(mainwin->window, NULL, NULL);

        }

        if (!force &&

            prefs_common.warn_queued_on_exit && get_queued_message_num() > 0) {

                if (alertpanel(_("Queued messages"),

                               _("Some unsent messages are queued. Exit now?"),

                               GTK_STOCK_OK, GTK_STOCK_CANCEL, NULL)

                    != G_ALERTDEFAULT) {

                        on_exit = FALSE;

                        return;

                }

                manage_window_focus_in(mainwin->window, NULL, NULL);

        }

        g_signal_emit_by_name(syl_app_get(), "app-exit");

        inc_autocheck_timer_remove();

        if (prefs_common.clean_on_exit)

                main_window_empty_trash(mainwin,

                                        !force && prefs_common.ask_on_clean);

        for (cur = account_get_list(); cur != NULL; cur = cur->next) {

                PrefsAccount *ac = (PrefsAccount *)cur->data;

                if (ac->protocol == A_IMAP4 && ac->imap_clear_cache_on_exit &&

                    ac->folder)

                        procmsg_remove_all_cached_messages(FOLDER(ac->folder));

        }

        syl_plugin_unload_all();

        trayicon_destroy(mainwin->tray_icon);

        /* save all state before exiting */

        summary_write_cache(mainwin->summaryview);

        main_window_get_size(mainwin);

        main_window_get_position(mainwin);

        syl_save_all_state();

        addressbook_export_to_file();

        filename = g_strconcat(get_rc_dir(), G_DIR_SEPARATOR_S, MENU_RC, NULL);

        gtk_accel_map_save(filename);

        g_free(filename);

        /* remove temporary files, close log file, socket cleanup */

        syl_cleanup();

        lock_socket_remove();

        cleanup_console();

        if (gtk_main_level() > 0)

                gtk_main_quit();

        exit(0);

}

#if 0

#if USE_GPGME

static void idle_function_for_gpgme(void)

{

        while (gtk_events_pending())

                gtk_main_iteration();

}

#endif /* USE_GPGME */

#endif /* 0 */

static void check_gpg(void)

{

#if USE_GPGME

        if (gpgme_check_version("0.4.5") &&

            !gpgme_engine_check_version(GPGME_PROTOCOL_OpenPGP)) {

                /* Also does some gpgme init */

                gpgme_engine_info_t engineInfo;

#if HAVE_LOCALE_H

                gpgme_set_locale(NULL, LC_CTYPE, setlocale(LC_CTYPE, NULL));

                gpgme_set_locale(NULL, LC_MESSAGES,

                                 setlocale(LC_MESSAGES, NULL));

#endif

                if (!gpgme_get_engine_info(&engineInfo)) {

                        while (engineInfo) {

                                debug_print("GpgME Protocol: %s\n      Version: %s\n",

                                            gpgme_get_protocol_name

                                                (engineInfo->protocol),

                                            engineInfo->version ?

                                            engineInfo->version : "(unknown)");

                                engineInfo = engineInfo->next;

                        }

                }

                procmsg_set_decrypt_message_func

                        (rfc2015_open_message_decrypted);

                procmsg_set_auto_decrypt_message(TRUE);

        } else {

                rfc2015_disable_all();

                if (prefs_common.gpg_warning) {

                        AlertValue val;

                        val = alertpanel_message_with_disable

                                (_("Warning"),

                                 _("GnuPG is not installed properly, or its version is too old.\n"

                                   "OpenPGP support disabled."),

                                 ALERT_WARNING);

                        if (val & G_ALERTDISABLE)

                                prefs_common.gpg_warning = FALSE;

                }

        }

        /* FIXME: This function went away.  We can either block until gpgme

         * operations finish (currently implemented) or register callbacks

         * with the gtk main loop via the gpgme io callback interface instead.

         *

         * gpgme_register_idle(idle_function_for_gpgme);

         */

#endif

}

static void default_log_func(const gchar *log_domain, GLogLevelFlags log_level,

                             const gchar *message, gpointer user_data)

{

        gchar *prefix = "";

        gchar *file_prefix = "";

        LogType level = LOG_NORMAL;

        gchar *str;

        const gchar *message_;

        switch (log_level) {

        case G_LOG_LEVEL_ERROR:

                prefix = "ERROR";

                file_prefix = "*** ";

                level = LOG_ERROR;

                break;

        case G_LOG_LEVEL_CRITICAL:

                prefix = "CRITICAL";

                file_prefix = "** ";

                level = LOG_WARN;

                break;

        case G_LOG_LEVEL_WARNING:

                prefix = "WARNING";

                file_prefix = "** ";

                level = LOG_WARN;

                break;

        case G_LOG_LEVEL_MESSAGE:

                prefix = "Message";

                file_prefix = "* ";

                level = LOG_MSG;

                break;

        case G_LOG_LEVEL_INFO:

                prefix = "INFO";

                file_prefix = "* ";

                level = LOG_MSG;

                break;

        case G_LOG_LEVEL_DEBUG:

                prefix = "DEBUG";

                break;

        default:

                prefix = "LOG";

                break;

        }

        if (!message)

                message_ = "(NULL) message";

        else

                message_ = message;

        if (log_domain)

                str = g_strconcat(log_domain, "-", prefix, ": ", message_, "\n",

                                  NULL);

        else

                str = g_strconcat(prefix, ": ", message_, "\n", NULL);

        log_window_append(str, level);

        log_write(str, file_prefix);

        g_free(str);

        g_log_default_handler(log_domain, log_level, message, user_data);

}

static void set_log_handlers(gboolean enable)

{

#if GLIB_CHECK_VERSION(2, 6, 0)

        if (enable)

                g_log_set_default_handler(default_log_func, NULL);

        else

                g_log_set_default_handler(g_log_default_handler, NULL);

#else

        static guint handler_id[4] = {0, 0, 0, 0};

        if (enable) {

                handler_id[0] = g_log_set_handler

                        ("GLib", G_LOG_LEVEL_MASK | G_LOG_FLAG_FATAL

                         | G_LOG_FLAG_RECURSION, default_log_func, NULL);

                handler_id[1] = g_log_set_handler

                        ("Gtk", G_LOG_LEVEL_MASK | G_LOG_FLAG_FATAL

                         | G_LOG_FLAG_RECURSION, default_log_func, NULL);

                handler_id[2] = g_log_set_handler

                        ("LibSylph", G_LOG_LEVEL_MASK | G_LOG_FLAG_FATAL

                         | G_LOG_FLAG_RECURSION, default_log_func, NULL);

                handler_id[3] = g_log_set_handler

                        ("Sylpheed", G_LOG_LEVEL_MASK | G_LOG_FLAG_FATAL

                         | G_LOG_FLAG_RECURSION, default_log_func, NULL);

        } else {

                g_log_remove_handler("GLib", handler_id[0]);

                g_log_remove_handler("Gtk", handler_id[1]);

                g_log_remove_handler("LibSylph", handler_id[2]);

                g_log_remove_handler("Sylpheed", handler_id[3]);

                handler_id[0] = 0;

                handler_id[1] = 0;

                handler_id[2] = 0;

                handler_id[3] = 0;

        }

#endif

}

#ifdef G_OS_WIN32

static BOOL WINAPI

ctrl_handler(DWORD dwctrltype)

{

        log_print("ctrl_handler: received %d\n", dwctrltype);

        app_will_exit(TRUE);

        return TRUE;

}

static LRESULT CALLBACK

wndproc(HWND hwnd, UINT message, WPARAM wparam, LPARAM lparam)

{

        switch (message) {

        case WM_POWERBROADCAST:

                debug_print("WM_POWERBROADCAST received: wparam = %d\n",

                            wparam);

                if (wparam == PBT_APMSUSPEND || wparam == PBT_APMSTANDBY) {

                        debug_print("suspend now\n");

                        inc_autocheck_timer_remove();

                } else if (wparam == PBT_APMRESUMESUSPEND ||

                           wparam == PBT_APMRESUMESTANDBY) {

                        debug_print("resume now\n");

                        inc_autocheck_timer_set();

                }

                break;

        case WM_ENDSESSION:

                if (wparam == 1) {

                        log_print("WM_ENDSESSION received: system is quitting\n");

                        app_will_exit(TRUE);

                }

                break;

        default:

                break;

        }

        return DefWindowProc(hwnd, message, wparam, lparam);

}

static void register_system_events(void)

{

        WNDCLASS wclass;

        static HWND hwnd = NULL;

        static BOOL ctrl_handler_set = FALSE;

        ATOM klass;

        HINSTANCE hmodule = GetModuleHandle(NULL);

        if (init_console_done && !ctrl_handler_set) {

                debug_print("register_system_events(): SetConsoleCtrlHandler\n");

                ctrl_handler_set = SetConsoleCtrlHandler(ctrl_handler, TRUE);

                if (!ctrl_handler_set)

                        g_warning("SetConsoleCtrlHandler() failed\n");

        }

        if (hwnd)

                return;

        debug_print("register_system_events(): RegisterClass\n");

        memset(&wclass, 0, sizeof(WNDCLASS));

        wclass.lpszClassName = "sylpheed-observer";

        wclass.lpfnWndProc   = wndproc;

        wclass.hInstance     = hmodule;

        klass = RegisterClass(&wclass);

        if (!klass)

                return;

        hwnd = CreateWindow(MAKEINTRESOURCE(klass), NULL, WS_POPUP,

                            0, 0, 1, 1, NULL, NULL, hmodule, NULL);

        if (!hwnd)

                UnregisterClass(MAKEINTRESOURCE(klass), hmodule);

}

#else /* G_OS_WIN32 */

static void sig_handler(gint signum)

{

        debug_print("signal %d received\n", signum);

        switch (signum) {

        case SIGHUP:

        case SIGINT:

        case SIGTERM:

        case SIGQUIT:

                app_will_exit(TRUE);

                break;

        default:

                break;

        }

}

static void register_system_events(void)

{

        struct sigaction sa;

        memset(&sa, 0, sizeof(sa));

        sa.sa_handler = sig_handler;

        sa.sa_flags = SA_RESTART;

        sigemptyset(&sa.sa_mask);

        sigaddset(&sa.sa_mask, SIGHUP);

        sigaddset(&sa.sa_mask, SIGINT);

        sigaddset(&sa.sa_mask, SIGTERM);

        sigaddset(&sa.sa_mask, SIGQUIT);

        sigaddset(&sa.sa_mask, SIGPIPE);

        sigaction(SIGHUP, &sa, NULL);

        sigaction(SIGINT, &sa, NULL);

        sigaction(SIGTERM, &sa, NULL);

        sigaction(SIGQUIT, &sa, NULL);

        sigaction(SIGPIPE, &sa, NULL);

}

#endif

static void plugin_init(void)

{

        MainWindow *mainwin;

        mainwin = main_window_get();

        if (syl_plugin_init_lib() != 0)

                return;

        syl_plugin_add_symbol("prog_version", prog_version);

        syl_plugin_add_symbol("main_window_get", main_window_get);

        syl_plugin_add_symbol("main_window_popup", main_window_popup);

        syl_plugin_add_symbol("app_will_exit", app_will_exit);

        syl_plugin_add_symbol("main_window_menu_factory",

                              mainwin->menu_factory);

        syl_plugin_add_symbol("folderview", mainwin->folderview);

        syl_plugin_add_symbol("folderview_get_selected_item",

                              folderview_get_selected_item);

        syl_plugin_add_symbol("folderview_mail_popup_factory",

                              mainwin->folderview->mail_factory);

        syl_plugin_add_symbol("summaryview", mainwin->summaryview);

        syl_plugin_add_symbol("summary_select_by_msgnum",

                              summary_select_by_msgnum);

        syl_plugin_add_symbol("summary_select_by_msginfo",

                              summary_select_by_msginfo);

        syl_plugin_add_symbol("messageview_create_with_new_window",

                              messageview_create_with_new_window);

        syl_plugin_add_symbol("messageview_show", messageview_show);

        syl_plugin_add_symbol("foldersel_folder_sel",

                              foldersel_folder_sel);

        syl_plugin_add_symbol("foldersel_folder_sel_full",

                              foldersel_folder_sel_full);

        syl_plugin_add_symbol("input_dialog", input_dialog);

        syl_plugin_add_symbol("input_dialog_with_invisible",

                              input_dialog_with_invisible);

        syl_plugin_add_symbol("manage_window_set_transient",

                              manage_window_set_transient);

        syl_plugin_add_symbol("manage_window_signals_connect",

                              manage_window_signals_connect);

        syl_plugin_add_symbol("manage_window_get_focus_window",

                              manage_window_get_focus_window);

        syl_plugin_add_symbol("inc_mail", inc_mail);

        syl_plugin_add_symbol("inc_lock", inc_lock);

        syl_plugin_add_symbol("inc_unlock", inc_unlock);

        syl_plugin_signal_connect("plugin-load", G_CALLBACK(load_cb), NULL);

#ifdef G_OS_WIN32

        {

                gchar *path;

                path = g_strconcat(get_startup_dir(), G_DIR_SEPARATOR_S,

                                   "plugins", NULL);

                syl_plugin_load_all(path);

                g_free(path);

        }

#else

        syl_plugin_load_all(PLUGINDIR);

#endif

}

static gchar *get_socket_name(void)

{

        static gchar *filename = NULL;

        if (filename == NULL) {

                filename = g_strdup_printf("%s%csylpheed-%d",

                                           g_get_tmp_dir(), G_DIR_SEPARATOR,

#if HAVE_GETUID

                                           getuid());

#else

                                           0);

#endif

        }

        return filename;

}

static gint prohibit_duplicate_launch(void)

{

        gint sock;

#ifdef G_OS_WIN32

        HANDLE hmutex;

        hmutex = CreateMutexA(NULL, FALSE, "Sylpheed");

        if (!hmutex) {

                g_warning("cannot create Mutex\n");

                return -1;

        }

        if (GetLastError() != ERROR_ALREADY_EXISTS) {

                sock = fd_open_inet(cmd.ipcport ? cmd.ipcport : REMOTE_CMD_PORT);

                if (sock < 0)

                        return 0;

                return sock;

        }

        sock = fd_connect_inet(cmd.ipcport ? cmd.ipcport : REMOTE_CMD_PORT);

        if (sock < 0)

                return -1;

#else

        gchar *path;

        path = get_socket_name();

        sock = fd_connect_unix(path);

        if (sock < 0) {

                g_unlink(path);

                return fd_open_unix(path);

        }

#endif

        /* remote command mode */

        debug_print(_("another Sylpheed is already running.\n"));

        if (cmd.receive_all)

                fd_write_all(sock, "receive_all\n", 12);

        else if (cmd.receive)

                fd_write_all(sock, "receive\n", 8);

        else if (cmd.compose && cmd.attach_files) {

                gchar *str, *compose_str;

                gint i;

                if (cmd.compose_mailto)

                        compose_str = g_strdup_printf("compose_attach %s\n",

                                                      cmd.compose_mailto);

                else

                        compose_str = g_strdup("compose_attach\n");

                fd_write_all(sock, compose_str, strlen(compose_str));

                g_free(compose_str);

                for (i = 0; i < cmd.attach_files->len; i++) {

                        str = g_ptr_array_index(cmd.attach_files, i);

                        fd_write_all(sock, str, strlen(str));

                        fd_write_all(sock, "\n", 1);

                }

                fd_write_all(sock, ".\n", 2);

        } else if (cmd.compose) {

                gchar *compose_str;

                if (cmd.compose_mailto)

                        compose_str = g_strdup_printf

                                ("compose %s\n", cmd.compose_mailto);

                else

                        compose_str = g_strdup("compose\n");

                fd_write_all(sock, compose_str, strlen(compose_str));

                g_free(compose_str);

        } else if (cmd.send) {

                fd_write_all(sock, "send\n", 5);

        } else if (cmd.status || cmd.status_full) {

                gchar buf[BUFFSIZE];

                gint i;

                const gchar *command;

                GPtrArray *folders;

                gchar *folder;

                command = cmd.status_full ? "status-full\n" : "status\n";

                folders = cmd.status_full ? cmd.status_full_folders :

                        cmd.status_folders;

                fd_write_all(sock, command, strlen(command));

                for (i = 0; folders && i < folders->len; ++i) {

                        folder = g_ptr_array_index(folders, i);

                        fd_write_all(sock, folder, strlen(folder));

                        fd_write_all(sock, "\n", 1);

                }

                fd_write_all(sock, ".\n", 2);

                for (;;) {

                        fd_gets(sock, buf, sizeof(buf));

                        if (!strncmp(buf, ".\n", 2)) break;

                        fputs(buf, stdout);

                }

        } else if (cmd.open_msg) {

                gchar *str;

                str = g_strdup_printf("open %s\n", cmd.open_msg);

                fd_write_all(sock, str, strlen(str));

                g_free(str);

        } else if (cmd.exit) {

                fd_write_all(sock, "exit\n", 5);

        } else {

#ifdef G_OS_WIN32

                HWND hwnd;

                fd_write_all(sock, "popup\n", 6);

                if (fd_read(sock, (gchar *)&hwnd, sizeof(hwnd)) == sizeof(hwnd))

                        SetForegroundWindow(hwnd);

#else

                fd_write_all(sock, "popup\n", 6);

#endif

        }

        fd_close(sock);

        return -1;

}

static gint lock_socket_remove(void)

{

#ifndef G_OS_WIN32

        gchar *filename;

#endif

        if (lock_socket < 0) return -1;

        if (lock_socket_tag > 0)

                g_source_remove(lock_socket_tag);

        if (lock_ch) {

                g_io_channel_shutdown(lock_ch, FALSE, NULL);

                g_io_channel_unref(lock_ch);

                lock_ch = NULL;

        }

#ifndef G_OS_WIN32

        filename = get_socket_name();

        g_unlink(filename);

#endif

        return 0;

}

static GPtrArray *get_folder_item_list(gint sock)

{

        gchar buf[BUFFSIZE];

        FolderItem *item;

        GPtrArray *folders = NULL;

        for (;;) {

                fd_gets(sock, buf, sizeof(buf));

                if (!strncmp(buf, ".\n", 2)) break;

                strretchomp(buf);

                if (!folders) folders = g_ptr_array_new();

                item = folder_find_item_from_identifier(buf);

                if (item)

                        g_ptr_array_add(folders, item);

                else

                        g_warning("no such folder: %s\n", buf);

        }

        return folders;

}

static gboolean lock_socket_input_cb(GIOChannel *source, GIOCondition condition,

                                     gpointer data)

{

        MainWindow *mainwin = (MainWindow *)data;

        gint fd, sock;