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
|
/* This file is part of KDE
Copyright (C) 2000 by Wolfram Diestel <[email protected]>
Copyright (C) 2005 by Tim Way <[email protected]>
Copyright (C) 2005 by Volker Krause <[email protected]>
This is free software; you can redistribute it and/or
modify it under the terms of the GNU Library General Public
License version 2 as published by the Free Software Foundation.
*/
#ifndef _NNTP_H
#define _NNTP_H
#include <tqstring.h>
#include <kio/global.h>
#include <kio/tcpslavebase.h>
#define MAX_PACKET_LEN 4096
/* TODO:
- test special post command
- progress information in get, and maybe post
- remove unnecessary debug stuff
*/
class NNTPProtocol:public TDEIO::TCPSlaveBase
{
public:
/** Default Constructor
* @param isSSL is a true or false to indicate whether ssl is to be used
*/
NNTPProtocol ( const TQCString & pool, const TQCString & app, bool isSSL );
virtual ~NNTPProtocol();
virtual void get(const KURL& url );
virtual void put( const KURL& url, int permissions, bool overwrite, bool resume );
virtual void stat(const KURL& url );
virtual void listDir(const KURL& url );
virtual void setHost(const TQString& host, int port,
const TQString& user, const TQString& pass);
/**
* Special command: 1 = post article
* it takes no other args, the article data are
* requested by dataReq() and should be valid
* as in RFC850. It's not checked for correctness here.
* @deprecated use put() for posting
*/
virtual void special(const TQByteArray& data);
protected:
/**
* Send a command to the server. Returns the response code and
* the response line
*/
int sendCommand( const TQString &cmd );
/**
* Attempt to properly shut down the NNTP connection by sending
* "QUIT\r\n" before closing the socket.
*/
void nntp_close ();
/**
* Attempt to initiate a NNTP connection via a TCP socket, if no existing
* connection could be reused.
*/
bool nntp_open();
/**
* Post article. Invoked by special() and put()
*/
bool post_article();
private:
TQString mHost, mUser, mPass;
bool postingAllowed, opened;
char readBuffer[MAX_PACKET_LEN];
ssize_t readBufferLen;
/**
* Fetch all new groups since the given date or (if the date is empty)
* all available groups.
* @param since Date as specified in RFC 977 for the NEWGROUPS command
*/
void fetchGroups( const TQString &since );
/**
* Fetch message listing from the given newsgroup.
* This will use RFC2980 XOVER if available, plain RFC977 STAT/NEXT
* otherwise.
* @param group The newsgroup name
* @param first Serial number of the first message, 0 lists all messages.
* @return true on sucess, false otherwise.
*/
bool fetchGroup ( TQString &group, unsigned long first = 0 );
/**
* Fetch message listing from the current group using RFC977 STAT/NEXT
* commands.
* @param first message number of the first article
* @return true on sucess, false otherwise.
*/
bool fetchGroupRFC977( unsigned long first );
/**
* Fetch message listing from the current group using the RFC2980 XOVER
* command.
* Additional headers provided by XOVER are added as UDS_EXTRA entries
* to the listing.
* @param first message number of the first article
* @param notSupported boolean reference to indicate if command failed
* due to missing XOVER support on the server.
* @return true on sucess, false otherwise
*/
bool fetchGroupXOVER( unsigned long first, bool ¬Supported );
/// creates an UDSEntry with file information used in stat and listDir
void fillUDSEntry ( TDEIO::UDSEntry & entry, const TQString & name, long size,
bool postingAllowed, bool is_article );
/// error handling for unexpected responses
void unexpected_response ( int res_code, const TQString & command );
/**
* grabs the response line from the server. used after most send_cmd calls. max
* length for the returned string ( char *data ) is 4096 characters including
* the "\r\n" terminator.
*/
int evalResponse ( char *data, ssize_t &len );
};
#endif
|
