d1161484d848a24fa010b2a9850b6ab3d3b5e407
[fms.git] / include / nntp / nntpconnection.h
1 #ifndef _nntpconnection_\r
2 #define _nntpconnection_\r
3 \r
4 #include "../socketdefines.h"\r
5 #include "../ilogger.h"\r
6 #include "../message.h"\r
7 #include "../localidentity.h"\r
8 \r
9 #include <string>\r
10 #include <vector>\r
11 //#include <zthread/Runnable.h>\r
12 #include "../pthreadwrapper/runnable.h"\r
13 \r
14 #ifdef _WIN32\r
15 \r
16 #else\r
17         #include <sys/socket.h>\r
18         #include <sys/select.h>\r
19         #include <sys/types.h>\r
20         #include <netdb.h>\r
21         #include <netinet/in.h>\r
22         #include <arpa/inet.h>\r
23 #endif\r
24 \r
25 class NNTPConnection:public PThread::Runnable,public ILogger\r
26 {\r
27 public:\r
28         NNTPConnection(SOCKET sock);\r
29         ~NNTPConnection();\r
30 \r
31         void Disconnect();\r
32         const bool Disconnected()               { return m_socket==INVALID_SOCKET; }\r
33 \r
34         void Run();\r
35 \r
36 private:\r
37 \r
38         typedef enum ClientMode\r
39         {\r
40                 MODE_NONE=0,\r
41                 MODE_READER\r
42         };\r
43         struct NNTPCommand\r
44         {\r
45                 std::string m_command;\r
46                 std::vector<std::string> m_arguments;\r
47         };\r
48         struct ClientStatus\r
49         {\r
50                 ClientMode m_mode;\r
51                 bool m_allowpost;\r
52                 bool m_isposting;\r
53                 long m_boardid;\r
54                 long m_messageid;\r
55                 LocalIdentity m_authuser;               // -1 if user not authenticated, otherwise id of user from tblLocalIdentity\r
56                 bool m_authenticated;\r
57         };\r
58 \r
59         void SendBuffered(const std::string &data);\r
60         void SendBufferedLine(const std::string &data)  { SendBuffered(data+"\r\n"); }\r
61         void SocketSend();                      // immediately send buffered data - will block if send if no ready\r
62         void SocketReceive();           // immediately recv data on socket - will block if no data is waiting\r
63         void HandleReceivedData();\r
64         std::vector<char>::iterator Find(std::vector<char> &buffer, const std::string &val);\r
65         const bool HandleCommand(const NNTPCommand &command);\r
66         void HandlePostedMessage(const std::string &message);\r
67 \r
68         void SendArticleParts(const NNTPCommand &command);\r
69         void SendArticleOverInfo(Message &message);\r
70 \r
71         // various NNTP commands to handle\r
72         const bool HandleQuitCommand(const NNTPCommand &command);\r
73         const bool HandleModeCommand(const NNTPCommand &command);\r
74         const bool HandleCapabilitiesCommand(const NNTPCommand &command);\r
75         const bool HandleHelpCommand(const NNTPCommand &command);\r
76         const bool HandleDateCommand(const NNTPCommand &command);\r
77         const bool HandleListCommand(const NNTPCommand &command);\r
78         const bool HandleGroupCommand(const NNTPCommand &command);\r
79         const bool HandleListGroupCommand(const NNTPCommand &command);\r
80         const bool HandleNextCommand(const NNTPCommand &command);\r
81         const bool HandleLastCommand(const NNTPCommand &command);\r
82         const bool HandleArticleCommand(const NNTPCommand &command);\r
83         const bool HandleHeadCommand(const NNTPCommand &command);\r
84         const bool HandleBodyCommand(const NNTPCommand &command);\r
85         const bool HandleStatCommand(const NNTPCommand &command);\r
86         const bool HandleNewGroupsCommand(const NNTPCommand &command);\r
87         const bool HandlePostCommand(const NNTPCommand &command);\r
88         const bool HandleOverCommand(const NNTPCommand &command);\r
89         const bool HandleAuthInfoCommand(const NNTPCommand &command);\r
90         const bool HandleGetTrustCommand(const NNTPCommand &command);\r
91         const bool HandleSetTrustCommand(const NNTPCommand &command);\r
92         const bool HandleGetTrustListCommand(const NNTPCommand &command);\r
93 \r
94         SOCKET m_socket;\r
95         ClientStatus m_status;\r
96         std::vector<char> m_sendbuffer;\r
97         std::vector<char> m_receivebuffer;\r
98         std::vector<char> m_tempbuffer;\r
99 \r
100 };\r
101 \r
102 #endif  // _nntpconnection_\r