#include <gtk/gtk.h>
#include "teleportpeer.h"

enum {
  ADD, REMOVE, N_SIGNALS
};

static gint signalIds [N_SIGNALS];

struct _TeleportPeer
{
  GObject parent;
  GArray *list;
  /* instance members */
};

G_DEFINE_TYPE (TeleportPeer, teleport_peer, G_TYPE_OBJECT)

static void
teleport_peer_constructed (GObject *obj)
{
  G_OBJECT_CLASS (teleport_peer_parent_class)->constructed (obj);
}

static void
teleport_peer_class_init (TeleportPeerClass *klass)
{
  GObjectClass *object_class = G_OBJECT_CLASS (klass);

  object_class->constructed = teleport_peer_constructed;
  signalIds[ADD] = g_signal_new ("addpeer",
      G_TYPE_OBJECT,
      G_SIGNAL_RUN_LAST | G_SIGNAL_NO_RECURSE | G_SIGNAL_NO_HOOKS,
      0,
      NULL /* accumulator */,
      NULL /* accumulator data */,
      NULL /* C marshaller */,
      G_TYPE_NONE /* return_type */,
      1,
      G_TYPE_POINTER);

  signalIds[REMOVE] = g_signal_new ("removepeer",
      G_TYPE_OBJECT,
      G_SIGNAL_RUN_LAST | G_SIGNAL_NO_RECURSE | G_SIGNAL_NO_HOOKS,
      0,
      NULL /* accumulator */,
      NULL /* accumulator data */,
      NULL /* C marshaller */,
      G_TYPE_NONE /* return_type */,
      1,
      G_TYPE_POINTER);

}

static void
teleport_peer_init (TeleportPeer *self)
{
  self->list = g_array_new (FALSE, FALSE, sizeof(Peer *));
}

gchar * teleport_peer_get_name (TeleportPeer *self, gint index, GError **error)
{
  //g_return_if_fail (TELEPORT_IS_PEER (self));
  //g_return_if_fail (error == NULL || *error == NULL);
  if (index > self->list->len-1)
    return NULL;
  Peer *element = g_array_index(self->list, Peer *, index);
  return element->name;
}

gchar * teleport_peer_get_ip (TeleportPeer *self, gint index, GError **error)
{
  //g_return_if_fail (TELEPORT_IS_PEER (self));
  //g_return_if_fail (error == NULL || *error == NULL);
  Peer *element = g_array_index(self->list, Peer *, index);
  if (index > self->list->len-1)
    return NULL;
  return element->ip;
}
gint teleport_peer_get_port (TeleportPeer *self, gint index, GError **error)
{
  Peer *element = g_array_index(self->list, Peer*, index);
  if (index > self->list->len-1)
    return 0;
  return element->port;
}

void teleport_peer_add_peer (TeleportPeer *self, gchar * name, gchar * ip, gint port)
{
  Peer *new = g_new(Peer, 1);
  new->ip = ip;
  new->port = port;
  new->name = name;
  g_array_append_val(self->list, new);

  g_signal_emit (self, signalIds[ADD], 0, new);
}

void teleport_peer_remove_peer (TeleportPeer *self, Peer *device)
{
  Peer *element;
  gboolean found = FALSE;
  //Maybe I could just compare the addresses
  for (int i = 0; i < self->list->len && !found; i++) {
    element = g_array_index(self->list, Peer *, i);
    if (g_strcmp0(element->name, device->name) == 0) {
      found = TRUE;
      g_array_remove_index(self->list, i);
    }
  }
  g_signal_emit (self, signalIds[REMOVE], 0, device);
}

void teleport_peer_remove_peer_by_name (TeleportPeer *self, gchar *name)
{

  g_print("Remove this device %s", name);
  Peer *element;
  gboolean found = FALSE;
  for (int i = 0; i < self->list->len && !found; i++) {
    element = g_array_index(self->list, Peer *, i);
    if (g_strcmp0(element->name, name) == 0) {
      found = TRUE;
      g_array_remove_index(self->list, i);
    }
  }
  g_signal_emit (self, signalIds[REMOVE], 0, element);
}