//
// Copyright (c) 2025 Marcelo Zimbres Silva (mzimbres@gmail.com),
// Ruben Perez Hidalgo (rubenperez038 at gmail dot com)
//
// Distributed under the Boost Software License, Version 1.0. (See accompanying
// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
//

#include <boost/redis/adapter/any_adapter.hpp>
#include <boost/redis/config.hpp>
#include <boost/redis/detail/connection_state.hpp>
#include <boost/redis/impl/sentinel_utils.hpp>
#include <boost/redis/resp3/node.hpp>
#include <boost/redis/resp3/parser.hpp>

#include <boost/assert/source_location.hpp>
#include <boost/core/lightweight_test.hpp>
#include <boost/system/error_code.hpp>

#include "sansio_utils.hpp"

#include <initializer_list>
#include <ostream>
#include <string_view>
#include <vector>

using namespace boost::redis;
using detail::nodes_from_resp3;
using detail::parse_sentinel_response;
using detail::sentinel_response;
using boost::system::error_code;

// Operators
namespace boost::redis {

std::ostream& operator<<(std::ostream& os, const address& addr)
{
   return os << "address{ .host=" << addr.host << ", .port=" << addr.port << " }";
}

}  // namespace boost::redis

namespace {

struct fixture {
   sentinel_response resp{
      "leftover",
      {"leftover_host", "6543"},
      {address()},
      {address()},
   };

