summaryrefslogtreecommitdiff
path: root/libopie
authoreilers <eilers>2002-10-16 10:52:40 (UTC)
committer eilers <eilers>2002-10-16 10:52:40 (UTC)
commitf9756ca203a06fa60413ef1a96416d87b9dc1a6b (patch) (unidiff)
tree0b67c3c485349a1c31ea82e7c12526b990654d58 /libopie
parent9eba62fc184260f1a0455a6dd057e2ccebf4bdac (diff)
downloadopie-f9756ca203a06fa60413ef1a96416d87b9dc1a6b.zip
opie-f9756ca203a06fa60413ef1a96416d87b9dc1a6b.tar.gz
opie-f9756ca203a06fa60413ef1a96416d87b9dc1a6b.tar.bz2
Added some docu to the interface and now using the cache infrastucture by zecke.. :)
Diffstat (limited to 'libopie') (more/less context) (ignore whitespace changes)
-rw-r--r--libopie/pim/ocontactaccess.cpp57
-rw-r--r--libopie/pim/ocontactaccess.h43
-rw-r--r--libopie/pim/ocontactaccessbackend_xml.h21
-rw-r--r--libopie/pim/opimaccesstemplate.h27
4 files changed, 55 insertions, 93 deletions
diff --git a/libopie/pim/ocontactaccess.cpp b/libopie/pim/ocontactaccess.cpp
index e8c0a45..2ca0283 100644
--- a/libopie/pim/ocontactaccess.cpp
+++ b/libopie/pim/ocontactaccess.cpp
@@ -8,32 +8,35 @@
8 *modify it under the terms of the GNU Library General Public 8 *modify it under the terms of the GNU Library General Public
9 * License as published by the Free Software Foundation; either 9 * License as published by the Free Software Foundation; either
10 * version 2 of the License, or (at your option) any later version. 10 * version 2 of the License, or (at your option) any later version.
11 * ===================================================================== 11 * =====================================================================
12 * Info: This class could just work with a change in the header-file 12 * Info: This class could just work with a change in the header-file
13 * of the Contact class ! Therefore our libopie only compiles 13 * of the Contact class ! Therefore our libopie only compiles
14 * with our version of libqpe 14 * with our version of libqpe
15 * ===================================================================== 15 * =====================================================================
16 * ToDo: XML-Backend: Automatic reload if something was changed... 16 * ToDo: XML-Backend: Automatic reload if something was changed...
17 * 17 *
18 * 18 *
19 * ===================================================================== 19 * =====================================================================
20 * Version: $Id$ 20 * Version: $Id$
21 * ===================================================================== 21 * =====================================================================
22 * History: 22 * History:
23 * $Log$ 23 * $Log$
24 * Revision 1.5 2002/10/16 10:52:40 eilers
25 * Added some docu to the interface and now using the cache infrastucture by zecke.. :)
26 *
24 * Revision 1.4 2002/10/14 16:21:54 eilers 27 * Revision 1.4 2002/10/14 16:21:54 eilers
25 * Some minor interface updates 28 * Some minor interface updates
26 * 29 *
27 * Revision 1.3 2002/10/07 17:34:24 eilers 30 * Revision 1.3 2002/10/07 17:34:24 eilers
28 * added OBackendFactory for advanced backend access 31 * added OBackendFactory for advanced backend access
29 * 32 *
30 * Revision 1.2 2002/10/02 16:18:11 eilers 33 * Revision 1.2 2002/10/02 16:18:11 eilers
31 * debugged and seems to work almost perfectly .. 34 * debugged and seems to work almost perfectly ..
32 * 35 *
33 * Revision 1.1 2002/09/27 17:11:44 eilers 36 * Revision 1.1 2002/09/27 17:11:44 eilers
34 * Added API for accessing the Contact-Database ! It is compiling, but 37 * Added API for accessing the Contact-Database ! It is compiling, but
35 * please do not expect that anything is working ! 38 * please do not expect that anything is working !
36 * I will debug that stuff in the next time .. 39 * I will debug that stuff in the next time ..
37 * Please read README_COMPILE for compiling ! 40 * Please read README_COMPILE for compiling !
38 * 41 *
39 * 42 *
@@ -49,140 +52,102 @@
49#include <qlist.h> 52#include <qlist.h>
50#include <qcopchannel_qws.h> 53#include <qcopchannel_qws.h>
51 54
52//#include <qpe/qcopenvelope_qws.h> 55//#include <qpe/qcopenvelope_qws.h>
53#include <qpe/global.h> 56#include <qpe/global.h>
54 57
55#include <errno.h> 58#include <errno.h>
56#include <fcntl.h> 59#include <fcntl.h>
57#include <unistd.h> 60#include <unistd.h>
58#include <stdlib.h> 61#include <stdlib.h>
59 62
60#include "ocontactaccessbackend_xml.h" 63#include "ocontactaccessbackend_xml.h"
61 64
62 65
63OContactAccess::OContactAccess ( const QString appname, const QString , 66OContactAccess::OContactAccess ( const QString appname, const QString ,
64 OContactAccessBackend* end, bool autosync ): 67 OContactAccessBackend* end, bool autosync ):
65 OPimAccessTemplate<OContact>( end ), 68 OPimAccessTemplate<OContact>( end )
66 m_changed ( false )
67{ 69{
68 /* take care of the backend. If there is no one defined, we 70 /* take care of the backend. If there is no one defined, we
69 * will use the XML-Backend as default (until we have a cute SQL-Backend..). 71 * will use the XML-Backend as default (until we have a cute SQL-Backend..).
70 */ 72 */
71 if( end == 0 ) { 73 if( end == 0 ) {
72 qWarning ("Using BackendFactory !"); 74 qWarning ("Using BackendFactory !");
73 end = OBackendFactory<OContactAccessBackend>::Default( "contact", appname ); 75 end = OBackendFactory<OContactAccessBackend>::Default( "contact", appname );
74 } 76 }
75 // Set backend locally and in template 77 // Set backend locally and in template
76 m_backEnd = end; 78 m_backEnd = end;
77 OPimAccessTemplate<OContact>::setBackEnd (end); 79 OPimAccessTemplate<OContact>::setBackEnd (end);
78 80
79 81
80 /* Connect signal of external db change to function */ 82 /* Connect signal of external db change to function */
81 QCopChannel *dbchannel = new QCopChannel( "QPE/PIM", this ); 83 QCopChannel *dbchannel = new QCopChannel( "QPE/PIM", this );
82 connect( dbchannel, SIGNAL(received(const QCString &, const QByteArray &)), 84 connect( dbchannel, SIGNAL(received(const QCString &, const QByteArray &)),
83 this, SLOT(copMessage( const QCString &, const QByteArray &)) ); 85 this, SLOT(copMessage( const QCString &, const QByteArray &)) );
84 if ( autosync ){ 86 if ( autosync ){
85 QCopChannel *syncchannel = new QCopChannel( "QPE/Sync", this ); 87 QCopChannel *syncchannel = new QCopChannel( "QPE/Sync", this );
86 connect( syncchannel, SIGNAL(received(const QCString &, const QByteArray &)), 88 connect( syncchannel, SIGNAL(received(const QCString &, const QByteArray &)),
87 this, SLOT(copMessage( const QCString &, const QByteArray &)) ); 89 this, SLOT(copMessage( const QCString &, const QByteArray &)) );
88 } 90 }
89 91
90 92
91} 93}
92OContactAccess::~OContactAccess () 94OContactAccess::~OContactAccess ()
93{ 95{
94 /* The user may forget to save the changed database, therefore try to 96 /* The user may forget to save the changed database, therefore try to
95 * do it for him.. 97 * do it for him..
96 */ 98 */
97 if ( m_changed ) 99 save();
98 save();
99 // delete m_backEnd; is done by template.. 100 // delete m_backEnd; is done by template..
100} 101}
101 102
102bool OContactAccess::load()
103{
104 return ( m_backEnd->load() );
105}
106 103
107bool OContactAccess::save () 104bool OContactAccess::save ()
108{ 105{
109 /* If the database was changed externally, we could not save the 106 /* If the database was changed externally, we could not save the
110 * Data. This will remove added items which is unacceptable ! 107 * Data. This will remove added items which is unacceptable !
111 * Therefore: Reload database and merge the data... 108 * Therefore: Reload database and merge the data...
112 */ 109 */
113 if ( m_backEnd->wasChangedExternally() ) 110 if ( OPimAccessTemplate<OContact>::wasChangedExternally() )
114 reload(); 111 reload();
115 112
116 if ( m_changed ){ 113 bool status = OPimAccessTemplate<OContact>::save();
117 bool status = m_backEnd->save(); 114 if ( !status ) return false;
118 if ( !status ) return false;
119 115
120 m_changed = false; 116 /* Now tell everyone that new data is available.
121 /* Now tell everyone that new data is available. 117 */
122 */ 118 QCopEnvelope e( "QPE/PIM", "addressbookUpdated()" );
123 QCopEnvelope e( "QPE/PIM", "addressbookUpdated()" );
124
125 }
126 119
127 return true; 120 return true;
128} 121}
129 122
130const uint OContactAccess::querySettings() 123const uint OContactAccess::querySettings()
131{ 124{
132 return ( m_backEnd->querySettings() ); 125 return ( m_backEnd->querySettings() );
133} 126}
134 127
135bool OContactAccess::hasQuerySettings ( int querySettings ) const 128bool OContactAccess::hasQuerySettings ( int querySettings ) const
136{ 129{
137 return ( m_backEnd->hasQuerySettings ( querySettings ) ); 130 return ( m_backEnd->hasQuerySettings ( querySettings ) );
138} 131}
139 132
140bool OContactAccess::add ( const OContact& newcontact )
141{
142 m_changed = true;
143 return ( m_backEnd->add ( newcontact ) );
144}
145
146bool OContactAccess::replace ( const OContact& contact )
147{
148 m_changed = true;
149 return ( m_backEnd->replace ( contact ) );
150}
151
152bool OContactAccess::remove ( const OContact& t )
153{
154 m_changed = true;
155 return ( m_backEnd->remove ( t.uid() ) );
156}
157
158bool OContactAccess::remove ( int uid )
159{
160 m_changed = true;
161 return ( m_backEnd->remove ( uid ) );
162}
163 133
164bool OContactAccess::wasChangedExternally()const 134bool OContactAccess::wasChangedExternally()const
165{ 135{
166 return ( m_backEnd->wasChangedExternally() ); 136 return ( m_backEnd->wasChangedExternally() );
167} 137}
168 138
169 139
170bool OContactAccess::reload()
171{
172 return ( m_backEnd->reload() );
173}
174
175void OContactAccess::copMessage( const QCString &msg, const QByteArray & ) 140void OContactAccess::copMessage( const QCString &msg, const QByteArray & )
176{ 141{
177 if ( msg == "addressbookUpdated()" ){ 142 if ( msg == "addressbookUpdated()" ){
178 qWarning ("OContactAccess: Received addressbokUpdated()"); 143 qWarning ("OContactAccess: Received addressbokUpdated()");
179 emit signalChanged ( this ); 144 emit signalChanged ( this );
180 } else if ( msg == "flush()" ) { 145 } else if ( msg == "flush()" ) {
181 qWarning ("OContactAccess: Received flush()"); 146 qWarning ("OContactAccess: Received flush()");
182 save (); 147 save ();
183 } else if ( msg == "reload()" ) { 148 } else if ( msg == "reload()" ) {
184 qWarning ("OContactAccess: Received reload()"); 149 qWarning ("OContactAccess: Received reload()");
185 reload (); 150 reload ();
186 emit signalChanged ( this ); 151 emit signalChanged ( this );
187 } 152 }
188} 153}
diff --git a/libopie/pim/ocontactaccess.h b/libopie/pim/ocontactaccess.h
index adc66cf..da9c942 100644
--- a/libopie/pim/ocontactaccess.h
+++ b/libopie/pim/ocontactaccess.h
@@ -4,32 +4,35 @@
4 * Copyright (c) 2002 by Stefan Eilers (Eilers.Stefan@epost.de) 4 * Copyright (c) 2002 by Stefan Eilers (Eilers.Stefan@epost.de)
5 * Copyright (c) 2002 by Holger Freyther (zecke@handhelds.org) 5 * Copyright (c) 2002 by Holger Freyther (zecke@handhelds.org)
6 * 6 *
7 * ===================================================================== 7 * =====================================================================
8 *This program is free software; you can redistribute it and/or 8 *This program is free software; you can redistribute it and/or
9 *modify it under the terms of the GNU Library General Public 9 *modify it under the terms of the GNU Library General Public
10 * License as published by the Free Software Foundation; 10 * License as published by the Free Software Foundation;
11 * either version 2 of the License, or (at your option) any later 11 * either version 2 of the License, or (at your option) any later
12 * version. 12 * version.
13 * ===================================================================== 13 * =====================================================================
14 * ToDo: Define enum for query settings 14 * ToDo: Define enum for query settings
15 * ===================================================================== 15 * =====================================================================
16 * Version: $Id$ 16 * Version: $Id$
17 * ===================================================================== 17 * =====================================================================
18 * History: 18 * History:
19 * $Log$ 19 * $Log$
20 * Revision 1.3 2002/10/16 10:52:40 eilers
21 * Added some docu to the interface and now using the cache infrastucture by zecke.. :)
22 *
20 * Revision 1.2 2002/10/14 16:21:54 eilers 23 * Revision 1.2 2002/10/14 16:21:54 eilers
21 * Some minor interface updates 24 * Some minor interface updates
22 * 25 *
23 * Revision 1.1 2002/09/27 17:11:44 eilers 26 * Revision 1.1 2002/09/27 17:11:44 eilers
24 * Added API for accessing the Contact-Database ! It is compiling, but 27 * Added API for accessing the Contact-Database ! It is compiling, but
25 * please do not expect that anything is working ! 28 * please do not expect that anything is working !
26 * I will debug that stuff in the next time .. 29 * I will debug that stuff in the next time ..
27 * Please read README_COMPILE for compiling ! 30 * Please read README_COMPILE for compiling !
28 * 31 *
29 * ===================================================================== 32 * =====================================================================
30 */ 33 */
31#ifndef _OCONTACTACCESS_H 34#ifndef _OCONTACTACCESS_H
32#define _OCONTACTACCESS_H 35#define _OCONTACTACCESS_H
33 36
34#include <qobject.h> 37#include <qobject.h>
35 38
@@ -78,91 +81,51 @@ class OContactAccess: public QObject, public OPimAccessTemplate<OContact>
78 IgnoreCase = 0x0002, 81 IgnoreCase = 0x0002,
79 RegExp = 0x0004, 82 RegExp = 0x0004,
80 ExactMatch = 0x0008, 83 ExactMatch = 0x0008,
81 }; 84 };
82 85
83 /** Return all possible settings. 86 /** Return all possible settings.
84 * @return All settings provided by the current backend 87 * @return All settings provided by the current backend
85 * (i.e.: query_WildCards & query_IgnoreCase) 88 * (i.e.: query_WildCards & query_IgnoreCase)
86 */ 89 */
87 const uint querySettings(); 90 const uint querySettings();
88 91
89 /** Check whether settings are correct. 92 /** Check whether settings are correct.
90 * @return <i>true</i> if the given settings are correct and possible. 93 * @return <i>true</i> if the given settings are correct and possible.
91 */ 94 */
92 bool hasQuerySettings ( int querySettings ) const; 95 bool hasQuerySettings ( int querySettings ) const;
93 96
94 /** Add Contact to database.
95 * @param newcontact The contact to add.
96 * @return <i>true</i> if added successfully.
97 */
98 bool add (const OContact& newcontact);
99
100 /** Replace contact.
101 * Replaces given contact with contact with the user id <i>uid</i>.
102 * @param uid The user ID
103 * @param contact The new contact
104 * @return <i>true</i> if successful.
105 */
106 bool replace ( const OContact& contact );
107
108 /** Remove contact.
109 * Removes contact with the user id <i>uid</i>.
110 * @param The contact to remove
111 * @return <i>true</i> if successful.
112 */
113 bool remove ( const OContact& t );
114
115 /** Remove contact.
116 * Removes contact with the user id <i>uid</i>.
117 * @param The user id of the contact to remove
118 * @return <i>true</i> if successful.
119 */
120 bool remove ( int uid );
121
122 /** Load Database *
123 */
124 bool load();
125
126 /** 97 /**
127 * if the resource was changed externally. 98 * if the resource was changed externally.
128 * You should use the signal instead of polling possible changes ! 99 * You should use the signal instead of polling possible changes !
129 */ 100 */
130 bool wasChangedExternally()const; 101 bool wasChangedExternally()const;
131 102
132 /** Reload database.
133 * You should execute this function if the external database
134 * was changed.
135 * This function will load the external database and afterwards
136 * rejoin the local changes. Therefore the local database will be set consistent.
137 */
138 bool reload();
139 103
140 /** Save contacts database. 104 /** Save contacts database.
141 * Save is more a "commit". After calling this function, all changes are public available. 105 * Save is more a "commit". After calling this function, all changes are public available.
142 * @return true if successful 106 * @return true if successful
143 */ 107 */
144 bool save(); 108 bool save();
145 109
146 signals: 110 signals:
147 /* Signal is emitted if the database was changed. Therefore 111 /* Signal is emitted if the database was changed. Therefore
148 * we may need to reload to stay consistent. 112 * we may need to reload to stay consistent.
149 * @param which Pointer to the database who created this event. This pointer 113 * @param which Pointer to the database who created this event. This pointer
150 * is useful if an application has to handle multiple databases at the same time. 114 * is useful if an application has to handle multiple databases at the same time.
151 * @see reload() 115 * @see reload()
152 */ 116 */
153 void signalChanged ( const OContactAccess *which ); 117 void signalChanged ( const OContactAccess *which );
154 118
155 119
156 private: 120 private:
157 // class OContactAccessPrivate; 121 // class OContactAccessPrivate;
158 // OContactAccessPrivate* d; 122 // OContactAccessPrivate* d;
159 OContactAccessBackend *m_backEnd; 123 OContactAccessBackend *m_backEnd;
160 bool m_loading:1; 124 bool m_loading:1;
161 bool m_changed;
162 125
163 private slots: 126 private slots:
164 void copMessage( const QCString &msg, const QByteArray &data ); 127 void copMessage( const QCString &msg, const QByteArray &data );
165 128
166 129
167}; 130};
168#endif 131#endif
diff --git a/libopie/pim/ocontactaccessbackend_xml.h b/libopie/pim/ocontactaccessbackend_xml.h
index 50ea329..12a75ba 100644
--- a/libopie/pim/ocontactaccessbackend_xml.h
+++ b/libopie/pim/ocontactaccessbackend_xml.h
@@ -4,32 +4,35 @@
4 * Copyright (c) 2002 by Stefan Eilers (Eilers.Stefan@epost.de) 4 * Copyright (c) 2002 by Stefan Eilers (Eilers.Stefan@epost.de)
5 * 5 *
6 * ===================================================================== 6 * =====================================================================
7 *This program is free software; you can redistribute it and/or 7 *This program is free software; you can redistribute it and/or
8 *modify it under the terms of the GNU Library General Public 8 *modify it under the terms of the GNU Library General Public
9 * License as published by the Free Software Foundation; either 9 * License as published by the Free Software Foundation; either
10 * version 2 of the License, or (at your option) any later version. 10 * version 2 of the License, or (at your option) any later version.
11 * ===================================================================== 11 * =====================================================================
12 * ToDo: XML-Backend: Automatic reload if something was changed... 12 * ToDo: XML-Backend: Automatic reload if something was changed...
13 * 13 *
14 * 14 *
15 * ===================================================================== 15 * =====================================================================
16 * Version: $Id$ 16 * Version: $Id$
17 * ===================================================================== 17 * =====================================================================
18 * History: 18 * History:
19 * $Log$ 19 * $Log$
20 * Revision 1.4 2002/10/16 10:52:40 eilers
21 * Added some docu to the interface and now using the cache infrastucture by zecke.. :)
22 *
20 * Revision 1.3 2002/10/14 16:21:54 eilers 23 * Revision 1.3 2002/10/14 16:21:54 eilers
21 * Some minor interface updates 24 * Some minor interface updates
22 * 25 *
23 * Revision 1.2 2002/10/07 17:34:24 eilers 26 * Revision 1.2 2002/10/07 17:34:24 eilers
24 * added OBackendFactory for advanced backend access 27 * added OBackendFactory for advanced backend access
25 * 28 *
26 * Revision 1.1 2002/09/27 17:11:44 eilers 29 * Revision 1.1 2002/09/27 17:11:44 eilers
27 * Added API for accessing the Contact-Database ! It is compiling, but 30 * Added API for accessing the Contact-Database ! It is compiling, but
28 * please do not expect that anything is working ! 31 * please do not expect that anything is working !
29 * I will debug that stuff in the next time .. 32 * I will debug that stuff in the next time ..
30 * Please read README_COMPILE for compiling ! 33 * Please read README_COMPILE for compiling !
31 * 34 *
32 * 35 *
33 */ 36 */
34 37
35#ifndef _OContactAccessBackend_XML_ 38#ifndef _OContactAccessBackend_XML_
@@ -43,51 +46,56 @@
43#include <qarray.h> 46#include <qarray.h>
44 47
45#include <qpe/global.h> 48#include <qpe/global.h>
46 49
47#include <opie/xmltree.h> 50#include <opie/xmltree.h>
48#include "ocontactaccessbackend.h" 51#include "ocontactaccessbackend.h"
49#include "ocontactaccess.h" 52#include "ocontactaccess.h"
50 53
51#include <stdlib.h> 54#include <stdlib.h>
52#include <errno.h> 55#include <errno.h>
53 56
54using namespace Opie; 57using namespace Opie;
55 58
56/* the default xml implementation */ 59/* the default xml implementation */
57class OContactAccessBackend_XML : public OContactAccessBackend { 60class OContactAccessBackend_XML : public OContactAccessBackend {
58 public: 61 public:
59 OContactAccessBackend_XML ( QString appname, QString filename = 0l ) 62 OContactAccessBackend_XML ( QString appname, QString filename = 0l ):
63 m_changed( false )
60 { 64 {
61 m_appName = appname; 65 m_appName = appname;
62 66
63 /* Set journalfile name ... */ 67 /* Set journalfile name ... */
64 m_journalName = getenv("HOME"); 68 m_journalName = getenv("HOME");
65 m_journalName +="/.abjournal" + appname; 69 m_journalName +="/.abjournal" + appname;
66 70
67 /* Expecting to access the default filename if nothing else is set */ 71 /* Expecting to access the default filename if nothing else is set */
68 if ( filename.isEmpty() ){ 72 if ( filename.isEmpty() ){
69 m_fileName = Global::applicationFileName( "addressbook","addressbook.xml" ); 73 m_fileName = Global::applicationFileName( "addressbook","addressbook.xml" );
70 } else 74 } else
71 m_fileName = filename; 75 m_fileName = filename;
72 76
73 /* Load Database now */ 77 /* Load Database now */
74 load (); 78 load ();
75 } 79 }
76 80
77 bool save() { 81 bool save() {
82
83 if ( !m_changed )
84 return true;
85
78 QString strNewFile = m_fileName + ".new"; 86 QString strNewFile = m_fileName + ".new";
79 QFile f( strNewFile ); 87 QFile f( strNewFile );
80 if ( !f.open( IO_WriteOnly|IO_Raw ) ) 88 if ( !f.open( IO_WriteOnly|IO_Raw ) )
81 return false; 89 return false;
82 90
83 int total_written; 91 int total_written;
84 QString out; 92 QString out;
85 out = "<?xml version=\"1.0\" encoding=\"UTF-8\"?><!DOCTYPE Addressbook ><AddressBook>\n" 93 out = "<?xml version=\"1.0\" encoding=\"UTF-8\"?><!DOCTYPE Addressbook ><AddressBook>\n"
86 " <Groups>\n" 94 " <Groups>\n"
87 " </Groups>\n" 95 " </Groups>\n"
88 " <Contacts>\n"; 96 " <Contacts>\n";
89 //QValueList<Contact>::iterator it; 97 //QValueList<Contact>::iterator it;
90 QValueListConstIterator<OContact> it; 98 QValueListConstIterator<OContact> it;
91 for ( it = m_contactList.begin(); it != m_contactList.end(); ++it ) { 99 for ( it = m_contactList.begin(); it != m_contactList.end(); ++it ) {
92 out += "<Contact "; 100 out += "<Contact ";
93 (*it).save( out ); 101 (*it).save( out );
@@ -110,54 +118,57 @@ class OContactAccessBackend_XML : public OContactAccessBackend {
110 QFile::remove( strNewFile ); 118 QFile::remove( strNewFile );
111 return false; 119 return false;
112 } 120 }
113 f.close(); 121 f.close();
114 122
115 // move the file over, I'm just going to use the system call 123 // move the file over, I'm just going to use the system call
116 // because, I don't feel like using QDir. 124 // because, I don't feel like using QDir.
117 if ( ::rename( strNewFile.latin1(), m_fileName.latin1() ) < 0 ) { 125 if ( ::rename( strNewFile.latin1(), m_fileName.latin1() ) < 0 ) {
118 qWarning( "problem renaming file %s to %s, errno: %d", 126 qWarning( "problem renaming file %s to %s, errno: %d",
119 strNewFile.latin1(), m_journalName.latin1(), errno ); 127 strNewFile.latin1(), m_journalName.latin1(), errno );
120 // remove the tmp file... 128 // remove the tmp file...
121 QFile::remove( strNewFile ); 129 QFile::remove( strNewFile );
122 } 130 }
123 131
124 /* The journalfile should be removed now... */ 132 /* The journalfile should be removed now... */
125 removeJournal(); 133 removeJournal();
134
135 m_changed = false;
126 return true; 136 return true;
127 } 137 }
128 138
129 bool load () { 139 bool load () {
130 m_contactList.clear(); 140 m_contactList.clear();
131 141
132 /* Load XML-File and journal if it exists */ 142 /* Load XML-File and journal if it exists */
133 if ( !load ( m_fileName, false ) ) 143 if ( !load ( m_fileName, false ) )
134 return false; 144 return false;
135 /* The returncode of the journalfile is ignored due to the 145 /* The returncode of the journalfile is ignored due to the
136 * fact that it does not exist when this class is instantiated ! 146 * fact that it does not exist when this class is instantiated !
137 * But there may such a file exist, if the application crashed. 147 * But there may such a file exist, if the application crashed.
138 * Therefore we try to load it to get the changes before the # 148 * Therefore we try to load it to get the changes before the #
139 * crash happened... 149 * crash happened...
140 */ 150 */
141 load (m_journalName, true); 151 load (m_journalName, true);
142 152
143 return true; 153 return true;
144 } 154 }
145 155
146 void clear () { 156 void clear () {
147 m_contactList.clear(); 157 m_contactList.clear();
158 m_changed = false;
148 159
149 } 160 }
150 161
151 bool wasChangedExternally() 162 bool wasChangedExternally()
152 { 163 {
153 QFileInfo fi( m_fileName ); 164 QFileInfo fi( m_fileName );
154 165
155 QDateTime lastmod = fi.lastModified (); 166 QDateTime lastmod = fi.lastModified ();
156 167
157 return (lastmod != m_readtime); 168 return (lastmod != m_readtime);
158 } 169 }
159 170
160 QArray<int> allRecords() const { 171 QArray<int> allRecords() const {
161 QArray<int> uid_list( m_contactList.count() ); 172 QArray<int> uid_list( m_contactList.count() );
162 173
163 uint counter = 0; 174 uint counter = 0;
@@ -262,57 +273,64 @@ class OContactAccessBackend_XML : public OContactAccessBackend {
262 case OContactAccess::RegExp: 273 case OContactAccess::RegExp:
263 return ( true ); 274 return ( true );
264 case OContactAccess::WildCards: 275 case OContactAccess::WildCards:
265 return ( true ); 276 return ( true );
266 case OContactAccess::ExactMatch: 277 case OContactAccess::ExactMatch:
267 return ( true ); 278 return ( true );
268 default: 279 default:
269 return ( false ); 280 return ( false );
270 } 281 }
271 } 282 }
272 283
273 bool add ( const OContact &newcontact ) 284 bool add ( const OContact &newcontact )
274 { 285 {
275 //qWarning("odefaultbackend: ACTION::ADD"); 286 //qWarning("odefaultbackend: ACTION::ADD");
276 updateJournal (newcontact, OContact::ACTION_ADD); 287 updateJournal (newcontact, OContact::ACTION_ADD);
277 addContact_p( newcontact ); 288 addContact_p( newcontact );
289
290 m_changed = true;
291
278 return true; 292 return true;
279 } 293 }
280 294
281 bool replace ( const OContact &contact ) 295 bool replace ( const OContact &contact )
282 { 296 {
297 m_changed = true;
298
283 bool found = false; 299 bool found = false;
284 300
285 QValueListIterator<OContact> it; 301 QValueListIterator<OContact> it;
286 for( it = m_contactList.begin(); it != m_contactList.end(); ++it ){ 302 for( it = m_contactList.begin(); it != m_contactList.end(); ++it ){
287 if ( (*it).uid() == contact.uid() ){ 303 if ( (*it).uid() == contact.uid() ){
288 found = true; 304 found = true;
289 break; 305 break;
290 } 306 }
291 } 307 }
292 if (found) { 308 if (found) {
293 updateJournal (contact, OContact::ACTION_REPLACE); 309 updateJournal (contact, OContact::ACTION_REPLACE);
294 m_contactList.remove (it); 310 m_contactList.remove (it);
295 m_contactList.append (contact); 311 m_contactList.append (contact);
296 return true; 312 return true;
297 } else 313 } else
298 return false; 314 return false;
299 } 315 }
300 316
301 bool remove ( int uid ) 317 bool remove ( int uid )
302 { 318 {
319 m_changed = true;
320
303 bool found = false; 321 bool found = false;
304 QValueListIterator<OContact> it; 322 QValueListIterator<OContact> it;
305 for( it = m_contactList.begin(); it != m_contactList.end(); ++it ){ 323 for( it = m_contactList.begin(); it != m_contactList.end(); ++it ){
306 if ((*it).uid() == uid){ 324 if ((*it).uid() == uid){
307 found = true; 325 found = true;
308 break; 326 break;
309 } 327 }
310 } 328 }
311 if (found) { 329 if (found) {
312 updateJournal ( *it, OContact::ACTION_REMOVE); 330 updateJournal ( *it, OContact::ACTION_REMOVE);
313 m_contactList.remove (it); 331 m_contactList.remove (it);
314 return true; 332 return true;
315 } else 333 } else
316 return false; 334 return false;
317 } 335 }
318 336
@@ -540,24 +558,25 @@ class OContactAccessBackend_XML : public OContactAccessBackend {
540 buf = "<Contact "; 558 buf = "<Contact ";
541 cnt.save( buf ); 559 cnt.save( buf );
542 buf += " action=\"" + QString::number( (int)action ) + "\" "; 560 buf += " action=\"" + QString::number( (int)action ) + "\" ";
543 buf += "/>\n"; 561 buf += "/>\n";
544 QCString cstr = buf.utf8(); 562 QCString cstr = buf.utf8();
545 f.writeBlock( cstr.data(), cstr.length() ); 563 f.writeBlock( cstr.data(), cstr.length() );
546 } 564 }
547 565
548 void removeJournal() 566 void removeJournal()
549 { 567 {
550 QFile f ( m_journalName ); 568 QFile f ( m_journalName );
551 if ( f.exists() ) 569 if ( f.exists() )
552 f.remove(); 570 f.remove();
553 } 571 }
554 572
555 protected: 573 protected:
574 bool m_changed;
556 QString m_journalName; 575 QString m_journalName;
557 QString m_fileName; 576 QString m_fileName;
558 QString m_appName; 577 QString m_appName;
559 QValueList<OContact> m_contactList; 578 QValueList<OContact> m_contactList;
560 QDateTime m_readtime; 579 QDateTime m_readtime;
561}; 580};
562 581
563#endif 582#endif
diff --git a/libopie/pim/opimaccesstemplate.h b/libopie/pim/opimaccesstemplate.h
index 3e1f393..50cb1e4 100644
--- a/libopie/pim/opimaccesstemplate.h
+++ b/libopie/pim/opimaccesstemplate.h
@@ -24,94 +24,108 @@ class OPimAccessTemplate : public OTemplateBase<T> {
24public: 24public:
25 typedef ORecordList<T> List; 25 typedef ORecordList<T> List;
26 typedef OPimAccessBackend<T> BackEnd; 26 typedef OPimAccessBackend<T> BackEnd;
27 typedef OPimCache<T> Cache; 27 typedef OPimCache<T> Cache;
28 28
29 /** 29 /**
30 * c'tor BackEnd 30 * c'tor BackEnd
31 */ 31 */
32 OPimAccessTemplate( BackEnd* end); 32 OPimAccessTemplate( BackEnd* end);
33 virtual ~OPimAccessTemplate(); 33 virtual ~OPimAccessTemplate();
34 34
35 /** 35 /**
36 * load from the backend 36 * load from the backend
37 */ 37 */
38 virtual bool load(); 38 virtual bool load();
39 39
40 /** 40 /** Reload database.
41 * reload from the backend 41 * You should execute this function if the external database
42 * was changed.
43 * This function will load the external database and afterwards
44 * rejoin the local changes. Therefore the local database will be set consistent.
42 */ 45 */
43 virtual bool reload(); 46 virtual bool reload();
44 47
45 /** 48 /** Save contacts database.
46 * save to the backend 49 * Save is more a "commit". After calling this function, all changes are public available.
50 * @return true if successful
47 */ 51 */
48 virtual bool save(); 52 virtual bool save();
49 53
50 /** 54 /**
51 * if the resource was changed externally 55 * if the resource was changed externally
56 * You should use the signal handling instead of polling possible changes !
57 * zecke: Do you implement a signal for otodoaccess ?
52 */ 58 */
53 bool wasChangedExternally()const; 59 bool wasChangedExternally()const;
54 60
55 /** 61 /**
56 * return a List of records 62 * return a List of records
57 * you can iterate over them 63 * you can iterate over them
58 */ 64 */
59 virtual List allRecords()const; 65 virtual List allRecords()const;
60 66
61 /** 67 /**
62 * queryByExample) 68 * queryByExample.
63 * @see otodoaccess, ocontactaccess 69 * @see otodoaccess, ocontactaccess
64 */ 70 */
65 virtual List queryByExample( const T& t, int querySettings ); 71 virtual List queryByExample( const T& t, int querySettings );
66 72
67 /** 73 /**
68 * find the OPimRecord uid 74 * find the OPimRecord uid
69 */ 75 */
70 virtual T find( int uid )const; 76 virtual T find( int uid )const;
71 77
72 /** 78 /**
73 * read ahead cache find method ;) 79 * read ahead cache find method ;)
74 */ 80 */
75 virtual T find( int uid, const QArray<int>&, 81 virtual T find( int uid, const QArray<int>&,
76 uint current, CacheDirection dir = Forward )const; 82 uint current, CacheDirection dir = Forward )const;
77 83
78 /* invalidate cache here */ 84 /* invalidate cache here */
79 /** 85 /**
80 * clears the backend and invalidates the backend 86 * clears the backend and invalidates the backend
81 */ 87 */
82 virtual void clear() ; 88 virtual void clear() ;
83 89
84 /** 90 /**
85 * add T to the backend 91 * add T to the backend
92 * @param t The item to add.
93 * @return <i>true</i> if added successfully.
86 */ 94 */
87 virtual bool add( const T& t ) ; 95 virtual bool add( const T& t ) ;
88 96
89 /* only the uid matters */ 97 /* only the uid matters */
90 /** 98 /**
91 * remove T from the backend 99 * remove T from the backend
100 * @param t The item to remove
101 * @return <i>true</i> if successful.
92 */ 102 */
93 virtual bool remove( const T& t ); 103 virtual bool remove( const T& t );
94 104
95 /** 105 /**
96 * remove the OPimRecord with uid 106 * remove the OPimRecord with uid
107 * @param uid The ID of the item to remove
108 * @return <i>true</i> if successful.
97 */ 109 */
98 virtual bool remove( int uid ); 110 virtual bool remove( int uid );
99 111
100 /** 112 /**
101 * replace T from backend 113 * replace T from backend
114 * @param t The item to replace
115 * @return <i>true</i> if successful.
102 */ 116 */
103 virtual bool replace( const T& t) ; 117 virtual bool replace( const T& t) ;
104 118
105 /** 119 /**
106 * @internal 120 * @internal
107 */ 121 */
108 void cache( const T& )const; 122 void cache( const T& )const;
109 void setSaneCacheSize( int ); 123 void setSaneCacheSize( int );
110protected: 124protected:
111 /** 125 /**
112 * invalidate the cache 126 * invalidate the cache
113 */ 127 */
114 void invalidateCache(); 128 void invalidateCache();
115 129
116 void setBackEnd( BackEnd* end ); 130 void setBackEnd( BackEnd* end );
117 /** 131 /**
@@ -129,33 +143,34 @@ OPimAccessTemplate<T>::OPimAccessTemplate( BackEnd* end )
129{ 143{
130 if (end ) 144 if (end )
131 end->setFrontend( this ); 145 end->setFrontend( this );
132} 146}
133template <class T> 147template <class T>
134OPimAccessTemplate<T>::~OPimAccessTemplate() { 148OPimAccessTemplate<T>::~OPimAccessTemplate() {
135 qWarning("~OPimAccessTemplate<T>"); 149 qWarning("~OPimAccessTemplate<T>");
136 delete m_backEnd; 150 delete m_backEnd;
137} 151}
138template <class T> 152template <class T>
139bool OPimAccessTemplate<T>::load() { 153bool OPimAccessTemplate<T>::load() {
140 invalidateCache(); 154 invalidateCache();
141 return m_backEnd->load(); 155 return m_backEnd->load();
142} 156}
143template <class T> 157template <class T>
144bool OPimAccessTemplate<T>::reload() { 158bool OPimAccessTemplate<T>::reload() {
145 return m_backEnd->reload(); 159 invalidateCache(); // zecke: I think this should be added (se)
160 return m_backEnd->reload();
146} 161}
147template <class T> 162template <class T>
148bool OPimAccessTemplate<T>::save() { 163bool OPimAccessTemplate<T>::save() {
149 return m_backEnd->save(); 164 return m_backEnd->save();
150} 165}
151template <class T> 166template <class T>
152OPimAccessTemplate<T>::List OPimAccessTemplate<T>::allRecords()const { 167OPimAccessTemplate<T>::List OPimAccessTemplate<T>::allRecords()const {
153 QArray<int> ints = m_backEnd->allRecords(); 168 QArray<int> ints = m_backEnd->allRecords();
154 List lis(ints, this ); 169 List lis(ints, this );
155 return lis; 170 return lis;
156} 171}
157template <class T> 172template <class T>
158OPimAccessTemplate<T>::List 173OPimAccessTemplate<T>::List
159OPimAccessTemplate<T>::queryByExample( const T& t, int sortOrder ) { 174OPimAccessTemplate<T>::queryByExample( const T& t, int sortOrder ) {
160 QArray<int> ints = m_backEnd->queryByExample( t, sortOrder ); 175 QArray<int> ints = m_backEnd->queryByExample( t, sortOrder );
161 176