/*
 * disco.c         -- Service discovery requests
 *
 * Copyrigth (C) 2009      Myhailo Danylenko <isbear@ukrpost.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 <glib.h>
#include <gmodule.h>
#include <loudmouth/loudmouth.h>
#include <strings.h>

#include "commands.h"
#include "logprint.h"
#include "utils.h"
#include "xmpp.h"
#include "compl.h"

#define DISCO_INFO_XMLNS  ( "http:/" "/jabber.org/protocol/disco#info"  )
#define DISCO_ITEMS_XMLNS ( "http:/" "/jabber.org/protocol/disco#items" )

// TODO merge
static LmHandlerResult disco_info_handler (LmMessageHandler *handler, LmConnection *connection, LmMessage *message, gpointer ignore)
{
	switch (lm_message_get_sub_type (message)) {
	case LM_MESSAGE_SUB_TYPE_RESULT:

		{
			LmMessageNode *node = lm_message_get_node (message);
			const gchar *from = lm_message_node_get_attribute (node, "from");
			const gchar *rnode;
			node = lm_message_node_get_child (node, "query");
			// TODO check xmlns
			if (!node)
				break;
			rnode = lm_message_node_get_attribute (node, "node");
			// TODO print to buddy buffer
			scr_LogPrint (LPRINT_NORMAL, "Service discovery info results for %s (%s):", from, rnode ? rnode : "main");
			for (node = node->children; node; node = node->next) {
				if (!strcasecmp (node->name, "identity")) {
					const gchar *category = lm_message_node_get_attribute (node, "category");
					const gchar *type     = lm_message_node_get_attribute (node, "type");
					const gchar *name     = lm_message_node_get_attribute (node, "name");
					scr_LogPrint (LPRINT_NORMAL, "Identity: [%s (%s)] %s", category ? category : "none", type ? type : "none", name ? name : "");
				} else if (!strcasecmp (node->name, "feature")) {
					const gchar *var = lm_message_node_get_attribute (node, "var");
					scr_LogPrint (LPRINT_NORMAL, "Feature: [%s]", var ? var : "unset");
				}
			}
		}

		break;

	case LM_MESSAGE_SUB_TYPE_ERROR:

		{
			LmMessageNode   *node   = lm_message_get_node (message);
			const gchar     *type;
			const gchar     *reason;

			node = lm_message_node_get_child (node, "error");
			type = lm_message_node_get_attribute (node, "type");
			if (node->children)
				reason = node->children->name;
			else
				reason = "undefined";

			scr_LogPrint (LPRINT_LOGNORM, "Service info discovery failed: %s - %s", type, reason);
		}

		break;

	default:
		return LM_HANDLER_RESULT_ALLOW_MORE_HANDLERS;
		break;
	}

	return LM_HANDLER_RESULT_REMOVE_MESSAGE;
}

static LmHandlerResult disco_items_handler (LmMessageHandler *handler, LmConnection *connection, LmMessage *message, gpointer ignore)
{
	switch (lm_message_get_sub_type (message)) {
	case LM_MESSAGE_SUB_TYPE_RESULT:

		{
			LmMessageNode *node = lm_message_get_node (message);
			const gchar *from = lm_message_node_get_attribute (node, "from");
			const gchar *rnode;
			node = lm_message_node_get_child (node, "query");
			// TODO check xmlns
			if (!node)
				break;
			rnode = lm_message_node_get_attribute (node, "node");
			// TODO print to buddy buffer
			scr_LogPrint (LPRINT_NORMAL, "Service discovery items results for %s (%s):", from, rnode ? rnode : "main");
			for (node = node->children; node; node = node->next) {
				const gchar *name = lm_message_node_get_attribute (node, "name");
				const gchar *jid  = lm_message_node_get_attribute (node, "jid");
				scr_LogPrint (LPRINT_NORMAL, "  [%s] %s", jid ? jid : "none", name ? name : "");
			}
		}

		break;

	case LM_MESSAGE_SUB_TYPE_ERROR:

		{
			LmMessageNode   *node   = lm_message_get_node (message);
			const gchar     *type;
			const gchar     *reason;

			node = lm_message_node_get_child (node, "error");
			type = lm_message_node_get_attribute (node, "type");
			if (node->children)
				reason = node->children->name;
			else
				reason = "undefined";

			scr_LogPrint (LPRINT_LOGNORM, "Service items discovery failed: %s - %s", type, reason);
		}

		break;

	default:
		return LM_HANDLER_RESULT_ALLOW_MORE_HANDLERS;
		break;
	}

	return LM_HANDLER_RESULT_REMOVE_MESSAGE;
}

static void do_disco (char *arg)
{
	char **args = split_arg (arg, 3, 0);
	int    info = -1;

	if (!args[0])
		scr_LogPrint (LPRINT_NORMAL, "Subcommand not specified!");
	else if (!strcmp (args[0], "info"))
		info = 1;
	else if (!strcmp (args[0], "items"))
		info = 0;
	else
		scr_LogPrint (LPRINT_NORMAL, "Unknown subcomand.");

	if (info != -1) {
		LmMessageHandler *handler;
		LmMessage        *request;
		LmMessageNode    *node;
		const char       *to      = NULL;
		char             *dnode   = NULL;
		
		if (args[1]) {
			if (strcmp (args[1], "."))
				to = args[1];

			if (args[2])
				dnode = args[2];
		}

		if (!to)
			to = CURRENT_JID; // TODO: send to all resources?

		handler = lm_message_handler_new (info ? disco_info_handler : disco_items_handler, NULL, NULL);

		request = lm_message_new_with_sub_type (to, LM_MESSAGE_TYPE_IQ, LM_MESSAGE_SUB_TYPE_GET);
		node    = lm_message_get_node (request);
		node    = lm_message_node_add_child (node, "query", NULL);
		lm_message_node_set_attribute (node, "xmlns", info ? DISCO_INFO_XMLNS : DISCO_ITEMS_XMLNS);
		if (dnode)
			lm_message_node_set_attribute (node, "node", dnode);

		lm_connection_send_with_reply (lconnection, request, handler, NULL);
	}
}

const gchar *g_module_check_init(GModule *module)
{
	// TODO: completion
	cmd_add ("disco", "", 0, COMPL_JID, do_disco, NULL);
	return NULL;
}

void g_module_unload(GModule *module)
{
	cmd_del ("disco");
}