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
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
|
#ifndef PLACE_H
#define PLACE_H
#include <QObject>
#include "message.h"
#include "gnunet.h"
class Place : public QObject
{
Q_OBJECT;
Q_PROPERTY (QString pubkey READ pubKeyString NOTIFY pubKeyStringChanged);
Q_PROPERTY (QString name READ name WRITE setName NOTIFY nameChanged);
Q_PROPERTY (QString desc READ desc WRITE setDesc NOTIFY descChanged);
public:
explicit Place (QObject *parent = 0);
//Index
int index () const
{
return m_index;
}
void setIndex (int index)
{
m_index = index;
}
//Name
QString name () const
{
return m_name;
}
void setName (QString name)
{
m_name = name;
emit nameChanged (name);
emit modified (this);
}
// Desc
QString desc () const
{
return m_desc;
}
void setDesc (QString desc)
{
m_desc = desc;
emit descChanged (desc);
emit modified (this);
}
//Type
QString type () const
{
return m_type;
}
void setType (QString type)
{
m_type = type;
emit typeChanged (type);
emit modified (this);
}
//Is Host ?
bool isHost () const
{
return m_isHost;
}
//Public Key
GNUNET_CRYPTO_EddsaPublicKey pubKey () const
{
return m_pubKey;
}
QString pubKeyString () const
{
return m_pubKeyStr;
}
void setPubKey (GNUNET_CRYPTO_EddsaPublicKey pubKey)
{
m_pubKey = pubKey;
char *pubKeyChr = GNUNET_CRYPTO_eddsa_public_key_to_string (&pubKey);
m_pubKeyStr = QString::fromLatin1 (pubKeyChr);
GNUNET_free (pubKeyChr);
emit pubKeyStringChanged (m_pubKeyStr);
emit modified (this);
}
const QList<Message *> &
threads ()
{
return m_threads;
}
Q_INVOKABLE void
copyToClipboard ();
Q_INVOKABLE void
talk (QString text);
protected:
int m_index;
QString m_name;
QString m_desc;
QString m_type; // FIXME
/// Message currently being received.
Message *m_msg;
/// Modifier currently being received.
Modifier *m_mod;
/// List of top-level, thread-starting messages.
QList<Message *> m_threads;
/// _thread_id -> thread starter Message
QHash<uint64_t, Message *> m_threadHash;
/// _message_id -> Message
QHash<uint64_t, Message *> m_msgHash;
QString m_pubKeyStr;
GNUNET_CRYPTO_EddsaPublicKey m_pubKey;
bool m_isHost;
GNUNET_SOCIAL_App *m_app;
GNUNET_SOCIAL_Ego *m_ego;
GNUNET_SOCIAL_Place *m_plc;
GNUNET_PSYC_Slicer *m_slicer;
bool m_inTransmit;
std::string m_tmitData;
size_t m_tmitSent;
void
init (GNUNET_CRYPTO_EddsaPublicKey pubKey);
GNUNET_PSYC_Slicer *
createSlicer ();
static int
notifyDataCallback (void *cls, uint16_t *data_size, void *data);
int
notifyData (uint16_t *data_size, void *data);
void
insertMessage (Message *msg);
static void
recvMethodCallback (void *cls,
const struct GNUNET_PSYC_MessageHeader *msg,
const struct GNUNET_PSYC_MessageMethod *meth,
uint64_t message_id,
const char *method_name);
void
recvMethod (const struct GNUNET_PSYC_MessageHeader *msg,
const struct GNUNET_PSYC_MessageMethod *meth,
uint64_t message_id,
const char *method_name);
static void
recvModifierCallback (void *cls,
const struct GNUNET_PSYC_MessageHeader *msg,
const struct GNUNET_MessageHeader *pmsg,
uint64_t message_id,
enum GNUNET_PSYC_Operator oper,
const char *name, const void *value,
uint16_t value_size,
uint16_t full_value_size);
void
recvModifier (const struct GNUNET_PSYC_MessageHeader *msg,
const struct GNUNET_MessageHeader *pmsg,
uint64_t message_id,
enum GNUNET_PSYC_Operator oper,
const char *name,
const void *value,
uint16_t value_size,
uint16_t full_value_size);
static void
recvDataCallback (void *cls,
const struct GNUNET_PSYC_MessageHeader *msg,
const struct GNUNET_MessageHeader *pmsg,
uint64_t message_id,
const void *data,
uint16_t data_size);
void
recvData (const struct GNUNET_PSYC_MessageHeader *msg,
const struct GNUNET_MessageHeader *pmsg,
uint64_t message_id,
const void *data,
uint16_t data_size);
static void
recvEomCallback (void *cls,
const struct GNUNET_PSYC_MessageHeader *msg,
const struct GNUNET_MessageHeader *pmsg,
uint64_t message_id,
uint8_t is_cancelled);
void
recvEom (const struct GNUNET_PSYC_MessageHeader *msg,
const struct GNUNET_MessageHeader *pmsg,
uint64_t message_id,
uint8_t is_cancelled);
signals:
void modified (Place *place);
void pubKeyStringChanged (QString pubKeyString);
void nameChanged (QString name);
void descChanged (QString desc);
void typeChanged (QString type);
void dataSent ();
void messageReceived (Message *msg, Message *parent, Message *thread);
void threadAdded (Message *msg);
#if FIXME
void talkSignal (QString text);
void setTrayMessage (QString place, QString text);
#endif
public slots:
};
#endif
|
