implemented

2001-02-13  Rodrigo Moya <rodrigo@ximian.com>

	* pcs/cal-backend-db.c (cal_backend_db_get_alarms_for_object):
	implemented

svn path=/trunk/; revision=8213

1 files changed, 73 insertions, 38 deletions

diff --git a/calendar/pcs/cal-backend-db.c b/calendar/pcs/cal-backend-db.c
index f407d31b08..049cf4d5c7 100644
--- a/calendar/pcs/cal-backend-db.c
+++ b/calendar/pcs/cal-backend-db.c
@@ -20,11 +20,11 @@
  */
 
 #include <config.h>
-#include <gtk/gtkobject.h>
+#include <gtk/gtksignal.h>
 #include "cal-util/cal-recur.h"
 #include "cal-backend-db.h"
 #include <db.h>
-#if DB_MAJOR_VERSION < 3
+#if DB_VERSION_MAJOR < 3
 #  error "You need libdb3 to compile the DB backend"
 #endif
 
@@ -361,7 +361,7 @@ commit_transaction (DB_TXN *tid)
 	
 	g_return_if_fail(tid != NULL);
 	
-	if ((ret = txn_begin(tid, 0)) != 0) {
+	if ((ret = txn_commit(tid, 0)) != 0) {
 		/* TODO: error logging? */
 	}
 }
