/*
   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 */