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
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
|
/* KMail Mail Sender
*
* Author: Stefan Taferner <taferner@alpin.or.at>
*/
#ifndef __KMAIL_SENDER_P_H__
#define __KMAIL_SENDER_P_H__
#include "kmsender.h"
#include <tqstring.h>
#include <tqstringlist.h>
#include <tqobject.h>
#include <tdeio/global.h>
#include <tdeversion.h>
class TDEProcess;
namespace TDEIO {
class Job;
class TransferJob;
class Slave;
}
class KMSendProc: public TQObject
{
TQ_OBJECT
public:
KMSendProc(KMSender*);
virtual ~KMSendProc() {}
/** Initialize sending of one or more messages. */
void start() { emit started( doStart() ); }
/** Send given message. May return before message is sent. */
bool send( const TQString & sender, const TQStringList & to, const TQStringList & cc, const TQStringList & bcc, const TQByteArray & message ) {
reset(); return doSend( sender, to, cc, bcc, message );
}
/** Cleanup after sending messages. */
void finish() { doFinish(); deleteLater(); }
/** Abort sending the current message. Sets mSending to false */
virtual void abort() = 0;
/** Returns TRUE if send was successful, and FALSE otherwise.
Returns FALSE if sending is still in progress. */
bool sendOk() const { return mSendOk; }
/** Returns error message of last call of failed(). */
TQString lastErrorMessage() const { return mLastErrorMessage; }
signals:
/** Emitted when the current message is sent or an error occurred. */
void idle();
/** Emitted when the initialization sequence has finished */
void started(bool);
protected:
/** Called to signal a transmission error. The sender then
calls finish() and terminates sending of messages.
Sets mSending to FALSE. */
void failed(const TQString &msg);
/** Informs the user about what is going on. */
void statusMsg(const TQString&);
private:
void reset();
private:
virtual void doFinish() = 0;
virtual bool doSend( const TQString & sender, const TQStringList & to, const TQStringList & cc, const TQStringList & bcc, const TQByteArray & message ) = 0;
virtual bool doStart() = 0;
protected:
KMSender* mSender;
TQString mLastErrorMessage;
bool mSendOk : 1;
bool mSending : 1;
};
//-----------------------------------------------------------------------------
class KMSendSendmail: public KMSendProc
{
TQ_OBJECT
public:
KMSendSendmail(KMSender*);
~KMSendSendmail();
void start();
void abort();
protected slots:
void receivedStderr(TDEProcess*,char*,int);
void wroteStdin(TDEProcess*);
void sendmailExited(TDEProcess*);
private:
/** implemented from KMSendProc */
void doFinish();
/** implemented from KMSendProc */
bool doSend( const TQString & sender, const TQStringList & to, const TQStringList & cc, const TQStringList & bcc, const TQByteArray & message );
/** implemented from KMSendProc */
bool doStart();
private:
TQByteArray mMsgStr;
char* mMsgPos;
int mMsgRest;
TDEProcess* mMailerProc;
};
//-----------------------------------------------------------------------------
class KMSendSMTP : public KMSendProc
{
TQ_OBJECT
public:
KMSendSMTP(KMSender *sender);
~KMSendSMTP();
void abort();
private slots:
void dataReq(TDEIO::Job *, TQByteArray &);
void result(TDEIO::Job *);
void slaveError(TDEIO::Slave *, int, const TQString &);
private:
/** implemented from KMSendProc */
void doFinish();
/** implemented from KMSendProc */
bool doSend( const TQString & sender, const TQStringList & to, const TQStringList & cc, const TQStringList & bcc, const TQByteArray & message );
/** implemented from KMSendProc */
bool doStart() { return true; }
void cleanup();
private:
TQByteArray mMessage;
uint mMessageLength;
uint mMessageOffset;
bool mInProcess;
TDEIO::TransferJob *mJob;
TDEIO::Slave *mSlave;
};
#endif /* __KMAIL_SENDER_P_H__ */
|
