#include "test.h"
#include "tap.h"
#include "mongo-wire.h"
#include "mongo-client.h"

#include <errno.h>
#include <sys/socket.h>

#include "libmongo-private.h"

void
test_mongo_packet_send (void)
{
  mongo_packet *p;
  mongo_connection c, *conn;
  mongo_packet_header h;
  bson *b;

  p = mongo_wire_cmd_kill_cursors (1, 2, (gint64)3, (gint64)4);
  c.fd = -1;

  ok (mongo_packet_send (NULL, p) == FALSE,
      "mongo_packet_send() fails with a NULL connection");
  ok (errno == ENOTCONN,
      "mongo_packet_send() with a NULL connection sets errno to ENOTCONN");
  ok (mongo_packet_send (&c, NULL) == FALSE,
      "mongo_packet_send() fails with a NULL packet");
  ok (errno == EINVAL,
      "mongo_packet_send() with a NULL packet sets errno to EINVAL");
  ok (mongo_packet_send (&c, p) == FALSE,
      "mongo_packet_send() fails if the FD is less than zero");
  ok (errno == EBADF,
      "mongo_packet_send() sets errno to EBADF is the FD is bad");
  mongo_wire_packet_free (p);

  p = mongo_wire_packet_new ();

  h.id = 42;
  h.resp_to = 0;
  h.opcode = 1;
  h.length = sizeof (mongo_packet_header);
  mongo_wire_packet_set_header (p, &h);

  c.fd = 1;
  ok (mongo_packet_send (&c, p) == FALSE,
      "mongo_packet_send() fails with an unfinished packet");

  mongo_wire_packet_free (p);

  begin_network_tests (2);

  b = bson_new ();
  bson_append_int32 (b, "getnonce", 1);
  bson_finish (b);

  p = mongo_wire_cmd_custom (42, config.db, 0, b);
  bson_free (b);

  conn = mongo_connect (config.primary_host, config.primary_port);
  ok (mongo_packet_send (conn, p),
      "mongo_packet_send() works");

  close (conn->fd);
  sleep (3);

  ok (mongo_packet_send (conn, p) == FALSE,
      "mongo_packet_send() fails on a closed socket");
  mongo_wire_packet_free (p);

  mongo_disconnect (conn);

  end_network_tests ();
}

RUN_TEST (9, mongo_packet_send);