version 0.3.29
[fms.git] / include / nntp / nntpconnection.h
index e31fd1b..d048375 100644 (file)
@@ -1,15 +1,15 @@
 #ifndef _nntpconnection_\r
 #define _nntpconnection_\r
 \r
+#include "../threadwrapper/cancelablerunnable.h"\r
 #include "../socketdefines.h"\r
 #include "../ilogger.h"\r
 #include "../message.h"\r
 #include "../localidentity.h"\r
+#include "../ithreaddatabase.h"\r
 \r
 #include <string>\r
 #include <vector>\r
-//#include <zthread/Runnable.h>\r
-#include "../pthreadwrapper/runnable.h"\r
 \r
 #ifdef _WIN32\r
 \r
@@ -22,7 +22,7 @@
        #include <arpa/inet.h>\r
 #endif\r
 \r
-class NNTPConnection:public PThread::Runnable,public ILogger\r
+class NNTPConnection:public CancelableRunnable,public ILogger,public IThreadDatabase\r
 {\r
 public:\r
        NNTPConnection(SOCKET sock);\r
@@ -31,7 +31,7 @@ public:
        void Disconnect();\r
        const bool Disconnected()               { return m_socket==INVALID_SOCKET; }\r
 \r
-       void Run();\r
+       void run();\r
 \r
 private:\r
 \r
@@ -47,6 +47,8 @@ private:
        };\r
        struct ClientStatus\r
        {\r
+               ClientStatus(SQLite3DB::DB *db):m_authuser(db)          {}\r
+\r
                ClientMode m_mode;\r
                bool m_allowpost;\r
                bool m_isposting;\r
@@ -87,6 +89,9 @@ private:
        const bool HandlePostCommand(const NNTPCommand &command);\r
        const bool HandleOverCommand(const NNTPCommand &command);\r
        const bool HandleAuthInfoCommand(const NNTPCommand &command);\r
+       const bool HandleGetTrustCommand(const NNTPCommand &command);\r
+       const bool HandleSetTrustCommand(const NNTPCommand &command);\r
+       const bool HandleGetTrustListCommand(const NNTPCommand &command);\r
 \r
        SOCKET m_socket;\r
        ClientStatus m_status;\r