aboutsummaryrefslogtreecommitdiff
path: root/src/messenger/test_messenger.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/messenger/test_messenger.c')
-rw-r--r--src/messenger/test_messenger.c181
1 files changed, 0 insertions, 181 deletions
diff --git a/src/messenger/test_messenger.c b/src/messenger/test_messenger.c
deleted file mode 100644
index 5784dfd82..000000000
--- a/src/messenger/test_messenger.c
+++ /dev/null
@@ -1,181 +0,0 @@
1/*
2 This file is part of GNUnet.
3 Copyright (C) 2020--2021 GNUnet e.V.
4
5 GNUnet is free software: you can redistribute it and/or modify it
6 under the terms of the GNU Affero General Public License as published
7 by the Free Software Foundation, either version 3 of the License,
8 or (at your option) any later version.
9
10 GNUnet is distributed in the hope that it will be useful, but
11 WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 Affero General Public License for more details.
14
15 You should have received a copy of the GNU Affero General Public License
16 along with this program. If not, see <http://www.gnu.org/licenses/>.
17
18 SPDX-License-Identifier: AGPL3.0-or-later
19 */
20/**
21 * @file messenger/test_messenger.c
22 * @author Tobias Frisch
23 * @brief Test for the messenger service using cadet API.
24 */
25#include <stdio.h>
26#include "platform.h"
27#include "gnunet_util_lib.h"
28#include "gnunet_testing_lib.h"
29#include "gnunet_messenger_service.h"
30
31/**
32 * How long until we really give up on a particular testcase portion?
33 */
34#define TOTAL_TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, \
35 60)
36
37/**
38 * How long until we give up on any particular operation (and retry)?
39 */
40#define BASE_TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 5)
41
42#define TESTER_NAME "tester"
43
44static int status = 1;
45
46static struct GNUNET_SCHEDULER_Task *die_task = NULL;
47static struct GNUNET_SCHEDULER_Task *op_task = NULL;
48
49struct GNUNET_MESSENGER_Handle *messenger = NULL;
50
51static void
52end (void *cls)
53{
54 die_task = NULL;
55
56 if (op_task)
57 {
58 GNUNET_SCHEDULER_cancel (op_task);
59 op_task = NULL;
60 }
61
62 if (messenger)
63 {
64 GNUNET_MESSENGER_disconnect (messenger);
65 messenger = NULL;
66 }
67
68 status = 0;
69}
70
71static void
72end_badly (void *cls)
73{
74 fprintf (stderr, "Testcase failed (timeout).\n");
75
76 end (NULL);
77 status = 1;
78}
79
80static void
81end_operation (void *cls)
82{
83 op_task = NULL;
84
85 fprintf (stderr, "Testcase failed (operation: '%s').\n", cls ? (const char*) cls : "unknown");
86
87 if (die_task)
88 GNUNET_SCHEDULER_cancel (die_task);
89
90 end (NULL);
91 status = 1;
92}
93
94static int identity_counter = 0;
95
96/**
97 * Function called when an identity is retrieved.
98 *
99 * @param cls Closure
100 * @param handle Handle of messenger service
101 */
102static void
103on_identity (void *cls,
104 struct GNUNET_MESSENGER_Handle *handle)
105{
106 if (op_task)
107 {
108 GNUNET_SCHEDULER_cancel (op_task);
109 op_task = NULL;
110 }
111
112 const char *name = GNUNET_MESSENGER_get_name (handle);
113
114 if (0 != strcmp (name, TESTER_NAME))
115 {
116 op_task = GNUNET_SCHEDULER_add_now (&end_operation, "name");
117 return;
118 }
119
120 const struct GNUNET_IDENTITY_PublicKey *key = GNUNET_MESSENGER_get_key (handle);
121
122 if (((!identity_counter) && (key)) || ((identity_counter) && (!key)))
123 {
124 op_task = GNUNET_SCHEDULER_add_now (&end_operation, "key");
125 return;
126 }
127
128 if (identity_counter)
129 {
130 GNUNET_MESSENGER_disconnect (handle);
131
132 op_task = NULL;
133 messenger = NULL;
134
135 if (die_task)
136 GNUNET_SCHEDULER_cancel (die_task);
137
138 die_task = GNUNET_SCHEDULER_add_now (&end, NULL);
139 return;
140 }
141
142 GNUNET_MESSENGER_update (messenger);
143 identity_counter++;
144}
145
146/**
147 * Main function for testcase.
148 *
149 * @param cls Closure
150 * @param cfg Configuration
151 * @param peer Peer for testing
152 */
153static void
154run (void *cls,
155 const struct GNUNET_CONFIGURATION_Handle *cfg,
156 struct GNUNET_TESTING_Peer *peer)
157{
158 die_task = GNUNET_SCHEDULER_add_delayed (TOTAL_TIMEOUT, &end_badly, NULL);
159
160 identity_counter = 0;
161
162 op_task = GNUNET_SCHEDULER_add_delayed (BASE_TIMEOUT, &end_operation, "connect");
163 messenger = GNUNET_MESSENGER_connect (cfg, TESTER_NAME, &on_identity, NULL, NULL, NULL);
164}
165
166/**
167 * The main function.
168 *
169 * @param argc number of arguments from the command line
170 * @param argv command line arguments
171 * @return 0 ok, 1 on error
172 */
173int
174main (int argc,
175 char **argv)
176{
177 if (0 != GNUNET_TESTING_peer_run ("test-messenger", "test_messenger_api.conf", &run, NULL))
178 return 1;
179
180 return status;
181}