00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021 #include "searchcreatejob.h"
00022
00023 #include "collection.h"
00024 #include "imapparser_p.h"
00025 #include "protocolhelper_p.h"
00026 #include "job_p.h"
00027 #include <akonadi/private/protocol_p.h>
00028
00029 using namespace Akonadi;
00030
00031 class Akonadi::SearchCreateJobPrivate : public JobPrivate
00032 {
00033 public:
00034 SearchCreateJobPrivate( SearchCreateJob *parent )
00035 : JobPrivate( parent )
00036 {
00037 }
00038
00039 QString mName;
00040 QString mQuery;
00041 QString mQueryLanguage;
00042 Collection mCreatedCollection;
00043 };
00044
00045 SearchCreateJob::SearchCreateJob( const QString & name, const QString & query, QObject * parent )
00046 : Job( new SearchCreateJobPrivate( this ), parent )
00047 {
00048 Q_D( SearchCreateJob );
00049
00050 d->mName = name;
00051 d->mQuery = query;
00052 }
00053
00054 SearchCreateJob::~SearchCreateJob()
00055 {
00056 }
00057
00058 void SearchCreateJob::setQueryLanguage(const QString& queryLanguage)
00059 {
00060 Q_D( SearchCreateJob );
00061 d->mQueryLanguage = queryLanguage;
00062 }
00063
00064 void SearchCreateJob::doStart()
00065 {
00066 Q_D( SearchCreateJob );
00067
00068 QByteArray command = d->newTag() + " SEARCH_STORE ";
00069 command += ImapParser::quote( d->mName.toUtf8() );
00070 command += ' ';
00071 command += ImapParser::quote( d->mQuery.toUtf8() );
00072 if ( !d->mQueryLanguage.isEmpty() ) {
00073 command += " (" AKONADI_PARAM_PERSISTENTSEARCH_QUERYLANG " ";
00074 command += ImapParser::quote( d->mQueryLanguage.toUtf8() );
00075 command += ')';
00076 }
00077 command += '\n';
00078 d->writeData( command );
00079 }
00080
00081 Akonadi::Collection SearchCreateJob::createdCollection() const
00082 {
00083 Q_D( const SearchCreateJob );
00084 return d->mCreatedCollection;
00085 }
00086
00087 void SearchCreateJob::doHandleResponse( const QByteArray &tag, const QByteArray &data )
00088 {
00089 Q_D( SearchCreateJob );
00090 if ( tag == "*" ) {
00091 ProtocolHelper::parseCollection( data, d->mCreatedCollection );
00092 return;
00093 }
00094 kDebug() << "Unhandled response: " << tag << data;
00095 }
00096
00097 #include "searchcreatejob.moc"