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.c177
1 files changed, 0 insertions, 177 deletions
diff --git a/src/messenger/test_messenger.c b/src/messenger/test_messenger.c
deleted file mode 100644
index fb3e3e1bc..000000000
--- a/src/messenger/test_messenger.c
+++ /dev/null
@@ -1,177 +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, struct GNUNET_MESSENGER_Handle *handle)
104{
105 if (op_task)
106 {
107 GNUNET_SCHEDULER_cancel (op_task);
108 op_task = NULL;
109 }
110
111 const char *name = GNUNET_MESSENGER_get_name (handle);
112
113 if (0 != strcmp (name, TESTER_NAME))
114 {
115 op_task = GNUNET_SCHEDULER_add_now (&end_operation, "name");
116 return;
117 }
118
119 const struct GNUNET_IDENTITY_PublicKey *key = GNUNET_MESSENGER_get_key (handle);
120
121 if (((!identity_counter) && (key)) || ((identity_counter) && (!key)))
122 {
123 op_task = GNUNET_SCHEDULER_add_now (&end_operation, "key");
124 return;
125 }
126
127 if (identity_counter)
128 {
129 GNUNET_MESSENGER_disconnect (handle);
130
131 op_task = NULL;
132 messenger = NULL;
133
134 if (die_task)
135 GNUNET_SCHEDULER_cancel (die_task);
136
137 die_task = GNUNET_SCHEDULER_add_now (&end, NULL);
138 return;
139 }
140
141 GNUNET_MESSENGER_update (messenger);
142 identity_counter++;
143}
144
145/**
146 * Main function for testcase.
147 *
148 * @param cls Closure
149 * @param cfg Configuration
150 * @param peer Peer for testing
151 */
152static void
153run (void *cls, const struct GNUNET_CONFIGURATION_Handle *cfg, struct GNUNET_TESTING_Peer *peer)
154{
155 die_task = GNUNET_SCHEDULER_add_delayed (TOTAL_TIMEOUT, &end_badly, NULL);
156
157 identity_counter = 0;
158
159 op_task = GNUNET_SCHEDULER_add_delayed (BASE_TIMEOUT, &end_operation, "connect");
160 messenger = GNUNET_MESSENGER_connect (cfg, TESTER_NAME, &on_identity, NULL, NULL, NULL);
161}
162
163/**
164 * The main function.
165 *
166 * @param argc number of arguments from the command line
167 * @param argv command line arguments
168 * @return 0 ok, 1 on error
169 */
170int
171main (int argc, char **argv)
172{
173 if (0 != GNUNET_TESTING_peer_run ("test-messenger", "test_messenger_api.conf", &run, NULL))
174 return 1;
175
176 return status;
177}