Line data Source code
1 : // Copyright (c) 2012-2022 Made to Order Software Corp. All Rights Reserved
2 : //
3 : // https://snapwebsites.org/project/eventdispatcher
4 : // contact@m2osw.com
5 : //
6 : // This program is free software; you can redistribute it and/or modify
7 : // it under the terms of the GNU General Public License as published by
8 : // the Free Software Foundation; either version 2 of the License, or
9 : // (at your option) any later version.
10 : //
11 : // This program is distributed in the hope that it will be useful,
12 : // but WITHOUT ANY WARRANTY; without even the implied warranty of
13 : // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 : // GNU General Public License for more details.
15 : //
16 : // You should have received a copy of the GNU General Public License along
17 : // with this program; if not, write to the Free Software Foundation, Inc.,
18 : // 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
19 :
20 : // self
21 : //
22 : #include "catch_main.h"
23 :
24 :
25 : // eventdispatcher lib
26 : //
27 : #include <eventdispatcher/message.h>
28 :
29 :
30 : // C lib
31 : //
32 : #include <unistd.h>
33 :
34 :
35 :
36 5 : CATCH_TEST_CASE("message", "[message]")
37 : {
38 6 : CATCH_START_SECTION("Simple message fields")
39 : {
40 2 : ed::message msg;
41 :
42 : // SENT FROM SERVER
43 : //
44 1 : CATCH_REQUIRE(msg.get_sent_from_server().empty());
45 1 : msg.set_sent_from_server("remote");
46 1 : CATCH_REQUIRE_FALSE(msg.get_sent_from_server().empty());
47 1 : CATCH_REQUIRE(msg.get_sent_from_server() == "remote");
48 :
49 : // SENT FROM SERVICE
50 : //
51 1 : CATCH_REQUIRE(msg.get_sent_from_service().empty());
52 1 : msg.set_sent_from_service("firewall");
53 1 : CATCH_REQUIRE_FALSE(msg.get_sent_from_service().empty());
54 1 : CATCH_REQUIRE(msg.get_sent_from_service() == "firewall");
55 :
56 : // SERVER
57 : //
58 1 : CATCH_REQUIRE(msg.get_server().empty());
59 1 : msg.set_server("jungle");
60 1 : CATCH_REQUIRE_FALSE(msg.get_server().empty());
61 1 : CATCH_REQUIRE(msg.get_server() == "jungle");
62 :
63 : // SERVICE
64 : //
65 1 : CATCH_REQUIRE(msg.get_service().empty());
66 1 : msg.set_service("watchdog");
67 1 : CATCH_REQUIRE_FALSE(msg.get_service().empty());
68 1 : CATCH_REQUIRE(msg.get_service() == "watchdog");
69 :
70 : // COMMAND
71 : //
72 1 : CATCH_REQUIRE(msg.get_command().empty());
73 1 : msg.set_command("CONNECT");
74 1 : CATCH_REQUIRE_FALSE(msg.get_command().empty());
75 1 : CATCH_REQUIRE(msg.get_command() == "CONNECT");
76 :
77 : // MESSAGE VERSION
78 : //
79 1 : CATCH_REQUIRE(msg.get_message_version() == ed::MESSAGE_VERSION);
80 1 : msg.add_version_parameter();
81 1 : CATCH_REQUIRE(msg.check_version_parameter());
82 :
83 : // PARAMETER (race)
84 : //
85 1 : CATCH_REQUIRE_FALSE(msg.has_parameter("race"));
86 1 : msg.add_parameter("race", "true");
87 1 : CATCH_REQUIRE(msg.has_parameter("race"));
88 1 : CATCH_REQUIRE(msg.get_parameter("race") == "true");
89 :
90 : // PARAMETER (speed)
91 : //
92 1 : CATCH_REQUIRE_FALSE(msg.has_parameter("speed"));
93 1 : msg.add_parameter("speed", 1078);
94 1 : CATCH_REQUIRE(msg.has_parameter("speed"));
95 1 : CATCH_REQUIRE(msg.get_parameter("speed") == "1078");
96 1 : CATCH_REQUIRE(msg.get_integer_parameter("speed") == 1078);
97 :
98 : // PARAMETER (height)
99 : //
100 1 : CATCH_REQUIRE_FALSE(msg.has_parameter("height"));
101 1 : msg.add_parameter("height", 27U);
102 1 : CATCH_REQUIRE(msg.has_parameter("height"));
103 1 : CATCH_REQUIRE(msg.get_parameter("height") == "27");
104 1 : CATCH_REQUIRE(msg.get_integer_parameter("height") == 27);
105 :
106 : // PARAMETER (huge)
107 : //
108 1 : CATCH_REQUIRE_FALSE(msg.has_parameter("huge"));
109 1 : msg.add_parameter("huge", 7428447997487423361LL);
110 1 : CATCH_REQUIRE(msg.has_parameter("huge"));
111 1 : CATCH_REQUIRE(msg.get_parameter("huge") == "7428447997487423361");
112 1 : CATCH_REQUIRE(msg.get_integer_parameter("huge") == 7428447997487423361LL);
113 :
114 : // PARAMETER (huge #2)
115 : //
116 1 : CATCH_REQUIRE_FALSE(msg.has_parameter("huge2"));
117 1 : msg.add_parameter("huge2", 7428447997487423961ULL);
118 1 : CATCH_REQUIRE(msg.has_parameter("huge2"));
119 1 : CATCH_REQUIRE(msg.get_parameter("huge2") == "7428447997487423961");
120 1 : CATCH_REQUIRE(msg.get_integer_parameter("huge2") == 7428447997487423961ULL);
121 :
122 : // PARAMETER (a64bit)
123 : //
124 1 : std::int64_t const a64bit = 7428447907487423361LL;
125 1 : CATCH_REQUIRE_FALSE(msg.has_parameter("a64bit"));
126 1 : msg.add_parameter("a64bit", a64bit);
127 1 : CATCH_REQUIRE(msg.has_parameter("a64bit"));
128 1 : CATCH_REQUIRE(msg.get_parameter("a64bit") == "7428447907487423361");
129 1 : CATCH_REQUIRE(msg.get_integer_parameter("a64bit") == a64bit);
130 :
131 : // PARAMETER (u64bit)
132 : //
133 1 : std::uint64_t const u64bit = 428447907487423361UL;
134 1 : CATCH_REQUIRE_FALSE(msg.has_parameter("u64bit"));
135 1 : msg.add_parameter("u64bit", u64bit);
136 1 : CATCH_REQUIRE(msg.has_parameter("u64bit"));
137 1 : CATCH_REQUIRE(msg.get_parameter("u64bit") == "428447907487423361");
138 1 : CATCH_REQUIRE(msg.get_integer_parameter("u64bit") == u64bit);
139 :
140 9 : for(auto p : msg.get_all_parameters())
141 : {
142 8 : if(p.first == "huge")
143 : {
144 1 : CATCH_REQUIRE(p.second == "7428447997487423361");
145 : }
146 7 : else if(p.first == "u64bit")
147 : {
148 1 : CATCH_REQUIRE(p.second == "428447907487423361");
149 : }
150 : }
151 :
152 : // REPLY TO
153 : //
154 2 : ed::message msg2;
155 1 : msg2.reply_to(msg);
156 :
157 1 : CATCH_REQUIRE(msg2.get_sent_from_server().empty());
158 1 : CATCH_REQUIRE(msg2.get_sent_from_service().empty());
159 1 : CATCH_REQUIRE(msg2.get_server() == "remote");
160 1 : CATCH_REQUIRE(msg2.get_service() == "firewall");
161 1 : CATCH_REQUIRE(msg2.get_command().empty());
162 1 : CATCH_REQUIRE(msg2.get_message_version() == ed::MESSAGE_VERSION);
163 1 : CATCH_REQUIRE_FALSE(msg2.has_parameter("race"));
164 1 : CATCH_REQUIRE_FALSE(msg2.has_parameter("speed"));
165 1 : CATCH_REQUIRE_FALSE(msg2.has_parameter("height"));
166 1 : CATCH_REQUIRE_FALSE(msg2.has_parameter("huge"));
167 1 : CATCH_REQUIRE_FALSE(msg2.has_parameter("huge2"));
168 1 : CATCH_REQUIRE_FALSE(msg2.has_parameter("a64bit"));
169 1 : CATCH_REQUIRE_FALSE(msg2.has_parameter("u64bit"));
170 1 : CATCH_REQUIRE(msg2.get_all_parameters().empty());
171 :
172 : //for(auto p : msg2.get_all_parameters())
173 : //{
174 : //std::cerr << "--- " << p.first << "=" << p.second << "\n";
175 : //}
176 :
177 : // make sure the original wasn't modified
178 : //
179 1 : CATCH_REQUIRE(msg.get_sent_from_server() == "remote");
180 1 : CATCH_REQUIRE(msg.get_sent_from_service() == "firewall");
181 1 : CATCH_REQUIRE(msg.get_server() == "jungle");
182 1 : CATCH_REQUIRE(msg.get_service() == "watchdog");
183 : }
184 : CATCH_END_SECTION()
185 :
186 6 : CATCH_START_SECTION("To & From Messages (simple)")
187 : {
188 2 : ed::message msg;
189 :
190 1 : CATCH_REQUIRE(msg.get_command().empty());
191 1 : msg.set_command("FIRE");
192 1 : CATCH_REQUIRE_FALSE(msg.get_command().empty());
193 1 : CATCH_REQUIRE(msg.get_command() == "FIRE");
194 :
195 1 : CATCH_REQUIRE_FALSE(msg.has_parameter("name"));
196 1 : msg.add_parameter("name", "Charles");
197 1 : CATCH_REQUIRE(msg.has_parameter("name"));
198 1 : CATCH_REQUIRE(msg.get_parameter("name") == "Charles");
199 :
200 1 : CATCH_REQUIRE_FALSE(msg.has_parameter("length"));
201 1 : msg.add_parameter("length", -35);
202 1 : CATCH_REQUIRE(msg.has_parameter("length"));
203 1 : CATCH_REQUIRE(msg.get_parameter("length") == "-35");
204 1 : CATCH_REQUIRE(msg.get_integer_parameter("length") == -35);
205 :
206 : {
207 2 : std::string const m(msg.to_message());
208 :
209 2 : ed::message rcv;
210 :
211 1 : CATCH_REQUIRE(rcv.get_command().empty());
212 1 : CATCH_REQUIRE_FALSE(rcv.has_parameter("name"));
213 1 : CATCH_REQUIRE_FALSE(rcv.has_parameter("length"));
214 :
215 1 : rcv.from_message(m);
216 :
217 1 : CATCH_REQUIRE_FALSE(rcv.get_command().empty());
218 1 : CATCH_REQUIRE(rcv.get_command() == "FIRE");
219 :
220 1 : CATCH_REQUIRE(rcv.has_parameter("name"));
221 1 : CATCH_REQUIRE(rcv.get_parameter("name") == "Charles");
222 :
223 1 : CATCH_REQUIRE(rcv.has_parameter("length"));
224 1 : CATCH_REQUIRE(rcv.get_parameter("length") == "-35");
225 1 : CATCH_REQUIRE(rcv.get_integer_parameter("length") == -35);
226 : }
227 :
228 : {
229 2 : std::string const m(msg.to_message(ed::message::format_t::MESSAGE_FORMAT_JSON));
230 :
231 2 : ed::message rcv;
232 :
233 1 : CATCH_REQUIRE(rcv.get_command().empty());
234 1 : CATCH_REQUIRE_FALSE(rcv.has_parameter("name"));
235 1 : CATCH_REQUIRE_FALSE(rcv.has_parameter("length"));
236 :
237 1 : rcv.from_message(m);
238 :
239 1 : CATCH_REQUIRE_FALSE(rcv.get_command().empty());
240 1 : CATCH_REQUIRE(rcv.get_command() == "FIRE");
241 :
242 1 : CATCH_REQUIRE(rcv.has_parameter("name"));
243 1 : CATCH_REQUIRE(rcv.get_parameter("name") == "Charles");
244 :
245 1 : CATCH_REQUIRE(rcv.has_parameter("length"));
246 1 : CATCH_REQUIRE(rcv.get_parameter("length") == "-35");
247 1 : CATCH_REQUIRE(rcv.get_integer_parameter("length") == -35);
248 : }
249 : }
250 : CATCH_END_SECTION()
251 :
252 6 : CATCH_START_SECTION("To & From Messages (full message)")
253 : {
254 2 : ed::message msg;
255 :
256 1 : CATCH_REQUIRE(msg.get_command().empty());
257 1 : msg.set_command("FIRE");
258 1 : CATCH_REQUIRE_FALSE(msg.get_command().empty());
259 1 : CATCH_REQUIRE(msg.get_command() == "FIRE");
260 :
261 1 : CATCH_REQUIRE_FALSE(msg.has_parameter("name"));
262 1 : msg.add_parameter("name", "Charles");
263 1 : CATCH_REQUIRE(msg.has_parameter("name"));
264 1 : CATCH_REQUIRE(msg.get_parameter("name") == "Charles");
265 :
266 1 : CATCH_REQUIRE_FALSE(msg.has_parameter("length"));
267 1 : msg.add_parameter("length", -35);
268 1 : CATCH_REQUIRE(msg.has_parameter("length"));
269 1 : CATCH_REQUIRE(msg.get_parameter("length") == "-35");
270 1 : CATCH_REQUIRE(msg.get_integer_parameter("length") == -35);
271 :
272 1 : CATCH_REQUIRE_FALSE(msg.has_parameter("range"));
273 1 : msg.add_parameter("range", "+101");
274 1 : CATCH_REQUIRE(msg.has_parameter("range"));
275 1 : CATCH_REQUIRE(msg.get_parameter("range") == "+101");
276 1 : CATCH_REQUIRE(msg.get_integer_parameter("range") == 101);
277 :
278 1 : CATCH_REQUIRE_FALSE(msg.has_parameter("valid"));
279 1 : msg.add_parameter("valid", "true");
280 1 : CATCH_REQUIRE(msg.has_parameter("valid"));
281 1 : CATCH_REQUIRE(msg.get_parameter("valid") == "true");
282 :
283 1 : CATCH_REQUIRE_FALSE(msg.has_parameter("correct"));
284 1 : msg.add_parameter("correct", "false");
285 1 : CATCH_REQUIRE(msg.has_parameter("correct"));
286 1 : CATCH_REQUIRE(msg.get_parameter("correct") == "false");
287 :
288 1 : CATCH_REQUIRE_FALSE(msg.has_parameter("void"));
289 1 : msg.add_parameter("void", "");
290 1 : CATCH_REQUIRE(msg.has_parameter("void"));
291 1 : CATCH_REQUIRE(msg.get_parameter("void") == "");
292 :
293 : {
294 2 : std::string const m(msg.to_message());
295 :
296 2 : ed::message rcv;
297 :
298 1 : CATCH_REQUIRE(rcv.get_command().empty());
299 1 : CATCH_REQUIRE_FALSE(rcv.has_parameter("name"));
300 1 : CATCH_REQUIRE_FALSE(rcv.has_parameter("length"));
301 :
302 1 : rcv.from_message(m);
303 :
304 1 : CATCH_REQUIRE_FALSE(rcv.get_command().empty());
305 1 : CATCH_REQUIRE(rcv.get_command() == "FIRE");
306 :
307 1 : CATCH_REQUIRE(rcv.has_parameter("name"));
308 1 : CATCH_REQUIRE(rcv.get_parameter("name") == "Charles");
309 :
310 1 : CATCH_REQUIRE(rcv.has_parameter("length"));
311 1 : CATCH_REQUIRE(rcv.get_parameter("length") == "-35");
312 1 : CATCH_REQUIRE(rcv.get_integer_parameter("length") == -35);
313 :
314 1 : CATCH_REQUIRE(rcv.has_parameter("range"));
315 1 : CATCH_REQUIRE(rcv.get_parameter("range") == "+101");
316 1 : CATCH_REQUIRE(rcv.get_integer_parameter("range") == 101);
317 :
318 1 : CATCH_REQUIRE(rcv.has_parameter("valid"));
319 1 : CATCH_REQUIRE(rcv.get_parameter("valid") == "true");
320 :
321 1 : CATCH_REQUIRE(rcv.has_parameter("correct"));
322 1 : CATCH_REQUIRE(rcv.get_parameter("correct") == "false");
323 :
324 1 : CATCH_REQUIRE(rcv.has_parameter("void"));
325 1 : CATCH_REQUIRE(rcv.get_parameter("void") == "");
326 : }
327 :
328 : {
329 2 : std::string const m(msg.to_json());
330 :
331 1 : std::cerr << "JSON [" << m << "]\n";
332 2 : ed::message rcv;
333 :
334 1 : CATCH_REQUIRE(rcv.get_command().empty());
335 1 : CATCH_REQUIRE_FALSE(rcv.has_parameter("name"));
336 1 : CATCH_REQUIRE_FALSE(rcv.has_parameter("length"));
337 :
338 : // this statement prints out an error message
339 1 : CATCH_REQUIRE_FALSE(rcv.from_string(m));
340 :
341 1 : CATCH_REQUIRE(rcv.from_json(m));
342 :
343 1 : CATCH_REQUIRE_FALSE(rcv.get_command().empty());
344 1 : CATCH_REQUIRE(rcv.get_command() == "FIRE");
345 :
346 1 : CATCH_REQUIRE(rcv.has_parameter("name"));
347 1 : CATCH_REQUIRE(rcv.get_parameter("name") == "Charles");
348 :
349 1 : CATCH_REQUIRE(rcv.has_parameter("length"));
350 1 : CATCH_REQUIRE(rcv.get_parameter("length") == "-35");
351 1 : CATCH_REQUIRE(rcv.get_integer_parameter("length") == -35);
352 :
353 1 : CATCH_REQUIRE(rcv.has_parameter("range"));
354 1 : CATCH_REQUIRE(rcv.get_parameter("range") == "101"); // we lose the '+' sign in JSON
355 1 : CATCH_REQUIRE(rcv.get_integer_parameter("range") == 101);
356 :
357 1 : CATCH_REQUIRE(rcv.has_parameter("valid"));
358 1 : CATCH_REQUIRE(rcv.get_parameter("valid") == "true");
359 :
360 1 : CATCH_REQUIRE(rcv.has_parameter("correct"));
361 1 : CATCH_REQUIRE(rcv.get_parameter("correct") == "false");
362 :
363 1 : CATCH_REQUIRE(rcv.has_parameter("void"));
364 1 : CATCH_REQUIRE(rcv.get_parameter("void") == "");
365 : }
366 : }
367 : CATCH_END_SECTION()
368 9 : }
369 :
370 :
371 : // vim: ts=4 sw=4 et
|
