/*

 * jab_iq.c     -- Jabber protocol IQ-related fonctions

 *

 * Copyright (C) 2005, 2006 Mikael Berthe <bmikael@lists.lilotux.net>

 * Some parts initially came from the centericq project:

 * Copyright (C) 2002-2005 by Konstantin Klyagin <konst@konst.org.ua>

 * Some small parts come from the Gaim project <http://gaim.sourceforge.net/>

 *

 * This program is free software; you can redistribute it and/or modify

 * it under the terms of the GNU General Public License as published by

 * the Free Software Foundation; either version 2 of the License, or (at

 * your option) any later version.

 *

 * This program 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

 * General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307

 * USA

 */

#include <sys/utsname.h>

#include <glib.h>

#include "jabglue.h"

#include "jab_priv.h"

#include "roster.h"

#include "utils.h"

#include "screen.h"

#include "settings.h"

#include "hbuf.h"

static GSList *iqs_list;

//  iqs_new(type, namespace, prefix, timeout)

// Create a query (GET, SET) IQ structure.  This function should not be used

// for RESULT packets.

eviqs *iqs_new(guint8 type, const char *ns, const char *prefix, time_t timeout)

{

  static guint iqs_idn;

  eviqs *new_iqs;

  time_t now_t;

  iqs_idn++;

  new_iqs = g_new0(eviqs, 1);

  time(&now_t);

  new_iqs->ts_create = now_t;

  if (timeout)

    new_iqs->ts_expire = now_t + timeout;

  new_iqs->type = type;

  new_iqs->xmldata = jutil_iqnew(type, (char*)ns);

  if (prefix)

    new_iqs->id = g_strdup_printf("%s_%d", prefix, iqs_idn);

  else

    new_iqs->id = g_strdup_printf("%d", iqs_idn);

  xmlnode_put_attrib(new_iqs->xmldata, "id", new_iqs->id);

  iqs_list = g_slist_append(iqs_list, new_iqs);

  return new_iqs;

}

int iqs_del(const char *iqid)

{

  GSList *p;

  eviqs *i;

  if (!iqid) return 1;

  for (p = iqs_list; p; p = g_slist_next(p)) {

    i = p->data;

    if (!strcmp(iqid, i->id))

      break;

  }

  if (p) {

    g_free(i->id);

    xmlnode_free(i->xmldata);

    g_free(i->data);

    g_free(i);

    iqs_list = g_slist_remove(iqs_list, p->data);

    return 0; // Ok, deleted

  }

  return -1;  // Not found

}

static eviqs *iqs_find(const char *iqid)

{

  GSList *p;

  eviqs *i;

  if (!iqid) return NULL;

  for (p = iqs_list; p; p = g_slist_next(p)) {

    i = p->data;

    if (!strcmp(iqid, i->id))

      return i;

  }

  return NULL;

}

//  iqs_callback(iqid, xml_result, iqcontext)

// Callback processing for the iqid message.

// If we've received an answer, xml_result should point to the xmldata packet.

// If this is a timeout, xml_result should be NULL.

// Return 0 in case of success, -1 if the iqid hasn't been found.

int iqs_callback(const char *iqid, xmlnode xml_result, guint iqcontext)

{

  eviqs *i;

  i = iqs_find(iqid);

  if (!i) return -1;

  // IQ processing

  // Note: If xml_result is NULL, this is a timeout

  if (i->callback)

    (*i->callback)(i, xml_result, iqcontext);

  iqs_del(iqid);

  return 0;

}

void iqs_check_timeout(time_t now_t)

{

  GSList *p;

  eviqs *i;

  p = iqs_list;

  while (p) {

    i = p->data;

    // We must get next IQ eviqs element now because the current one

    // could be freed.

    p = g_slist_next(p);

    if ((!i->ts_expire && now_t > i->ts_create + (time_t)IQS_MAX_TIMEOUT) ||

        (i->ts_expire && now_t > i->ts_expire)) {

      iqs_callback(i->id, NULL, IQS_CONTEXT_TIMEOUT);

    }

  }

}

void jb_iqs_display_list(void)

{

  GSList *p;

  eviqs *i;

  scr_LogPrint(LPRINT_LOGNORM, "IQ list:");

  for (p = iqs_list; p; p = g_slist_next(p)) {

    i = p->data;

    scr_LogPrint(LPRINT_LOGNORM, "Id [%s]", i->id);

  }

  scr_LogPrint(LPRINT_LOGNORM, "End of IQ list.");

}

static void request_roster(void)

{

  eviqs *iqn = iqs_new(JPACKET__GET, NS_ROSTER, "Roster", IQS_DEFAULT_TIMEOUT);

  jab_send(jc, iqn->xmldata);

  iqs_del(iqn->id); // XXX

}

static void handle_iq_roster(xmlnode x)

