123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187 |
- /*
- This file is part of GNUnet
- (C) 2019 GNUnet e.V.
- GNUnet is free software: you can redistribute it and/or modify it
- under the terms of the GNU Affero General Public License as published
- by the Free Software Foundation, either version 3 of the License,
- or (at your option) any later version.
- GNUnet is distributed in the hope that it will be useful, but
- WITHOUT ANY WARRANTY; without even the implied warranty of
- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- Affero General Public License for more details.
- You should have received a copy of the GNU Affero General Public License
- along with this program. If not, see <http://www.gnu.org/licenses/>.
- SPDX-License-Identifier: AGPL3.0-or-later
- */
- /**
- * @file json/test_json_mhd.c
- * @brief Tests for JSON MHD integration functions
- * @author Christian Grothoff <christian@grothoff.org>
- */
- #include "platform.h"
- #include "gnunet_util_lib.h"
- #include "gnunet_json_lib.h"
- #include "gnunet_curl_lib.h"
- #include <zlib.h>
- #define MAX_SIZE 1024 * 1024
- static json_t *bigj;
- static int global_ret;
- static int
- access_handler_cb (void *cls,
- struct MHD_Connection *connection,
- const char *url,
- const char *method,
- const char *version,
- const char *upload_data,
- size_t *upload_data_size,
- void **con_cls)
- {
- int ret;
- json_t *json;
- struct MHD_Response *resp;
- json = NULL;
- ret = GNUNET_JSON_post_parser (MAX_SIZE,
- connection,
- con_cls,
- upload_data,
- upload_data_size,
- &json);
- switch (ret)
- {
- case GNUNET_JSON_PR_SUCCESS:
- if (json_equal (bigj, json))
- {
- global_ret = 0;
- }
- else
- {
- GNUNET_break (0);
- global_ret = 6;
- }
- json_decref (json);
- resp = MHD_create_response_from_buffer (3, "OK\n", MHD_RESPMEM_PERSISTENT);
- ret = MHD_queue_response (connection, MHD_HTTP_OK, resp);
- MHD_destroy_response (resp);
- return ret;
- case GNUNET_JSON_PR_CONTINUE:
- return MHD_YES;
- case GNUNET_JSON_PR_OUT_OF_MEMORY:
- GNUNET_break (0);
- global_ret = 3;
- break;
- case GNUNET_JSON_PR_REQUEST_TOO_LARGE:
- GNUNET_break (0);
- global_ret = 4;
- break;
- case GNUNET_JSON_PR_JSON_INVALID:
- GNUNET_break (0);
- global_ret = 5;
- break;
- }
- GNUNET_break (0);
- return MHD_NO;
- }
- int
- main (int argc, const char *const argv[])
- {
- struct MHD_Daemon *daemon;
- uint16_t port;
- CURL *easy;
- char *url;
- char *str;
- size_t slen;
- long post_data_size;
- void *post_data;
- uLongf dlen;
- struct curl_slist *json_header;
- GNUNET_log_setup ("test-json-mhd", "WARNING", NULL);
- global_ret = 2;
- daemon = MHD_start_daemon (MHD_USE_DUAL_STACK | MHD_USE_AUTO_INTERNAL_THREAD,
- 0,
- NULL,
- NULL,
- &access_handler_cb,
- NULL,
- MHD_OPTION_END);
- if (NULL == daemon)
- return 77;
- bigj = json_object ();
- json_object_set_new (bigj, "test", json_string ("value"));
- for (unsigned int i = 0; i < 1000; i++)
- {
- char tmp[5];
- GNUNET_snprintf (tmp, sizeof (tmp), "%u", i);
- json_object_set_new (bigj, tmp, json_string (tmp));
- }
- str = json_dumps (bigj, JSON_INDENT (2));
- slen = strlen (str);
- #ifdef compressBound
- dlen = compressBound (slen);
- #else
- dlen = slen + slen / 100 + 20;
- /* documentation says 100.1% oldSize + 12 bytes, but we
- * should be able to overshoot by more to be safe */
- #endif
- post_data = GNUNET_malloc (dlen);
- if (Z_OK !=
- compress2 ((Bytef *) post_data, &dlen, (const Bytef *) str, slen, 9))
- {
- GNUNET_break (0);
- MHD_stop_daemon (daemon);
- json_decref (bigj);
- GNUNET_free (post_data);
- GNUNET_free (str);
- return 1;
- }
- post_data_size = (long) dlen;
- port = MHD_get_daemon_info (daemon, MHD_DAEMON_INFO_BIND_PORT)->port;
- easy = curl_easy_init ();
- GNUNET_asprintf (&url, "http://localhost:%u/", (unsigned int) port);
- curl_easy_setopt (easy, CURLOPT_VERBOSE, 0);
- curl_easy_setopt (easy, CURLOPT_URL, url);
- curl_easy_setopt (easy, CURLOPT_POST, 1);
- curl_easy_setopt (easy, CURLOPT_POSTFIELDS, post_data);
- curl_easy_setopt (easy, CURLOPT_POSTFIELDSIZE, post_data_size);
- json_header = curl_slist_append (NULL, "Content-Type: application/json");
- json_header = curl_slist_append (json_header, "Content-Encoding: deflate");
- curl_easy_setopt (easy, CURLOPT_HTTPHEADER, json_header);
- if (0 != curl_easy_perform (easy))
- {
- GNUNET_break (0);
- MHD_stop_daemon (daemon);
- GNUNET_free (url);
- json_decref (bigj);
- GNUNET_free (post_data);
- GNUNET_free (str);
- curl_slist_free_all (json_header);
- curl_easy_cleanup (easy);
- return 1;
- }
- MHD_stop_daemon (daemon);
- GNUNET_free (url);
- json_decref (bigj);
- GNUNET_free (post_data);
- GNUNET_free (str);
- curl_slist_free_all (json_header);
- curl_easy_cleanup (easy);
- return global_ret;
- }
- /* end of test_json_mhd.c */
|