aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/nntp/MCNNTPSession.h
blob: 5e371eead4e640d13ba9c5dc12082fa9253ca761 (plain)
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
#ifndef MAILCORE_MCNNTPSESSION_H
#define MAILCORE_MCNNTPSESSION_H

#include <MailCore/MCBaseTypes.h>
#include <MailCore/MCMessageConstants.h>

#ifdef __cplusplus

namespace mailcore {
    
    class NNTPProgressCallback;
    class MessageHeader;
    
    class MAILCORE_EXPORT NNTPSession : public Object {
    public:
        NNTPSession();
        virtual ~NNTPSession();
        
        virtual void setHostname(String * hostname);
        virtual String * hostname();
        
        virtual void setPort(unsigned int port);
        virtual unsigned int port();
        
        virtual void setUsername(String * username);
        virtual String * username();
        
        virtual void setPassword(String * password);
        virtual String * password();
        
        virtual void setConnectionType(ConnectionType connectionType);
        virtual ConnectionType connectionType();
        
        virtual void setTimeout(time_t timeout);
        virtual time_t timeout();
        
        virtual void setCheckCertificateEnabled(bool enabled);
        virtual bool isCheckCertificateEnabled();
        
        virtual void connect(ErrorCode * pError);
        virtual void disconnect();
        
        virtual void login(ErrorCode * pError);
        
        virtual void checkAccount(ErrorCode * pError);
        
        virtual Array * /* NNTPGroupInfo */ listAllNewsgroups(ErrorCode * pError);
        virtual Array * /* NNTPGroupInfo */ listDefaultNewsgroups(ErrorCode * pError);
        
        virtual MessageHeader * fetchHeader(String * groupName, unsigned int index, ErrorCode * pError);
        virtual Array /*MessageHeader*/ * fetchOverArticlesInRange(Range range, String * groupname, ErrorCode * pError);
        
        virtual IndexSet * fetchAllArticles(String * groupname, ErrorCode * pError);
                
        virtual Data * fetchArticle(String *groupName, unsigned int index, NNTPProgressCallback * callback, ErrorCode * pError);
        virtual Data * fetchArticleByMessageID(String * messageID, ErrorCode * pError);
        
        virtual time_t fetchServerDate(ErrorCode * pError);
        
        virtual void postMessage(Data * messageData, NNTPProgressCallback * callback, ErrorCode * pError);
        virtual void postMessage(String * messagePath, NNTPProgressCallback * callback, ErrorCode * pError);
        
        virtual void setConnectionLogger(ConnectionLogger * logger);
        virtual ConnectionLogger * connectionLogger();
        
    public: // private
        virtual void lockConnectionLogger();
        virtual void unlockConnectionLogger();
        virtual ConnectionLogger * connectionLoggerNoLock();

    private:
        String * mHostname;
        unsigned int mPort;
        String * mUsername;
        String * mPassword;
        ConnectionType mConnectionType;
        bool mCheckCertificateEnabled;
        time_t mTimeout;
        
        newsnntp * mNNTP;
        NNTPProgressCallback * mProgressCallback;
        int mState;
        
        ConnectionLogger * mConnectionLogger;
        pthread_mutex_t mConnectionLoggerLock;

        void init();
        Data * dataWithFilteredBcc(Data * data);
        static void body_progress(size_t current, size_t maximum, void * context);
        void bodyProgress(unsigned int current, unsigned int maximum);
        bool checkCertificate();
        void setup();
        void unsetup();
        void connectIfNeeded(ErrorCode * pError);
        void loginIfNeeded(ErrorCode * pError);
        void readerIfNeeded(ErrorCode * pError);
        void listIfNeeded(ErrorCode * pError);
        void selectGroup(String * folder, ErrorCode * pError);
    };
	
}

#endif

#endif