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
|
#include "host.h"
#include <QDebug>
Host::Host (GNUNET_SOCIAL_App *app,
GNUNET_SOCIAL_Ego *ego,
enum GNUNET_PSYC_Policy policy,
QObject *parent)
: Place (parent)
{
m_app = app;
m_ego = ego;
m_isHost = true;
m_host =
GNUNET_SOCIAL_host_enter (m_app, ego, policy, createSlicer (),
enterCallback,
answerDoorCallback,
farewellCallback,
this);
m_plc = GNUNET_SOCIAL_host_get_place (m_host);
connectSignals ();
}
Host::Host (GNUNET_SOCIAL_App *app,
GNUNET_SOCIAL_Ego *ego,
GNUNET_SOCIAL_HostConnection *hconn,
QObject *parent)
: Place (parent)
{
m_app = app;
m_ego = ego;
m_isHost = true;
m_host =
GNUNET_SOCIAL_host_enter_reconnect (hconn, createSlicer (),
enterCallback,
answerDoorCallback,
farewellCallback,
this);
m_plc = GNUNET_SOCIAL_host_get_place (m_host);
connectSignals ();
}
Host::~Host ()
{
GNUNET_SOCIAL_host_disconnect (m_host, NULL, NULL);
}
void
Host::connectSignals ()
{
connect (this, SIGNAL (announceSignal (QString)),
this, SLOT (announce (QString)),
Qt::QueuedConnection);
}
void
Host::answerDoorCallback (void *cls, struct GNUNET_SOCIAL_Nym *nym,
const char *method_name,
struct GNUNET_PSYC_Environment *env,
const void *data, size_t data_size)
{
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
"Host received entry request from guest .\n");
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
"%s\n%.*s\n", method_name, data_size, data);
Host *host = (Host *) cls;
emit host->answerDoorSignal (new Message (method_name, env, data, data_size,
0, nym));
}
void
Host::entryDecision (GNUNET_SOCIAL_Nym *nym,
bool isAdmitted,
Message *response)
{
GNUNET_PSYC_Message *msg = NULL;
if (NULL != response)
msg = response->toPsyc ();
GNUNET_SOCIAL_host_entry_decision (m_host, nym,
isAdmitted ? GNUNET_YES : GNUNET_NO,
msg);
if (NULL != msg)
GNUNET_free (msg);
}
void
Host::enterCallback (void *cls, int result,
const struct GNUNET_CRYPTO_EddsaPublicKey *placePubKey,
uint64_t max_message_id)
{
Host *host = (Host *) cls;
host->init (*placePubKey);
}
void
Host::farewellCallback (void *cls,
const struct GNUNET_SOCIAL_Nym *nym,
struct GNUNET_PSYC_Environment *env)
{
const struct GNUNET_CRYPTO_EcdsaPublicKey *
nym_key = GNUNET_SOCIAL_nym_get_pub_key (nym);
GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Nym %s has left the place.\n",
GNUNET_CRYPTO_ecdsa_public_key_to_string (nym_key));
}
void
Host::announce (Message *msg)
{
if (m_inTransmit)
{
// FIXME: queue message
qDebug () << "Host.announce: already in transmit";
return;
}
m_inTransmit = true;
m_tmitData = msg->data ().toStdString ();
m_tmitSent = 0;
GNUNET_PSYC_Environment *env = msg->getPsycEnv ();
m_announce =
GNUNET_SOCIAL_host_announce (m_host, msg->method ().toStdString ().c_str (),
env, notifyDataCallback, this,
GNUNET_SOCIAL_ANNOUNCE_NONE);
GNUNET_PSYC_env_destroy (env);
}
void
Host::announce (QString text)
{
qDebug () << "Host.announce: " << text;
Message msg ("_converse", QList<Modifier *>(), text);
announce (&msg);
}
void
Host::talk (QString text)
{
qDebug () << "Host.talk: " << text;
emit announceSignal (text);
}
int
Host::zoneAddPlace (QString name)
{
return
GNUNET_SOCIAL_zone_add_place (m_app, m_ego, name.toStdString().c_str(), NULL,
&m_pubKey, NULL, 0, NULL,
GNUNET_TIME_relative_to_absolute (GNUNET_TIME_UNIT_MONTHS),
NULL, NULL);
}
|
