kjk / moriarty-sm
watch download tarball
public
Forks0Right
Watchers1Right
Description:
Homepage:
Clone URL: git://github.com/kjk/moriarty-sm.git
moriarty-sm / InfoManConnection.h
100644 86 lines (55 sloc) 2.049 kb
raw blame history 
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

#ifndef INFOMAN_CONNECTION_H__
#define INFOMAN_CONNECTION_H__
 
#include <FieldPayloadProtocolConnection.hpp>
#include "LookupManager.h"
 
class DataStoreWriter;
struct ResponseFieldDescriptor;
class HistoryCache;
 
#define FIELD_HANDLER_NAME(name) handle##name##Field
#define FIELD_HANDLER(name) status_t FIELD_HANDLER_NAME(name) (const char* name, ulong_t nameLen, const char* value, ulong_t valueLen)
 
class InfoManConnection: public FieldPayloadProtocolConnection
{
    LookupManager& lookupManager_;
    LookupResult result_;
    ServerError serverError_;
 
    char* url_;
    DataStoreWriter* writer_;
    HistoryCache* historyCache_;
    const ResponseFieldDescriptor* currentField_;
 
public:
 
    InfoManConnection(LookupManager& lm);
 
    ~InfoManConnection();
 
    ulong_t transactionId;
    const char* url() const {return url_;}
 
    status_t setUrl(const char* url);
 
protected:
 
    friend class LookupManager;
 
#ifdef _WIN32
    friend class ConnectionProgressDialog;
#endif     
 
    status_t enqueue();
 
    status_t handleField(const char* name, ulong_t nameLen, const char* value, ulong_t valueLen);
 
    void handleError(status_t error);
 
    status_t open();
 
    status_t notifyProgress();
 
    status_t notifyFinished();
 
    status_t notifyPayloadFinished();
 
    status_t handlePayloadIncrement(const char * payload, ulong_t& length, bool finish);
 
private:
 
    void prepareWriter();
 
    status_t prepareRequest();
 
public:
 
    FIELD_HANDLER(Udf);
    FIELD_HANDLER(DefinitionModel);
    FIELD_HANDLER(StringList);
 
    status_t completeUdfField(BinaryIncrementalProcessor& processor);
    status_t completeDefinitionModelField(BinaryIncrementalProcessor& processor);
    status_t completeStringListField(BinaryIncrementalProcessor& processor);
 
    FIELD_HANDLER(Error);
    FIELD_HANDLER(TransactionId);
    FIELD_HANDLER(Cookie);
    FIELD_HANDLER(LatestClientVersion);
    FIELD_HANDLER(EBookVersion);
 
};
 
#undef FIELD_HANDLER
 
#endif