← Back to branch summary

~ubuntu-branches/ubuntu/oneiric/kdepim/oneiric-updates

« back to all changes in this revision

Viewing changes to kresources/lib/groupwaredataadaptor.cpp

  • Committer: Package Import Robot
  • Author(s): Philip Muškovac
  • Date: 2011-06-28 19:33:24 UTC
  • mfrom: (0.2.13) (0.1.13 sid)
  • Revision ID: package-import@ubuntu.com-20110628193324-8yvjs8sdv9rdoo6c
Tags: 4:4.7.0-0ubuntu1
* New upstream release
  - update install files
  - add missing kdepim-doc package to control file
  - Fix Vcs lines
  - kontact breaks/replaces korganizer << 4:4.6.80
  - tighten the dependency of kdepim-dev on libkdepim4 to fix lintian error

Show diffs side-by-side

added added

removed removed

Lines of Context:
kresources/lib/groupwaredataadaptor.cpp
1
 
/*
2
 
    This file is part of kdepim.
3
 
 
4
 
    Copyright (c) 2004 Cornelius Schumacher <schumacher@kde.org>
5
 
    Copyright (c) 2004 Till Adam <adam@kde.org>
6
 
    Copyright (c) 2005 Reinhold Kainhofer <reinhold@kainhofer.com>
7
 
 
8
 
    This library is free software; you can redistribute it and/or
9
 
    modify it under the terms of the GNU Library General Public
10
 
    License as published by the Free Software Foundation; either
11
 
    version 2 of the License, or (at your option) any later version.
12
 
 
13
 
    This library is distributed in the hope that it will be useful,
14
 
    but WITHOUT ANY WARRANTY; without even the implied warranty of
15
 
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
16
 
    Library General Public License for more details.
17
 
 
18
 
    You should have received a copy of the GNU Library General Public License
19
 
    along with this library; see the file COPYING.LIB.  If not, write to
20
 
    the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
21
 
    Boston, MA 02110-1301, USA.
22
 
*/
23
 
 
24
 
#include "groupwaredataadaptor.h"
25
 
#include <kdebug.h>
26
 
#include <kio/job.h>
27
 
#include <kio/deletejob.h>
28
 
#include <kresources/idmapper.h>
29
 
 
30
 
using namespace KPIM;
31
 
 
32
 
GroupwareUploadItem::GroupwareUploadItem( UploadType type ) : mItemType( KPIM::FolderLister::Unknown ), mType( type )
33
 
{
34
 
}
35
 
 
36
 
KUrl GroupwareUploadItem::adaptNewItemUrl( GroupwareDataAdaptor *adaptor,
37
 
                                           const KUrl &baseurl )
38
 
{
39
 
kDebug()<<"GroupwareUploadItem::adaptNewItemUrl, baseurl=" << baseurl.url();
40
 
  if ( adaptor ) {
41
 
    QString path( adaptor->defaultNewItemName( this ) );
42
 
kDebug() <<"path=" << path;
43
 
    KUrl u( baseurl );
44
 
    if ( path.isEmpty() ) return u;
45
 
    else {
46
 
      u.addPath( path );
47
 
kDebug() <<"Final Path for new item:" << u.url();
48
 
      return u;
49
 
    }
50
 
  } else return baseurl;
51
 
}
52
 
 
53
 
KIO::TransferJob *GroupwareUploadItem::createRawUploadJob(
54
 
                       GroupwareDataAdaptor *adaptor, const KUrl &/*baseurl*/ )
55
 
{
56
 
  Q_ASSERT( adaptor );
57
 
  if ( !adaptor ) return 0;
58
 
  const QString dta = data();
59
 
  //kDebug(7000) <<"Uploading:" << data;
60
 
  KUrl upUrl( url() );
61
 
  if ( adaptor )
62
 
    adaptor->adaptUploadUrl( upUrl );
63
 
  kDebug(7000) <<"Uploading to:" << upUrl.prettyUrl();
64
 
  KIO::TransferJob *job = KIO::storedPut( dta.toUtf8(), upUrl, -1, KIO::Overwrite | 
65
 
                                          KIO::HideProgressInfo );
66
 
  job->addMetaData( "PropagateHttpHeader", "true" );
67
 
  if ( adaptor ) {
68
 
    job->addMetaData( "customHTTPHeader", "Content-Type: " + adaptor->mimeType() );
69
 
  }
70
 
  return job;
71
 
}
72
 
 
73
 
KIO::TransferJob *GroupwareUploadItem::createUploadNewJob(
74
 
      GroupwareDataAdaptor *adaptor, const KUrl &baseurl )
75
 
