/* vi: set sw=2: */ /* * Copyright (C) 2007 by OpenMoko, Inc. * Written by OpenedHand Ltd * All Rights Reserved * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation; either version 2 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License along * with this program; if not, write to the Free Software Foundation, Inc., * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. */ #include #include #include #include #include #include #ifdef HAVE_CONFIG # include #endif #include "moko-journal.h" #include "moko-time-priv.h" typedef struct _MokoJournalPrivate MokoJournalPrivate ; typedef struct _MokoJournalVoiceInfo MokoJournalVoiceInfo ; typedef struct _MokoJournalDataInfo MokoJournalDataInfo ; typedef struct _MokoJournalFaxInfo MokoJournalFaxInfo ; typedef struct _MokoJournalSMSInfo MokoJournalSMSInfo ; typedef struct _MokoJournalEmailInfo MokoJournalEmailInfo ; #define WIFI_AP_MAC_ADDR_LEN 48 G_DEFINE_TYPE (MokoJournal, moko_journal, G_TYPE_OBJECT) #define MOKO_JOURNAL_GET_PRIVATE(obj) (G_TYPE_INSTANCE_GET_PRIVATE ((obj), MOKO_TYPE_JOURNAL, MokoJournalPrivate)) struct _MokoJournalPrivate { ECal *ecal ; ECalView *ecal_view ; GList *entries_to_delete ; GArray *entries ; }; struct _MokoJournalVoiceInfo { gchar *distant_number ; gchar *local_number ; gboolean was_missed ; }; struct _MokoJournalFaxInfo { int nothing ; }; struct _MokoJournalDataInfo { int nothing ; }; struct _MokoJournalEmailInfo { int nothing ; }; struct _MokoJournalSMSInfo { int nothing ; }; struct _MokoJournalEntry { MokoJournalEntryType type; gchar *uid ; gchar *contact_uid ; gchar *summary ; MessageDirection direction ; MokoTime *dtstart ; MokoTime *dtend ; float start_longitude ; float start_latitude ; gchar *source ; MokoGSMLocation gsm_loc ; guchar *wifi_ap_mac ; guchar *bluetooth_ap_mac ; gint ref_count ; union { MokoJournalEmailInfo *email_info ; MokoJournalVoiceInfo *voice_info ; MokoJournalFaxInfo *fax_info ; MokoJournalDataInfo *data_info ; MokoJournalSMSInfo *sms_info ; } extra ; }; struct _MokoJournalEntryInfo { MokoJournalEntryType type; const gchar *type_as_string ; }; typedef struct _MokoJournalEntryInfo MokoJournalEntryInfo ; static const MokoJournalEntryInfo entries_info[] = { {VOICE_JOURNAL_ENTRY, "VOICEENTRY"}, {EMAIL_JOURNAL_ENTRY, "EMAILENTRY"}, {SMS_JOURNAL_ENTRY, "SMSENTRY"}, {FAX_JOURNAL_ENTRY, "FAXENTRY"}, {DATA_JOURNAL_ENTRY, "DATAENTRY"}, {0} } ; /* add your signals here */ enum { ENTRY_ADDED, ENTRY_REMOVED, LAST_SIGNAL, }; static guint moko_journal_signals[LAST_SIGNAL] = { 0 }; static void moko_journal_finalize (GObject *self) ; static MokoJournalVoiceInfo* moko_journal_voice_info_new () ; static MokoJournalFaxInfo* moko_journal_fax_info_new () ; static MokoJournalDataInfo* moko_journal_data_info_new () ; static MokoJournalEmailInfo* moko_journal_email_info_new () ; static MokoJournalSMSInfo* moko_journal_sms_info_new () ; static gboolean moko_journal_entry_get_voice_info (MokoJournalEntry *a_entry, MokoJournalVoiceInfo **a_info); static void moko_journal_voice_info_free (MokoJournalVoiceInfo *a_info) ; static void moko_journal_fax_info_free (MokoJournalFaxInfo *a_info) ; static void moko_journal_data_info_free (MokoJournalDataInfo *a_info) ; static void moko_journal_email_info_free (MokoJournalEmailInfo *a_info) ; static void moko_journal_sms_info_free (MokoJournalSMSInfo *a_info) ; static gboolean moko_journal_find_entry_from_uid (MokoJournalPrivate *a_journal, const gchar *a_uid, MokoJournalEntry **a_entry, int *a_offset) ; static const gchar* entry_type_to_string (MokoJournalEntryType a_type) ; static MokoJournalEntryType entry_type_from_string (const gchar* a_str) ; static gboolean moko_journal_entry_type_is_valid (MokoJournalEntryType a_type) ; static gboolean moko_journal_entry_to_icalcomponent (MokoJournalEntry *a_entry, icalcomponent **a_comp) ; static gboolean icalcomponent_to_entry (icalcomponent *a_comp, MokoJournalEntry **a_entry) ; static gboolean icalcomponent_find_property (const icalcomponent *a_comp, const gchar *a_name, icalproperty **a_property) ; static gboolean icalcomponent_find_property_as_string (const icalcomponent *a_comp, const gchar *a_name, gchar **a_property) ; static void on_entries_added_cb (ECalView *a_view, GList *a_entries, MokoJournal *a_journal) ; static void on_entries_removed_cb (ECalView *a_view, GList *uids, MokoJournal *a_journal) ; static void moko_journal_class_init (MokoJournalClass *klass) { g_type_class_add_private (klass, sizeof(MokoJournalPrivate)) ; moko_journal_signals[ENTRY_ADDED] = g_signal_new ("entry_added", G_TYPE_FROM_CLASS (klass), G_SIGNAL_RUN_FIRST | G_SIGNAL_ACTION, G_STRUCT_OFFSET (MokoJournalClass, entry_added), NULL, NULL, g_cclosure_marshal_VOID__BOXED, G_TYPE_NONE, 1, MOKO_TYPE_JOURNAL_ENTRY | G_SIGNAL_TYPE_STATIC_SCOPE) ; moko_journal_signals[ENTRY_REMOVED] = g_signal_new ("entry_removed", G_TYPE_FROM_CLASS (klass), G_SIGNAL_RUN_FIRST | G_SIGNAL_ACTION, G_STRUCT_OFFSET (MokoJournalClass, entry_removed), NULL, NULL, g_cclosure_marshal_VOID__BOXED, G_TYPE_NONE, 1, MOKO_TYPE_JOURNAL_ENTRY | G_SIGNAL_TYPE_STATIC_SCOPE) ; G_OBJECT_CLASS(klass)->finalize = moko_journal_finalize; } static void moko_journal_init (MokoJournal* self) { MokoJournalPrivate* priv = MOKO_JOURNAL_GET_PRIVATE (self) ; priv->entries = g_array_new (TRUE, TRUE, sizeof (MokoJournalEntry*)) ; } static void moko_journal_finalize (GObject *self) { MokoJournal* journal = MOKO_JOURNAL (self) ; MokoJournalPrivate *private = MOKO_JOURNAL_GET_PRIVATE (journal) ; if (private->ecal) { g_object_unref (G_OBJECT (private->ecal)) ; private->ecal = NULL ; } if (private->entries_to_delete) { g_list_free (private->entries_to_delete) ; private->entries_to_delete = NULL ; } if (private->entries) { int i ; for (i=0 ; i < private->entries->len ; ++i) { if (g_array_index (private->entries, MokoJournalEntry*, i)) { moko_journal_entry_unref (g_array_index (private->entries, MokoJournalEntry*, i)); g_array_index (private->entries, MokoJournalEntry*, i) = NULL; } } g_array_free (private->entries, TRUE) ; private->entries = NULL ; } if (G_OBJECT_CLASS(moko_journal_parent_class)->finalize) G_OBJECT_CLASS(moko_journal_parent_class)->finalize (self) ; } static void notify_entry_added (MokoJournal *a_journal, MokoJournalEntry *entry) { g_signal_emit (G_OBJECT (a_journal), moko_journal_signals[ENTRY_ADDED], 0, entry, NULL) ; } static void notify_entry_removed (MokoJournal *a_journal, MokoJournalEntry *entry) { g_signal_emit (G_OBJECT (a_journal), moko_journal_signals[ENTRY_REMOVED], 0, entry, NULL) ; } static const gchar* entry_type_to_string (MokoJournalEntryType a_type) { MokoJournalEntryInfo *cur ; for (cur = (MokoJournalEntryInfo*)entries_info ; cur ; ++cur) { if (cur->type == a_type) return cur->type_as_string ; } return NULL ; } static MokoJournalEntryType entry_type_from_string (const gchar* a_str) { MokoJournalEntryInfo *cur ; for (cur = (MokoJournalEntryInfo*)entries_info ; cur ; ++cur) { if (!strcmp (cur->type_as_string, a_str)) { return cur->type ; } } return UNDEF_ENTRY ; } /**/ static gboolean moko_journal_find_entry_from_uid (MokoJournalPrivate *a_journal, const gchar *a_uid, MokoJournalEntry **a_entry, int *a_offset) { int i=0 ; g_return_val_if_fail (a_journal, FALSE) ; g_return_val_if_fail (a_journal->entries, FALSE) ; g_return_val_if_fail (a_entry, FALSE) ; g_return_val_if_fail (a_offset, FALSE) ; g_return_val_if_fail (a_uid, FALSE) ; if (!a_journal->entries) return FALSE ; for (i = 0 ; i < a_journal->entries->len ; ++i) { if (g_array_index (a_journal->entries, MokoJournalEntry*, i) && g_array_index (a_journal->entries, MokoJournalEntry*, i)->uid && !strcmp (g_array_index (a_journal->entries, MokoJournalEntry*, i)->uid, a_uid)) { *a_entry = g_array_index (a_journal->entries, MokoJournalEntry*, i) ; *a_offset = i ; return TRUE ; } } return FALSE ; } static gboolean moko_journal_entry_get_voice_info (MokoJournalEntry *a_entry, MokoJournalVoiceInfo **a_info) { g_return_val_if_fail (a_entry, FALSE) ; g_return_val_if_fail (a_entry->type == VOICE_JOURNAL_ENTRY, FALSE) ; g_return_val_if_fail (a_info, FALSE) ; if (!a_entry->extra.voice_info) { a_entry->extra.voice_info = moko_journal_voice_info_new (); } g_return_val_if_fail (a_entry->extra.voice_info, FALSE) ; *a_info = a_entry->extra.voice_info ; return TRUE ; } static void moko_journal_voice_info_free (MokoJournalVoiceInfo *a_info) { g_return_if_fail (a_info) ; if (a_info) { if (a_info->distant_number) { g_free (a_info->distant_number) ; a_info->distant_number = NULL ; } if (a_info->local_number) { g_free (a_info->local_number) ; a_info->local_number = NULL ; } } g_free (a_info) ; } static void moko_journal_email_info_free (MokoJournalEmailInfo *a_info) { g_return_if_fail (a_info) ; g_free (a_info) ; } static void moko_journal_fax_info_free (MokoJournalFaxInfo *a_info) { g_return_if_fail (a_info) ; g_free (a_info) ; } static void moko_journal_data_info_free (MokoJournalDataInfo *a_info) { g_return_if_fail (a_info) ; g_free (a_info) ; } static void moko_journal_sms_info_free (MokoJournalSMSInfo *a_info) { g_return_if_fail (a_info) ; g_free (a_info) ; } static gboolean moko_journal_entry_get_fax_info (MokoJournalEntry *a_entry, MokoJournalFaxInfo **a_info) { g_return_val_if_fail (a_entry, FALSE) ; g_return_val_if_fail (a_entry->type == FAX_JOURNAL_ENTRY, FALSE) ; g_return_val_if_fail (a_info, FALSE) ; if (!a_entry->extra.fax_info) { a_entry->extra.fax_info = moko_journal_fax_info_new () ; } g_return_val_if_fail (a_entry->extra.fax_info, FALSE) ; *a_info = a_entry->extra.fax_info ; return FALSE ; } static gboolean moko_journal_entry_get_data_info (MokoJournalEntry *a_entry, MokoJournalDataInfo **a_info) { g_return_val_if_fail (a_entry, FALSE) ; g_return_val_if_fail (a_entry->type == DATA_JOURNAL_ENTRY, FALSE) ; g_return_val_if_fail (a_info, FALSE) ; if (!a_entry->extra.data_info) { a_entry->extra.data_info = moko_journal_data_info_new () ; } g_return_val_if_fail (a_entry->extra.data_info, FALSE) ; *a_info = a_entry->extra.data_info ; return TRUE ; } /** * moko_journal_entry_get_sms_info: * @entry: the current instance of journal entry * @info: the resulting properties set * * Get the extra properties set associated to journal entries of type * SMS_JOURNAL_ENTRY */ static gboolean moko_journal_entry_get_sms_info (MokoJournalEntry *a_entry, MokoJournalSMSInfo **a_info) { g_return_val_if_fail (a_entry, FALSE) ; g_return_val_if_fail (a_entry->type == SMS_JOURNAL_ENTRY, FALSE) ; g_return_val_if_fail (a_info, FALSE) ; if (a_entry->extra.sms_info) { a_entry->extra.sms_info = moko_journal_sms_info_new () ; } g_return_val_if_fail (a_entry->extra.sms_info, FALSE) ; *a_info = a_entry->extra.sms_info ; return TRUE ; } /** * moko_journal_entry_get_email_info: * @entry: the current instance of journal entry * @info: extra information attached to the email info, or NULL. * Client code must *NOT* of deallocate the returned info. * It is the duty of the MokoJournalEntry code to deallocate it when * necessary * * Return value: TRUE if the call succeeded, FALSE otherwise. */ static gboolean moko_journal_entry_get_email_info (MokoJournalEntry *a_entry, MokoJournalEmailInfo **a_info) { g_return_val_if_fail (a_entry->type == EMAIL_JOURNAL_ENTRY, FALSE) ; if (!a_entry->extra.email_info) { a_entry->extra.email_info = moko_journal_email_info_new () ; } g_return_val_if_fail (a_entry->extra.email_info, FALSE) ; *a_info = a_entry->extra.email_info ; return TRUE ; } static MokoJournalVoiceInfo* moko_journal_voice_info_new () { return g_new0 (MokoJournalVoiceInfo, 1) ; } static MokoJournalEmailInfo* moko_journal_email_info_new () { return g_new0 (MokoJournalEmailInfo, 1) ; } static MokoJournalFaxInfo* moko_journal_fax_info_new () { return g_new0 (MokoJournalFaxInfo, 1) ; } static MokoJournalDataInfo* moko_journal_data_info_new () { return g_new0 (MokoJournalDataInfo, 1) ; } static MokoJournalSMSInfo* moko_journal_sms_info_new () { return g_new0 (MokoJournalSMSInfo, 1) ; } static MokoJournalEntry* moko_journal_entry_alloc () { MokoJournalEntry *result ; result = g_new0 (MokoJournalEntry, 1) ; result->ref_count = 1; return moko_journal_entry_ref (result) ; } static void moko_journal_entry_free_real (MokoJournalEntry *a_entry) { g_return_if_fail (a_entry) ; if (a_entry->uid) { g_free (a_entry->uid) ; a_entry->uid = NULL ; } if (a_entry->contact_uid) { g_free (a_entry->contact_uid) ; a_entry->contact_uid = NULL ; } if (a_entry->summary) { g_free (a_entry->summary) ; a_entry->summary = NULL ; } if (a_entry->dtstart) { moko_time_free (a_entry->dtstart) ; a_entry->dtstart = NULL ; } if (a_entry->dtend) { moko_time_free (a_entry->dtend) ; a_entry->dtend = NULL ; } if (a_entry->source) { g_free (a_entry->source) ; a_entry->source = NULL ; } if (a_entry->wifi_ap_mac) { g_free (a_entry->wifi_ap_mac) ; a_entry->wifi_ap_mac = NULL ; } if (a_entry->bluetooth_ap_mac) { g_free (a_entry->bluetooth_ap_mac) ; a_entry->bluetooth_ap_mac = NULL; } switch (a_entry->type) { case EMAIL_JOURNAL_ENTRY: if (a_entry->extra.email_info) { moko_journal_email_info_free (a_entry->extra.email_info) ; a_entry->extra.email_info = NULL ; } break ; case VOICE_JOURNAL_ENTRY: if (a_entry->extra.voice_info) { moko_journal_voice_info_free (a_entry->extra.voice_info) ; a_entry->extra.voice_info = NULL ; } break ; case FAX_JOURNAL_ENTRY: if (a_entry->extra.fax_info) { moko_journal_fax_info_free (a_entry->extra.fax_info) ; a_entry->extra.fax_info = NULL; } break ; case DATA_JOURNAL_ENTRY: if (a_entry->extra.data_info) { moko_journal_data_info_free (a_entry->extra.data_info) ; a_entry->extra.data_info = NULL ; } break ; case SMS_JOURNAL_ENTRY: if (a_entry->extra.sms_info) { moko_journal_sms_info_free (a_entry->extra.sms_info) ; a_entry->extra.sms_info = NULL ; } break ; default: g_warning ("unknown journal entry type. This is a leak!\n") ; break ; } g_free (a_entry) ; } static gboolean moko_journal_entry_type_is_valid (MokoJournalEntryType a_type) { if (a_type > 0 && a_type < NB_OF_ENTRY_TYPES) return TRUE ; return FALSE ; } static gboolean moko_journal_entry_to_icalcomponent (MokoJournalEntry *a_entry, icalcomponent **a_comp) { icalcomponent *comp = NULL ; icalproperty *prop = NULL ; gboolean result = FALSE ; gchar *str=NULL ; MessageDirection dir = DIRECTION_IN ; g_return_val_if_fail (a_entry, FALSE) ; g_return_val_if_fail (a_comp, FALSE) ; g_return_val_if_fail (moko_journal_entry_type_is_valid (a_entry->type), FALSE) ; comp = icalcomponent_new (ICAL_VJOURNAL_COMPONENT) ; /*add uid, if it exists*/ if (a_entry->uid) { prop = icalproperty_new_uid (a_entry->uid) ; icalcomponent_add_property (comp, prop) ; } /*add contact prop*/ prop = icalproperty_new_contact (moko_journal_entry_get_contact_uid (a_entry)) ; icalcomponent_add_property (comp, prop) ; /*add summary prop*/ prop = icalproperty_new_summary (moko_journal_entry_get_summary (a_entry)) ; icalcomponent_add_property (comp, prop) ; /*add direction*/ if (!moko_journal_entry_get_direction (a_entry, &dir)) { g_warning ("failed to get entry direction") ; goto out ; } if (dir == DIRECTION_IN) { prop = icalproperty_new_x ("IN") ; } else { prop = icalproperty_new_x ("OUT") ; } icalproperty_set_x_name (prop, "X-OPENMOKO-ENTRY-DIRECTION") ; icalcomponent_add_property (comp, prop) ; /*add dtstart*/ const MokoTime *date = moko_journal_entry_get_dtstart (a_entry) ; if (!date) goto out ; prop = icalproperty_new_dtstart (date->t) ; icalcomponent_add_property (comp, prop) ; /*add dtend*/ date = moko_journal_entry_get_dtend (a_entry) ; if (!date) goto out ; prop = icalproperty_new_dtend (date->t) ; icalcomponent_add_property (comp, prop) ; /*add location start*/ if ( ( a_entry->start_longitude != 0.0 ) && ( a_entry->start_latitude != 0.0 ) ) { struct icalgeotype geo; if (moko_journal_entry_get_start_location (a_entry, (MokoLocation*)(void*)&geo)) { prop = icalproperty_new_geo (geo) ; icalcomponent_add_property (comp, prop) ; } } /*add source*/ if (moko_journal_entry_get_source (a_entry)) prop = icalproperty_new_x (moko_journal_entry_get_source (a_entry)) ; else prop = icalproperty_new_x ("null") ; icalproperty_set_x_name (prop, "X-OPENMOKO-ENTRY-SOURCE") ; icalcomponent_add_property (comp, prop) ; /* * add gsm location (pair of "local area code" and "cell id". * gsm location is stored in an * x-property named X-OPENMOKO-ENTRY-GSM-LOCATION that has the form: * X-OPENMOKO-GSMLOCATION;LAC="";CID=: dummy */ if ( ( a_entry->gsm_loc.lac > 0 ) && ( a_entry->gsm_loc.cid > 0 ) ) { prop = icalproperty_new_x ("dummy") ; icalproperty_set_x_name (prop, "X-OPENMOKO-ENTRY-GSM-LOCATION") ; str = g_strdup_printf ("%d", a_entry->gsm_loc.lac); icalproperty_set_parameter_from_string (prop, "X-LAC", str) ; g_free (str) ; str = g_strdup_printf ("%d", a_entry->gsm_loc.cid); icalproperty_set_parameter_from_string (prop, "X-CID", str) ; g_free (str) ; icalcomponent_add_property (comp, prop) ; } /*add entry type*/ prop = icalproperty_new_x (entry_type_to_string (moko_journal_entry_get_entry_type (a_entry))) ; icalproperty_set_x_name (prop, "X-OPENMOKO-ENTRY-TYPE") ; icalcomponent_add_property (comp, prop) ; switch (moko_journal_entry_get_entry_type (a_entry)) { case UNDEF_ENTRY: g_warning ("entry is of undefined type\n") ; return FALSE ; case EMAIL_JOURNAL_ENTRY: break ; case VOICE_JOURNAL_ENTRY: { gchar *number="NULL" ; gchar *missed=NULL ; if (!moko_journal_entry_has_voice_info (a_entry)) break ; /* * serialize caller number */ if (moko_journal_voice_info_get_distant_number (a_entry)) { number = (gchar*)moko_journal_voice_info_get_distant_number (a_entry) ; prop = icalproperty_new_x (number) ; if (dir == DIRECTION_OUT) { icalproperty_set_x_name (prop, "X-OPENMOKO-VOICE-CALLEE-NUMBER") ; } else { icalproperty_set_x_name (prop, "X-OPENMOKO-VOICE-CALLER-NUMBER") ; } icalcomponent_add_property (comp, prop) ; } /* * serialize the local_number property */ if (moko_journal_voice_info_get_local_number (a_entry)) { number = (gchar*)moko_journal_voice_info_get_local_number (a_entry) ; prop = icalproperty_new_x (number) ; if (dir == DIRECTION_OUT) { icalproperty_set_x_name (prop, "X-OPENMOKO-VOICE-CALLER-NUMBER") ; } else { icalproperty_set_x_name (prop, "X-OPENMOKO-VOICE-CALLEE-NUMBER") ; } icalcomponent_add_property (comp, prop) ; } /* * serialize the "was-missed" property */ if (moko_journal_voice_info_get_was_missed (a_entry)) missed = "YES" ; else missed = "NO" ; prop = icalproperty_new_x (missed) ; icalproperty_set_x_name (prop, "X-OPENMOKO-VOICE-CALL-WAS-MISSED") ; icalcomponent_add_property (comp, prop) ; } break ; case FAX_JOURNAL_ENTRY: break ; case DATA_JOURNAL_ENTRY: break ; case SMS_JOURNAL_ENTRY: break ; default: break ; } *a_comp = comp ; prop = NULL ; comp = NULL ; result = TRUE ; out: if (prop) icalproperty_free (prop) ; if (comp) icalcomponent_free (comp) ; return result ; } static gboolean icalcomponent_to_entry (icalcomponent *a_comp, MokoJournalEntry **a_entry) { icalproperty *prop=NULL ; gchar *prop_name=NULL, *prop_value=NULL ; MokoJournalEntry *entry=NULL; g_return_val_if_fail (a_comp, FALSE) ; g_return_val_if_fail (icalcomponent_isa (a_comp) == ICAL_VJOURNAL_COMPONENT, FALSE) ; entry = moko_journal_entry_alloc () ; MessageDirection direction = DIRECTION_OUT; /*get the type*/ if (icalcomponent_find_property_as_string (a_comp, "X-OPENMOKO-ENTRY-TYPE", &prop_value)) { MokoJournalEntryType entry_type = UNDEF_ENTRY ; if (!prop_value) { g_warning ("could not get entry type") ; goto out ; } entry_type = entry_type_from_string (prop_value) ; if (entry_type == UNDEF_ENTRY) { g_warning ("Could not recognize type of entry from: %s\n", prop_value); goto out ; } entry->type = entry_type ; } /*make sure we got the type*/ if (entry->type == UNDEF_ENTRY || entry->type >= NB_OF_ENTRY_TYPES) { g_warning ("bad entry type") ; goto out ; } /*look for the x-properties we may have*/ if (icalcomponent_find_property_as_string (a_comp, "X-OPENMOKO-ENTRY-DIRECTION", &prop_value)) { if (prop_value && !strcmp (prop_value, "IN")) direction = DIRECTION_IN; else direction = DIRECTION_OUT; } moko_journal_entry_set_direction (entry, direction); if (icalcomponent_find_property_as_string (a_comp, "X-OPENMOKO-ENTRY-SOURCE", &prop_value)) { if (!prop_value || (prop_value && !strcmp (prop_value, "null"))) { moko_journal_entry_set_source (entry, NULL) ; } else { moko_journal_entry_set_source (entry, prop_value) ; } } if (icalcomponent_find_property (a_comp, "X-OPENMOKO-ENTRY-GSM-LOCATION", &prop)) { if (prop ) { gchar *str=NULL ; gint code=0 ; str = (gchar*)icalproperty_get_parameter_as_string (prop, "X-LAC") ; code = atoi (str) ; entry->gsm_loc.lac = (gushort)code ; str = (gchar*)icalproperty_get_parameter_as_string (prop, "X-CID") ; code = atoi (str) ; entry->gsm_loc.cid = (gushort)code ; } } /*now iterate through properties to scan core properties*/ for (prop = icalcomponent_get_first_property (a_comp, ICAL_ANY_PROPERTY); prop ; prop = icalcomponent_get_next_property (a_comp, ICAL_ANY_PROPERTY)) { prop_name = (gchar*)icalproperty_get_property_name (prop) ; if (!prop_name) continue ; if (icalproperty_isa (prop) == ICAL_UID_PROPERTY) { if (entry->uid) g_free (entry->uid) ; entry->uid = g_strdup (icalproperty_get_uid (prop)) ; } else if (icalproperty_isa (prop) == ICAL_CONTACT_PROPERTY) { moko_journal_entry_set_contact_uid (entry, icalproperty_get_contact (prop)) ; } else if (icalproperty_isa (prop) == ICAL_SUMMARY_PROPERTY) { moko_journal_entry_set_summary (entry, icalproperty_get_summary (prop)) ; } else if (icalproperty_isa (prop) == ICAL_DTSTART_PROPERTY) { moko_journal_entry_set_dtstart (entry, moko_time_new_from_icaltimetype (icalproperty_get_dtstart (prop))); } else if (icalproperty_isa (prop) == ICAL_DTEND_PROPERTY) { moko_journal_entry_set_dtend (entry, moko_time_new_from_icaltimetype (icalproperty_get_dtend (prop))); } else if (icalproperty_isa (prop) == ICAL_GEO_PROPERTY) { struct icalgeotype geo = icalproperty_get_geo (prop); moko_journal_entry_set_start_location (entry, (MokoLocation*)(void*)&geo) ; } } /*scan extra info related properties*/ switch (entry->type) { case VOICE_JOURNAL_ENTRY: { prop = NULL ; prop_value = NULL ; g_return_val_if_fail (moko_journal_entry_has_voice_info (entry), FALSE) ; /* * deserialize caller number */ if (icalcomponent_find_property_as_string (a_comp, "X-OPENMOKO-VOICE-CALLER-NUMBER", &prop_value)) { if (prop_value) { if ( direction == DIRECTION_OUT) { moko_journal_voice_info_set_local_number (entry, prop_value); } else { moko_journal_voice_info_set_distant_number (entry, prop_value); } } } /* * deserialize callee number */ if (icalcomponent_find_property_as_string (a_comp, "X-OPENMOKO-VOICE-CALLEE-NUMBER", &prop_value)) { if (prop_value) { if ( direction == DIRECTION_OUT) { moko_journal_voice_info_set_distant_number (entry, prop_value); } else { moko_journal_voice_info_set_local_number (entry, prop_value); } } } prop_value = NULL ; if (icalcomponent_find_property_as_string (a_comp, "X-OPENMOKO-VOICE-CALL-WAS-MISSED", &prop_value)) { if (prop_value) { gboolean was_missed = FALSE ; if (!strcmp ("YES", prop_value)) was_missed = TRUE ; moko_journal_voice_info_set_was_missed (entry, was_missed) ; } } } break ; case FAX_JOURNAL_ENTRY: break ; case DATA_JOURNAL_ENTRY: break ; case SMS_JOURNAL_ENTRY: break ; case EMAIL_JOURNAL_ENTRY: break ; default: break ; } *a_entry = entry ; entry = NULL ; out: if (entry) moko_journal_entry_unref (entry) ; return TRUE ; } static gboolean icalcomponent_find_property (const icalcomponent *a_comp, const gchar *a_name, icalproperty **a_property) { icalproperty *prop = NULL ; g_return_val_if_fail (a_comp, FALSE) ; for (prop = icalcomponent_get_first_property ((icalcomponent*)a_comp, ICAL_ANY_PROPERTY); prop; prop = icalcomponent_get_next_property ((icalcomponent*)a_comp, ICAL_ANY_PROPERTY)) { if (icalproperty_get_property_name (prop) && ! strcasecmp (icalproperty_get_property_name (prop), a_name)) { *a_property = prop ; return TRUE ; } } return FALSE ; } static gboolean icalcomponent_find_property_as_string (const icalcomponent *a_comp, const gchar *a_name, gchar **a_property) { icalproperty *prop = NULL ; g_return_val_if_fail (a_comp, FALSE) ; g_return_val_if_fail (a_name, FALSE) ; if (icalcomponent_find_property (a_comp, a_name, &prop)) { *a_property = (gchar*) icalproperty_get_value_as_string (prop) ; return TRUE ; } return FALSE ; } /**/ /**/ /** * moko_journal_open_default: * * Opens the default journal. * * Return value: a pointer to the journal object */ MokoJournal* moko_journal_open_default () { ECal *ecal = NULL; gchar *uri = NULL ; MokoJournal *result=NULL, *journal=NULL ; GError *error = NULL ; uri = g_build_filename ("file://", g_get_home_dir (), ".moko", "journal", NULL); ecal = e_cal_new_from_uri (uri, E_CAL_SOURCE_TYPE_JOURNAL) ; if (!ecal) { g_warning ("failed to create ecal with uri: %s\n", uri) ; goto out ; } if (!e_cal_open (ecal, FALSE, &error)) { g_warning ("could not open the journal at uri %s\n", uri) ; goto out ; } if (error) { g_warning ("got error: %s\n", error->message) ; goto out ; } journal = g_object_new (MOKO_TYPE_JOURNAL, NULL); MOKO_JOURNAL_GET_PRIVATE(journal)->ecal = ecal ; ecal = NULL ; result = journal ; journal = NULL ; out: g_free (uri) ; if (ecal) g_object_unref (G_OBJECT (ecal)) ; if (journal) g_object_unref (journal) ; if (error) g_error_free (error) ; return result ; } /** * moko_journal_close: * @journal: the journal to close * * Close the journal previously opened with moko_journal_open_default(). * This function deallocates the memory of the Journal object. */ void moko_journal_close (MokoJournal *a_journal) { g_return_if_fail (a_journal) ; g_object_unref (a_journal) ; } /** * moko_journal_add_entry: * @journal: the current instance of journal * @entry: the new entry to add to the journal. The journal is responsible * of deallocating the memory of the entry object. * * Add a journal entry to the journal * * Return value: TRUE if the entry got successfully added to the journal, * FALSE otherwise */ gboolean moko_journal_add_entry (MokoJournal *_a_journal, MokoJournalEntry *a_entry) { g_return_val_if_fail (_a_journal, FALSE) ; g_return_val_if_fail (a_entry, FALSE) ; MokoJournalPrivate *a_journal = MOKO_JOURNAL_GET_PRIVATE(_a_journal); g_array_append_val (a_journal->entries, a_entry) ; return TRUE ; } /** * moko_journal_get_nb_entries: * @journal: the current instance of journal * * Return value: the number of entries in the journal or a negative value * in case of error. */ int moko_journal_get_nb_entries (MokoJournal *_a_journal) { g_return_val_if_fail (_a_journal, -1) ; MokoJournalPrivate *a_journal = MOKO_JOURNAL_GET_PRIVATE (_a_journal); if (!a_journal->entries) return 0 ; return a_journal->entries->len ; } /** * moko_journal_get_entry_at: * @journal: the current instance of journal * @index: the index to get the journal entry from * @entry: out parameter. the resulting journal entry * * Get the journal entry at a given index. * * Return value: TRUE in case of success, FALSE otherwise. */ gboolean moko_journal_get_entry_at (MokoJournal *_a_journal, guint a_index, MokoJournalEntry **a_entry) { g_return_val_if_fail (_a_journal, FALSE) ; g_return_val_if_fail (a_entry, FALSE) ; MokoJournalPrivate *a_journal = MOKO_JOURNAL_GET_PRIVATE(_a_journal); g_return_val_if_fail (a_journal->entries, FALSE) ; g_return_val_if_fail (a_index < a_journal->entries->len, FALSE) ; *a_entry = g_array_index (a_journal->entries, MokoJournalEntry*, a_index) ; return TRUE ; } /** * moko_journal_remove_entry_at: * @journal: the current instance of journal * @index: the index to remove the entry from * * Remove a journal entry from index #index */ gboolean moko_journal_remove_entry_at (MokoJournal *_a_journal, guint a_index) { g_return_val_if_fail (_a_journal, FALSE) ; MokoJournalPrivate *a_journal = MOKO_JOURNAL_GET_PRIVATE(_a_journal) ; g_return_val_if_fail (a_journal->entries, FALSE) ; g_return_val_if_fail (a_index < a_journal->entries->len, FALSE) ; MokoJournalEntry *entry = NULL ; entry = g_array_index (a_journal->entries, MokoJournalEntry*, a_index) ; if (entry) { /* * if entry has been persisted already, * queue a removal from storage */ if (entry->uid) { a_journal->entries_to_delete = g_list_prepend (a_journal->entries_to_delete, entry); } /* * remove entry from memory cache */ g_array_remove_index (a_journal->entries, a_index) ; /* * if entry has not been pushed onto * storage deletion queue, * deallocate its memory */ if (!entry->uid) { moko_journal_entry_unref (entry) ; } return TRUE ; } return FALSE ; } /** * moko_journal_remove_entry_by_uid: * @journal: the current instance of journal * @uid: the uid of the journal entry to remove * * Remove the journal entry that has a given UID. * * Return value: TRUE in case of success, FALSE otherwise */ gboolean moko_journal_remove_entry_by_uid (MokoJournal *_a_journal, const gchar* a_uid) { g_return_val_if_fail (_a_journal, FALSE) ; MokoJournalPrivate *a_journal = MOKO_JOURNAL_GET_PRIVATE(_a_journal); g_return_val_if_fail (a_journal->entries, FALSE) ; g_return_val_if_fail (a_uid, FALSE) ; int i=0 ; MokoJournalEntry *entry=NULL ; for (i=0 ; i < a_journal->entries->len ; ++i) { entry = g_array_index (a_journal->entries, MokoJournalEntry*, i) ; if (entry && entry->uid && !strcmp (entry->uid, a_uid)) { notify_entry_removed (_a_journal, entry); return moko_journal_remove_entry_at (_a_journal, i) ; } } return FALSE ; } /** * moko_journal_write_to_storage: * @journal: the journal to save to storage * * Saves the journal to persistent storage (e.g disk) using the * appropriate backend. The backend currently used is evolution data server * * Return value: TRUE in case of success, FALSE otherwise */ gboolean moko_journal_write_to_storage (MokoJournal *_a_journal) { g_return_val_if_fail (_a_journal, FALSE) ; MokoJournalPrivate *a_journal = MOKO_JOURNAL_GET_PRIVATE(_a_journal); g_return_val_if_fail (a_journal->ecal, FALSE) ; MokoJournalEntry *cur_entry=NULL ; int i=0 ; GList *ecal_comps=NULL, *cur_elem=NULL ; ECalComponent *ecal_comp=NULL ; icalcomponent *ical_comp=NULL ; GError *error=NULL ; gboolean wrote = FALSE; gboolean result = TRUE; /*create ECalComponent objects out of the list of MokoJournalEntry* we have*/ for (i=0; a_journal->entries && ientries->len; ++i) { cur_entry = g_array_index (a_journal->entries, MokoJournalEntry*, i) ; if (!cur_entry) break ; if (!moko_journal_entry_to_icalcomponent (cur_entry, &ical_comp)) { if (ical_comp) { icalcomponent_free (ical_comp) ; ical_comp = NULL ; } continue ; } ecal_comp = e_cal_component_new () ; e_cal_component_set_icalcomponent (ecal_comp, ical_comp) ; g_object_set_data (G_OBJECT (ecal_comp), "journal-entry", cur_entry) ; ecal_comps = g_list_prepend (ecal_comps, ecal_comp) ; ecal_comp = NULL ; ical_comp = NULL ; } /* * walk the list of ECalComponent objects to either add them * to eds or modify them (in eds) if there were already present in eds. */ for (cur_elem = ecal_comps ; cur_elem ; cur_elem = cur_elem->next) { if (!cur_elem->data) { g_warning ("Got an empty ECalComponent\n") ; result = FALSE ; continue ; } ical_comp = e_cal_component_get_icalcomponent (cur_elem->data) ; if (!ical_comp) { g_warning ("Got an empty icalcomponent") ; result = FALSE ; continue ; } cur_entry = g_object_get_data (G_OBJECT (cur_elem->data), "journal-entry") ; if (!cur_entry) { g_warning ("could not get journal entry from cur_elem->data") ; continue ; } if (cur_entry->uid) { /*entry exists already in eds, modify it*/ if (!e_cal_modify_object (a_journal->ecal, ical_comp, CALOBJ_MOD_THIS, &error)) { g_warning ("Could not modify entry in the journal") ; result = FALSE ; } } else { /*entry did not exist in eds previously, add it*/ if (!e_cal_create_object (a_journal->ecal, ical_comp, &cur_entry->uid, &error)) { g_warning ("Could not write the entry to the journal") ; result = FALSE ; } else { e_cal_component_commit_sequence (cur_elem->data) ; wrote = TRUE ; } } if (error) { g_warning ("got error: %s\n", error->message) ; g_error_free (error) ; error = NULL ; } } /* * remove entries that have been * queued to be removed */ for (cur_elem = a_journal->entries_to_delete ; cur_elem ; cur_elem = cur_elem->next) { if (!cur_elem->data) continue ; if (((MokoJournalEntry*)cur_elem->data)->uid) { if (!e_cal_remove_object (a_journal->ecal, ((MokoJournalEntry*)cur_elem->data)->uid, &error)) { /* * this can happen if another process for instance, has * already deleted the entry. In that case, we just * print message and continue */ g_message ("failed to remove object with UID %s\n", ((MokoJournalEntry*)cur_elem->data)->uid) ; } if (error) { g_warning ("got error %s\n", error->message) ; g_error_free (error) ; error = NULL ; } } moko_journal_entry_unref ((MokoJournalEntry*)cur_elem->data) ; cur_elem->data = NULL ; } if (a_journal->entries_to_delete) { g_list_free (a_journal->entries_to_delete) ; a_journal->entries_to_delete = NULL ; } if (ecal_comps) { GList *cur; for (cur = ecal_comps ; cur ; cur = cur->next) g_object_unref (cur->data) ; g_list_free (ecal_comps) ; } return result ; } static void on_entries_added_cb (ECalView *a_view, GList *a_entries, MokoJournal *a_journal) { icalcomponent *ical_comp = NULL ; GList *cur_entry = NULL ; int offset=0 ; for (cur_entry = a_entries ; cur_entry ; cur_entry = cur_entry->next) { MokoJournalEntry *entry = NULL ; /***************** * *****************/ if (!icalcomponent_isa_component (cur_entry->data)) { /*hugh ? this does not look like an ical component. ignore it.*/ continue ; } if (!icalcomponent_get_uid (cur_entry->data)) { /*hugh ? an ical component without uid ? ignore it*/ continue ; } if (moko_journal_find_entry_from_uid (MOKO_JOURNAL_GET_PRIVATE(a_journal), icalcomponent_get_uid (cur_entry->data), &entry, &offset)) { /*we already have the component in memory, ignore it*/ if (entry) notify_entry_added (a_journal, entry); continue ; } /***************** * *****************/ /* * okay, build a journal entry from the ical component and cache it * in memory */ ical_comp = cur_entry->data ; if (!icalcomponent_to_entry (ical_comp, &entry) || !entry) { if (entry) { moko_journal_entry_unref (entry) ; entry = NULL ; } continue ; } moko_journal_add_entry (a_journal, entry) ; notify_entry_added (a_journal, entry) ; } } static void on_entries_removed_cb (ECalView *a_view, GList *a_uids, MokoJournal *a_journal) { GList *cur = NULL ; g_return_if_fail (a_view && E_IS_CAL_VIEW (a_view)) ; g_return_if_fail (a_journal) ; /*TODO: * we should notify the world before removing an entry. * Otherwise, client code may hold a reference to * what will become a dangling pointer after we remove it here */ for (cur = a_uids ; cur ; cur = cur->next) { const gchar *uid; #ifdef HAVE_ECALCOMPONENTID ECalComponentId *id = cur->data; uid = id->uid; #else uid = cur->data; #endif if (!moko_journal_remove_entry_by_uid (a_journal, uid)) { g_message ("failed to remove entry of uid %s\n", uid) ; } } } /** * moko_journal_load_from_storage: * @a_journal: the journal to load entries into * * Read the journal entries stored in the persistent storage (filesystem) * and load then into the current instance of MokoJournal. * * Return value: TRUE in case of success, FALSE otherwise */ gboolean moko_journal_load_from_storage (MokoJournal *_a_journal) { GError *error = NULL ; GList *objs = NULL ; g_return_val_if_fail (_a_journal, FALSE) ; MokoJournalPrivate* a_journal = MOKO_JOURNAL_GET_PRIVATE (_a_journal); g_return_val_if_fail (a_journal->ecal, FALSE) ; if (!a_journal->ecal_view) { /* * first, issue a query to get a view that we can * listen to, to get notified by new objects that get added to eds * during the life time of a_journal */ if (!e_cal_get_query (a_journal->ecal, "#t", &a_journal->ecal_view, &error) || error) { if (error) { if (error->message) { g_warning ("got error: %s\n", error->message) ; } g_error_free (error) ; error = NULL ; } return FALSE ; } g_signal_connect (G_OBJECT (a_journal->ecal_view), "objects-added", G_CALLBACK (on_entries_added_cb), _a_journal) ; g_signal_connect (G_OBJECT (a_journal->ecal_view), "objects-removed", G_CALLBACK (on_entries_removed_cb), _a_journal) ; e_cal_view_start (a_journal->ecal_view) ; } /* * really get the objects from eds to let the caller start working * right after the call completes */ if (!e_cal_get_object_list (a_journal->ecal, "#t", &objs, &error)) { g_warning ("failed to get ical journal objects from eds") ; } if (error) { g_warning ("got error %s\n", error->message) ; g_error_free (error) ; error = NULL ; return FALSE; } if (objs) { GList *cur=NULL ; MokoJournalEntry *entry = NULL ; for (cur = objs ; cur ; cur = cur->next) { if (!icalcomponent_isa (cur->data)) continue ; if (icalcomponent_to_entry (cur->data, &entry) && entry) { moko_journal_add_entry (_a_journal, entry) ; entry = NULL ; } if (entry) { g_warning ("entry should be NULL here") ; moko_journal_entry_unref (entry) ; entry = NULL ; } } e_cal_free_object_list (objs) ; objs = NULL ; } /*give us a chance to get notified by entries arriving ...*/ while (g_main_context_pending (g_main_context_default ())) { g_main_context_iteration (g_main_context_default (), FALSE) ; } return TRUE ; } /** * moko_journal_entry_new: * * Create a Journal entry with no properties set. * Use the JEntry accessors to get/set properties. * * Return value: the newly created journal entry object */ MokoJournalEntry* moko_journal_entry_new (MokoJournalEntryType a_type) { MokoJournalEntry *result ; result = moko_journal_entry_alloc () ; result->type = a_type ; return result ; } /** * moko_journal_entry_get_entry_type: * @entry: the current journal entry * * get the primary type of the journal entry * * Return value: the type of the journal entry */ MokoJournalEntryType moko_journal_entry_get_entry_type (MokoJournalEntry *a_entry) { g_return_val_if_fail (a_entry, UNDEF_ENTRY) ; return a_entry->type ; } /** * moko_journal_entry_set_entry_type: * @entry: the current instance of journal entry * @type: the new type * * Set the type of the journal entry */ void moko_journal_entry_set_entry_type (MokoJournalEntry *a_entry, MokoJournalEntryType a_type) { g_return_if_fail (a_entry) ; g_return_if_fail (a_type != UNDEF_ENTRY) ; a_entry->type = a_type ; } /** * moko_journal_entry_get_uid: * @entry: the current instance of journal entry * * Gets the UID of the current entry. This UID is non NULL if and * only if the entry has been persistet at least once. * * Return value: the UID in case the entry has been persisted at least once, * NULL otherwise. The client code must *NOT* free the returned string. */ const gchar* moko_journal_entry_get_uid (MokoJournalEntry *a_entry) { g_return_val_if_fail (a_entry, NULL) ; return a_entry->uid ; } /** * moko_journal_entry_get_contact_uid: * @entry: the current instance of journal entry * * get the contact uid * * Return value: the UID of the contact. It can be NULL. Client code * must not deallocate or attempt to alter it. */ const gchar* moko_journal_entry_get_contact_uid (MokoJournalEntry *a_entry) { g_return_val_if_fail (a_entry, NULL) ; return a_entry->contact_uid ; } void moko_journal_entry_set_contact_uid (MokoJournalEntry *a_entry, const gchar *a_uid) { g_return_if_fail (a_entry) ; if (a_entry->contact_uid) { g_free (a_entry->contact_uid) ; a_entry->contact_uid = NULL ; } if (a_uid) { a_entry->contact_uid = g_strdup (a_uid) ; } } /** * moko_journal_entry_get_summary: * @entry: the current instance of journal entry * * get the summary of the journal entry * * Return value: the summary of the journal entry. It can be NULL. * Client code must not deallocate or alter it. */ const gchar* moko_journal_entry_get_summary (MokoJournalEntry *a_entry) { g_return_val_if_fail (a_entry, NULL) ; return a_entry->summary ; } /** * moko_journal_entry_set_summary: * @entry: the current instance of journal entry * @summary: the new summary of the journal entry. It is copied * so client code is reponsible of its lifecyle. * * Set the summary of the journal entry */ void moko_journal_entry_set_summary (MokoJournalEntry *a_entry, const gchar* a_summary) { g_return_if_fail (a_entry) ; if (a_entry->summary) { g_free (a_entry->summary) ; a_entry->summary = NULL ; } if (a_summary) { a_entry->summary = g_strdup (a_summary) ; } } /** * moko_journal_entry_get_dtdstart: * @entry: the current instance of journal entry * * get the starting date associated to the journal entry * * Return value: an icaltimetype representing the starting date expected. * It can be NULL. Client code must not deallocate it. */ const MokoTime* moko_journal_entry_get_dtstart (MokoJournalEntry *a_entry) { g_return_val_if_fail (a_entry, NULL) ; if (!a_entry->dtstart) a_entry->dtstart = moko_time_new_today () ; return a_entry->dtstart ; } /** * moko_journal_entry_get_dtend: * @entry: the current instance of journal entry * * get the ending date associated to the journal entry * * Return value: an icaltimetype representing the ending date expected. * It can be NULL. Client code must not deallocate it. */ const MokoTime* moko_journal_entry_get_dtend (MokoJournalEntry *a_entry) { g_return_val_if_fail (a_entry, NULL) ; if (!a_entry->dtend) a_entry->dtend = moko_time_new_today () ; return a_entry->dtend ; } /** * moko_journal_entry_get_start_location: * @a_entry: the current instance of journal entry * @a_location: the requested location * * Get the location at which the message got received or sent. * * Returns: TRUE upon sucessful completion, FALSE otherwise. */ gboolean moko_journal_entry_get_start_location (MokoJournalEntry *a_entry, MokoLocation *a_location) { g_return_val_if_fail (a_entry, FALSE) ; g_return_val_if_fail (a_location, FALSE) ; a_location->longitude = a_entry->start_longitude ; a_location->latitude = a_entry->start_latitude ; return TRUE ; } /** * moko_journal_entry_set_location: * @a_entry: the current intance of journal entry * @a_location: the new location * * Set a new location to the journal entry * Location represents the longitude/latitude at which a call or message * occured. * * Returns: TRUE upon successful completion, FALSE otherwise. */ gboolean moko_journal_entry_set_start_location (MokoJournalEntry *a_entry, MokoLocation *a_location) { g_return_val_if_fail (a_entry, FALSE) ; g_return_val_if_fail (a_location, FALSE) ; a_entry->start_longitude = a_location->longitude ; a_entry->start_latitude = a_location->latitude ; return TRUE ; } /** * moko_journal_entry_get_direction: * @entry: the current instance of journal entry * @direction: either DIRECTION_IN for a received message or DIRECTION_OUT * for a sent message. * * get the direction of the message * * Returns: TRUE in case of success, FALSE otherwise. */ gboolean moko_journal_entry_get_direction (MokoJournalEntry *a_entry, MessageDirection *a_direction) { g_return_val_if_fail (a_entry, FALSE) ; g_return_val_if_fail (a_direction, FALSE) ; *a_direction = a_entry->direction ; return TRUE ; } /** * moko_journal_entry_set_direction: * @entry: the current instance of journal entry * @direction: the new message direction to set * * set message direction * */ void moko_journal_entry_set_direction (MokoJournalEntry *a_entry, MessageDirection direction) { g_return_if_fail (a_entry) ; a_entry->direction = direction ; } /** * moko_journal_entry_set_dtstart: * @entry: the current instance of journal entry * @dtstart: the new starting date associated to the journal entry. */ void moko_journal_entry_set_dtstart (MokoJournalEntry *a_entry, MokoTime* a_dtstart) { g_return_if_fail (a_entry) ; if (a_entry->dtstart) { moko_time_free (a_entry->dtstart) ; a_entry->dtstart = NULL ; } if (a_dtstart) a_entry->dtstart = a_dtstart ; } /** * moko_journal_entry_set_dtend: * @entry: the current instance of journal entry * @dtstart: the new ending date associated to the journal entry. */ void moko_journal_entry_set_dtend (MokoJournalEntry *a_entry, MokoTime* a_dtend) { g_return_if_fail (a_entry) ; if (a_entry->dtend) { moko_time_free (a_entry->dtend) ; a_entry->dtend = NULL ; } if (a_dtend) a_entry->dtend = a_dtend ; } /** * moko_journal_entry_get_source: * @a_entry: the current instance of journal entry * * Returns: the source property. It is an arbitrary string representing * the application that was the source of the entry (like mokodialer) */ const gchar* moko_journal_entry_get_source (MokoJournalEntry *a_entry) { g_return_val_if_fail (a_entry, NULL) ; return a_entry->source ; } /** * moko_journal_entry_set_source: * @a_entry: the current instance of journal entry * @a_source: the new source to set * * Set the source property. It is an arbitrary string representing * the application that was the source of the entry (like mokodialer) */ void moko_journal_entry_set_source (MokoJournalEntry *a_entry, const gchar *a_source) { g_return_if_fail (a_entry) ; if (a_entry->source) { g_free (a_entry->source) ; a_entry->source = NULL ; } if (a_source) a_entry->source = g_strdup (a_source) ; } /** * moko_journal_entry_set_gsm_location: * @a_entry: the current instance of voice call extra properties set * @a_location: the gsm location * * Returns: TRUE upon completion, FALSE otherwise */ gboolean moko_journal_entry_set_gsm_location (MokoJournalEntry *a_entry, MokoGSMLocation *a_location) { g_return_val_if_fail (a_entry, FALSE) ; g_return_val_if_fail (a_location, FALSE) ; memcpy (&a_entry->gsm_loc, a_location, sizeof (MokoGSMLocation)) ; return TRUE ; } /** * moko_journal_entry_get_gsm_location: * @a_entry: the current instance of voice call extra properties set * @a_location: the gsm location * * Returns: TRUE upon completion, FALSE otherwise */ gboolean moko_journal_entry_get_gsm_location (MokoJournalEntry *a_info, MokoGSMLocation *a_location) { g_return_val_if_fail (a_info, FALSE) ; g_return_val_if_fail (a_info, FALSE) ; memcpy (a_location, &a_info->gsm_loc, sizeof (MokoGSMLocation)) ; return TRUE ; } /** * moko_journal_entry_set_wifi_ap_mac_address: * @entry: the current instance of journal entry * * the mac address of the wifi access point. * It is must be a 48 bits long string of bytes. * * Returns: TRUE in case of success, FALSE otherwise. */ gboolean moko_journal_entry_set_wifi_ap_mac_address (MokoJournalEntry *a_entry, const guchar *a_address) { g_return_val_if_fail (a_entry, FALSE) ; if (!a_address) { if (a_entry->wifi_ap_mac) { g_free (a_entry->wifi_ap_mac) ; a_entry->wifi_ap_mac = NULL ; } return TRUE ; } if (!a_entry->wifi_ap_mac) { a_entry->wifi_ap_mac = g_new0 (guchar, WIFI_AP_MAC_ADDR_LEN) ; } g_return_val_if_fail (a_entry->wifi_ap_mac, FALSE) ; memcpy (a_entry->wifi_ap_mac, a_address, WIFI_AP_MAC_ADDR_LEN) ; return TRUE ; } /** * moko_journal_entry_get_wifi_ap_mac_address: * @entry: the current instance of journal entry * * Returns: the mac address of the wifi access point. * It is a 48 bits long string of bytes. The calling code must * *NOT* delete this pointer. This function can also return NULL if * no wifi access point mac address has been set in the entry. */ const guchar* moko_journal_entry_get_wifi_ap_mac_address (MokoJournalEntry *a_entry) { g_return_val_if_fail (a_entry, NULL) ; return a_entry->wifi_ap_mac ; } /** * moko_journal_voice_info_set_distant_number: * @info: the current * @info: the extra property set attached to the voice call */ void moko_journal_voice_info_set_distant_number (MokoJournalEntry *journal_entry, const gchar *a_number) { MokoJournalVoiceInfo *a_info = NULL; moko_journal_entry_get_voice_info (journal_entry, &a_info) ; g_return_if_fail (a_info) ; if (a_info->distant_number) { g_free (a_info->distant_number) ; a_info->distant_number = NULL ; } if (a_number) a_info->distant_number = g_strdup (a_number) ; } const gchar* moko_journal_voice_info_get_distant_number (MokoJournalEntry *journal_entry) { MokoJournalVoiceInfo *a_info = NULL ; moko_journal_entry_get_voice_info (journal_entry, &a_info) ; g_return_val_if_fail (a_info, NULL) ; return a_info->distant_number ; } void moko_journal_voice_info_set_local_number (MokoJournalEntry *journal_entry, const gchar *a_number) { MokoJournalVoiceInfo *a_info = NULL ; moko_journal_entry_get_voice_info (journal_entry, &a_info) ; g_return_if_fail (a_info); g_return_if_fail (a_number) ; if (a_info->local_number) { g_free (a_info->local_number) ; a_info->local_number = NULL ; } if (a_number) a_info->local_number = g_strdup (a_number) ; } const gchar* moko_journal_voice_info_get_local_number (MokoJournalEntry *journal_entry) { MokoJournalVoiceInfo *a_info = NULL ; moko_journal_entry_get_voice_info (journal_entry, &a_info) ; g_return_val_if_fail (a_info, NULL) ; return a_info->local_number ; } void moko_journal_voice_info_set_was_missed (MokoJournalEntry *journal_entry, gboolean a_flag) { MokoJournalVoiceInfo *a_info = NULL ; moko_journal_entry_get_voice_info (journal_entry, &a_info) ; g_return_if_fail (a_info) ; a_info->was_missed = a_flag ; } gboolean moko_journal_voice_info_get_was_missed (MokoJournalEntry *journal_entry) { MokoJournalVoiceInfo *a_info = NULL ; moko_journal_entry_get_voice_info (journal_entry, &a_info) ; g_return_val_if_fail (a_info, FALSE) ; return a_info->was_missed ; } /** * moko_journal_entry_has_voice_info: * @entry: the current instance of journal entry * * Returns the specific property set associated to instance of MokoJournalEntry * of type VOICE_JOURNAL_ENTRY. * * Returns: TRUE if the type is of VOICE_JOURNAL_ENTRY, FALSE otherwise. */ gboolean moko_journal_entry_has_voice_info (MokoJournalEntry *entry) { g_return_val_if_fail (entry, FALSE); if (entry->type == VOICE_JOURNAL_ENTRY) return TRUE; else return FALSE; } /** * moko_journal_entry_has_fax_info: * @entry: the current instance of journal entry * @info: the fax info properties set * * get the extra properties set associated to journal entries of * type FAX_JOURNAL_ENTRY * * Returns: TRUE i, FALSE otherwise. */ gboolean moko_journal_entry_has_fax_info (MokoJournalEntry *entry) { g_return_val_if_fail (entry, FALSE); MokoJournalFaxInfo *info = NULL; return moko_journal_entry_get_fax_info (entry, &info) && info; } /** * moko_journal_entry_has_data_info: * @entry: the current instance of journal entry * @info: the resulting properties set * * Get the extra properties set associated to journal entries of type * DATA_JOURNAL_ENTRY * * Returns: TRUE in case of success, FALSE otherwise. */ gboolean moko_journal_entry_has_data_info (MokoJournalEntry *entry) { g_return_val_if_fail (entry, FALSE); MokoJournalDataInfo *info = NULL; return moko_journal_entry_get_data_info (entry, &info) && info; } gboolean moko_journal_entry_has_sms_info (MokoJournalEntry *entry) { g_return_val_if_fail (entry, FALSE); MokoJournalSMSInfo *info = NULL; return moko_journal_entry_get_sms_info (entry, &info) && info; } gboolean moko_journal_entry_has_email_info (MokoJournalEntry *entry) { g_return_val_if_fail (entry, FALSE); MokoJournalEmailInfo *info = NULL; return moko_journal_entry_get_email_info (entry, &info) && info; } #define MOKO_JOURNAL_BOXED_TYPE(name,copy,free) \ static GType this_type = 0; \ if (this_type == 0) \ this_type = g_boxed_type_register_static(name, (GBoxedCopyFunc)copy, (GBoxedFreeFunc)free ); \ return this_type; GType moko_location_get_type (void) { MOKO_JOURNAL_BOXED_TYPE("MokoLocation", moko_location_copy, moko_location_free) } GType moko_gsm_location_get_type (void) { MOKO_JOURNAL_BOXED_TYPE("MokoGSMLocation", moko_gsm_location_copy, moko_gsm_location_free) } GType moko_journal_entry_get_type (void) { MOKO_JOURNAL_BOXED_TYPE("MokoJournalEntry", moko_journal_entry_ref, moko_journal_entry_unref) } MokoJournalEntry* moko_journal_entry_ref (MokoJournalEntry* entry) { g_return_val_if_fail (entry, NULL) ; g_return_val_if_fail (entry->ref_count > 0, NULL) ; g_atomic_int_add (&entry->ref_count, 1); return entry ; } void moko_journal_entry_unref (MokoJournalEntry *entry) { g_return_if_fail (entry) ; g_return_if_fail (entry->ref_count > 0) ; g_atomic_int_add (&entry->ref_count, -1); if (entry->ref_count == 0) moko_journal_entry_free_real (entry); } MokoLocation* moko_location_copy (const MokoLocation *location) { g_return_val_if_fail (location, NULL); MokoLocation *result = g_new(MokoLocation, 1) ; *result = *location ; return result ; } void moko_location_free (MokoLocation *location) { g_return_if_fail (location); g_free (location) ; } MokoGSMLocation* moko_gsm_location_copy (const MokoGSMLocation *location) { g_return_val_if_fail (location, NULL); MokoGSMLocation *result = g_new(MokoGSMLocation, 1) ; *result = *location ; return result ; } void moko_gsm_location_free (MokoGSMLocation *location) { g_return_if_fail (location); g_free (location); } /**/