diff options
author | Bharath Acharya <abharath@novell.com> | 2009-01-15 22:38:05 +0800 |
---|---|---|
committer | Bharath Acharya <abharath@src.gnome.org> | 2009-01-15 22:38:05 +0800 |
commit | 8772855cc43886feadea096de92fc378330a14b4 (patch) | |
tree | 89d54d17b97fb55da62ab73b79bfabc34a564486 /plugins/pst-import/pst-importer.c | |
parent | da073416c7611f821410cd18bdc5751b43b64d91 (diff) | |
download | gsoc2013-evolution-8772855cc43886feadea096de92fc378330a14b4.tar.gz gsoc2013-evolution-8772855cc43886feadea096de92fc378330a14b4.tar.zst gsoc2013-evolution-8772855cc43886feadea096de92fc378330a14b4.zip |
** Fix for bug #208426
2009-01-15 Bharath Acharya <abharath@novell.com>
** Fix for bug #208426
* configure.in: Added support for importing .pst files into Evolution.
svn path=/trunk/; revision=37078
Diffstat (limited to 'plugins/pst-import/pst-importer.c')
-rw-r--r-- | plugins/pst-import/pst-importer.c | 1765 |
1 files changed, 1765 insertions, 0 deletions
diff --git a/plugins/pst-import/pst-importer.c b/plugins/pst-import/pst-importer.c new file mode 100644 index 0000000000..acd84c1a67 --- /dev/null +++ b/plugins/pst-import/pst-importer.c @@ -0,0 +1,1765 @@ +/* -*- Mode: C; indent-tabs-mode: t; c-basic-offset: 8; tab-width: 8 -*- */ +/* pst-importer.c +* +* Author: Chris Halls <chris.halls@credativ.co.uk> +* Bharath Acharya <abharath@novell.com> +* +* Copyright (C) 2006 Chris Halls +* +* This program is free software; you can redistribute it and/or +* modify it under the terms of the GNU Lesser General Public +* License as published by the Free Software Foundation; either +* version 2 of the License, or (at your option) version 3. +* +* 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 +* Lesser General Public License for more details. +* +* You should have received a copy of the GNU Lesser General Public +* License along with the program; if not, see <http://www.gnu.org/licenses/> +* +*/ + +#ifdef HAVE_CONFIG_H +#include <config.h> +#endif + +#define G_LOG_DOMAIN "eplugin-readpst" + +#include <sys/types.h> +#include <sys/stat.h> +#include <fcntl.h> +#include <string.h> +#include <unistd.h> +#include <errno.h> + +#include <glib/gi18n-lib.h> +#include <glib/gstdio.h> +#include <glib/gprintf.h> + +#include <gtk/gtk.h> + +#include <e-util/e-import.h> + +#include <libebook/e-contact.h> +#include <libebook/e-book.h> + +#include <libecal/e-cal.h> +#include <libecal/e-cal-component.h> + +#include <libedataserver/e-data-server-util.h> +#include <libedataserverui/e-source-selector-dialog.h> + +#include <camel/camel-folder.h> +#include <camel/camel-store.h> +#include <camel/camel-exception.h> +#include <camel/camel-mime-message.h> +#include <camel/camel-multipart.h> +#include <camel/camel-data-wrapper.h> +#include <camel/camel-stream-mem.h> +#include <camel/camel-stream-fs.h> +#include <camel/camel-file-utils.h> + +#include <mail/mail-component.h> +#include <mail/mail-mt.h> +#include <mail/mail-tools.h> +#include <mail/em-utils.h> + +#include <libpst/libpst.h> +#include <libpst/define.h> +#include <libpst/timeconv.h> + +typedef struct _PstImporter PstImporter; + +int pst_init (pst_file *pst, char *filename); +gchar *get_pst_rootname (pst_file *pst, gchar *filename); +static void pst_error_msg (const char *fmt, ...); +static void pst_import_folders (PstImporter *m, pst_desc_ll *topitem); +static void pst_process_item (PstImporter *m, pst_desc_ll *d_ptr); +static void pst_process_folder (PstImporter *m, pst_item *item); +static void pst_process_email (PstImporter *m, pst_item *item); +static void pst_process_contact (PstImporter *m, pst_item *item); +static void pst_process_appointment (PstImporter *m, pst_item *item); +static void pst_process_task (PstImporter *m, pst_item *item); +static void pst_process_journal (PstImporter *m, pst_item *item); + +static void pst_import_file (PstImporter *m); +gchar *foldername_to_utf8 (const gchar *pstname); +gchar *string_to_utf8(const gchar *string); +void contact_set_date (EContact *contact, EContactField id, FILETIME *date); +struct icaltimetype get_ical_date (FILETIME *date, gboolean is_date); +char *rfc2445_datetime_format (FILETIME *ft); + +gboolean org_credativ_evolution_readpst_supported (EPlugin *epl, EImportTarget *target); +GtkWidget *org_credativ_evolution_readpst_getwidget (EImport *ei, EImportTarget *target, EImportImporter *im); +void org_credativ_evolution_readpst_import (EImport *ei, EImportTarget *target, EImportImporter *im); +void org_credativ_evolution_readpst_cancel (EImport *ei, EImportTarget *target, EImportImporter *im); +int e_plugin_lib_enable (EPluginLib *ep, int enable); + + +/* em-folder-selection-button.h is private, even though other internal evo plugins use it! + so declare the functions here + TODO: sort out whether this should really be private +*/ +typedef struct _EMFolderSelectionButton EMFolderSelectionButton; +GtkWidget *em_folder_selection_button_new (const char *title, const char *caption); +void em_folder_selection_button_set_selection (EMFolderSelectionButton *button, const char *uri); +const char *em_folder_selection_button_get_selection (EMFolderSelectionButton *button); + +static unsigned char pst_signature [] = { '!', 'B', 'D', 'N' }; + +struct _PstImporter { + MailMsg base; + + EImport *import; + EImportTarget *target; + + GMutex *status_lock; + char *status_what; + int status_pc; + int status_timeout_id; + CamelOperation *status; + CamelException ex; + + pst_file pst; + + CamelOperation *cancel; + CamelFolder *folder; + gchar *parent_uri; + gchar *folder_name; + gchar *folder_uri; + int folder_count; + int current_item; + + EBook *addressbook; + ECal *calendar; + ECal *tasks; + ECal *journal; +}; + +gboolean +org_credativ_evolution_readpst_supported (EPlugin *epl, EImportTarget *target) +{ + char signature[sizeof (pst_signature)]; + gboolean ret = FALSE; + int fd, n; + EImportTargetURI *s; + char *filename; + + if (target->type != E_IMPORT_TARGET_URI) { + return FALSE; + } + + s = (EImportTargetURI *)target; + + if (s->uri_src == NULL) { + return TRUE; + } + + if (strncmp (s->uri_src, "file:///", strlen ("file:///")) != 0) { + return FALSE; + } + + filename = g_filename_from_uri (s->uri_src, NULL, NULL); + fd = g_open (filename, O_RDONLY, 0); + g_free (filename); + + if (fd != -1) { + n = read (fd, signature, sizeof (pst_signature)); + ret = n == sizeof (pst_signature) && memcmp (signature, pst_signature, sizeof (pst_signature)) == 0; + close (fd); + } + + return ret; +} + +static void +checkbox_mail_toggle_cb (GtkToggleButton *tb, EImportTarget *target) +{ + g_datalist_set_data (&target->data, "pst-do-mail", GINT_TO_POINTER (gtk_toggle_button_get_active (tb))); +} + +static void +checkbox_addr_toggle_cb (GtkToggleButton *tb, EImportTarget *target) +{ + g_datalist_set_data (&target->data, "pst-do-addr", GINT_TO_POINTER (gtk_toggle_button_get_active (tb))); +} + +static void +checkbox_appt_toggle_cb (GtkToggleButton *tb, EImportTarget *target) +{ + g_datalist_set_data (&target->data, "pst-do-appt", GINT_TO_POINTER (gtk_toggle_button_get_active (tb))); +} + +static void +checkbox_task_toggle_cb (GtkToggleButton *tb, EImportTarget *target) +{ + g_datalist_set_data (&target->data, "pst-do-task", GINT_TO_POINTER (gtk_toggle_button_get_active (tb))); +} + +static void +checkbox_journal_toggle_cb (GtkToggleButton *tb, EImportTarget *target) +{ + g_datalist_set_data (&target->data, "pst-do-journal", GINT_TO_POINTER (gtk_toggle_button_get_active (tb))); +} + +static void +folder_selected (EMFolderSelectionButton *button, EImportTargetURI *target) +{ + g_free (target->uri_dest); + target->uri_dest = g_strdup (em_folder_selection_button_get_selection (button)); +} + + +/** + * Suggest a folder to import data into + * @param target + * @return + */ +static gchar* +get_suggested_foldername (EImportTargetURI *target) +{ + const gchar *inbox; + gchar *delim, *filename; + gchar *rootname = NULL; + GString *foldername; + pst_file pst; + + /* Suggest a folder that is in the same mail storage as the users' inbox, + with a name derived from the .PST file */ + inbox = mail_component_get_folder_uri (NULL, MAIL_COMPONENT_FOLDER_INBOX); + + delim = g_strrstr (inbox, "#"); + if (delim != NULL) { + foldername = g_string_new_len (inbox, delim-inbox); + } else { + foldername = g_string_new (inbox); + } + + g_string_append_c (foldername, '#'); + + filename = g_filename_from_uri (target->uri_src, NULL, NULL); + + if (pst_init (&pst, filename) == 0) { + rootname = get_pst_rootname (&pst, filename); + } + + g_free (filename); + + if (rootname != NULL) { + gchar *utf8name; + utf8name = foldername_to_utf8 (rootname); + g_string_append (foldername, utf8name); + g_free (utf8name); + g_free (rootname); + } else { + g_string_append (foldername, "outlook_data"); + } + + if (mail_tool_uri_to_folder (foldername->str, 0, NULL) != NULL) { + /* Folder exists - add a number */ + int i, len; + len = foldername->len; + CamelFolder *folder; + + for (i=1; i<10000; i++) { + g_string_truncate (foldername, len); + g_string_append_printf (foldername, "_%d", i); + if ((folder=mail_tool_uri_to_folder (foldername->str, 0, NULL)) == NULL) { + /* Folder does not exist */ + break; + } + } + + if (folder != NULL) { + pst_error_msg ("Error searching for an unused folder name. uri=%s", foldername); + } + } + + return g_string_free (foldername, FALSE); + +} + +GtkWidget * +org_credativ_evolution_readpst_getwidget (EImport *ei, EImportTarget *target, EImportImporter *im) +{ + GtkWidget *hbox, *framebox, *w; + gchar *foldername; + + g_datalist_set_data (&target->data, "pst-do-mail", GINT_TO_POINTER (TRUE)); + g_datalist_set_data (&target->data, "pst-do-addr", GINT_TO_POINTER (TRUE)); + g_datalist_set_data (&target->data, "pst-do-appt", GINT_TO_POINTER (TRUE)); + g_datalist_set_data (&target->data, "pst-do-task", GINT_TO_POINTER (TRUE)); + g_datalist_set_data (&target->data, "pst-do-journal", GINT_TO_POINTER (TRUE)); + + framebox = gtk_vbox_new (FALSE, 2); + + /* Mail */ + hbox = gtk_hbox_new (FALSE, 0); + w = gtk_check_button_new_with_mnemonic (_("_Mail")); + gtk_toggle_button_set_active ((GtkToggleButton *) w, TRUE); + g_signal_connect (w, "toggled", G_CALLBACK (checkbox_mail_toggle_cb), target); + gtk_box_pack_start ((GtkBox *) hbox, w, FALSE, FALSE, 0); + + w = em_folder_selection_button_new (_("Select folder"), _("Select folder to import into")); + foldername = get_suggested_foldername ((EImportTargetURI *) target); + ((EImportTargetURI *) target)->uri_dest = g_strdup (foldername); + em_folder_selection_button_set_selection ((EMFolderSelectionButton *) w, foldername); + g_signal_connect (w, "selected", G_CALLBACK (folder_selected), target); + gtk_box_pack_end ((GtkBox *) hbox, w, FALSE, FALSE, 0); + + w = gtk_label_new (_("Destination folder:")); + gtk_box_pack_end ((GtkBox *) hbox, w, FALSE, TRUE, 6); + + gtk_box_pack_start ((GtkBox *) framebox, hbox, FALSE, FALSE, 0); + + /* Address book */ + w = gtk_check_button_new_with_mnemonic (_("_Address Book")); + gtk_toggle_button_set_active ((GtkToggleButton *) w, FALSE); + /*gtk_widget_set_sensitive ((GtkWidget *)w, FALSE);*/ /* Disable until implemented */ + g_signal_connect (w, "toggled", G_CALLBACK (checkbox_addr_toggle_cb), target); + gtk_box_pack_start ((GtkBox *) framebox, w, FALSE, FALSE, 0); + + /* Appointments */ + w = gtk_check_button_new_with_mnemonic (_("A_ppointments")); + gtk_toggle_button_set_active ((GtkToggleButton *) w, FALSE); + g_signal_connect (w, "toggled", G_CALLBACK (checkbox_appt_toggle_cb), target); + gtk_box_pack_start ((GtkBox *)framebox, w, FALSE, FALSE, 0); + + /* Tasks */ + w = gtk_check_button_new_with_mnemonic (_("_Tasks")); + gtk_toggle_button_set_active ((GtkToggleButton *)w, FALSE); + g_signal_connect (w, "toggled", G_CALLBACK (checkbox_task_toggle_cb), target); + gtk_box_pack_start ((GtkBox *)framebox, w, FALSE, FALSE, 0); + + /* Journal */ + w = gtk_check_button_new_with_mnemonic (_("_Journal entries")); + gtk_toggle_button_set_active ((GtkToggleButton *)w, FALSE); + g_signal_connect (w, "toggled", G_CALLBACK (checkbox_journal_toggle_cb), target); + gtk_box_pack_start ((GtkBox *)framebox, w, FALSE, FALSE, 0); + + gtk_widget_show_all (framebox); + + g_free (foldername); + + return framebox; +} + +static char * +pst_import_describe (PstImporter *m, int complete) +{ + return g_strdup (_("Importing Outlook data")); +} + +static ECal* +open_ecal (ECalSourceType type, char *name) +{ + /* Hack - grab the first calendar we can find + TODO - add a selection mechanism in get_widget */ + ESource *primary; + ESourceList *source_list; + ECal *cal; + + if ((e_cal_get_sources (&source_list, type, NULL)) == 0) { + g_warning ("Could not get any sources of type %s.", name); + return NULL; + } + + primary = e_source_list_peek_source_any (source_list); + + if ((cal = e_cal_new (primary, type)) == NULL) { + g_warning ("Could not create %s.", name); + g_object_unref (source_list); + return NULL; + } + + e_cal_open (cal, TRUE, NULL); + g_object_unref (primary); + g_object_unref (source_list); + + return cal; +} + +static void +pst_import_import (PstImporter *m) +{ + CamelOperation *oldcancel = NULL; + + oldcancel = camel_operation_register (m->status); + + if (GPOINTER_TO_INT (g_datalist_get_data (&m->target->data, "pst-do-addr"))) { + /* Hack - grab the first address book we can find + TODO - add a selection mechanism in get_widget */ + ESource *primary; + ESourceList *source_list; + + if (e_book_get_addressbooks (&source_list, NULL)) { + primary = e_source_list_peek_source_any (source_list); + + if ((m->addressbook = e_book_new (primary,NULL))) { + e_book_open (m->addressbook, TRUE, NULL); + g_object_unref (primary); + g_object_unref (source_list); + } else { + g_warning ("Could not create EBook."); + } + } else { + g_warning ("Could not get address books."); + } + } + + if (GPOINTER_TO_INT (g_datalist_get_data (&m->target->data, "pst-do-appt"))) { + m->calendar = open_ecal (E_CAL_SOURCE_TYPE_EVENT, "calendar"); + } + + if (GPOINTER_TO_INT (g_datalist_get_data (&m->target->data, "pst-do-task"))) { + m->tasks = open_ecal (E_CAL_SOURCE_TYPE_TODO, "task list"); + } + + if (GPOINTER_TO_INT (g_datalist_get_data (&m->target->data, "pst-do-journal"))) { + m->journal = open_ecal (E_CAL_SOURCE_TYPE_JOURNAL, "journal"); + } + + pst_import_file (m); + +/* FIXME: Crashes often in here. + if (m->addressbook) { + g_object_unref (m->addressbook); + } + + if (m->calendar) { + g_object_unref (m->calendar); + } + + if (m->tasks) { + g_object_unref (m->tasks); + } + + if (m->journal) { + g_object_unref (m->journal); + } +*/ + camel_operation_register (oldcancel); +} + +static void +pst_import_file (PstImporter *m) +{ + int ret; + gchar *filename; + pst_item *item = NULL; + pst_desc_ll *d_ptr; + + filename = g_filename_from_uri (((EImportTargetURI *)m->target)->uri_src, NULL, NULL); + m->parent_uri = g_strdup (((EImportTargetURI *)m->target)->uri_dest); /* Destination folder, was set in our widget */ + + camel_operation_start (NULL, _("Importing `%s'"), filename); + + if (GPOINTER_TO_INT (g_datalist_get_data (&m->target->data, "pst-do-mail"))) { + mail_tool_uri_to_folder (m->parent_uri, CAMEL_STORE_FOLDER_CREATE, &m->base.ex); + } + + ret = pst_init (&m->pst, filename); + + if (ret < 0) { + g_free (filename); + camel_operation_end (NULL); + return; + } + + g_free (filename); + + camel_operation_progress_count (NULL, 1); + + if ((item = pst_parse_item (&m->pst, m->pst.d_head)) == NULL) { + pst_error_msg ("Could not get root record"); + return; + } + + camel_operation_progress_count (NULL, 2); + + if ((d_ptr = pst_getTopOfFolders (&m->pst, item)) == NULL) { + pst_error_msg ("Top of folders record not found. Cannot continue"); + return; + } + + camel_operation_progress_count (NULL, 3); + pst_import_folders (m, d_ptr); + + camel_operation_progress_count (NULL, 4); + + camel_operation_end (NULL); + + pst_freeItem (item); + +} + +static void +pst_import_folders (PstImporter *m, pst_desc_ll *topitem) +{ + pst_desc_ll *d_ptr; + gchar *seperator; + + d_ptr = topitem->child; + + /* Walk through folder tree */ + while (d_ptr != NULL && (camel_operation_cancel_check (NULL) == FALSE)) { + + pst_process_item (m, d_ptr); + + if (d_ptr->child != NULL) { + g_free (m->parent_uri); + m->parent_uri = g_strdup (m->folder_uri); + d_ptr = d_ptr->child; + } else if (d_ptr->next != NULL) { + d_ptr = d_ptr->next; + } else { + while (d_ptr != topitem && d_ptr->next == NULL) { + if(m->folder_uri) { + g_free(m->folder_uri); + } + + m->folder_uri = g_strdup (m->parent_uri); + seperator = g_strrstr (m->parent_uri, "/"); + + if (seperator != NULL) { + *seperator = '\0'; /* Truncate uri */ + } + + d_ptr = d_ptr->parent; + + } + if (d_ptr == topitem) { + return; + } + + d_ptr = d_ptr->next; + } + } +} + +static void +pst_process_item (PstImporter *m, pst_desc_ll *d_ptr) +{ + pst_item *item = NULL; + + if (d_ptr->desc == NULL) + return; + + item = pst_parse_item (&m->pst, d_ptr); + + if (item == NULL) + return; + + if (item->message_store != NULL) { + pst_error_msg ("A second message_store has been found - ignored"); + pst_freeItem (item); + return; + } + + if (item->folder != NULL) { + pst_process_folder (m, item); + camel_operation_start (NULL, _("Importing `%s'"), item->file_as); + } else { + if (m->folder_count && (m->current_item < m->folder_count)) { + camel_operation_progress (NULL, (m->current_item * 100) / m->folder_count); + } else { + camel_operation_progress (NULL, 100); + } + + if (item->email != NULL && + (item->type == PST_TYPE_NOTE || item->type == PST_TYPE_REPORT)) { + + if (GPOINTER_TO_INT (g_datalist_get_data (&m->target->data, "pst-do-mail"))) + pst_process_email (m, item); + + } else if (item->contact && item->type == PST_TYPE_CONTACT) { + + if (m->addressbook && GPOINTER_TO_INT (g_datalist_get_data (&m->target->data, "pst-do-addr"))) { + pst_process_contact (m, item); + } + + } else if (item->type == PST_TYPE_APPOINTMENT) { + + if (m->calendar && GPOINTER_TO_INT (g_datalist_get_data (&m->target->data, "pst-do-appt"))) { + pst_process_appointment (m, item); + } + + } else if (item->type == PST_TYPE_TASK) { + + if (m->tasks && GPOINTER_TO_INT (g_datalist_get_data (&m->target->data, "pst-do-task"))) { + pst_process_task (m, item); + } + + } else if (item->type == PST_TYPE_JOURNAL) { + + if (m->journal && GPOINTER_TO_INT (g_datalist_get_data (&m->target->data, "pst-do-journal"))) { + pst_process_journal (m, item); + } + + } + + m->current_item++; + } + + pst_freeItem (item); + + if (d_ptr->next == NULL) { + camel_operation_end (NULL); + } +} + +/** + * Convert string to utf8. Currently we just use the locale, but maybe there is encoding + * information hidden somewhere in the PST file? + * + * @param string String from PST file + * @return utf8 representation (caller should free), or NULL for error. + */ +gchar * +string_to_utf8(const gchar *string) +{ + gchar *utf8; + + utf8 = g_locale_to_utf8 (string, -1, NULL, NULL, NULL); + + return utf8; +} + +/** + * Convert foldername to utf8 and escape characters if needed + * @param foldername from PST file + * @return converted folder name, or NULL for error. Caller should free + */ +gchar * +foldername_to_utf8 (const gchar *pstname) +{ + gchar *utf8name, *folder_name; + + utf8name = string_to_utf8(pstname); + + if (utf8name == NULL) { + folder_name = camel_url_encode (pstname, NULL); + g_warning ("foldername_to_utf8: Cannot convert to utf8! foldername=%s", folder_name); + } else { + /* Encode using the current locale */ + folder_name = camel_url_encode (utf8name, NULL); + g_free (utf8name); + } + + g_strdelimit (folder_name, "/", '_'); + g_strescape (folder_name, NULL); + + return folder_name; +} + +static void +pst_process_folder (PstImporter *m, pst_item *item) +{ + gchar *uri; + g_free (m->folder_name); + g_free (m->folder_uri); + + if (item->file_as != NULL) { + m->folder_name = foldername_to_utf8 (item->file_as); + } else { + g_critical ("Folder: No name! item->file_as=%s", item->file_as); + m->folder_name = g_strdup ("unknown_name"); + } + + uri = g_strjoin ("/", m->parent_uri, m->folder_name, NULL); + m->folder_uri = uri; + + if (m->folder) { + camel_object_unref (m->folder); + m->folder = NULL; + } + + m->folder_count = item->folder->email_count; + m->current_item = 0; +} + +/** + * Create current folder in mail hierarchy. Parent folders will also be created. + * @param m PstImporter set to current folder + */ +static void +pst_create_folder (PstImporter *m) +{ + const gchar *parent; + gchar *dest, *dest_end, *pos; + int dest_len; + + parent = ((EImportTargetURI *)m->target)->uri_dest; + dest = g_strdup (m->folder_uri); + + g_assert (g_str_has_prefix (dest, parent)); + + dest_len = strlen (dest); + dest_end = dest + dest_len; + + pos = dest + strlen(parent); + + while (pos != NULL && pos < dest_end) { + pos = g_strstr_len (pos+1, dest_end-pos, "/"); + if (pos != NULL) { + CamelFolder *folder; + + *pos = '\0'; + + folder = mail_tool_uri_to_folder (dest, CAMEL_STORE_FOLDER_CREATE, &m->base.ex); + camel_object_unref(folder); + *pos = '/'; + } + } + + g_free (dest); + + if (m->folder) { + camel_object_unref (m->folder); + } + + m->folder = mail_tool_uri_to_folder (m->folder_uri, CAMEL_STORE_FOLDER_CREATE, &m->base.ex); + +} + +/** + * Create a camel mime part from given PST attachment + * @param attach attachment to convert + * @return CamelMimePart containing data and mime type + */ +static CamelMimePart * +attachment_to_part (PstImporter *m, pst_item_attach *attach) +{ + CamelMimePart *part; + char *mimetype; + + part = camel_mime_part_new (); + + if (attach->filename2 || attach->filename1) { + camel_mime_part_set_filename (part, (attach->filename2 ? attach->filename2 : attach->filename1)); + camel_mime_part_set_disposition (part, "attachment"); + camel_mime_part_set_encoding (part, CAMEL_TRANSFER_ENCODING_BASE64); + } else { + camel_mime_part_set_disposition (part, "inline"); + } + + if (attach->mimetype != NULL) { + mimetype = attach->mimetype; + } else { + mimetype = "application/octet-stream"; + } + + if (attach->data != NULL) { + camel_mime_part_set_content (part, attach->data, strlen (attach->data), mimetype); + } else { + char *buf = NULL; + size_t size; + size = pst_attach_to_mem (&m->pst, attach, &buf); + + camel_mime_part_set_content (part, (char*) buf, size, mimetype); + free(buf); + } + + return part; +} + +static void +pst_process_email (PstImporter *m, pst_item *item) +{ + CamelMimeMessage *msg; + CamelInternetAddress *addr; + CamelMultipart *mp; + CamelMimePart *part; + CamelMessageInfo *info; + + if (m->folder == NULL) { + pst_create_folder (m); + } + + camel_folder_freeze (m->folder); + + msg = camel_mime_message_new (); + + if (item->email->subject != NULL) { + gchar *subj; + + subj = string_to_utf8 (item->email->subject->subj); + if (subj == NULL) { + g_warning ("Could not convert email subject to utf8: %s", item->email->subject->subj); + camel_mime_message_set_subject (msg, "(lost subject)"); + } else { + camel_mime_message_set_subject (msg, subj); + g_free(subj); + } + } + + addr = camel_internet_address_new (); + + if (item->email->outlook_sender_name != NULL && item->email->outlook_sender != NULL) { + camel_internet_address_add (addr, item->email->outlook_sender_name, item->email->outlook_sender); + } else if (item->email->outlook_sender_name != NULL) { + camel_address_decode (CAMEL_ADDRESS (addr), item->email->outlook_sender_name); + } else if (item->email->outlook_sender != NULL) { + camel_address_decode (CAMEL_ADDRESS (addr), item->email->outlook_sender); + } else { + /* Evo prints a warning if no from is set, so supply an empty address */ + camel_internet_address_add (addr, "", ""); + } + + camel_mime_message_set_from (msg, addr); + camel_object_unref (addr); + + if (item->email->sent_date != NULL) { + camel_mime_message_set_date (msg, fileTimeToUnixTime (item->email->sent_date, 0), 0); + } + + if (item->email->messageid != NULL) { + camel_mime_message_set_message_id (msg, item->email->messageid); + } + + if (item->email->header != NULL) { + /* Use mime parser to read headers */ + CamelStream *stream; + /*g_debug (" Email headers length=%zd", strlen (item->email->header));*/ + /*g_message (" Email headers... %s...", item->email->header);*/ + + stream = camel_stream_mem_new_with_buffer (item->email->header, strlen (item->email->header)); + if (camel_data_wrapper_construct_from_stream ((CamelDataWrapper *)msg, stream) == -1) + g_warning ("Error reading headers, skipped"); + + } else { + + if (item->email->sentto_address != NULL) { + addr = camel_internet_address_new (); + + if (camel_address_decode (CAMEL_ADDRESS (addr), item->email->sentto_address) > 0); + camel_mime_message_set_recipients (msg, "To", addr); + + camel_object_unref (addr); + } + + if (item->email->cc_address != NULL) { + addr = camel_internet_address_new (); + + if (camel_address_decode (CAMEL_ADDRESS (addr), item->email->cc_address) > 0); + camel_mime_message_set_recipients (msg, "CC", addr); + + camel_object_unref (addr); + } + } + + mp = camel_multipart_new (); + + if (item->attach != NULL) { + + camel_data_wrapper_set_mime_type (CAMEL_DATA_WRAPPER (mp), "multipart/mixed"); + + } else if (item->email->htmlbody && item->email->body) { + + camel_data_wrapper_set_mime_type (CAMEL_DATA_WRAPPER (mp), "multipart/alternate"); + + } else if (item->email->htmlbody) { + + camel_data_wrapper_set_mime_type (CAMEL_DATA_WRAPPER (mp), "text/html"); + + } + + camel_multipart_set_boundary (mp, NULL); + + if (item->email->body != NULL) { + /* Read internet headers */ + + /*g_debug (" Email body length=%zd", strlen (item->email->body)); + g_message (" Email body %100s...", item->email->body);*/ + + part = camel_mime_part_new (); + camel_mime_part_set_content (part, item->email->body, strlen (item->email->body), "text/plain"); + camel_multipart_add_part (mp, part); + camel_object_unref (part); + } + + if (item->email->htmlbody != NULL) { + /*g_debug (" HTML body length=%zd", strlen (item->email->htmlbody));*/ + part = camel_mime_part_new (); + camel_mime_part_set_content (part, item->email->htmlbody, strlen (item->email->htmlbody), "text/html"); + camel_multipart_add_part (mp, part); + camel_object_unref (part); + } + + item->current_attach = item->attach; + + while (item->current_attach != NULL) { + pst_item_attach *attach; + + attach = item->current_attach; + part = attachment_to_part(m, attach); + + camel_multipart_add_part (mp, part); + camel_object_unref (part); + + item->current_attach = item->current_attach->next; + } + + /*camel_mime_message_dump (msg, TRUE);*/ + + if (item->email->htmlbody || item->attach) { + camel_medium_set_content_object (CAMEL_MEDIUM (msg), CAMEL_DATA_WRAPPER (mp)); + } else if (item->email->body) { + camel_mime_part_set_content (CAMEL_MIME_PART (msg), item->email->body, strlen (item->email->body), "text/plain"); + } else { + g_warning ("Email without body. Subject:%s", + (item->email->subject->subj ? item->email->subject->subj : "(empty)")); + camel_mime_part_set_content (CAMEL_MIME_PART (msg), "\n", 1, "text/plain"); + } + + info = camel_message_info_new (NULL); + + /* Read message flags (see comments in libpst.c */ + if(item->email->flag && 0x01) + camel_message_info_set_flags (info, CAMEL_MESSAGE_SEEN, ~0); + + if(item->email->importance == 2) + camel_message_info_set_flags (info, CAMEL_MESSAGE_FLAGGED, ~0); + + if(item->email->flag && 0x08) + camel_message_info_set_flags (info, CAMEL_MESSAGE_DRAFT, ~0); + + camel_folder_append_message (m->folder, msg, info, NULL, &m->ex); + camel_message_info_free (info); + camel_object_unref (msg); + + camel_folder_sync (m->folder, FALSE, NULL); + camel_folder_thaw (m->folder); + + if (camel_exception_is_set (&m->ex)) { + g_critical ("Exception!"); + camel_exception_clear (&m->ex); + return; + } + +} + +static void +contact_set_string (EContact *contact, EContactField id, char *string) +{ + if (string != NULL) { + e_contact_set (contact, id, string); + } +} + +static void +unknown_field (EContact *contact, GString *notes, char *name, char *string) +{ + /* Field could not be mapped directly so add to notes field */ + if (string != NULL) { + g_string_append_printf (notes, "%s: %s\n", name, string); + } +} + +static void +contact_set_address (EContact *contact, EContactField id, char *address, char *city, char *country, char *po_box, char *postal_code, char *state, char *street) +{ + EContactAddress *eaddress; + + if (address || city || country || po_box || postal_code || state || street) { + eaddress = g_new0 (EContactAddress, 1); + if (po_box) { + eaddress->po = g_strdup (po_box); + } + //eaddress->ext = + + if (street) { + eaddress->street = g_strdup (street); + } + + if (city) { + eaddress->locality = g_strdup (city); + } + + if (state) { + eaddress->region = g_strdup (state); + } + + if (postal_code) { + eaddress->code = g_strdup (postal_code); + } + + if (country) { + eaddress->country = g_strdup (country); + } + + e_contact_set (contact, id, eaddress); + } +} + +void +contact_set_date (EContact *contact, EContactField id, FILETIME *date) +{ + if (date && (date->dwLowDateTime || date->dwHighDateTime) ) { + time_t t1; + struct tm tm; + EContactDate *bday; + bday = e_contact_date_new (); + + t1 = fileTimeToUnixTime (date, 0); + gmtime_r (&t1, &tm); + + bday->year = tm.tm_year + 1900; + bday->month = tm.tm_mon + 1; + bday->day = tm.tm_mday; + + e_contact_set (contact, id, bday); + } +} + +static void +pst_process_contact (PstImporter *m, pst_item *item) +{ + pst_item_contact *c; + EContact *ec; + c = item->contact; + GString *notes; + + notes = g_string_sized_new (2048); + + ec = e_contact_new (); + /* pst's fullname field only contains first, middle, surname */ + if (c->display_name_prefix || c->suffix) { + GString *name = g_string_sized_new (128); + + if (c->display_name_prefix) { + g_string_assign (name, c->display_name_prefix); + } + + if (c->first_name) { + g_string_append_printf (name, "%s%s", (name->len ? " " : ""), c->first_name); + } + + if (c->middle_name) { + g_string_append_printf (name, "%s%s", (name->len ? " " : ""), c->middle_name); + } + + if (c->surname) { + g_string_append_printf (name, "%s%s", (name->len ? " " : ""), c->surname); + } + + if (c->suffix) { + g_string_append_printf (name, "%s%s", (name->len ? " " : ""), c->suffix); + } + + contact_set_string (ec, E_CONTACT_FULL_NAME, name->str); + g_string_free (name, TRUE); + + } else { + contact_set_string (ec, E_CONTACT_FULL_NAME, c->fullname); + } + + /* unknown_field (ec, notes, "initials", c->initials); */ + + contact_set_string (ec, E_CONTACT_NICKNAME, c->nickname); + + contact_set_string (ec, E_CONTACT_ORG, c->company_name); + contact_set_string (ec, E_CONTACT_ORG_UNIT, c->department); + contact_set_string (ec, E_CONTACT_TITLE, c->job_title); + + contact_set_address (ec,E_CONTACT_ADDRESS_WORK, + c->business_address, c->business_city, c->business_country, + c->business_po_box, c->business_postal_code, c->business_state, c->business_street); + + contact_set_address (ec,E_CONTACT_ADDRESS_HOME, + c->home_address, c->home_city, c->home_country, + c->home_po_box, c->home_postal_code, c->home_state, c->home_street); + + contact_set_address (ec,E_CONTACT_ADDRESS_OTHER, + c->other_address, c->other_city, c->other_country, + c->other_po_box, c->other_postal_code, c->other_state, c->other_street); + + contact_set_string (ec, E_CONTACT_PHONE_ASSISTANT, c->assistant_phone); + contact_set_string (ec, E_CONTACT_PHONE_BUSINESS_FAX, c->business_fax); + contact_set_string (ec, E_CONTACT_PHONE_BUSINESS, c->business_phone); + contact_set_string (ec, E_CONTACT_PHONE_BUSINESS_2, c->business_phone2); + contact_set_string (ec, E_CONTACT_PHONE_CALLBACK, c->callback_phone); + contact_set_string (ec, E_CONTACT_PHONE_CAR, c->car_phone); + contact_set_string (ec, E_CONTACT_PHONE_COMPANY, c->company_main_phone); + contact_set_string (ec, E_CONTACT_PHONE_HOME_FAX, c->home_fax); + contact_set_string (ec, E_CONTACT_PHONE_HOME, c->home_phone); + contact_set_string (ec, E_CONTACT_PHONE_HOME_2, c->home_phone2); + contact_set_string (ec, E_CONTACT_PHONE_ISDN, c->isdn_phone); + contact_set_string (ec, E_CONTACT_PHONE_MOBILE, c->mobile_phone); + contact_set_string (ec, E_CONTACT_PHONE_OTHER_FAX, c->primary_fax); /* ? */ + contact_set_string (ec, E_CONTACT_PHONE_PAGER, c->pager_phone); + contact_set_string (ec, E_CONTACT_PHONE_PRIMARY, c->primary_phone); + contact_set_string (ec, E_CONTACT_PHONE_RADIO, c->radio_phone); + contact_set_string (ec, E_CONTACT_PHONE_TTYTDD, c->ttytdd_phone); + contact_set_string (ec, E_CONTACT_PHONE_TELEX, c->telex); + unknown_field (ec, notes, "account_name", c->account_name); + contact_set_date (ec, E_CONTACT_ANNIVERSARY, c->wedding_anniversary); + contact_set_string (ec, E_CONTACT_ASSISTANT, c->assistant_name); + unknown_field (ec, notes, "billing_information", c->billing_information); + contact_set_date (ec, E_CONTACT_BIRTH_DATE, c->birthday); + /* contact_set_string (ec, E_CONTACT_CATEGORIES, c->??); */ + + contact_set_string (ec, E_CONTACT_EMAIL_1 , c->address1); + contact_set_string (ec, E_CONTACT_EMAIL_2 , c->address2); + contact_set_string (ec, E_CONTACT_EMAIL_3 , c->address3); + + /*unknown_field (ec, notes, "address1_desc" , c->address1_desc); + unknown_field (ec, notes, "address1_transport" , c->address1_transport); + unknown_field (ec, notes, "address2_desc" , c->address2_desc); + unknown_field (ec, notes, "address2_transport" , c->address2_transport); + unknown_field (ec, notes, "address3_desc" , c->address3_desc); + unknown_field (ec, notes, "address3_transport" , c->address3_transport);*/ + + /*unknown_field (ec, notes, "def_postal_address", c->def_postal_address);*/ + + /* unknown_field (ec, ??, c->gender); */ + unknown_field (ec, notes, "access_method", c->access_method); + unknown_field (ec, notes, "gov_id", c->gov_id); + unknown_field (ec, notes, "customer_id", c->customer_id); + unknown_field (ec, notes, "hobbies", c->hobbies); + unknown_field (ec, notes, "followup", c->followup); + + contact_set_string (ec, E_CONTACT_FREEBUSY_URL , c->free_busy_address); + + unknown_field (ec, notes, "keyword", c->keyword); + unknown_field (ec, notes, "language", c->language); + unknown_field (ec, notes, "location", c->location); + contact_set_string (ec, E_CONTACT_OFFICE, c->office_loc); + unknown_field (ec, notes, "computer_name", c->computer_name); + unknown_field (ec, notes, "ftp_site", c->ftp_site); + + contact_set_string (ec, E_CONTACT_MANAGER , c->manager_name); + unknown_field (ec, notes, "mileage", c->mileage); + unknown_field (ec, notes, "org_id", c->org_id); + contact_set_string (ec, E_CONTACT_ROLE, c->profession); + + contact_set_string (ec, E_CONTACT_SPOUSE , c->spouse_name); + + if (c->personal_homepage) { + contact_set_string (ec, E_CONTACT_HOMEPAGE_URL , c->personal_homepage); + if (c->business_homepage) { + unknown_field (ec, notes, "business_homepage", c->business_homepage); + } + } else if (c->business_homepage) { + contact_set_string (ec, E_CONTACT_HOMEPAGE_URL , c->business_homepage); + } + + if (item->comment) { + g_string_append_printf (notes, "%s\n", item->comment); + } + + if (item->email && item->email->body) { + g_string_append_printf (notes, "%s\n", item->email->body); + } + + contact_set_string (ec, E_CONTACT_NOTE, notes->str); + g_string_free (notes, TRUE); + + e_book_add_contact (m->addressbook, ec, NULL); + g_object_unref (ec); + +} + +/** + * Convert pst time to icaltimetype + * @param date time value from libpst + * @param is_date treat as date only (all day event)? + * @return converted date + */ +struct icaltimetype +get_ical_date (FILETIME *date, gboolean is_date) +{ + if (date && (date->dwLowDateTime || date->dwHighDateTime) ) { + time_t t; + + t = fileTimeToUnixTime (date, 0); + return icaltime_from_timet_with_zone (t, is_date, NULL); + } else { + return icaltime_null_date (); + } +} + +char *rfc2445_datetime_format (FILETIME *ft) { + static char* buffer = NULL; + struct tm *stm = NULL; + + if (buffer == NULL) { + buffer = malloc (30); // should be enough + } + + stm = fileTimeToStructTM (ft); + strftime (buffer, 30, "%Y%m%dT%H%M%SZ", stm); + return buffer; +} + +static void +set_cal_attachments (ECal *cal, ECalComponent *ec, PstImporter *m, pst_item_attach *attach) +{ + GSList *list = NULL; + const char *uid; + char *store_dir; + + if (attach == NULL) { + return; + } + + e_cal_component_get_uid (ec, &uid); + store_dir = g_filename_from_uri (e_cal_get_local_attachment_store (cal), NULL, NULL); + + while (attach != NULL) { + const char* orig_filename; + char *filename, *tmp, *path, *dirname, *uri; + CamelMimePart *part; + CamelDataWrapper *content; + CamelStream *stream; + struct stat st; + + part = attachment_to_part(m, attach); + + orig_filename = camel_mime_part_get_filename(part); + + if (orig_filename == NULL) { + g_warning("Ignoring unnamed attachment"); + attach = attach->next; + continue; /* Ignore unnamed attachments */ + } + + tmp = camel_file_util_safe_filename (orig_filename); + filename = g_strdup_printf ("%s-%s", uid, tmp); + path = g_build_filename (store_dir, filename, NULL); + + g_free (tmp); + g_free (filename); + + dirname = g_path_get_dirname(path); + if (g_mkdir_with_parents(dirname, 0777) == -1) { + g_warning("Could not create directory %s: %s", dirname, g_strerror(errno)); + g_free(dirname); + attach = attach->next; + continue; + } + g_free(dirname); + + if (g_access(path, F_OK) == 0) { + if (g_access(path, W_OK) != 0) { + g_warning("Could not write file %s - file exists", path); + attach = attach->next; + continue; + } + } + + if (g_stat(path, &st) != -1 && !S_ISREG(st.st_mode)) { + g_warning("Could not write file %s - not a file", path); + attach = attach->next; + continue; + } + + if (!(stream = camel_stream_fs_new_with_name (path, O_WRONLY | O_CREAT | O_TRUNC, 0666))) { + g_warning ("Could not create stream for file %s - %s", path, g_strerror (errno)); + attach = attach->next; + continue; + } + + content = camel_medium_get_content_object (CAMEL_MEDIUM (part)); + + if (camel_data_wrapper_decode_to_stream (content, stream) == -1 + || camel_stream_flush (stream) == -1) + { + g_warning ("Could not write attachment to %s: %s", path, g_strerror (errno)); + camel_object_unref (stream); + attach = attach->next; + continue; + } + + camel_object_unref (stream); + + uri = g_filename_to_uri (path, NULL, NULL); + list = g_slist_append (list, g_strdup (uri)); + g_free (uri); + + camel_object_unref (part); + g_free (path); + + attach = attach->next; + + } + + g_free (store_dir); + + e_cal_component_set_attachment_list (ec, list); +} + +static void +fill_calcomponent (PstImporter *m, pst_item *item, ECalComponent *ec, const char *type) +{ + pst_item_appointment *a; + pst_item_email *e; + + a = item->appointment; + e = item->email; + ECalComponentText text; + struct icaltimetype tt_start, tt_end; + ECalComponentDateTime dt_start, dt_end; + + if (item->create_date) { + struct icaltimetype tt; + tt = get_ical_date (item->create_date, FALSE); + e_cal_component_set_created (ec, &tt); + } + if (item->modify_date) { + struct icaltimetype tt; + tt = get_ical_date (item->modify_date, FALSE); + e_cal_component_set_last_modified (ec, &tt); + } + + if (e) { + if (e->subject || e->proc_subject) { + if (e->subject) { + text.value = e->subject->subj; + } else if (e->proc_subject) { + text.value = e->proc_subject; + } + + text.altrep = NULL; /* email->proc_subject? */ + e_cal_component_set_summary (ec, &text); + } + if (e->body) { + GSList l; + text.value = e->body; + text.altrep = NULL; + l.data = &text; + l.next = NULL; + e_cal_component_set_description_list (ec, &l); + } + } else { + g_warning ("%s without subject / body!", type); + } + + if (a->location) { + e_cal_component_set_location (ec, a->location); + } + + if (a->start) { + tt_start = get_ical_date (a->start, a->all_day); + dt_start.value = &tt_start; + dt_start.tzid = NULL; + e_cal_component_set_dtstart (ec, &dt_start); + } + + if (a->end) { + tt_end = get_ical_date (a->end, a->all_day); + dt_end.value = &tt_end; + dt_end.tzid = NULL; + e_cal_component_set_dtend (ec, &dt_end); + } + + switch (a->showas) { + case PST_FREEBUSY_TENTATIVE: + e_cal_component_set_status (ec, ICAL_STATUS_TENTATIVE); + break; + case PST_FREEBUSY_FREE: + // mark as transparent and as confirmed + e_cal_component_set_transparency (ec, E_CAL_COMPONENT_TRANSP_TRANSPARENT); + case PST_FREEBUSY_BUSY: + case PST_FREEBUSY_OUT_OF_OFFICE: + e_cal_component_set_status (ec, ICAL_STATUS_CONFIRMED); + break; + } + switch (a->label) { + case PST_APP_LABEL_NONE: + break; + case PST_APP_LABEL_IMPORTANT: + e_cal_component_set_categories (ec, "Important"); break; + case PST_APP_LABEL_BUSINESS: + e_cal_component_set_categories (ec, "Business"); break; + case PST_APP_LABEL_PERSONAL: + e_cal_component_set_categories (ec, "Personal"); break; + case PST_APP_LABEL_VACATION: + e_cal_component_set_categories (ec, "Vacation"); break; + case PST_APP_LABEL_MUST_ATTEND: + e_cal_component_set_categories (ec, "Must-attend"); break; + case PST_APP_LABEL_TRAVEL_REQ: + e_cal_component_set_categories (ec, "Travel-required"); break; + case PST_APP_LABEL_NEEDS_PREP: + e_cal_component_set_categories (ec, "Needs-preparation"); break; + case PST_APP_LABEL_BIRTHDAY: + e_cal_component_set_categories (ec, "Birthday"); break; + case PST_APP_LABEL_ANNIVERSARY: + e_cal_component_set_categories (ec, "Anniversary"); break; + case PST_APP_LABEL_PHONE_CALL: + e_cal_component_set_categories (ec, "Phone-call"); break; + } + + if (a->alarm || a->alarm_minutes) { + ECalComponentAlarm *alarm; + ECalComponentAlarmTrigger trigger; + + alarm = e_cal_component_alarm_new (); + + if (a->alarm_minutes) { + trigger.type = E_CAL_COMPONENT_ALARM_TRIGGER_RELATIVE_START; + trigger.u.rel_duration = icaldurationtype_from_int (- (a->alarm_minutes)*60); + e_cal_component_alarm_set_trigger (alarm, trigger); + } + + if (a->alarm) { + if (a->alarm_filename) { + e_cal_component_alarm_set_action (alarm, E_CAL_COMPONENT_ALARM_AUDIO); + } else { + e_cal_component_alarm_set_action (alarm, E_CAL_COMPONENT_ALARM_DISPLAY); + } + } + + e_cal_component_add_alarm (ec, alarm); + e_cal_component_alarm_free(alarm); + + } + + if (a->recurrence != PST_APP_RECUR_NONE) { + struct icalrecurrencetype r; + GSList recur_list; + + icalrecurrencetype_clear (&r); + r.interval = 1; /* Interval not implemented in libpst */ + if (a->recurrence_end) { + r.until = get_ical_date (a->recurrence_end, FALSE); + } + + switch (a->recurrence_type) { + case PST_APP_RECUR_DAILY: + r.freq = ICAL_DAILY_RECURRENCE; break; + case PST_APP_RECUR_WEEKLY: + r.freq = ICAL_WEEKLY_RECURRENCE; break; + case PST_APP_RECUR_MONTHLY: + r.freq = ICAL_MONTHLY_RECURRENCE; break; + case PST_APP_RECUR_YEARLY: + r.freq = ICAL_YEARLY_RECURRENCE; break; + default: + r.freq = ICAL_NO_RECURRENCE; + } + + recur_list.data = &r; + recur_list.next = NULL; + e_cal_component_set_rrule_list (ec, &recur_list); + } + +} + +static void +pst_process_appointment (PstImporter *m, pst_item *item) +{ + ECalComponent *ec; + + ec = e_cal_component_new (); + e_cal_component_set_new_vtype (ec, E_CAL_COMPONENT_EVENT); + + fill_calcomponent (m, item, ec, "appointment"); + set_cal_attachments (m->calendar, ec, m, item->attach); + + if (!e_cal_create_object (m->calendar, e_cal_component_get_icalcomponent (ec), NULL, NULL)) { + g_warning("Creation of appointment failed"); + g_free(ec); + } + + g_object_unref (ec); + +} + +static void +pst_process_task (PstImporter *m, pst_item *item) +{ + ECalComponent *ec; + + ec = e_cal_component_new (); + e_cal_component_set_new_vtype (ec, E_CAL_COMPONENT_TODO); + + fill_calcomponent (m, item, ec, "task"); + set_cal_attachments (m->tasks, ec, m, item->attach); + + /* Note - libpst is missing many fields. E.g. task status, start/completion date, % complete */ + + if (!e_cal_create_object (m->tasks, e_cal_component_get_icalcomponent (ec), NULL, NULL)) { + g_warning("Creation of task failed"); + g_free(ec); + } + + g_object_unref (ec); + +} + +static void +pst_process_journal (PstImporter *m, pst_item *item) +{ + struct pst_item_journal *j; + ECalComponent *ec; + + j = item->journal; + ec = e_cal_component_new (); + e_cal_component_set_new_vtype (ec, E_CAL_COMPONENT_JOURNAL); + + fill_calcomponent (m, item, ec, "journal"); + set_cal_attachments (m->journal, ec, m, item->attach); + + /* Note - an Evo memo entry does not have date started/finished or type fields :( */ + /*if (j) { + ECalComponentText text; + struct icaltimetype tt_start, tt_end; + ECalComponentDateTime dt_start, dt_end; + + if (j->start) { + tt_start = get_ical_date (j->start, FALSE); + dt_start.value = &tt_start; + dt_start.tzid = NULL; + e_cal_component_set_dtstart (ec, &dt_start); + g_message ("journal start:%s", rfc2445_datetime_format (j->start)); + } + + if (j->end) { + tt_end = get_ical_date (j->end, FALSE); + dt_end.value = &tt_end; + dt_end.tzid = NULL; + e_cal_component_set_dtend (ec, &dt_end); + g_message ("end:%s", rfc2445_datetime_format (j->end)); + } + g_message ("type: %s", j->type); + }*/ + + if (!e_cal_create_object (m->journal, e_cal_component_get_icalcomponent (ec), NULL, NULL)) { + g_warning("Creation of journal entry failed"); + g_free(ec); + } + + g_object_unref (ec); + +} + +/* Print an error message - maybe later bring up an error dialog? */ +static void +pst_error_msg (const char *fmt, ...) +{ + va_list ap; + + va_start (ap, fmt); + g_critical (fmt, ap); + va_end (ap); +} + +static void +pst_import_imported (PstImporter *m) +{ + e_import_complete (m->target->import, (EImportTarget *)m->target); +} + +static void +pst_import_free (PstImporter *m) +{ +// pst_close (&m->pst); + camel_operation_unref (m->status); + + g_free (m->status_what); + g_mutex_free (m->status_lock); + + g_source_remove (m->status_timeout_id); + m->status_timeout_id = 0; + + g_free (m->folder_name); + g_free (m->folder_uri); + g_free (m->parent_uri); + + g_object_unref (m->import); +} + +static MailMsgInfo pst_import_info = { + sizeof (PstImporter), + (MailMsgDescFunc) pst_import_describe, + (MailMsgExecFunc) pst_import_import, + (MailMsgDoneFunc) pst_import_imported, + (MailMsgFreeFunc) pst_import_free, +}; + +static gboolean +pst_status_timeout (void *data) +{ + PstImporter *importer = data; + int pc; + char *what; + + if (importer->status_what) { + g_mutex_lock (importer->status_lock); + what = importer->status_what; + importer->status_what = NULL; + pc = importer->status_pc; + g_mutex_unlock (importer->status_lock); + + e_import_status (importer->target->import, (EImportTarget *)importer->target, what, pc); + } + + return TRUE; +} + +static void +pst_status (CamelOperation *op, const char *what, int pc, void *data) +{ + PstImporter *importer = data; + + if (pc == CAMEL_OPERATION_START) { + pc = 0; + } else if (pc == CAMEL_OPERATION_END) { + pc = 100; + } + + g_mutex_lock (importer->status_lock); + g_free (importer->status_what); + importer->status_what = g_strdup (what); + importer->status_pc = pc; + g_mutex_unlock (importer->status_lock); +} + +static int +pst_import (EImport *ei, EImportTarget *target) +{ + PstImporter *m; + int id; + + m = mail_msg_new (&pst_import_info); + g_datalist_set_data (&target->data, "pst-msg", m); + m->import = ei; + g_object_ref (m->import); + m->target = target; + + m->parent_uri = NULL; + m->folder_name = NULL; + m->folder_uri = NULL; + + m->addressbook = NULL; + m->calendar = NULL; + m->tasks = NULL; + m->journal = NULL; + + m->status_timeout_id = g_timeout_add (100, pst_status_timeout, m); + /*m->status_timeout_id = NULL;*/ + m->status_lock = g_mutex_new (); + m->status = camel_operation_new (pst_status, m); + + id = m->base.seq; + + mail_msg_unordered_push (m); + + return id; +} + +/* Start the main import operation */ +void +org_credativ_evolution_readpst_import (EImport *ei, EImportTarget *target, EImportImporter *im) +{ + if (GPOINTER_TO_INT (g_datalist_get_data (&target->data, "pst-do-mail")) + || GPOINTER_TO_INT (g_datalist_get_data (&target->data, "pst-do-addr")) + || GPOINTER_TO_INT (g_datalist_get_data (&target->data, "pst-do-appt")) + || GPOINTER_TO_INT (g_datalist_get_data (&target->data, "pst-do-task")) + || GPOINTER_TO_INT (g_datalist_get_data (&target->data, "pst-do-journal"))) { + pst_import (ei, target); + } else { + e_import_complete (target->import, target); + } +} + +void +org_credativ_evolution_readpst_cancel (EImport *ei, EImportTarget *target, EImportImporter *im) +{ + PstImporter *m = g_datalist_get_data (&target->data, "pst-msg"); + + if (m) { + camel_operation_cancel (m->status); + } +} + +int +e_plugin_lib_enable (EPluginLib *ep, int enable) +{ + if (enable) { + bindtextdomain (GETTEXT_PACKAGE, LOCALEDIR); + bind_textdomain_codeset (GETTEXT_PACKAGE, "UTF-8"); + g_message ("pst Plugin enabled"); + } else { + g_message ("pst Plugin disabled"); + } + + return 0; +} + +/** + * Open PST file and determine root folder name + * @param pst: pst_file structure to be used by libpst + * @param filename : path to file + * @return 0 for sucess, -1 for failure + */ +int +pst_init (pst_file *pst, gchar *filename) +{ + +#if 0 + char *d_log = "readpst.log"; + /* initialize log file */ + DEBUG_INIT (d_log); + DEBUG_REGISTER_CLOSE (); +#endif + + DEBUG_ENT ("main"); + if (pst_open (pst, filename) < 0) { + pst_error_msg ("Error opening PST file %s", filename); + return -1; + } + + if (pst_load_index (pst) < 0) { + pst_error_msg ("Error loading indexes"); + return -1; + } + + if (pst_load_extended_attributes (pst) < 0) { + pst_error_msg ("Error loading file items"); + return -1; + } + + return 0; +} + +/** + * Open determine root folder name of PST file + * @param pst: pst_file structure to be used by libpst + * @param filename : if non NULL, fallback to this name if folder name is not available + * @return pointer to name of root folder (should be freed by caller), or NULL if error + */ +gchar * +get_pst_rootname (pst_file *pst, gchar *filename) +{ + pst_item *item = NULL; + gchar *rootname = NULL; + + if ((item = pst_parse_item (pst, pst->d_head)) == NULL) { + pst_error_msg ("Could not get root record"); + return NULL; + } + + if (item->message_store == NULL) { + pst_error_msg ("Could not get root message store"); + pst_freeItem (item); + return NULL; + } + + /* default the file_as to the same as the main filename if it doesn't exist */ + if (item->file_as == NULL) { + if (filename == NULL) { + pst_freeItem (item); + return NULL; + } + rootname = g_path_get_basename (filename); + } else { + rootname = g_strdup (item->file_as); + } + + pst_freeItem (item); + + return rootname; +} |