{
76
 
kDebug()<<"GroupwareUploadItem::createUploadNewJob, baseurl=" << baseurl.url();
77
 
  setUrl( adaptNewItemUrl( adaptor, baseurl ) );
78
 
  KIO::TransferJob *job = createRawUploadJob( adaptor, baseurl );
79
 
  if ( job ) {
80
 
    kDebug() <<"Adding If-None-Match";
81
 
    QString header;
82
 
    if ( job->outgoingMetaData().contains("customHTTPHeader") ) {
83
 
      header = job->outgoingMetaData()["customHTTPHeader"];
84
 
      header += "\r\n";
85
 
    }
86
 
    header += "If-None-Match: *";
87
 
    job->addMetaData( "customHTTPHeader", header );
88
 
  }
89
 
  return job;
90
 
}
91
 
 
92
 
KIO::TransferJob *GroupwareUploadItem::createUploadJob(
93
 
                           GroupwareDataAdaptor *adaptor, const KUrl &baseurl )
94
 
{
95
 
kDebug()<<"GroupwareUploadItem::createUploadJob";
96
 
  KIO::TransferJob *job = createRawUploadJob( adaptor, baseurl );
97
 
  if ( job && adaptor ) {
98
 
  kDebug()<<"Adding If-Match header:" << adaptor->idMapper()->fingerprint( uid() );
99
 
    QString header;
100
 
    if ( job->outgoingMetaData().contains("customHTTPHeader") ) {
101
 
      header = job->outgoingMetaData()["customHTTPHeader"];
102
 
      header += "\r\n";
103
 
    }
104
 
kDebug()<<"old HEADER:" << header;
105
 
    header += "If-Match: " + adaptor->idMapper()->fingerprint( uid() );
106
 
kDebug()<<"new HEADER:" << header;
107
 
    job->addMetaData( "customHTTPHeader", header );
108
 
  }
109
 
  return job;
110
 
}
111
 
 
112
 
 
113
 
GroupwareDataAdaptor::GroupwareDataAdaptor()
114
 
  : QObject(), mFolderLister( 0 ), mIdMapper( 0 )
115
 
{
116
 
}
117
 
 
118
 
GroupwareDataAdaptor::~GroupwareDataAdaptor()
119
 
{
120
 
}
121
 
 
122
 
void GroupwareDataAdaptor::setUserPassword( KUrl &url )
123
 
{
124
 
  kDebug(5800) <<"GroupwareDataAdaptor::setUserPassword, mUser="
125
 
                << mUser;
126
 
  url.setUser( mUser );
127
 
  url.setPass( mPassword );
128
 
}
129
 
 
130
 
FolderLister::Entry::List GroupwareDataAdaptor::defaultFolders()
131
 
{
132
 
  return FolderLister::Entry::List();
133
 
}
134
 
 
135
 
KIO::TransferJob *GroupwareDataAdaptor::createUploadJob( const KUrl &url,
136
 
                                                     GroupwareUploadItem *item )
137
 
{
138
 
  if ( item ) {
139
 
    KIO::TransferJob *job = item->createUploadJob( this, url );
140
 
    setUidForJob( job, item->uid() );
141
 
    return job;
142
 
  } else return 0;
143
 
}
144
 
 
145
 
KIO::TransferJob *GroupwareDataAdaptor::createUploadNewJob( const KUrl &url,
146
 
                                                     GroupwareUploadItem *item )
147
 
{
148
 
kDebug()<<"GroupwareDataAdaptor::createUploadNewJob, url=" << url.url();
149
 
  if ( item ) {
150
 
    KIO::TransferJob *job = item->createUploadNewJob( this, url );
151
 
    setUidForJob( job, item->uid() );
152
 
    return job;
153
 
  } else return 0;
154
 
}
155
 
 
156
 
void GroupwareDataAdaptor::processDownloadListItem( const KUrl &entry,
157
 
        const QString &newFingerprint, KPIM::FolderLister::ContentType type )
158
 
{
159
 
  bool download = false;
160
 
  const QString &location = entry.path();
161
 
 
162
 
  emit itemOnServer( entry );
163
 
  // if not locally present, download
164
 
  const QString &localId = idMapper()->localId( location );
165
 
  kDebug(5800) <<"Looking up remote:" << location
166
 
                << "found:" << localId;
167
 
  if ( localId.isEmpty() || !localItemExists( localId ) ) {
168
 
    //kDebug(7000) <<"Not locally present, download:" << location;
169
 
    download = true;
170
 
  } else {
171
 
    kDebug(5800) <<"Locally present";
172
 
    // locally present, let's check if it's newer than what we have
173
 
    const QString &oldFingerprint = idMapper()->fingerprint( localId );
174
 
      if ( oldFingerprint != newFingerprint ) {
175
 
      kDebug(5800) <<"Fingerprint changed old:" << oldFingerprint <<
176
 
        "new:" << newFingerprint;
177
 
      // something changed on the server, check if we also changed it locally
178
 
      if ( localItemHasChanged( localId ) ) {
179
 
        // TODO conflict resolution
180
 
        kDebug(5800) <<"TODO conflict resolution";
181
 
        download = true;
182
 
      } else {
183
 
        download = true;
184
 
      }
185
 
    } else {
186
 
      kDebug(5800) <<"Fingerprint not changed, don't download this";
187
 
    }
188
 
  }
189
 
  if ( download ) {
190
 
    emit itemToDownload( entry, type );
191
 
  }
192
 
}
193
 
 
194
 
