1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
|
/*
Kopete Groupwise Protocol
searchusertask.cpp - high level search for users on the server - spawns PollSearchResultsTasks
Copyright (c) 2005 SUSE Linux Products GmbH http://www.suse.com
Based on Iris, Copyright (C) 2003 Justin Karneges
Kopete (c) 2002-2005 by the Kopete developers <kopete-devel@kde.org>
*************************************************************************
* *
* This library is free software; you can redistribute it and/or *
* modify it under the terms of the GNU Lesser General Public *
* License as published by the Free Software Foundation; either *
* version 2 of the License, or (at your option) any later version. *
* *
*************************************************************************
*/
#include <tqdatetime.h>
#include <tqtimer.h>
#include "client.h"
#include "gwerror.h"
#include "gwfield.h"
#include "response.h"
#include "pollsearchresultstask.h"
#include "searchusertask.h"
// the delay we allow the server to initially do the search
#define GW_POLL_INITIAL_DELAY 1000
// the maximum number of times to poll the server
#define GW_POLL_MAXIMUM 5
// the frequency between subsequent polls
#define GW_POLL_FREQUENCY_MS 8000
using namespace GroupWise;
SearchUserTask::SearchUserTask(Task* parent): RequestTask(parent), m_polls( 0 )
{
}
SearchUserTask::~SearchUserTask()
{
}
void SearchUserTask::search( const TQValueList<UserSearchQueryTerm> & query )
{
m_queryHandle = TQString::number( TQDateTime::tqcurrentDateTime().toTime_t () );
Field::FieldList lst;
if ( query.isEmpty() )
{
setError( 1, "no query terms" );
return;
}
// object Id identifies the search for later reference
lst.append( new Field::SingleField( NM_A_SZ_OBJECT_ID, 0, NMFIELD_TYPE_UTF8, m_queryHandle ) );
TQValueList<UserSearchQueryTerm>::ConstIterator it = query.begin();
const TQValueList<UserSearchQueryTerm>::ConstIterator end = query.end();
for ( ; it != end; ++it )
{
Field::SingleField * fld = new Field::SingleField( (*it).field.ascii(), (*it).operation, 0, NMFIELD_TYPE_UTF8, (*it).argument );
lst.append( fld );
}
//lst.append( new Field::SingleField( "Given Name", 0, NMFIELD_TYPE_UTF8, [ NMFIELD_METHOD_EQUAL | NMFIELD_METHOD_MATCHBEGIN | NMFIELD_METHOD_MATCHEND | NMFIELD_METHOD_SEARCH ], searchTerm );
// Or "Surname", NM_A_SZ_USERID, NM_A_SZ_TITLE, NM_A_SZ_DEPARTMENT in other fields
createTransfer( "createsearch", lst );
}
bool SearchUserTask::take( Transfer * transfer )
{
if ( !forMe( transfer ) )
return false;
Response * response = dynamic_cast<Response *>( transfer );
if ( !response )
return false;
if ( response->resultCode() )
{
kdDebug( GROUPWISE_DEBUG_GLOBAL ) << k_funcinfo << "got return code in response << " << response->resultCode() << endl;
setError( response->resultCode() );
return true;
}
// now start the results poll timer
TQTimer::singleShot( GW_POLL_INITIAL_DELAY, this, TQT_SLOT( slotPollForResults() ) );
return true;
}
void SearchUserTask::slotPollForResults()
{
//create a PollSearchResultsTask
PollSearchResultsTask * psrt = new PollSearchResultsTask( client()->rootTask() );
psrt->poll( m_queryHandle );
connect( psrt, TQT_SIGNAL( finished() ), TQT_SLOT( slotGotPollResults() ) );
psrt->go( true );
}
void SearchUserTask::slotGotPollResults()
{
PollSearchResultsTask * psrt = (PollSearchResultsTask *)sender();
kdDebug( GROUPWISE_DEBUG_GLOBAL ) << k_funcinfo << "status code is " << psrt->querytqStatus() << endl;
m_polls++;
switch ( psrt->querytqStatus() )
{
case PollSearchResultsTask::Pending:
case PollSearchResultsTask::InProgess:
if ( m_polls < GW_POLL_MAXIMUM ) // restart timer
TQTimer::singleShot( GW_POLL_FREQUENCY_MS, this, TQT_SLOT( slotPollForResults() ) );
else
setSuccess( psrt->statusCode() );
break;
case PollSearchResultsTask::Completed:
m_results = psrt->results();
setSuccess();
break;
case PollSearchResultsTask::Cancelled:
setError(psrt->statusCode() );
break;
case PollSearchResultsTask::Error:
setError( psrt->statusCode() );
break;
case PollSearchResultsTask::TimeOut:
setError( psrt->statusCode() );
break;
}
}
TQValueList< GroupWise::ContactDetails > SearchUserTask::results()
{
return m_results;
}
#include "searchusertask.moc"
|