{

  xmlnode y;

  const char *jid, *name, *group, *sub, *ask;

  char *cleanalias;

  enum subscr esub;

  int need_refresh = FALSE;

  guint roster_type;

  for (y = xmlnode_get_tag(x, "item"); y; y = xmlnode_get_nextsibling(y)) {

    jid = xmlnode_get_attrib(y, "jid");

    name = xmlnode_get_attrib(y, "name");

    sub = xmlnode_get_attrib(y, "subscription");

    ask = xmlnode_get_attrib(y, "ask");

    group = xmlnode_get_tag_data(y, "group");

    if (!jid)

      continue;

    cleanalias = jidtodisp(jid);

    esub = sub_none;

    if (sub) {

      if (!strcmp(sub, "to"))          esub = sub_to;

      else if (!strcmp(sub, "from"))   esub = sub_from;

      else if (!strcmp(sub, "both"))   esub = sub_both;

      else if (!strcmp(sub, "remove")) esub = sub_remove;

    }

    if (esub == sub_remove) {

      roster_del_user(cleanalias);

      scr_LogPrint(LPRINT_LOGNORM, "Buddy <%s> has been removed "

                   "from the roster", cleanalias);

      g_free(cleanalias);

      need_refresh = TRUE;

      continue;

    }

    if (ask && !strcmp(ask, "subscribe"))

      esub |= sub_pending;

    if (!name)

      name = cleanalias;

    // Tricky... :-\  My guess is that if there is no '@', this is an agent

    if (strchr(cleanalias, '@'))

      roster_type = ROSTER_TYPE_USER;

    else

      roster_type = ROSTER_TYPE_AGENT;

    roster_add_user(cleanalias, name, group, roster_type, esub);

    g_free(cleanalias);

  }

  buddylist_build();

  update_roster = TRUE;

  if (need_refresh)

    scr_UpdateBuddyWindow();

}

static void iqscallback_version(eviqs *iqp, xmlnode xml_result, guint iqcontext)

{

  xmlnode ansqry;

  char *bjid;

  char *buf;

  // Leave now if we cannot process xml_result

  if (!xml_result || iqcontext) return;

  ansqry = xmlnode_get_tag(xml_result, "query");

  if (!ansqry) {

    scr_LogPrint(LPRINT_LOGNORM, "Invalid IQ:version result!");

    return;

  }

  // Display IQ result sender...

  p = xmlnode_get_attrib(xml_result, "from");

  if (!p) {

    scr_LogPrint(LPRINT_LOGNORM, "Invalid IQ:version result (no sender name).");

    return;

  }

  bjid = p;

  buf = g_strdup_printf("Received IQ:version result from <%s>", bjid);

  scr_LogPrint(LPRINT_LOGNORM, "%s", buf);

  // bjid should now really be the "bare JID", let's strip the resource

  p = strchr(bjid, '/');

  if (p) *p = '\0';

  scr_WriteIncomingMessage(bjid, buf, 0, HBB_PREFIX_INFO);

  g_free(buf);

  // Get result data...

  p = xmlnode_get_tag_data(ansqry, "name");

  if (p) {

  }

  p = xmlnode_get_tag_data(ansqry, "version");

  if (p) {

  }

  p = xmlnode_get_tag_data(ansqry, "os");

  if (p) {

  }

}

void request_version(const char *fulljid)

{

  eviqs *iqn;

  iqn = iqs_new(JPACKET__GET, NS_VERSION, "version", IQS_DEFAULT_TIMEOUT);

  xmlnode_put_attrib(iqn->xmldata, "to", fulljid);

  iqn->callback = &iqscallback_version;

  jab_send(jc, iqn->xmldata);

}

static void iqscallback_time(eviqs *iqp, xmlnode xml_result, guint iqcontext)

{

  xmlnode ansqry;

  char *bjid;

  char *buf;

  // Leave now if we cannot process xml_result

  if (!xml_result || iqcontext) return;

  ansqry = xmlnode_get_tag(xml_result, "query");

  if (!ansqry) {

    scr_LogPrint(LPRINT_LOGNORM, "Invalid IQ:time result!");

    return;

  }

  // Display IQ result sender...

  p = xmlnode_get_attrib(xml_result, "from");

  if (!p) {

    scr_LogPrint(LPRINT_LOGNORM, "Invalid IQ:time result (no sender name).");

    return;

  }

  bjid = p;

  buf = g_strdup_printf("Received IQ:time result from <%s>", bjid);

  scr_LogPrint(LPRINT_LOGNORM, "%s", buf);

  // bjid should now really be the "bare JID", let's strip the resource

  p = strchr(bjid, '/');

  if (p) *p = '\0';

  scr_WriteIncomingMessage(bjid, buf, 0, HBB_PREFIX_INFO);

  g_free(buf);

  // Get result data...

  p = xmlnode_get_tag_data(ansqry, "utc");

  if (p) {

  }

  p = xmlnode_get_tag_data(ansqry, "tz");

  if (p) {

  }

  p = xmlnode_get_tag_data(ansqry, "display");

  if (p) {

  }

}

void request_time(const char *fulljid)

{

  eviqs *iqn;

  iqn = iqs_new(JPACKET__GET, NS_TIME, "time", IQS_DEFAULT_TIMEOUT);

  xmlnode_put_attrib(iqn->xmldata, "to", fulljid);

  iqn->callback = &iqscallback_time;

  jab_send(jc, iqn->xmldata);

}

void iqscallback_auth(eviqs *iqp, xmlnode xml_result)

{

  if (jstate == STATE_GETAUTH) {

    eviqs *iqn;

    if (xml_result) {

      xmlnode x = xmlnode_get_tag(xml_result, "query");

      if (x && !xmlnode_get_tag(x, "digest"))

        jc->sid = 0;

    }

    iqn = iqs_new(JPACKET__SET, NS_AUTH, "auth", IQS_DEFAULT_TIMEOUT);

    iqn->callback = &iqscallback_auth;

    jab_auth_mcabber(jc, iqn->xmldata);

    jab_send(jc, iqn->xmldata);

    jstate = STATE_SENDAUTH;

  } else if (jstate == STATE_SENDAUTH) {

    request_roster();

    jstate = STATE_LOGGED;

  }

}

static void handle_iq_result(jconn conn, char *from, xmlnode xmldata)

{

  xmlnode x;

  char *id;

  char *ns;

  id = xmlnode_get_attrib(xmldata, "id");

  if (!id) {