aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat
-rw-r--r--addressbook/ChangeLog27
-rw-r--r--addressbook/backend/pas/pas-backend-file.c18
-rw-r--r--addressbook/conduit/address-conduit.c163
3 files changed, 144 insertions, 64 deletions
diff --git a/addressbook/ChangeLog b/addressbook/ChangeLog
index c284d479ec..b98699246b 100644
--- a/addressbook/ChangeLog
+++ b/addressbook/ChangeLog
@@ -1,3 +1,30 @@
+2000-12-21 JP Rosevear <jpr@helixcode.com>
+
+ * conduit/address-conduit.c (cursor_cb): Ref the cards that get put
+ in the change list
+ (next_changed_item): util function to get the real next changed item
+ (compute_status): really compute the status of the record
+ (local_record_from_uid): Set the id of the temporary card
+ (check_for_slow_setting): Make this check a little saner
+ (card_added): Only record the CardObjectChange if the card is not
+ archived
+ (card_changed): ditto
+ (card_removed): ditto
+ (set_status_cleared): actually clear the status
+ (for_each_modified): Clean out cruft and use next_changed_item
+ (add_record): Set the new id properly in our local card copy
+ (replace_record): handle the case where the record has been deleted
+ and we need to call add. need to update the changed_hash entry
+ (delete_record): Don't panic if the card is not found, its already
+ been deleted.
+
+ * backend/pas/pas-backend-file.c (pas_backend_file_book_view_copy):
+ The change_context no longer has a del_cards member
+ (pas_backend_file_book_view_free): ditto
+ (pas_backend_file_process_get_changes): ditto
+ (pas_backend_file_changes_foreach_key): just record the id
+ (pas_backend_file_changes): notify_remove needs an id not a vcard
+
2000-12-20 JP Rosevear <jpr@helixcode.com>
* conduit/address-conduit.c (match): Use my own wrapper
diff --git a/addressbook/backend/pas/pas-backend-file.c b/addressbook/backend/pas/pas-backend-file.c
index 31004e596e..61456ddf3d 100644
--- a/addressbook/backend/pas/pas-backend-file.c
+++ b/addressbook/backend/pas/pas-backend-file.c
@@ -75,7 +75,6 @@ struct _PasBackendFileChangeContext {
GList *add_ids;
GList *mod_cards;
GList *mod_ids;
- GList *del_cards;
GList *del_ids;
};
@@ -104,7 +103,6 @@ pas_backend_file_book_view_copy(const PASBackendFileBookView *book_view, void *c
new_book_view->change_context->add_ids = book_view->change_context->add_ids;
new_book_view->change_context->mod_cards = book_view->change_context->mod_cards;
new_book_view->change_context->mod_ids = book_view->change_context->mod_ids;
- new_book_view->change_context->del_cards = book_view->change_context->del_cards;
new_book_view->change_context->del_ids = book_view->change_context->del_ids;
} else
new_book_view->change_context = NULL;
@@ -126,13 +124,11 @@ pas_backend_file_book_view_free(PASBackendFileBookView *book_view, void *closure
g_list_foreach (book_view->change_context->add_ids, (GFunc)g_free, NULL);
g_list_foreach (book_view->change_context->mod_cards, (GFunc)g_free, NULL);
g_list_foreach (book_view->change_context->mod_ids, (GFunc)g_free, NULL);
- g_list_foreach (book_view->change_context->del_cards, (GFunc)g_free, NULL);
g_list_foreach (book_view->change_context->del_ids, (GFunc)g_free, NULL);
g_list_free (book_view->change_context->add_cards);
g_list_free (book_view->change_context->add_ids);
g_list_free (book_view->change_context->mod_cards);
g_list_free (book_view->change_context->mod_ids);
- g_list_free (book_view->change_context->del_cards);
g_list_free (book_view->change_context->del_ids);
}
g_free(book_view->change_context);
@@ -548,13 +544,8 @@ pas_backend_file_changes_foreach_key (const char *key, gpointer user_data)
db_error = db->get (db, &id_dbt, &vcard_dbt, 0);
if (db_error == 1) {
- ECard *ecard;
char *id = id_dbt.data;
- ecard = e_card_new ("");
- e_card_set_id (ecard, id);
-
- ctx->del_cards = g_list_append (ctx->del_cards, e_card_get_vcard (ecard));
ctx->del_ids = g_list_append (ctx->del_ids, strdup(id));
}
}
@@ -576,7 +567,7 @@ pas_backend_file_changes (PASBackendFile *bf,
if (!bf->priv->loaded)
return;
- /* Find the changed ids - FIX ME, patch should not be hard coded */
+ /* Find the changed ids - FIX ME, path should not be hard coded */
filename = g_strdup_printf ("%s/evolution/local/Contacts/%s.db", g_get_home_dir (), view->change_id);
ehash = e_dbhash_new (filename);
g_free (filename);
@@ -640,9 +631,9 @@ pas_backend_file_changes (PASBackendFile *bf,
if (ctx->mod_cards != NULL)
pas_book_view_notify_change (view->book_view, ctx->mod_cards);
- for (v = ctx->del_cards; v != NULL; v = v->next){
- char *vcard = v->data;
- pas_book_view_notify_remove (view->book_view, vcard);
+ for (v = ctx->del_ids; v != NULL; v = v->next){
+ char *id = v->data;
+ pas_book_view_notify_remove (view->book_view, id);
}
pas_book_view_notify_complete (view->book_view);
@@ -1059,7 +1050,6 @@ pas_backend_file_process_get_changes (PASBackend *backend,
ctx.add_ids = NULL;
ctx.mod_cards = NULL;
ctx.mod_ids = NULL;
- ctx.del_cards = NULL;
ctx.del_ids = NULL;
view.search = NULL;
view.search_sexp = NULL;
diff --git a/addressbook/conduit/address-conduit.c b/addressbook/conduit/address-conduit.c
index b31cb61c6e..bcb40f337e 100644
--- a/addressbook/conduit/address-conduit.c
+++ b/addressbook/conduit/address-conduit.c
@@ -70,7 +70,7 @@ void conduit_destroy_gpilot_conduit (GnomePilotConduit*);
typedef struct {
EBookStatus status;
char *id;
-} add_card_cons;
+} CardObjectChangeStatus;
typedef enum {
CARD_ADDED,
@@ -80,7 +80,7 @@ typedef enum {
typedef struct
{
- char *uid;
+ ECard *card;
CardObjectChangeType type;
} CardObjectChange;
@@ -154,7 +154,7 @@ e_addr_context_destroy (EAddrConduitContext **ctxt)
static void
add_card_cb (EBook *ebook, EBookStatus status, const char *id, gpointer closure)
{
- add_card_cons *cons = (add_card_cons*)closure;
+ CardObjectChangeStatus *cons = closure;
cons->status = status;
cons->id = g_strdup (id);
@@ -182,8 +182,12 @@ cursor_cb (EBook *book, EBookStatus status, ECardCursor *cursor, gpointer closur
length = e_card_cursor_get_length (cursor);
ctxt->cards = NULL;
- for (i = 0; i < length; i ++)
- ctxt->cards = g_list_append (ctxt->cards, e_card_cursor_get_nth (cursor, i));
+ for (i = 0; i < length; i ++) {
+ ECard *card = e_card_cursor_get_nth (cursor, i);
+
+ gtk_object_ref (GTK_OBJECT (card));
+ ctxt->cards = g_list_append (ctxt->cards, card);
+ }
gtk_main_quit(); /* end the sub event loop */
}
@@ -245,6 +249,22 @@ map_name (EAddrConduitContext *ctxt)
return filename;
}
+static GList *
+next_changed_item (EAddrConduitContext *ctxt, GList *changes)
+{
+ CardObjectChange *coc;
+ GList *l;
+
+ for (l = changes; l != NULL; l = l->next) {
+ coc = l->data;
+
+ if (g_hash_table_lookup (ctxt->changed_hash, e_card_get_id (coc->card)))
+ return l;
+ }
+
+ return NULL;
+}
+
static char *
get_entry_text (struct Address address, int field)
{
@@ -257,9 +277,29 @@ get_entry_text (struct Address address, int field)
static void
compute_status (EAddrConduitContext *ctxt, EAddrLocalRecord *local, const char *uid)
{
+ CardObjectChange *coc;
+
local->local.archived = FALSE;
local->local.secret = FALSE;
- local->local.attr = GnomePilotRecordNothing;
+
+ coc = g_hash_table_lookup (ctxt->changed_hash, uid);
+
+ if (coc == NULL) {
+ local->local.attr = GnomePilotRecordNothing;
+ return;
+ }
+
+ switch (coc->type) {
+ case CARD_ADDED:
+ local->local.attr = GnomePilotRecordNew;
+ break;
+ case CARD_MODIFIED:
+ local->local.attr = GnomePilotRecordModified;
+ break;
+ case CARD_DELETED:
+ local->local.attr = GnomePilotRecordDeleted;
+ break;
+ }
}
static GnomePilotRecord
@@ -362,9 +402,9 @@ local_record_from_uid (EAddrLocalRecord *local,
char *uid,
EAddrConduitContext *ctxt)
{
- ECard *ecard;
+ ECard *ecard = NULL;
- g_assert(local!=NULL);
+ g_assert (local != NULL);
ecard = e_book_get_card (ctxt->ebook, uid);
@@ -372,7 +412,7 @@ local_record_from_uid (EAddrLocalRecord *local,
local_record_from_ecard (local, ecard, ctxt);
} else {
ecard = e_card_new ("");
- ecard_set_id (ecard, uid);
+ e_card_set_id (ecard, uid);
local_record_from_ecard (local, ecard, ctxt);
}
}
@@ -492,11 +532,9 @@ check_for_slow_setting (GnomePilotConduit *c, EAddrConduitContext *ctxt)
int count, map_count;
count = g_list_length (ctxt->cards);
-
map_count = g_hash_table_size (ctxt->map->pid_map);
- /* If there are no objects or objects but no log */
- if ((count == 0) || (count > 0 && map_count == 0)) {
+ if (map_count == 0) {
GnomePilotConduitStandard *conduit;
LOG (" doing slow sync\n");
conduit = GNOME_PILOT_CONDUIT_STANDARD (c);
@@ -512,14 +550,15 @@ card_added (EBookView *book_view, const GList *cards, EAddrConduitContext *ctxt)
const GList *l;
for (l = cards; l != NULL; l = l->next) {
- ECard *card = l->data;
CardObjectChange *coc = g_new0 (CardObjectChange, 1);
- coc->uid = g_strdup (e_card_get_id (card));
+ coc->card = E_CARD (l->data);
coc->type = CARD_ADDED;
+ gtk_object_ref (GTK_OBJECT (coc->card));
ctxt->changed = g_list_prepend (ctxt->changed, coc);
- g_hash_table_insert (ctxt->changed_hash, coc->uid, coc);
+ if (!e_pilot_map_uid_is_archived (ctxt->map, e_card_get_id (coc->card)))
+ g_hash_table_insert (ctxt->changed_hash, e_card_get_id (coc->card), coc);
}
}
@@ -529,14 +568,15 @@ card_changed (EBookView *book_view, const GList *cards, EAddrConduitContext *ctx
const GList *l;
for (l = cards; l != NULL; l = l->next) {
- ECard *card = l->data;
CardObjectChange *coc = g_new0 (CardObjectChange, 1);
-
- coc->uid = g_strdup (e_card_get_id (card));
+
+ coc->card = E_CARD (l->data);
coc->type = CARD_MODIFIED;
- g_print ("UID **** %s\n", coc->uid);
+
+ gtk_object_ref (GTK_OBJECT (coc->card));
ctxt->changed = g_list_prepend (ctxt->changed, coc);
- g_hash_table_insert (ctxt->changed_hash, coc->uid, coc);
+ if (!e_pilot_map_uid_is_archived (ctxt->map, e_card_get_id (coc->card)))
+ g_hash_table_insert (ctxt->changed_hash, e_card_get_id (coc->card), coc);
}
}
@@ -546,11 +586,13 @@ card_removed (EBookView *book_view, const char *id, EAddrConduitContext *ctxt)
{
CardObjectChange *coc = g_new0 (CardObjectChange, 1);
- coc->uid = g_strdup (id);
+ coc->card = e_card_new ("");
+ e_card_set_id (coc->card, id);
coc->type = CARD_DELETED;
ctxt->changed = g_list_prepend (ctxt->changed, coc);
- g_hash_table_insert (ctxt->changed_hash, coc->uid, coc);
+ if (!e_pilot_map_uid_is_archived (ctxt->map, id))
+ g_hash_table_insert (ctxt->changed_hash, e_card_get_id (coc->card), coc);
}
static void
@@ -693,6 +735,8 @@ set_status_cleared (GnomePilotConduitSyncAbs *conduit,
{
LOG ("set_status_cleared: clearing status\n");
+ g_hash_table_remove (ctxt->changed_hash, e_card_get_id (local->ecard));
+
return 0;
}
@@ -749,7 +793,7 @@ for_each_modified (GnomePilotConduitSyncAbs *conduit,
EAddrLocalRecord **local,
EAddrConduitContext *ctxt)
{
- static GList *changes, *iterator;
+ static GList *iterator;
static int count;
g_return_val_if_fail (local != NULL, 0);
@@ -757,39 +801,36 @@ for_each_modified (GnomePilotConduitSyncAbs *conduit,
if (*local == NULL) {
LOG ("beginning for_each_modified: beginning\n");
- changes = ctxt->changed;
+ iterator = ctxt->changed;
count = 0;
- if (changes != NULL) {
- CardObjectChange *coc = changes->data;
+ iterator = next_changed_item (ctxt, iterator);
+ if (iterator != NULL) {
+ CardObjectChange *coc = iterator->data;
- LOG ("iterating over %d records", g_list_length (changes));
+ LOG ("iterating over %d records", g_hash_table_size (ctxt->changed_hash));
*local = g_new0 (EAddrLocalRecord, 1);
- local_record_from_uid (*local, coc->uid, ctxt);
-
- iterator = changes;
+ local_record_from_ecard (*local, coc->card, ctxt);
} else {
LOG ("no events");
- (*local) = NULL;
- return 0;
+
+ *local = NULL;
}
} else {
count++;
- if (g_list_next (iterator)) {
- CardObjectChange *coc;
-
- iterator = g_list_next (iterator);
- coc = iterator->data;
+ iterator = g_list_next (iterator);
+ if (iterator && (iterator = next_changed_item (ctxt, iterator))) {
+ CardObjectChange *coc = iterator->data;
*local = g_new0 (EAddrLocalRecord, 1);
- local_record_from_uid (*local, coc->uid, ctxt);
+ local_record_from_ecard (*local, coc->card, ctxt);
} else {
LOG ("for_each_modified ending");
- /* Tell the pilot the iteration is over */
- (*local) = NULL;
+ /* Signal the iteration is over */
+ *local = NULL;
return 0;
}
@@ -834,7 +875,7 @@ add_record (GnomePilotConduitSyncAbs *conduit,
EAddrConduitContext *ctxt)
{
ECard *ecard;
- add_card_cons cons;
+ CardObjectChangeStatus cons;
int retval = 0;
g_return_val_if_fail (remote != NULL, -1);
@@ -842,7 +883,7 @@ add_record (GnomePilotConduitSyncAbs *conduit,
LOG ("add_record: adding %s to desktop\n", print_remote (remote));
ecard = ecard_from_remote_record (ctxt, remote, NULL);
-
+
/* add the ecard to the server */
e_book_add_card (ctxt->ebook, ecard, add_card_cb, &cons);
@@ -853,10 +894,7 @@ add_record (GnomePilotConduitSyncAbs *conduit,
return -1;
}
- e_card_set_id (ecard, cons.id);
- ctxt->cards = g_list_append (ctxt->cards, ecard);
- g_free (cons.id);
-
+ e_card_set_id (ecard, cons.id);
e_pilot_map_insert (ctxt->map, remote->ID, ecard->id, FALSE);
return retval;
@@ -870,6 +908,9 @@ replace_record (GnomePilotConduitSyncAbs *conduit,
{
ECard *new_ecard;
EBookStatus commit_status;
+ CardObjectChange *coc;
+ CardObjectChangeStatus cons;
+ char *old_id;
int retval = 0;
g_return_val_if_fail (remote != NULL, -1);
@@ -877,19 +918,41 @@ replace_record (GnomePilotConduitSyncAbs *conduit,
LOG ("replace_record: replace %s with %s\n",
print_local (local), print_remote (remote));
+ old_id = g_strdup (e_card_get_id (local->ecard));
+ coc = g_hash_table_lookup (ctxt->changed_hash, old_id);
+
new_ecard = ecard_from_remote_record (ctxt, remote, local->ecard);
gtk_object_unref (GTK_OBJECT (local->ecard));
local->ecard = new_ecard;
- e_book_commit_card (ctxt->ebook, local->ecard, status_cb, &commit_status);
+ if (coc && coc->type == CARD_DELETED)
+ e_book_add_card (ctxt->ebook, local->ecard, add_card_cb, &cons);
+ else
+ e_book_commit_card (ctxt->ebook, local->ecard, status_cb, &commit_status);
gtk_main (); /* enter sub mainloop */
+
+ /* Adding a record causes wombat to assign a new uid so we must tidy */
+ if (coc && coc->type == CARD_DELETED) {
+ gboolean arch = e_pilot_map_uid_is_archived (ctxt->map, e_card_get_id (local->ecard));
+
+ e_card_set_id (local->ecard, cons.id);
+ e_pilot_map_insert (ctxt->map, remote->ID, cons.id, arch);
+
+ coc = g_hash_table_lookup (ctxt->changed_hash, old_id);
+ if (coc) {
+ g_hash_table_remove (ctxt->changed_hash, e_card_get_id (coc->card));
+ coc->card = local->ecard;
+ g_hash_table_insert (ctxt->changed_hash, e_card_get_id (coc->card), coc);
+
+ }
+
+ commit_status = cons.status;
+ }
if (commit_status != E_BOOK_STATUS_SUCCESS)
WARN ("replace_record: failed to update card in ebook\n");
- gtk_object_unref (GTK_OBJECT (new_ecard));
-
return retval;
}
@@ -910,7 +973,7 @@ delete_record (GnomePilotConduitSyncAbs *conduit,
gtk_main (); /* enter sub mainloop */
- if (commit_status != E_BOOK_STATUS_SUCCESS)
+ if (commit_status != E_BOOK_STATUS_SUCCESS && commit_status != E_BOOK_STATUS_CARD_NOT_FOUND)
WARN ("delete_record: failed to delete card in ebook\n");
return retval;
generated by cgit v1.2.3 (git 2.25.1) at 2024-11-10 15:08:31 +0800