@@ -473,7 +473,7 @@ open_database_file (CalBackendDB *cbdb, const gchar *str_uri, gboolean only_if_e
 
 		/* if the directory exists, we're done, since DB will fail if it's the
 		 * wrong one. If it does not exist, create the environment */
-		if (mkdir(dir, I_RWXU) != 0) {
+		if (mkdir(dir, S_IRWXU) != 0) {
 			g_free((gpointer) dir);
 			return FALSE;
 		}
@@ -484,7 +484,7 @@ open_database_file (CalBackendDB *cbdb, const gchar *str_uri, gboolean only_if_e
 			return FALSE;
 		}
 		
-		cbdb->priv->environment->set_errorpfx(cbdb->priv->environment, "cal-backend-db");
+		cbdb->priv->environment->set_errpfx(cbdb->priv->environment, "cal-backend-db");
 		
 		/* open the transactional environment */
 		if ((ret = cbdb->priv->environment->open(cbdb->priv->environment,
@@ -545,7 +545,6 @@ cal_backend_db_open (CalBackend *backend, GnomeVFSURI *uri, gboolean only_if_exi
 {
 	CalBackendDB *cbdb;
 	gchar *str_uri;
-	gint ret;
 
 	cbdb = CAL_BACKEND_DB(backend);
 	g_return_val_if_fail(IS_CAL_BACKEND_DB(cbdb), CAL_BACKEND_OPEN_ERROR);
@@ -605,7 +604,7 @@ cal_backend_db_get_n_objects (CalBackend *backend, CalObjType type)
 						if (type & CALOBJ_TYPE_EVENT)
 							total_count++;
 						break;
-					case ICAL_VTODO_COMPONENTS :
+					case ICAL_VTODO_COMPONENT :
 						if (type & CALOBJ_TYPE_TODO)
 							total_count++;
 						break;
@@ -613,6 +612,8 @@ cal_backend_db_get_n_objects (CalBackend *backend, CalObjType type)
 						if (type & CALOBJ_TYPE_JOURNAL)
 							total_count++;
 						break;
+					default :
+						break;
 				}
 				icalcomponent_free(icalcomp);
 			}
@@ -682,7 +683,7 @@ cal_backend_db_get_type_by_uid (CalBackend *backend, const char *uid)
 	                                       &key,
 	                                       &data,
 	                                       0)) == 0) {
-		icalcomponent icalcomp = icalparser_parse_string((char *) data.data);
+		icalcomponent *icalcomp = icalparser_parse_string((char *) data.data);
 		if (icalcomp) {
 			CalObjType type;
 			
@@ -719,7 +720,7 @@ add_uid_if_match (GList *list, CalBackendDBCursor *cursor, GList *data_node, Cal
 	data = (DBT *) data_node->data;
 	if (data) {
 		icalcomponent *icalcomp;
-		gchar *uid;
+		gchar *uid = NULL;
 
 		icalcomp = icalparser_parse_string(data->data);
 		if (!icalcomp) return list;
@@ -727,15 +728,15 @@ add_uid_if_match (GList *list, CalBackendDBCursor *cursor, GList *data_node, Cal
 		switch (icalcomponent_isa(icalcomp)) {
 			case ICAL_VEVENT_COMPONENT :
 				if (type & CALOBJ_TYPE_EVENT)
-					uid = icalcomponent_get_uid(icalcomp);
+					uid = (gchar *) icalcomponent_get_uid(icalcomp);
 				break;
 			case ICAL_VTODO_COMPONENT :
 				if (type & CALOBJ_TYPE_TODO)
-					uid = icalcomponent_get_uid(icalcomp);
+					uid = (gchar *) icalcomponent_get_uid(icalcomp);
 				break;
 			case ICAL_VJOURNAL_COMPONENT :
 				if (type & CALOBJ_TYPE_JOURNAL)
-					uid = icalcomponent_get_uid(icalcomp);
+					uid = (gchar *) icalcomponent_get_uid(icalcomp);
 				break;
 			default :
 				uid = NULL;
@@ -848,9 +849,11 @@ get_instances_in_range (GHashTable *uid_hash,
 							                             add_instance,
 						 	                            uid_hash);
 						break;
+					default :
+						break;
 				}
 
-				gtk_object_unref(comp);
+				gtk_object_unref(GTK_OBJECT(comp));
 				icalcomponent_free(icalcomp);
 			}
 		}
@@ -1139,10 +1142,10 @@ generate_alarms_for_comp (CalComponent *comp, time_t start, time_t end)
 }
 
 /* retrieve list of alarms */
-static GList *
-get_list_of_alarms (CalBackendDBCursor *cursor, time_t start time_t end)
+static GSList *
+get_list_of_alarms (CalBackendDBCursor *cursor, time_t start, time_t end)
 {
-	GList *list = NULL;
+	GSList *list = NULL;
 	GList *node;
 
 	g_return_val_if_fail(cursor != NULL, NULL);
@@ -1168,7 +1171,7 @@ get_list_of_alarms (CalBackendDBCursor *cursor, time_t start time_t end)
 					
 					alarms = generate_alarms_for_comp(comp, start, end);
 					if (alarms)
-						list = g_list_prepend(list, (gpointer) alarms);
+						list = g_slist_prepend(list, (gpointer) alarms);
 
 					gtk_object_unref(GTK_OBJECT(comp));
 				}
@@ -1183,19 +1186,19 @@ get_list_of_alarms (CalBackendDBCursor *cursor, time_t start time_t end)
 
 /* fills a CORBA sequence of alarm instances */
 static void
-fill_alarm_instances_seq (GNOME_Evolution_Calendar_CalAlarmInstanceSeq *seq, GList *alarms)
+fill_alarm_instances_seq (GNOME_Evolution_Calendar_CalAlarmInstanceSeq *seq, GSList *alarms)
 {
 	int n_alarms;
-	GList *l;
+	GSList *l;
 	int i;
 
-	n_alarms = g_list_length (alarms);
+	n_alarms = g_slist_length(alarms);
 
 	CORBA_sequence_set_release(seq, TRUE);
 	seq->_length = n_alarms;
 	seq->_buffer = CORBA_sequence_GNOME_Evolution_Calendar_CalAlarmInstance_allocbuf(n_alarms);
 
-	for (l = g_list_first(alarms), i = 0; l != NULL; l = g_list_next(l), i++) {
+	for (l = alarms, i = 0; l != NULL; l = l->next, i++) {
 		CalAlarmInstance *instance;
 		GNOME_Evolution_Calendar_CalAlarmInstance *corba_instance;
 
@@ -1215,8 +1218,8 @@ cal_backend_db_get_alarms_in_range (CalBackend *backend, time_t start, time_t en
 	CalBackendDB *cbdb;
 	CalBackendDBCursor *cursor;
 	gint number_of_alarms;
-	GList *alarm_list;
-	GList *node;
+	GSList *alarm_list;
+	GSList *node;
 	gint i;
 	GNOME_Evolution_Calendar_CalComponentAlarmsSeq *seq = NULL;
 
@@ -1230,7 +1233,7 @@ cal_backend_db_get_alarms_in_range (CalBackend *backend, time_t start, time_t en
 	cursor = open_cursor(cbdb, cbdb->priv->objects_db);
 	if (cursor) {
 		alarm_list = get_list_of_alarms(cursor, start, end);
-		number_of_alarms = g_list_length(alarm_list);
+		number_of_alarms = g_slist_length(alarm_list);
 		
 		/* create the CORBA sequence */
 		seq = GNOME_Evolution_Calendar_CalComponentAlarmsSeq__alloc();
@@ -1240,9 +1243,7 @@ cal_backend_db_get_alarms_in_range (CalBackend *backend, time_t start, time_t en
 			number_of_alarms);
 		
 		/* populate CORBA sequence */
-		for (node = g_list_first(alarm_list), i = 0;
-		     node != NULL;
-		     node = g_list_next(node), i++) {
+		for (node = alarm_list, i = 0; node != NULL; node = node->next, i++) {
 			CalComponentAlarms *alarms;
 			gchar *comp_str;
 			
@@ -1252,12 +1253,12 @@ cal_backend_db_get_alarms_in_range (CalBackend *backend, time_t start, time_t en
 			seq->_buffer[i].calobj = CORBA_string_dup(comp_str);
 			g_free((gpointer) comp_str);
 
-			fill_alarm_instances_seq (&seq->_buffer[i].alarms, alarms->alarms);
+			fill_alarm_instances_seq(&seq->_buffer[i].alarms, alarms->alarms);
 			
-			cal_component_alarms_free (alarms);
+			cal_component_alarms_free(alarms);
 		}
 		
-		g_list_free(alarm_list);
+		g_slist_free(alarm_list);
 		close_cursor(cbdb, cursor);
 	}
 
@@ -1275,6 +1276,9 @@ cal_backend_db_get_alarms_for_object (CalBackend *backend,
 	CalBackendDB *cbdb;
 	CalBackendDBCursor *cursor;
 	GNOME_Evolution_Calendar_CalComponentAlarms *corba_alarms = NULL;
+	DBT *data;
+	gchar *comp_str;
+	CalComponentAlarms *alarms;
 
 	cbdb = CAL_BACKEND_DB(backend);
 	g_return_val_if_fail(IS_CAL_BACKEND_DB(cbdb), NULL);
@@ -1284,15 +1288,45 @@ cal_backend_db_get_alarms_for_object (CalBackend *backend,
 	g_return_val_if_fail(start <= end, NULL);
 	g_return_val_if_fail(object_found != NULL, NULL);
 
+	*object_found = FALSE;
+
 	/* open the cursor */
-	cursor = open_cursor(cbdb, cbdb->priv->object_db);
+	cursor = open_cursor(cbdb, cbdb->priv->objects_db);
 	if (cursor) {
-		/* TODO: retrieve list of alarms for this object */
-		
-		/* create the CORBA alarms */
-		corba_alarms = GNOME_Evolution_Calendar_CalComponentAlarms__alloc();
-		
-		/* TODO: populate the CORBA alarms */
+		data = find_record_by_id(cursor, uid);
+		if (data) {
+			icalcomponent *icalcomp;
+			CalComponent *comp;
+			
+			*object_found = TRUE;
+
+			comp_str = (gchar *) data->data;
+			
+			icalcomp = icalparser_parse_string(comp_str);
+			if (!icalcomp) {
+				close_cursor(cbdb, cursor);
+				return NULL;
+			}
+			
+			comp = cal_component_new();
+			cal_component_set_icalcomponent(comp, icalcomp);
+						
+			/* create the CORBA alarms */
+			corba_alarms = GNOME_Evolution_Calendar_CalComponentAlarms__alloc();
+			corba_alarms->calobj = CORBA_string_dup (comp_str);
+			
+			/* populate the CORBA sequence */
+			alarms = generate_alarms_for_comp(comp, start, end);
+			if (alarms) {
+				fill_alarm_instances_seq(&corba_alarms->alarms, alarms->alarms);
+				cal_component_alarms_free(alarms);
+			}
+			else
+				fill_alarm_instances_seq(&corba_alarms->alarms, NULL);
+
+			gtk_object_unref(GTK_OBJECT(comp));
+			icalcomponent_free(icalcomp);
+		}
 		
 		close_cursor(cbdb, cursor);
 	}
@@ -1328,6 +1362,7 @@ cal_backend_db_update_object (CalBackend *backend, const char *uid, const char *
 	DB_TXN *tid;
 	DBT key;
 	DBT new_data;
+	gint ret;
 
 	cbdb = CAL_BACKEND_DB(backend);
 	g_return_val_if_fail(IS_CAL_BACKEND_DB(cbdb), FALSE);
@@ -1379,7 +1414,7 @@ cal_backend_db_remove_object (CalBackend *backend, const char *uid)
 	g_return_val_if_fail(cbdb->priv != NULL, FALSE);
 	g_return_val_if_fail(uid != NULL, FALSE);
 	
-	memset(&key, 0, sizeof(key);
+	memset(&key, 0, sizeof(key));
 	key.data = (void *) uid;
 	key.size = strlen(uid); // + 1