#include "test.h"
#include "mongo.h"

#include <errno.h>
#include <sys/socket.h>
#include "libmongo-private.h"

void
test_mongo_sync_reconnect (void)
{
  mongo_sync_connection *conn, *o;
  GList *l;

  ok (mongo_sync_reconnect (NULL, FALSE) == NULL,
      "mongo_sync_reconnect() fails with a NULL connection");
  cmp_ok (errno, "==", ENOTCONN,
          "errno is ENOTCONN");

  conn = test_make_fake_sync_conn (-1, FALSE);
  ok (mongo_sync_reconnect (conn, FALSE) == NULL,
      "mongo_sync_reconnect() fails with a bogus FD");
  cmp_ok (errno, "==", EHOSTUNREACH,
          "errno is EHOSTUNREACH");

  mongo_sync_disconnect (conn);

  begin_network_tests (15);

  /* Connect & reconnect to master */
  o = conn = mongo_sync_connect (config.primary_host,
                                 config.primary_port, TRUE);
  ok ((conn = mongo_sync_reconnect (conn, TRUE)) != NULL,
      "mongo_sync_reconnect() works when reconnecting to self");
  ok (o == conn,
      "Reconnect to an existing master results in the same object");
  mongo_sync_disconnect (conn);

  /* Connect to master, kill FD, reconnect */
  conn = mongo_sync_connect (config.primary_host,
                             config.primary_port, TRUE);
  mongo_sync_cmd_is_master (conn);

  shutdown (conn->super.fd, SHUT_RDWR);
  sleep (3);

  ok ((conn = mongo_sync_reconnect (conn, TRUE)) != NULL,
       "mongo_sync_reconnect() succeed when the connection drops");
  mongo_sync_disconnect (conn);

  /* Connect, kill, reconnect; w/o knowing other hosts */
  o = conn = mongo_sync_connect (config.primary_host,
                                 config.primary_port, TRUE);
  shutdown (conn->super.fd, SHUT_RDWR);
  sleep (3);
  l = conn->rs.hosts;
  while (l)
    {
      g_free (l->data);
      l = g_list_delete_link (l, l);
    }
  conn->rs.hosts = NULL;

  l = conn->rs.seeds;
  while (l)
    {
      g_free (l->data);
      l = g_list_delete_link (l, l);
    }
  conn->rs.seeds = NULL;

  conn = mongo_sync_reconnect (conn, FALSE);

  ok (conn != o && conn == NULL,
      "mongo_sync_reconnect() fails if it can't reconnect anywhere");
  mongo_sync_disconnect (o);

  /* Gracefully ignore unparsable hosts during reconnect */
  o = conn = mongo_sync_connect (config.primary_host,
                                 config.primary_port, TRUE);
  mongo_sync_cmd_is_master (conn);
  conn->rs.hosts = g_list_prepend (conn->rs.hosts,
                                   g_strdup ("invalid:-42"));
  shutdown (conn->super.fd, SHUT_RDWR);
  sleep (3);
  conn = mongo_sync_reconnect (conn, TRUE);

  ok (conn == o,
      "mongo_sync_reconnect() gracefully ignores unparsable hosts "
      "during reconnect");
  mongo_sync_disconnect (conn);

  /* Ignore unreachable hosts during reconnect */
  o = conn = mongo_sync_connect (config.primary_host,
                                 config.primary_port, TRUE);
  mongo_sync_cmd_is_master (conn);
  conn->rs.hosts = g_list_prepend (conn->rs.hosts,
                                   g_strdup ("example.com:27017"));
  shutdown (conn->super.fd, SHUT_RDWR);
  sleep (3);
  conn = mongo_sync_reconnect (conn, TRUE);

  ok (conn == o,
      "mongo_sync_reconnect() gracefully ignores unparsable hosts "
      "during reconnect");
  mongo_sync_disconnect (conn);

  /*
   * Tests involving a secondary
   */

  skip (!config.secondary_host, 9,
        "Secondary host not set up");

  /* Connect to secondary & reconnect to master */
  o = conn = mongo_sync_connect (config.secondary_host,
                                 config.secondary_port, TRUE);
  ok (conn != NULL, "Connecting to secondary");
  ok (mongo_sync_cmd_is_master (conn) == FALSE,
      "Connected to a secondary");
  ok ((conn = mongo_sync_reconnect (conn, TRUE)) != NULL,
      "Reconnecting from slave to master succeeds");
  ok (conn == o, "Connection object updated in-place");
  ok (mongo_sync_cmd_is_master (conn),
      "Correctly reconnected to master");
  mongo_sync_disconnect (conn);

  /* Connect to secondary & reconnect to self */
  o = conn = mongo_sync_connect (config.secondary_host,
                                 config.secondary_port, TRUE);
  ok (conn != NULL, "Connecting to secondary");
  ok ((conn = mongo_sync_reconnect (conn, FALSE)) != NULL,
      "Reconnecting from slave to self succeeds");
  ok (conn == o, "Connection object updated in-place");
  ok (mongo_sync_cmd_is_master (conn) == FALSE,
      "Correctly reconnected to self");
  mongo_sync_disconnect (conn);

  endskip;

  end_network_tests ();
}

RUN_TEST (19, mongo_sync_reconnect);