bool GroupwareDataAdaptor::interpretRemoveJob( KIO::Job *job, const QString &/*jobData*/ )
195
 
{
196
 
  if ( !job ) return false;
197
 
  KIO::DeleteJob *deljob = dynamic_cast<KIO::DeleteJob*>(job);
198
 
  bool error = job->error();
199
 
  const QString err = job->errorString();
200
 
 
201
 
  if ( deljob ) {
202
 
    KUrl::List urls( deljob->urls() );
203
 
    for ( KUrl::List::Iterator it = urls.begin(); it != urls.end(); ++it ) {
204
 
      if ( error ) {
205
 
        emit itemDeletionError( *it, err );
206
 
      } else {
207
 
        // FIXME: Don't use QString() here
208
 
        emit itemDeleted( QString(), *it );
209
 
      }
210
 
    }
211
 
    return true;
212
 
  } else {
213
 
    return false;
214
 
  }
215
 
}
216
 
 
217
 
 
218
 
bool GroupwareDataAdaptor::interpretUploadJob( KIO::Job *job, const QString &/*jobData*/ )
219
 
{
220
 
  kDebug(7000) <<"GroupwareDataAdaptor::interpretUploadJob";
221
 
  KIO::TransferJob *trfjob = dynamic_cast<KIO::TransferJob*>(job);
222
 
  bool error = job->error();
223
 
  const QString err = job->errorString();
224
 
 
225
 
  if ( trfjob ) {
226
 
    KUrl url( trfjob->url() );
227
 
    if ( error ) {
228
 
      emit itemUploadError( url, err );
229
 
    } else {
230
 
      // We don't know the local id here (and we don't want to extract it from
231
 
      // the idMapper, that's the task of the receiver
232
 
      emit itemUploaded( uidFromJob( job ), url );
233
 
    }
234
 
    return true;
235
 
  } else {
236
 
    return false;
237
 
  }
238
 
}
239
 
 
240
 
bool GroupwareDataAdaptor::interpretUploadNewJob( KIO::Job *job, const QString &/*jobData*/ )
241
 
{
242
 
// TODO: How does the incidence mapper know the old/new ids???
243
 
  kDebug(7000) <<"GroupwareDataAdaptor::interpretUploadNewJob";
244
 
  KIO::TransferJob *trfjob = dynamic_cast<KIO::TransferJob*>(job);
245
 
  bool error = job->error();
246
 
  const QString err = job->errorString();
247
 
 
248
 
  if ( trfjob ) {
249
 
    KUrl url( trfjob->url() );
250
 
    if ( error ) {
251
 
      emit itemUploadNewError( idMapper()->localId( url.path() ), err );
252
 
    } else {
253
 
      // We don't know the local id here (and we don't want to extract it from
254
 
      // the idMapper, that's the task of the receiver
255
 
      emit itemUploadedNew( uidFromJob( job ), url );
256
 
    }
257
 
    return true;
258
 
  } else {
259
 
    return false;
260
 
  }
261
 
}
262
 
 
263
 
QString GroupwareDataAdaptor::uidFromJob( KIO::Job *job ) const
264
 
{
265
 
kDebug()<<"GroupwareDataAdaptor::uidFromJob("<<job<<")";
266
 
  if ( mJobUIDMap.contains( job ) ) {
267
 
    kDebug()<<"  Contained:"<< mJobUIDMap[job];
268
 
    return mJobUIDMap[ job ];
269
 
  } else {
270
 
    return QString();
271
 
  }
272
 
}
273
 
 
274
 
void GroupwareDataAdaptor::setUidForJob( KIO::Job *job, const QString &uid )
275
 
{
276
 
  if ( uid.isEmpty() ) {
277
 
    mJobUIDMap.remove( job );
278
 
  } else {
279
 
    mJobUIDMap[ job ] = uid;
280
 
  }
281
 
}
282
 
 
283
 
 
284
 
#include "groupwaredataadaptor.moc"