/*

 * jabglue.c    -- Jabber protocol handling

 * 

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

 * Parts come from the centericq project:

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

 *

 * 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 "../libjabber/jabber.h"

#include "jabglue.h"

#include "screen.h"

#include "utils.h"

#define JABBERPORT      5222

#define JABBERSSLPORT   5223

jconn jc;

  STATE_CONNECTING,

  STATE_GETAUTH,

  STATE_SENDAUTH,

  STATE_LOGGED

} jstate;

static void jidsplit(const char *jid, char **user, char **host,

        char **res)

{

  char *tmp, *ptr;

  tmp = strdup(jid);

  if ((ptr = strchr(tmp, '/')) != NULL) {

    *res = strdup(ptr+1);

    *ptr = 0;

  } else

    *res = NULL;

  if ((ptr = strchr(tmp, '@')) != NULL) {

    *host = strdup(ptr+1);

    *ptr = 0;

  } else

    *host = NULL;

  *user = strdup(tmp);

  free(tmp);

}

char *jidtodisp(const char *jid)

{

  char *ptr;

  char *alias = strdup(jid);

  if ((ptr = strchr(alias, '/')) != NULL) {

    *ptr = 0;

  }

  return alias;

}

jconn jb_connect(const char *servername, unsigned int port, int ssl,

                  const char *jid, const char *pass,

                  const char *resource)

{

  if (!port) {

    if (ssl)

      port = JABBERSSLPORT;

    else

      port = JABBERPORT;

  }

  if (jc)

    free(jc);

  //jc = jab_new(jid, pass, port, ssl);

  jc = jab_new("mctest@lilotux.net/mcabber", (char*)pass, (int)port, ssl);

  jab_packet_handler(jc, &packethandler);

  jab_state_handler(jc, &statehandler);

  if (jc->user) {

    scr_LogPrint("+ State_Connecting");

    jstate = STATE_CONNECTING;

    statehandler(0, -1);

    jab_start(jc);

  }

  return jc;

}

void jb_disconnect(void)

{

  statehandler(jc, JCONN_STATE_OFF);

}

void jb_keepalive()

{

  if (jc) {

    // XXX Only if connected...

    jab_send_raw(jc, " ");

  }

}

void jb_main()

{

  xmlnode x, z;

  char *cid;

  if (jc && jc->state == JCONN_STATE_CONNECTING) {

    jab_start(jc);

    return;

  }

  if (jstate == STATE_CONNECTING) {

    if (jc) {

      x = jutil_iqnew(JPACKET__GET, NS_AUTH);

      cid = jab_getid(jc);

      xmlnode_put_attrib(x, "id", cid);

      // id = atoi(cid);

      z = xmlnode_insert_tag(xmlnode_get_tag(x, "query"), "username");

      xmlnode_insert_cdata(z, jc->user->user, (unsigned) -1);

      jab_send(jc, x);

      xmlnode_free(x);

      jstate = STATE_GETAUTH;

    }

    if (!jc || jc->state == JCONN_STATE_OFF) {

      scr_LogPrint("Unable to connect to the server");

    }

  }

  if (!jc) {

    statehandler(jc, JCONN_STATE_OFF);

  } else if (jc->state == JCONN_STATE_OFF || jc->fd == -1) {

    statehandler(jc, JCONN_STATE_OFF);

  }

}

void setjabberstatus(enum imstatus st, char *msg)

{

  xmlnode x = jutil_presnew(JPACKET__UNKNOWN, 0, 0);

  switch(st) {

    case away:

        xmlnode_insert_cdata(xmlnode_insert_tag(x, "show"), "away",

                (unsigned) -1);

        break;

    case occupied:

    case dontdisturb:

        xmlnode_insert_cdata(xmlnode_insert_tag(x, "show"), "dnd",

                (unsigned) -1);

        break;

    case freeforchat:

        xmlnode_insert_cdata(xmlnode_insert_tag(x, "show"), "chat",

                (unsigned) -1);

        break;

    case notavail:

        xmlnode_insert_cdata(xmlnode_insert_tag(x, "show"), "xa",

                (unsigned) -1);

        break;

    case invisible:

        xmlnode_put_attrib(x, "type", "invisible");

        break;

  }

    xmlnode_insert_cdata(xmlnode_insert_tag(x, "priority"),

            add["prio"].c_str(), (unsigned) -1);

  */

  if (!msg || !*msg) {

    msg  = "unknownStatus";

    //msg = imstatus2str(st);

  }

  xmlnode_insert_cdata(xmlnode_insert_tag(x, "status"), msg,

          (unsigned) -1);

  jab_send(jc, x);

  xmlnode_free(x);

  //sendvisibility();

  // XXX logger.putourstatus(proto, getstatus(), ourstatus = st);

}

void gotloggedin(void)

{

  xmlnode x;

  /*

  x = jutil_iqnew(JPACKET__GET, NS_AGENTS);

  xmlnode_put_attrib(x, "id", "Agent List");

  jab_send(jc, x);

  xmlnode_free(x);

  */

  x = jutil_iqnew(JPACKET__GET, NS_ROSTER);

  xmlnode_put_attrib(x, "id", "Roster");

  jab_send(jc, x);

  xmlnode_free(x);

}

void gotroster(xmlnode x)

{

  xmlnode y; // z;

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

    const char *alias = xmlnode_get_attrib(y, "jid");

    const char *sub = xmlnode_get_attrib(y, "subscription");

    const char *name = xmlnode_get_attrib(y, "name");

    //const char *group = 0;

    //z = xmlnode_get_tag(y, "group");

    if (alias) {

      char *buddyname = jidtodisp(alias);

      if (buddyname) {

        scr_LogPrint("New buddy: %s", buddyname);

        free(buddyname);

      }

    }

  }

  postlogin();

}

void gotmessage(char *type, const char *from, const char *body,

        const char *enc)

{

  char *u, *h, *r;

  jidsplit(from, &u, &h, &r);

  if (*r)

    scr_LogPrint("There is an extra part in message: %s", *r);

  scr_WriteIncomingMessage(from, body);

}