   void check_response(
      const address& expected_master_addr,
      boost::span<const address> expected_replicas,
      boost::span<const address> expected_sentinels,
      boost::source_location loc = BOOST_CURRENT_LOCATION) const
   {
      if (!BOOST_TEST_EQ(resp.diagnostic, ""))
         std::cerr << "Called from " << loc << std::endl;
      if (!BOOST_TEST_EQ(resp.master_addr, expected_master_addr))
         std::cerr << "Called from " << loc << std::endl;
      if (!BOOST_TEST_ALL_EQ(
             resp.replicas.begin(),
             resp.replicas.end(),
             expected_replicas.begin(),
             expected_replicas.end()))
         std::cerr << "Called from " << loc << std::endl;
      if (!BOOST_TEST_ALL_EQ(
             resp.sentinels.begin(),
             resp.sentinels.end(),
             expected_sentinels.begin(),
             expected_sentinels.end()))
         std::cerr << "Called from " << loc << std::endl;
   }
};

// Usual response when asking for a master
void test_master()
{
   // Setup
   fixture fix;
   auto nodes = nodes_from_resp3({
      // clang-format off
      "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
      "*2\r\n"
         "%14\r\n"
            "$4\r\nname\r\n$40\r\nf14ef06a8a478cdd66ded467ec18accd2a24b731\r\n$2\r\nip\r\n$8\r\nhost.one\r\n$4\r\nport\r\n$5\r\n26380\r\n"
            "$5\r\nrunid\r\n$40\r\nf14ef06a8a478cdd66ded467ec18accd2a24b731\r\n$5\r\nflags\r\n$8\r\nsentinel\r\n"
            "$21\r\nlink-pending-commands\r\n$1\r\n0\r\n$13\r\nlink-refcount\r\n$1\r\n1\r\n$14\r\nlast-ping-sent\r\n$1\r\n0\r\n"
            "$18\r\nlast-ok-ping-reply\r\n$3\r\n696\r\n$15\r\nlast-ping-reply\r\n$3\r\n696\r\n$23\r\ndown-after-milliseconds\r\n$5\r\n10000\r\n"
            "$18\r\nlast-hello-message\r\n$3\r\n334\r\n$12\r\nvoted-leader\r\n$1\r\n?\r\n$18\r\nvoted-leader-epoch\r\n$1\r\n0\r\n"
         "%14\r\n"
            "$4\r\nname\r\n$40\r\nf9b54e79e2e7d3f17ad60527504191ec8a861f27\r\n$2\r\nip\r\n$8\r\nhost.two\r\n$4\r\nport\r\n$5\r\n26381\r\n"
            "$5\r\nrunid\r\n$40\r\nf9b54e79e2e7d3f17ad60527504191ec8a861f27\r\n$5\r\nflags\r\n$8\r\nsentinel\r\n"
            "$21\r\nlink-pending-commands\r\n$1\r\n0\r\n$13\r\nlink-refcount\r\n$1\r\n1\r\n$14\r\nlast-ping-sent\r\n$1\r\n0\r\n"
            "$18\r\nlast-ok-ping-reply\r\n$3\r\n696\r\n$15\r\nlast-ping-reply\r\n$3\r\n696\r\n$23\r\ndown-after-milliseconds\r\n$5\r\n10000\r\n"
            "$18\r\nlast-hello-message\r\n$3\r\n134\r\n$12\r\nvoted-leader\r\n$1\r\n?\r\n$18\r\nvoted-leader-epoch\r\n$1\r\n0\r\n",
      // clang-format on
   });

   // Call the function
   auto ec = parse_sentinel_response(nodes, role::master, fix.resp);
   BOOST_TEST_EQ(ec, error_code());

   // Check
   const address expected_sentinels[] = {
      {"host.one", "26380"},
      {"host.two", "26381"},
   };
   fix.check_response({"localhost", "6380"}, {}, expected_sentinels);
}

// Works correctly even if no Sentinels are present
void test_master_no_sentinels()
{
   // Setup
   fixture fix;
   auto nodes = nodes_from_resp3({
      "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
      "*0\r\n",
   });

   // Call the function
   auto ec = parse_sentinel_response(nodes, role::master, fix.resp);
   BOOST_TEST_EQ(ec, error_code());
   fix.check_response({"localhost", "6380"}, {}, {});
}

// The responses corresponding to the user-defined setup request are ignored
void test_master_setup_request()
{
   // Setup
   fixture fix;
   auto nodes = nodes_from_resp3({
      // clang-format off
      "+OK\r\n",
      "%6\r\n$6\r\nserver\r\n$5\r\nredis\r\n$7\r\nversion\r\n$5\r\n7.4.2\r\n$5\r\nproto\r\n:3\r\n$2\r\nid\r\n:3\r\n$4\r\nmode\r\n$8\r\nsentinel\r\n$7\r\nmodules\r\n*0\r\n",
      "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
      "*2\r\n"
         "%14\r\n"
            "$4\r\nname\r\n$40\r\nf14ef06a8a478cdd66ded467ec18accd2a24b731\r\n$2\r\nip\r\n$8\r\nhost.one\r\n$4\r\nport\r\n$5\r\n26380\r\n"
            "$5\r\nrunid\r\n$40\r\nf14ef06a8a478cdd66ded467ec18accd2a24b731\r\n$5\r\nflags\r\n$8\r\nsentinel\r\n"
            "$21\r\nlink-pending-commands\r\n$1\r\n0\r\n$13\r\nlink-refcount\r\n$1\r\n1\r\n$14\r\nlast-ping-sent\r\n$1\r\n0\r\n"
            "$18\r\nlast-ok-ping-reply\r\n$3\r\n696\r\n$15\r\nlast-ping-reply\r\n$3\r\n696\r\n$23\r\ndown-after-milliseconds\r\n$5\r\n10000\r\n"
            "$18\r\nlast-hello-message\r\n$3\r\n334\r\n$12\r\nvoted-leader\r\n$1\r\n?\r\n$18\r\nvoted-leader-epoch\r\n$1\r\n0\r\n"
         "%14\r\n"
            "$4\r\nname\r\n$40\r\nf9b54e79e2e7d3f17ad60527504191ec8a861f27\r\n$2\r\nip\r\n$8\r\nhost.two\r\n$4\r\nport\r\n$5\r\n26381\r\n"
            "$5\r\nrunid\r\n$40\r\nf9b54e79e2e7d3f17ad60527504191ec8a861f27\r\n$5\r\nflags\r\n$8\r\nsentinel\r\n"
            "$21\r\nlink-pending-commands\r\n$1\r\n0\r\n$13\r\nlink-refcount\r\n$1\r\n1\r\n$14\r\nlast-ping-sent\r\n$1\r\n0\r\n"
            "$18\r\nlast-ok-ping-reply\r\n$3\r\n696\r\n$15\r\nlast-ping-reply\r\n$3\r\n696\r\n$23\r\ndown-after-milliseconds\r\n$5\r\n10000\r\n"
            "$18\r\nlast-hello-message\r\n$3\r\n134\r\n$12\r\nvoted-leader\r\n$1\r\n?\r\n$18\r\nvoted-leader-epoch\r\n$1\r\n0\r\n",
      // clang-format on
   });

   // Call the function
   auto ec = parse_sentinel_response(nodes, role::master, fix.resp);
   BOOST_TEST_EQ(ec, error_code());

   // Check
   const address expected_sentinels[] = {
      {"host.one", "26380"},
      {"host.two", "26381"},
   };
   fix.check_response({"localhost", "6380"}, {}, expected_sentinels);
}

// IP and port can be out of order
void test_master_ip_port_out_of_order()
{
   // Setup
   fixture fix;
   auto nodes = nodes_from_resp3({
      // clang-format off
      "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
      "*1\r\n"
         "%2\r\n"
            "$4\r\nport\r\n$5\r\n26380\r\n$2\r\nip\r\n$8\r\nhost.one\r\n"
      // clang-format on
   });

   // Call the function
   auto ec = parse_sentinel_response(nodes, role::master, fix.resp);
   BOOST_TEST_EQ(ec, error_code());

   // Check
   const address expected_sentinels[] = {
      {"host.one", "26380"},
   };
   fix.check_response({"localhost", "6380"}, {}, expected_sentinels);
}

// Usual response when asking for a replica
void test_replica()
{
   // Setup
   fixture fix;
   auto nodes = nodes_from_resp3({
      // clang-format off
      "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
      "*2\r\n"
         "%21\r\n"
            "$4\r\nname\r\n$14\r\nlocalhost:6381\r\n$2\r\nip\r\n$9\r\nsome.host\r\n$4\r\nport\r\n$4\r\n6381\r\n"
            "$5\r\nrunid\r\n$40\r\ncdfa33e2d39958c0b10c0391c0c3d4ab096edfeb\r\n$5\r\nflags\r\n$5\r\nslave\r\n"
            "$21\r\nlink-pending-commands\r\n$1\r\n0\r\n$13\r\nlink-refcount\r\n$1\r\n1\r\n$14\r\nlast-ping-sent\r\n$1\r\n0\r\n"
            "$18\r\nlast-ok-ping-reply\r\n$3\r\n134\r\n$15\r\nlast-ping-reply\r\n$3\r\n134\r\n$23\r\ndown-after-milliseconds\r\n$5\r\n10000\r\n"
            "$12\r\ninfo-refresh\r\n$4\r\n5302\r\n$13\r\nrole-reported\r\n$5\r\nslave\r\n$18\r\nrole-reported-time\r\n$6\r\n442121\r\n"
            "$21\r\nmaster-link-down-time\r\n$1\r\n0\r\n$18\r\nmaster-link-status\r\n$2\r\nok\r\n$11\r\nmaster-host\r\n$9\r\nlocalhost\r\n"
            "$11\r\nmaster-port\r\n$4\r\n6380\r\n$14\r\nslave-priority\r\n$3\r\n100\r\n$17\r\nslave-repl-offset\r\n$5\r\n29110\r\n"
            "$17\r\nreplica-announced\r\n$1\r\n1\r\n"
         "%21\r\n"
            "$4\r\nname\r\n$14\r\nlocalhost:6382\r\n$2\r\nip\r\n$9\r\ntest.host\r\n$4\r\nport\r\n$4\r\n6382\r\n"
            "$5\r\nrunid\r\n$40\r\n11bfea62c25316e211fdf0e1ccd2dbd920e90815\r\n$5\r\nflags\r\n$5\r\nslave\r\n"
            "$21\r\nlink-pending-commands\r\n$1\r\n0\r\n$13\r\nlink-refcount\r\n$1\r\n1\r\n$14\r\nlast-ping-sent\r\n$1\r\n0\r\n"
            "$18\r\nlast-ok-ping-reply\r\n$3\r\n134\r\n$15\r\nlast-ping-reply\r\n$3\r\n134\r\n$23\r\ndown-after-milliseconds\r\n$5\r\n10000\r\n"
            "$12\r\ninfo-refresh\r\n$4\r\n5302\r\n$13\r\nrole-reported\r\n$5\r\nslave\r\n$18\r\nrole-reported-time\r\n$6\r\n442132\r\n"
            "$21\r\nmaster-link-down-time\r\n$1\r\n0\r\n$18\r\nmaster-link-status\r\n$2\r\nok\r\n$11\r\nmaster-host\r\n$9\r\nlocalhost\r\n"
            "$11\r\nmaster-port\r\n$4\r\n6380\r\n$14\r\nslave-priority\r\n$3\r\n100\r\n$17\r\nslave-repl-offset\r\n$5\r\n29110\r\n"
            "$17\r\nreplica-announced\r\n$1\r\n1\r\n",
      "*2\r\n"
         "%14\r\n"
            "$4\r\nname\r\n$40\r\nf14ef06a8a478cdd66ded467ec18accd2a24b731\r\n$2\r\nip\r\n$8\r\nhost.one\r\n$4\r\nport\r\n$5\r\n26380\r\n"
            "$5\r\nrunid\r\n$40\r\nf14ef06a8a478cdd66ded467ec18accd2a24b731\r\n$5\r\nflags\r\n$8\r\nsentinel\r\n"
            "$21\r\nlink-pending-commands\r\n$1\r\n0\r\n$13\r\nlink-refcount\r\n$1\r\n1\r\n$14\r\nlast-ping-sent\r\n$1\r\n0\r\n"
            "$18\r\nlast-ok-ping-reply\r\n$3\r\n696\r\n$15\r\nlast-ping-reply\r\n$3\r\n696\r\n$23\r\ndown-after-milliseconds\r\n$5\r\n10000\r\n"
            "$18\r\nlast-hello-message\r\n$3\r\n334\r\n$12\r\nvoted-leader\r\n$1\r\n?\r\n$18\r\nvoted-leader-epoch\r\n$1\r\n0\r\n"
         "%14\r\n"
            "$4\r\nname\r\n$40\r\nf9b54e79e2e7d3f17ad60527504191ec8a861f27\r\n$2\r\nip\r\n$8\r\nhost.two\r\n$4\r\nport\r\n$5\r\n26381\r\n"
            "$5\r\nrunid\r\n$40\r\nf9b54e79e2e7d3f17ad60527504191ec8a861f27\r\n$5\r\nflags\r\n$8\r\nsentinel\r\n"
            "$21\r\nlink-pending-commands\r\n$1\r\n0\r\n$13\r\nlink-refcount\r\n$1\r\n1\r\n$14\r\nlast-ping-sent\r\n$1\r\n0\r\n"
            "$18\r\nlast-ok-ping-reply\r\n$3\r\n696\r\n$15\r\nlast-ping-reply\r\n$3\r\n696\r\n$23\r\ndown-after-milliseconds\r\n$5\r\n10000\r\n"
            "$18\r\nlast-hello-message\r\n$3\r\n134\r\n$12\r\nvoted-leader\r\n$1\r\n?\r\n$18\r\nvoted-leader-epoch\r\n$1\r\n0\r\n",
      // clang-format on
   });

   // Call the function
   auto ec = parse_sentinel_response(nodes, role::replica, fix.resp);
   BOOST_TEST_EQ(ec, error_code());

   // Check
   const address expected_replicas[] = {
      {"some.host", "6381"},
      {"test.host", "6382"},
   };
   const address expected_sentinels[] = {
      {"host.one", "26380"},
      {"host.two", "26381"},
   };
   fix.check_response({"localhost", "6380"}, expected_replicas, expected_sentinels);
}

// Like the master case
void test_replica_no_sentinels()
{
   // Setup
   fixture fix;
   auto nodes = nodes_from_resp3({
      // clang-format off
      "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
      "*2\r\n"
         "%3\r\n"
            "$4\r\nname\r\n$14\r\nlocalhost:6381\r\n$2\r\nip\r\n$9\r\nsome.host\r\n$4\r\nport\r\n$4\r\n6381\r\n"
         "%3\r\n"
            "$4\r\nname\r\n$14\r\nlocalhost:6382\r\n$2\r\nip\r\n$9\r\ntest.host\r\n$4\r\nport\r\n$4\r\n6382\r\n",
      "*0\r\n"
      // clang-format on
   });

   // Call the function
   auto ec = parse_sentinel_response(nodes, role::replica, fix.resp);
   BOOST_TEST_EQ(ec, error_code());

   // Check
   const address expected_replicas[] = {
      {"some.host", "6381"},
      {"test.host", "6382"},
   };
   fix.check_response({"localhost", "6380"}, expected_replicas, {});
}

// Asking for replicas, but there is none
void test_replica_no_replicas()
{
   // Setup
   fixture fix;
   auto nodes = nodes_from_resp3({
      // clang-format off
      "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
      "*0\r\n",
      "*0\r\n",
      // clang-format on
   });

   // Call the function
   auto ec = parse_sentinel_response(nodes, role::replica, fix.resp);
   BOOST_TEST_EQ(ec, error_code());

   // Check
   fix.check_response({"localhost", "6380"}, {}, {});
}

// Setup requests work with replicas, too
void test_replica_setup_request()
{
   // Setup
   fixture fix;
   auto nodes = nodes_from_resp3({
      // clang-format off
      "*2\r\n+OK\r\n+OK\r\n",
      "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
      "*2\r\n"
         "%3\r\n"
            "$4\r\nname\r\n$14\r\nlocalhost:6381\r\n$2\r\nip\r\n$9\r\nsome.host\r\n$4\r\nport\r\n$4\r\n6381\r\n"
         "%3\r\n"
            "$4\r\nname\r\n$14\r\nlocalhost:6382\r\n$2\r\nip\r\n$9\r\ntest.host\r\n$4\r\nport\r\n$4\r\n6382\r\n",
      "*2\r\n"
         "%3\r\n"
            "$4\r\nname\r\n$40\r\nf14ef06a8a478cdd66ded467ec18accd2a24b731\r\n$2\r\nip\r\n$8\r\nhost.one\r\n$4\r\nport\r\n$5\r\n26380\r\n"
         "%3\r\n"
            "$4\r\nname\r\n$40\r\nf9b54e79e2e7d3f17ad60527504191ec8a861f27\r\n$2\r\nip\r\n$8\r\nhost.two\r\n$4\r\nport\r\n$5\r\n26381\r\n"
      // clang-format on
   });

   // Call the function
   auto ec = parse_sentinel_response(nodes, role::replica, fix.resp);
   BOOST_TEST_EQ(ec, error_code());

   // Check
   const address expected_replicas[] = {
      {"some.host", "6381"},
      {"test.host", "6382"},
   };
   const address expected_sentinels[] = {
      {"host.one", "26380"},
      {"host.two", "26381"},
   };
   fix.check_response({"localhost", "6380"}, expected_replicas, expected_sentinels);
}

// IP and port can be out of order
void test_replica_ip_port_out_of_order()
{
   // Setup
   fixture fix;
   auto nodes = nodes_from_resp3({
      // clang-format off
      "*2\r\n$9\r\ntest.host\r\n$4\r\n6389\r\n",
      "*1\r\n"
         "%2\r\n"
            "$4\r\nport\r\n$4\r\n6381\r\n$2\r\nip\r\n$9\r\nsome.host\r\n",
      "*0\r\n"
      // clang-format on
   });

   // Call the function
   auto ec = parse_sentinel_response(nodes, role::replica, fix.resp);
   BOOST_TEST_EQ(ec, error_code());

   // Check
   const address expected_replicas[] = {
      {"some.host", "6381"},
   };
   fix.check_response({"test.host", "6389"}, expected_replicas, {});
}

void test_errors()
{
   const struct {
      std::string_view name;
      role server_role;
      std::vector<std::string_view> responses;
      std::string_view expected_diagnostic;
      error_code expected_ec;
   } test_cases[]{
      // clang-format off
      {
         // A RESP3 simple error
         "setup_error_simple",
         role::master,
         {
            "-WRONGPASS invalid username-password pair or user is disabled.\r\n",
            "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
            "*0\r\n",
         },
         "WRONGPASS invalid username-password pair or user is disabled.",
         error::resp3_simple_error
      },
      {
         // A RESP3 blob error
         "setup_error_blob",
         role::master,
         {
            "!3\r\nBad\r\n",
            "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
            "*0\r\n",
         },
         "Bad",
         error::resp3_blob_error
      },
      {
         // Errors in intermediate nodes of the user-supplied request
         "setup_error_intermediate",
         role::master,
         {
            "+OK\r\n",
            "-Something happened!\r\n",
            "+OK\r\n",
            "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
            "*0\r\n",
         },
         "Something happened!",
         error::resp3_simple_error
      },
      {
         // Only the first error is processed (e.g. auth failure may cause subsequent cmds to fail)
         "setup_error_intermediate",
         role::master,
         {
            "-Something happened!\r\n",
            "-Something worse happened!\r\n",
            "-Bad\r\n",
            "-Worse\r\n",
         },
         "Something happened!",
         error::resp3_simple_error
      },
      {
         // This works for replicas, too
         "setup_error_replicas",
         role::replica,
         {
            "-Something happened!\r\n",
            "-Something worse happened!\r\n",
            "-Bad\r\n",
            "-Worse\r\n",
         },
         "Something happened!",
         error::resp3_simple_error
      },

      // SENTINEL GET-MASTER-ADDR-BY-NAME
      {
         // Unknown master. This returns NULL and causes SENTINEL SENTINELS to fail
         "getmasteraddr_unknown_master",
         role::master,
         {
            "_\r\n",
            "-ERR Unknown master\r\n",
         },
         "",
         error::resp3_null
      },
      {
         // The request errors for any other reason
         "getmasteraddr_error",
         role::master,
         {
            "-ERR something happened\r\n",
            "*0\r\n",
         },
         "ERR something happened",
         error::resp3_simple_error
      },
      {
         // Same, for replicas
         "getmasteraddr_unknown_master_replica",
         role::replica,
         {
            "_\r\n",
            "-ERR Unknown master\r\n",
            "-ERR Unknown master\r\n",
         },
         "",
         error::resp3_null
      },
      {
         // Root node should be a list
         "getmasteraddr_not_array",
         role::master,
         {
            "+OK\r\n",
            "*0\r\n",
         },
         "",
         error::expects_resp3_array
      },
      {
         // Root node should have exactly 2 elements
         "getmasteraddr_array_size_1",
         role::master,
         {
            "*1\r\n$5\r\nhello\r\n",
            "*0\r\n",
         },
         "",
         error::incompatible_size
      },
      {
         // Root node should have exactly 2 elements
         "getmasteraddr_array_size_3",
         role::master,
         {
            "*3\r\n$5\r\nhello\r\n$3\r\nbye\r\n$3\r\nabc\r\n",
            "*0\r\n",
         },
         "",
         error::incompatible_size
      },
      {
         // IP should be a string
         "getmasteraddr_ip_not_string",
         role::master,
         {
            "*2\r\n+OK\r\n$5\r\nhello\r\n",
            "*0\r\n",
         },
         "",
         error::expects_resp3_string
      },
      {
         // Port should be a string
         "getmasteraddr_port_not_string",
         role::master,
         {
            "*2\r\n$5\r\nhello\r\n+OK\r\n",
            "*0\r\n",
         },
         "",
         error::expects_resp3_string
      },

      // SENTINEL SENTINELS
      {
         // The request errors
         "sentinels_error",
         role::master,
         {
            "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
            "-ERR something went wrong\r\n",
         },
         "ERR something went wrong",
         error::resp3_simple_error
      },
      {
         // The root node should be an array
         "sentinels_not_array",
         role::master,
         {
            "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
            "+OK\r\n",
         },
         "",
         error::expects_resp3_array
      },
      {
         // Each Sentinel object should be a map
         "sentinels_subobject_not_map",
         role::master,
         {
            "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
            "*1\r\n*1\r\n$9\r\nlocalhost\r\n",
         },
         "",
         error::expects_resp3_map
      },
      {
         // Keys in the Sentinel object should be strings
         "sentinels_keys_not_strings",
         role::master,
         {
            "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
            "*1\r\n%1\r\n*0\r\n$5\r\nhello\r\n",
         },
         "",
         error::expects_resp3_string
      },
      {
         // Values in the Sentinel object should be strings
         "sentinels_keys_not_strings",
         role::master,
         {
            "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
            "*1\r\n%1\r\n$5\r\nhello\r\n*1\r\n+OK\r\n",
         },
         "",
         error::expects_resp3_string
      },
      {
         "sentinels_ip_not_found",
         role::master,
         {
            "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
            "*1\r\n%1\r\n$4\r\nport\r\n$4\r\n6380\r\n",
         },
         "",
         error::empty_field
      },
      {
         "sentinels_port_not_found",
         role::master,
         {
            "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
            "*1\r\n%1\r\n$2\r\nip\r\n$9\r\nlocalhost\r\n",
         },
         "",
         error::empty_field
      },

      // SENTINEL REPLICAS
      {
         // The request errors
         "replicas_error",
         role::replica,
         {
            "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
            "-ERR something went wrong\r\n",
            "*0\r\n",
         },
         "ERR something went wrong",
         error::resp3_simple_error
      },
      {
         // The root node should be an array
         "replicas_not_array",
         role::replica,
         {
            "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
            "+OK\r\n",
            "*0\r\n",
         },
         "",
         error::expects_resp3_array
      },
      {
         // Each replica object should be a map
         "replicas_subobject_not_map",
         role::replica,
         {
            "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
            "*1\r\n*1\r\n$9\r\nlocalhost\r\n",
            "*0\r\n",
         },
         "",
         error::expects_resp3_map
      },
      {
         // Keys in the replica object should be strings
         "replicas_keys_not_strings",
         role::replica,
         {
            "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
            "*1\r\n%1\r\n*0\r\n$5\r\nhello\r\n",
            "*0\r\n",
         },
         "",
         error::expects_resp3_string
      },
      {
         // Values in the replica object should be strings
         "replicas_keys_not_strings",
         role::replica,
         {
            "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
            "*1\r\n%1\r\n$5\r\nhello\r\n*1\r\n+OK\r\n",
            "*0\r\n",
         },
         "",
         error::expects_resp3_string
      },
      {
         "replicas_ip_not_found",
         role::replica,
         {
            "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
            "*1\r\n%1\r\n$4\r\nport\r\n$4\r\n6380\r\n",
            "*0\r\n",
         },
         "",
         error::empty_field
      },
      {
         "replicas_port_not_found",
         role::replica,
         {
            "*2\r\n$9\r\nlocalhost\r\n$4\r\n6380\r\n",
            "*1\r\n%1\r\n$2\r\nip\r\n$9\r\nlocalhost\r\n",
            "*0\r\n",
         },
         "",
         error::empty_field
      }

      // clang-format on
   };

   for (const auto& tc : test_cases) {
      // Setup
      std::cerr << "Running error test case: " << tc.name << std::endl;
      fixture fix;
      auto nodes = nodes_from_resp3(tc.responses);

      // Call the function
      auto ec = parse_sentinel_response(nodes, tc.server_role, fix.resp);
      BOOST_TEST_EQ(ec, tc.expected_ec);
      BOOST_TEST_EQ(fix.resp.diagnostic, tc.expected_diagnostic);
   }
}

}  // namespace

int main()
{
   test_master();
   test_master_no_sentinels();
   test_master_setup_request();
   test_master_ip_port_out_of_order();

   test_replica();
   test_replica_no_sentinels();
   test_replica_no_replicas();
   test_replica_setup_request();
   test_replica_ip_port_out_of_order();

   test_errors();

   return boost::report_errors();
}