/*

Tlen Protocol Plugin for Miranda IM
Copyright (C) 2004-2007  Piotr Piastucki

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 "jabber.h"
#include "jabber_list.h"
#include "jabber_iq.h"
#include "resource.h"
#include "tlen_muc.h"

static int TlenMUCHandleEvent(void *ptr, WPARAM wParam, LPARAM lParam);
static int TlenMUCQueryContacts(TlenProtocol *proto, const char *roomId);
static int TlenMUCSendInvitation(TlenProtocol *proto, const char *roomID, const char *user);
static int TlenMUCSendPresence(TlenProtocol *proto, const char *roomID, const char *nick, int desiredStatus);
static int TlenMUCSendMessage(TlenProtocol *proto, MUCCEVENT *event);
static int TlenMUCSendTopic(TlenProtocol *proto, MUCCEVENT *event);
static int TlenMUCSendQuery(TlenProtocol *proto, int type, const char *parent, int page);

static int isSelf(TlenProtocol *proto, const char *roomID, const char *nick)
{
	JABBER_LIST_ITEM *item;
	int result;
	result=0;
	item = JabberListGetItemPtr(proto, LIST_CHATROOM, roomID);
	if (item!=NULL) {
		if (item->nick==NULL) {
			if (!strcmp(nick, proto->threadData->username)) result = 1;
		} else if (nick[0]=='~') {
			if (!strcmp(nick+1, item->nick)) {
				result = 1;
			}
		}
	}
	return result;
}

static int stringToHex(const char *str)
{
	int i, val;
	val = 0;
	for (i=0;i<2;i++) {
		val <<= 4;
		if (str[i]>='A' && str[i]<='F') {
			val += 10 + str[i]-'A';
		} else if (str[i]>='0' && str[i]<='9') {
			val += str[i]-'0';
		}
	}
	return val;

}
static char *getDisplayName(TlenProtocol *proto, const char *id)
{
	CONTACTINFO ci;
	char jid[256];
	HANDLE hContact;
	DBVARIANT dbv;
	if (!DBGetContactSetting(NULL, proto->iface.m_szModuleName, "LoginServer", &dbv)) {
		_snprintf(jid, sizeof(jid), "%s@%s", id, dbv.pszVal);
		DBFreeVariant(&dbv);
		if (((hContact=JabberHContactFromJID(proto, jid)) != NULL) || !strcmp(id, proto->threadData->username)) {
			ZeroMemory(&ci, sizeof(ci));
			ci.cbSize = sizeof(ci);
			ci.hContact = hContact;
			ci.szProto = (char *)proto->iface.m_szModuleName;
			ci.dwFlag = CNF_DISPLAY;
			if (!CallService(MS_CONTACT_GETCONTACTINFO, 0, (LPARAM) & ci)) {
				if (ci.type == CNFT_ASCIIZ) {
					if (ci.pszVal) {
						char * str = mir_strdup((char *)ci.pszVal);
						miranda_sys_free(ci.pszVal);
						return str;
					}
				}
			}
		}
	}
	return mir_strdup(id);
}

BOOL TlenMUCInit(TlenProtocol *proto)
{
	HookEventObj_Ex(ME_MUCC_EVENT, proto, TlenMUCHandleEvent);
	return 0;
}
static int TlenMUCHandleEvent(void *ptr, WPARAM wParam, LPARAM lParam)
{
	HANDLE hContact;
	int id;
	MUCCEVENT *mucce=(MUCCEVENT *) lParam;
	TlenProtocol *proto = (TlenProtocol *)ptr;
	if (!strcmp(mucce->pszModule, proto->iface.m_szModuleName)) {
		switch (mucce->iType) {
			case MUCC_EVENT_INVITE:
				TlenMUCSendInvitation(proto, mucce->pszID, mucce->pszNick);
				break;
			case MUCC_EVENT_MESSAGE:
				TlenMUCSendMessage(proto, mucce);
				break;
			case MUCC_EVENT_TOPIC:
				TlenMUCSendTopic(proto, mucce);
				break;
			case MUCC_EVENT_LEAVE:
				TlenMUCSendPresence(proto, mucce->pszID, NULL, ID_STATUS_OFFLINE);
				break;
			case MUCC_EVENT_QUERY_GROUPS:
				TlenMUCSendQuery(proto, 1, mucce->pszID, 0);
				break;
			case MUCC_EVENT_QUERY_ROOMS:
				TlenMUCSendQuery(proto, 2, mucce->pszID, mucce->dwData);
				break;
			case MUCC_EVENT_QUERY_SEARCH:
				TlenMUCSendQuery(proto, 3, mucce->pszName, 0);
				break;
			case MUCC_EVENT_QUERY_USERS:
				switch (mucce->dwFlags) {
				case MUCC_EF_USER_OWNER:
					id = 1;
					break;
				case MUCC_EF_USER_ADMIN:
					id = 2;
					break;
				case MUCC_EF_USER_MEMBER:
					id = 3;
					break;
				case MUCC_EF_USER_BANNED:
					id = 4;
					break;
				case MUCC_EF_USER_MODERATOR:
					id = 6;
					break;
				default:
					id = 0;
				}
				TlenMUCSendQuery(proto, 4, mucce->pszID, id);
				break;
			case MUCC_EVENT_REGISTER_NICK:
				TlenMUCSendQuery(proto, 6, mucce->pszNick, 0);
				break;
			case MUCC_EVENT_REMOVE_NICK:
				TlenMUCSendQuery(proto, 6, mucce->pszNick, 1);
				break;
			case MUCC_EVENT_REGISTER_ROOM:
				id = JabberSerialNext(proto);
				if (proto->isOnline) {
					if (mucce->pszNick!=NULL) {
						JabberSend(proto, "<p to='c' tp='c' id='"JABBER_IQID"%d' x='%d' n='%s' p='%s' nick='%s'/>", id, mucce->dwFlags | 0x10, mucce->pszName, mucce->pszID);
					} else {
						JabberSend(proto, "<p to='c' tp='c' id='"JABBER_IQID"%d' x='%d' n='%s' p='%s'/>", id, mucce->dwFlags | 0x10, mucce->pszName, mucce->pszID);
					}
				}
				break;
			case MUCC_EVENT_REMOVE_ROOM:
				if (proto->isOnline) {
					JabberSend(proto, "<p to='%s' type='d'/>", mucce->pszID);
					JabberListRemove(proto, LIST_CHATROOM, mucce->pszID);
				//	TlenMUCSendPresence(mucce->pszID, NULL, ID_STATUS_OFFLINE);
				}
				break;
			case MUCC_EVENT_KICK_BAN:
				if (proto->isOnline) {
					char *nick;
					nick = JabberResourceFromJID(mucce->pszUID);
					if (!isSelf(proto, mucce->pszID, nick)) {
						char *reason = JabberTextEncode(mucce->pszText);
						JabberSend(proto, "<p to='%s'><x><i i='%s' a='4' ex='%d' rs='%s'/></x></p>", mucce->pszID, nick, mucce->dwData, reason);
						mir_free(reason);
					}
					mir_free(nick);
				}
				break;
			case MUCC_EVENT_UNBAN:
				if (proto->isOnline) {
					char *nick;
					nick = JabberResourceFromJID(mucce->pszUID);
					if (!isSelf(proto, mucce->pszID, nick)) {
						JabberSend(proto, "<p to='%s'><x><i i='%s' a='0'/></x></p>", mucce->pszID, nick);
					}
					mir_free(nick);
				}
				break;
			case MUCC_EVENT_SET_USER_ROLE:
				if (proto->isOnline) {
					char *nick;
					nick = JabberResourceFromJID(mucce->pszUID);
					if (!isSelf(proto, mucce->pszID, nick)) {
						if (mucce->dwFlags == MUCC_EF_USER_ADMIN) {
							id = 2;
						} else if (mucce->dwFlags == MUCC_EF_USER_MEMBER) {
							id = 3;
						} else {
							id = 0;
						}
						JabberSend(proto, "<p to='%s'><x><i i='%s' a='%d' /></x></p>", mucce->pszID, nick, id);
					}
					mir_free(nick);
				}
				break;
			case MUCC_EVENT_QUERY_USER_NICKS:
				TlenMUCSendQuery(proto, 7, mucce->pszID, 0);
				break;
			case MUCC_EVENT_QUERY_USER_ROOMS:
				TlenMUCSendQuery(proto, 8, mucce->pszID, 0);
				break;
			case MUCC_EVENT_QUERY_CONTACTS:
				TlenMUCQueryContacts(proto, mucce->pszID);
				break;
			case MUCC_EVENT_JOIN:
				if (proto->isOnline) {
					if (mucce->pszID==NULL || strlen(mucce->pszID)==0) {
						if (mucce->pszName==NULL || strlen(mucce->pszName)==0) { // create a new chat room
							id = JabberSerialNext(proto);
							JabberSend(proto, "<p to='c' tp='c' id='"JABBER_IQID"%d'/>", id);
						} else { // find a chat room by name
							TlenMUCSendQuery(proto, 3, mucce->pszName, 0);
						}
					} else { // join existing chat room
						if (!TlenMUCCreateWindow(proto, mucce->pszID, mucce->pszName, mucce->dwFlags, mucce->pszNick, NULL)) {
							TlenMUCSendPresence(proto, mucce->pszID, mucce->pszNick, ID_STATUS_ONLINE);
						}
					}
				}
				break;
			case MUCC_EVENT_START_PRIV:
				if (proto->isOnline) {
					JABBER_LIST_ITEM *item;
					item = JabberListGetItemPtr(proto, LIST_CHATROOM, mucce->pszID);
					if (item!=NULL) {
						char *nick;
						nick = JabberResourceFromJID(mucce->pszUID);
						if (!isSelf(proto, mucce->pszID, nick)) {
							if (nick[0]=='~' || item->nick!=NULL) {
								char str[256];
								sprintf(str, "%s/%s", mucce->pszID, nick);
								hContact = JabberDBCreateContact(proto, str, nick, TRUE); //(char *)mucce->pszUID
								DBWriteContactSettingByte(hContact, proto->iface.m_szModuleName, "bChat", TRUE);
								CallService(MS_MSG_SENDMESSAGE, (WPARAM) hContact, (LPARAM) NULL);
							} else {
								DBVARIANT dbv;
								if (!DBGetContactSetting(NULL, proto->iface.m_szModuleName, "LoginServer", &dbv)) {
									char str[512];
									_snprintf(str, sizeof(str), "%s@%s", nick, dbv.pszVal);
									DBFreeVariant(&dbv);
									hContact = JabberDBCreateContact(proto, str, nick, TRUE);
									CallService(MS_MSG_SENDMESSAGE, (WPARAM) hContact, (LPARAM) NULL);
								}
							}
						}
						mir_free(nick);
					}
				}
				break;
		}
	}
	return 0;
}

int TlenMUCRecvInvitation(TlenProtocol *proto, const char *roomId, const char *roomName, const char *from, const char *reason)
{
	char *nick;
	int	 ignore, ask, groupChatPolicy;
	if (roomId == NULL) return 1;
	groupChatPolicy = DBGetContactSettingWord(NULL, proto->iface.m_szModuleName, "GroupChatPolicy", 0);
	ask = TRUE;
	ignore = FALSE;
	if (groupChatPolicy == TLEN_MUC_ASK) {
		ignore = FALSE;
		ask = TRUE;
	} else if (groupChatPolicy == TLEN_MUC_IGNORE_ALL) {
		ignore = TRUE;
	} else if (groupChatPolicy == TLEN_MUC_IGNORE_NIR) {
		char jid[256];
		JABBER_LIST_ITEM *item;
		DBVARIANT dbv;
		if (!DBGetContactSetting(NULL, proto->iface.m_szModuleName, "LoginServer", &dbv)) {
			_snprintf(jid, sizeof(jid), "%s@%s", from, dbv.pszVal);
			DBFreeVariant(&dbv);
		} else {
			strcpy(jid, from);
		}
		ignore = !IsAuthorized(proto, jid);
		ask = TRUE;
	} else if (groupChatPolicy == TLEN_MUC_ACCEPT_IR) {
		char jid[256];
		JABBER_LIST_ITEM *item;
		DBVARIANT dbv;
		if (!DBGetContactSetting(NULL, proto->iface.m_szModuleName, "LoginServer", &dbv)) {
			_snprintf(jid, sizeof(jid), "%s@%s", from, dbv.pszVal);
			DBFreeVariant(&dbv);
		} else {
			strcpy(jid, from);
		}
		item = JabberListGetItemPtr(proto, LIST_ROSTER, jid);
		ask = !IsAuthorized(proto, jid);
		ignore = FALSE;
	} else if (groupChatPolicy == TLEN_MUC_ACCEPT_ALL) {
		ask = FALSE;
		ignore = FALSE;
	}
	if (!ignore) {
		if (ask) {
			MUCCEVENT mucce;
			mucce.cbSize = sizeof(MUCCEVENT);
			mucce.pszModule = proto->iface.m_szModuleName;
			mucce.pszID = roomId;
			mucce.pszName = roomName;
			mucce.iType = MUCC_EVENT_INVITATION;
			mucce.pszUID = from;
			nick = getDisplayName(proto, from);
			mucce.pszNick = nick;
			mucce.pszText = reason;
			CallService(MS_MUCC_EVENT, 0, (LPARAM) &mucce);
			mir_free(nick);
		} else {
			if (!TlenMUCCreateWindow(proto, roomId, roomName, 0, NULL, NULL)) {
				TlenMUCSendPresence(proto, roomId, NULL, ID_STATUS_ONLINE);
			}
		}
	}
	return 0;
}

int TlenMUCRecvPresence(TlenProtocol *proto, const char *from, int status, int flags, const char *kick)
{
	char str[512];
//	if (JabberListExist(LIST_CHATROOM, from)) {
		char *nick, *roomId, *userId;
		MUCCEVENT mucce;
		roomId = JabberLoginFromJID(from);
		userId = JabberResourceFromJID(from);
		nick = getDisplayName(proto, userId);
		mucce.cbSize = sizeof(MUCCEVENT);
		mucce.pszModule = proto->iface.m_szModuleName;
		mucce.pszID = roomId;
		mucce.iType = MUCC_EVENT_STATUS;
		mucce.pszUID = userId;//from;
		mucce.pszNick = nick;
		mucce.time = time(NULL);
		mucce.bIsMe = isSelf(proto, roomId, userId);
		mucce.dwData = status;
		mucce.dwFlags = 0;
		if (flags & USER_FLAGS_GLOBALOWNER) mucce.dwFlags |= MUCC_EF_USER_GLOBALOWNER;
		if (flags & USER_FLAGS_OWNER) mucce.dwFlags |= MUCC_EF_USER_OWNER;
		if (flags & USER_FLAGS_ADMIN) mucce.dwFlags |= MUCC_EF_USER_ADMIN;
		if (flags & USER_FLAGS_REGISTERED) mucce.dwFlags |= MUCC_EF_USER_REGISTERED;
		if (status == ID_STATUS_OFFLINE && mucce.bIsMe && kick!=NULL) {
			mucce.iType = MUCC_EVENT_ERROR;
			sprintf(str, Translate("You have been kicked. Reason: %s "), kick);
			mucce.pszText = str;
		}
		CallService(MS_MUCC_EVENT, 0, (LPARAM) &mucce);
		mir_free(roomId);
		mir_free(userId);
		mir_free(nick);
//	}
	return 0;
}

int TlenMUCRecvMessage(TlenProtocol *proto, const char *from, long timestamp, XmlNode *bodyNode)
{
//	if (JabberListExist(LIST_CHATROOM, from)) {
		char *localMessage;
		char *nick, *style, *roomId, *userId;
		int	 iStyle;
		MUCCEVENT mucce;
		roomId = JabberLoginFromJID(from);
		userId = JabberResourceFromJID(from);
		nick = getDisplayName(proto, userId);
		localMessage = JabberTextDecode(bodyNode->text);
		mucce.cbSize = sizeof(MUCCEVENT);
		mucce.iType = MUCC_EVENT_MESSAGE;
		mucce.pszID = roomId;
		mucce.pszModule = proto->iface.m_szModuleName;
		mucce.pszText = localMessage;
		mucce.pszUID = userId;//from;
		mucce.pszNick = nick;
		mucce.time = timestamp;
		mucce.bIsMe = isSelf(proto, roomId, userId);
		mucce.dwFlags = 0;
		mucce.iFontSize = 0;
		style = JabberXmlGetAttrValue(bodyNode, "f");
		if (style!=NULL) {
			iStyle = atoi(style);
			if (iStyle & 1) mucce.dwFlags |= MUCC_EF_FONT_BOLD;
			if (iStyle & 2) mucce.dwFlags |= MUCC_EF_FONT_ITALIC;
			if (iStyle & 4) mucce.dwFlags |= MUCC_EF_FONT_UNDERLINE;
		}
		style = JabberXmlGetAttrValue(bodyNode, "c");
		if (style!=NULL && strlen(style)>5) {
			iStyle = (stringToHex(style)<<16) | (stringToHex(style+2)<<8) | stringToHex(style+4);
		} else {
			iStyle = 0xFFFFFFFF;
		}
		mucce.color = (COLORREF) iStyle;
		style = JabberXmlGetAttrValue(bodyNode, "s");
		if (style!=NULL) {
			iStyle = atoi(style);
		} else {
			iStyle = 0;
		}
		mucce.iFontSize = iStyle;
		style = JabberXmlGetAttrValue(bodyNode, "n");
		if (style!=NULL) {
			iStyle = atoi(style)-1;
		} else {
			iStyle = 0;
		}
		mucce.iFont = iStyle;
		CallService(MS_MUCC_EVENT, 0, (LPARAM) &mucce);
		mir_free(roomId);
		mir_free(userId);
		mir_free(nick);
		mir_free(localMessage);
//	}
	return 0;
}
int TlenMUCRecvTopic(TlenProtocol *proto, const char *from, const char *subject)
{
//	if (JabberListExist(LIST_CHATROOM, from)) {
		MUCCEVENT mucce;
		mucce.cbSize = sizeof(MUCCEVENT);
		mucce.iType = MUCC_EVENT_TOPIC;
		mucce.pszID = from;
		mucce.pszModule = proto->iface.m_szModuleName;
		mucce.pszText = subject;
		mucce.time = time(NULL);
		CallService(MS_MUCC_EVENT, 0, (LPARAM) &mucce);
//	}
	return 0;
}

int TlenMUCRecvError(TlenProtocol *proto, const char *from, XmlNode *errorNode)
{
	int errCode;
	char str[512];
	JABBER_LIST_ITEM *item;
	MUCCEVENT mucce;
	mucce.cbSize = sizeof(MUCCEVENT);
	mucce.iType = MUCC_EVENT_ERROR;
	mucce.pszID = from;
	mucce.pszModule = proto->iface.m_szModuleName;
	errCode = atoi(JabberXmlGetAttrValue(errorNode, "code"));
	switch (errCode) {
		case 403:
			sprintf(str, Translate("You cannot join this chat room, because you are banned."));
			break;
		case 404:
			sprintf(str, Translate("Chat room not found."));
			break;
		case 407:
			sprintf(str, Translate("This is a private chat room and you are not one of the members."));
			break;
		case 408:
			sprintf(str, Translate("You cannot send any message unless you join this chat room."));
			break;
		case 410:
			sprintf(str, Translate("Chat room with already created."));
			break;
		case 411:
			sprintf(str, Translate("Nickname '%s' is already registered."),
				JabberXmlGetAttrValue(errorNode, "n"));
			break;
		case 412:
			sprintf(str, Translate("Nickname already in use, please try another one. Hint: '%s' is free."),
				JabberXmlGetAttrValue(errorNode, "free"));
			break;
		case 413:
			sprintf(str, Translate("You cannot register more than %s nicknames."),
				JabberXmlGetAttrValue(errorNode, "num"));
			break;
		case 414:
			sprintf(str, Translate("You cannot create more than %s chat rooms."),
				JabberXmlGetAttrValue(errorNode, "num"));
			break;
		case 415:
			sprintf(str, Translate("You cannot join more than %s chat rooms."),
				JabberXmlGetAttrValue(errorNode, "num"));
			break;
		case 601:
			sprintf(str, Translate("Anonymous nicknames are not allowed in this chat room."));
			break;
		default:
			sprintf(str, Translate("Unknown error code : %d"), errCode);
			break;
	}
	mucce.pszText = str;
	CallService(MS_MUCC_EVENT, 0, (LPARAM) &mucce);
	if (proto->isOnline) {
		switch (errCode) {
			case 412:
				item = JabberListGetItemPtr(proto, LIST_CHATROOM, from);
				if (item!=NULL) {
					mucce.iType = MUCC_EVENT_JOIN;
					mucce.dwFlags = MUCC_EF_ROOM_NICKNAMES;
					mucce.pszModule = proto->iface.m_szModuleName;
					mucce.pszID = from;
					mucce.pszName = item->roomName;
					mucce.pszNick = JabberXmlGetAttrValue(errorNode, "free");
					CallService(MS_MUCC_EVENT, 0, (LPARAM) &mucce);
				}
				break;
			case 601:
				item = JabberListGetItemPtr(proto, LIST_CHATROOM, from);
				if (item!=NULL) {
					mucce.iType = MUCC_EVENT_JOIN;
					mucce.dwFlags = 0;
					mucce.pszModule = proto->iface.m_szModuleName;
					mucce.pszID = from;
					mucce.pszName = item->roomName;
					mucce.pszNick = NULL;
					CallService(MS_MUCC_EVENT, 0, (LPARAM) &mucce);
				}
				break;
		}
	}
	return 1;
}
static int TlenMUCSendInvitation(TlenProtocol *proto, const char *roomID, const char *user)
{
	if (!proto->isOnline) {
		return 1;
	}
	JabberSend(proto, "<m to='%s'><x><inv to='%s'><r></r></inv></x></m>", roomID, user);
	return 0;
}

static int TlenMUCSendPresence(TlenProtocol *proto, const char *roomID, const char *nick, int desiredStatus)
{
	char str[512];
	char *jid;
	JABBER_LIST_ITEM *item;
	if (!proto->isOnline) {
		return 1;
	}
	if (nick!=NULL) {
		_snprintf(str, sizeof(str), "%s/%s", roomID, nick);
	} else {
		_snprintf(str, sizeof(str), "%s", roomID);
	}
	if ((jid = JabberTextEncode(str))!=NULL) {
		switch (desiredStatus) {
			case ID_STATUS_ONLINE:
				JabberSend(proto, "<p to='%s'/>", jid);
				item = JabberListGetItemPtr(proto, LIST_CHATROOM, roomID);
				if (item!=NULL) {
					if (item->nick!=NULL) mir_free(item->nick);
					item->nick = NULL;
					if (nick!=NULL) {
						item->nick = mir_strdup(nick);
					}
				}
				break;
			default:
				item = JabberListGetItemPtr(proto, LIST_CHATROOM, roomID);
				if (item!=NULL) {
					JabberSend(proto, "<p to='%s'><s>unavailable</s></p>", jid);
					JabberListRemove(proto, LIST_CHATROOM, roomID);
				}
				break;
		}
		mir_free(jid);
	}
	return 0;
}

static int TlenMUCSendMessage(TlenProtocol *proto, MUCCEVENT *event)
{
	char *msg, *jid;
	int style;

	if (!proto->isOnline) {
		return 1;
	}
	if ((msg = JabberTextEncode(event->pszText))!=NULL) {
		if ((jid = JabberTextEncode(event->pszID))!=NULL) {
			style = 0;
			if (event->dwFlags & MUCC_EF_FONT_BOLD) style |=1;
			if (event->dwFlags & MUCC_EF_FONT_ITALIC) style |=2;
			if (event->dwFlags & MUCC_EF_FONT_UNDERLINE) style |=4;
			JabberSend(proto, "<m to='%s'><b n='%d' s='%d' f='%d' c='%06X'>%s</b></m>", jid, event->iFont+1, event->iFontSize, style, event->color, msg);
			mir_free(jid);
		}
		mir_free(msg);
	}
	return 0;
}

static int TlenMUCSendTopic(TlenProtocol *proto, MUCCEVENT *event)
{
	char *msg, *jid;
	if (!proto->isOnline) {
		return 1;
	}
	if ((msg = JabberTextEncode(event->pszText))!=NULL) {
		if ((jid = JabberTextEncode(event->pszID))!=NULL) {
			JabberSend(proto, "<m to='%s'><subject>%s</subject></m>", jid, msg);
			mir_free(jid);
		}
		mir_free(msg);
	}
	return 0;
}

static int TlenMUCSendQuery(TlenProtocol *proto, int type, const char *parent, int page)
{
	if (!proto->isOnline) {
		return 1;
	}
	if (type==3) { // find chat room by name
		char serialId[32];
		JABBER_LIST_ITEM *item;
		sprintf(serialId, JABBER_IQID"%d", JabberSerialNext(proto));
		item = JabberListAdd(proto, LIST_SEARCH, serialId);
		item->roomName = mir_strdup(parent);
		JabberSend(proto, "<iq to='c' type='3' n='%s' id='%s'/>", parent, serialId);
	} else {
		if (parent==NULL) {
			JabberSend(proto, "<iq to='c' type='%d'/>", type);
		} else { // 1 - groups, 2 - chat rooms, 7 - user nicks, 8 - user rooms
			if (type==1 || (type==2 && page==0) || type==7 || type==8) {
				JabberSend(proto, "<iq to='c' type='%d' p='%s'/>", type, parent);
			} else if (type==2) {
				JabberSend(proto, "<iq to='c' type='%d' p='%s' n='%d'/>", type, parent, page);
			} else if (type==6) {
				if (page) {
					JabberSend(proto, "<iq to='c' type='%d' n='%s' k='u'/>", type, parent);
				} else {
					JabberSend(proto, "<iq to='c' type='%d' n='%s'/>", type, parent);
				}
			} else if (type==4) { // list of users, admins etc.
				JabberSend(proto, "<iq to='%s' type='%d' k='%d'/>", parent, type, page);
			}
		}
	}
	return 0;
}

int TlenMUCCreateWindow(TlenProtocol *proto, const char *roomID, const char *roomName, int roomFlags, const char *nick, const char *iqId)
{
	JABBER_LIST_ITEM *item;
	MUCCWINDOW mucw;
	if (!proto->isOnline || roomID==NULL) {
		return 1;
	}
	if (JabberListExist(proto, LIST_CHATROOM, roomID)) {
		return 0;
	}
	item = JabberListAdd(proto, LIST_CHATROOM, roomID);
	if (roomName!=NULL) {
		item->roomName = mir_strdup(roomName);
	}
	if (nick!=NULL) {
		item->nick = mir_strdup(nick);
	}
	mucw.cbSize = sizeof(MUCCWINDOW);
	mucw.iType = MUCC_WINDOW_CHATROOM;
	mucw.pszModule = proto->iface.m_szModuleName;
	mucw.pszModuleName = proto->iface.m_szProtoName;
	mucw.pszID = roomID;
	mucw.pszName = roomName;
	mucw.pszNick = nick;
	mucw.dwFlags = roomFlags;
	mucw.pszStatusbarText = "hello";
	CallService(MS_MUCC_NEW_WINDOW, 0, (LPARAM) &mucw);
	if (iqId != NULL) {
		item = JabberListGetItemPtr(proto, LIST_INVITATIONS, iqId);
		if (item !=NULL) {
			TlenMUCSendInvitation(proto, roomID, item->nick);
		}
		JabberListRemove(proto, LIST_INVITATIONS, iqId);
	}
	return 0;
}

static void TlenMUCFreeQueryResult(MUCCQUERYRESULT *result)
{	int i;
	for (i=0; i<result->iItemsNum; i++) {
		if (result->pItems[i].pszID != NULL) {
			mir_free((char *) result->pItems[i].pszID);
		}
		if (result->pItems[i].pszName != NULL) {
			mir_free((char *) result->pItems[i].pszName);
		}
		if (result->pItems[i].pszNick != NULL) {
			mir_free((char *) result->pItems[i].pszNick);
		}
		if (result->pItems[i].pszText != NULL) {
			mir_free((char *) result->pItems[i].pszText);
		}
	}
	mir_free((MUCCQUERYITEM *)result->pItems);
}

void TlenIqResultChatGroups(TlenProtocol *proto, XmlNode *iqNode)
{
	XmlNode *lNode, *itemNode;
	char *p, *n, *id, *f;
	int i, j;
	MUCCQUERYRESULT queryResult;

	if ((lNode=JabberXmlGetChild(iqNode, "l")) == NULL) return;
	p = JabberXmlGetAttrValue(iqNode, "p");
	if (p==NULL) {
		p="";
	}
	p = JabberTextDecode(p);
	queryResult.cbSize = sizeof (MUCCQUERYRESULT);
	queryResult.iType = MUCC_EVENT_QUERY_GROUPS;
	queryResult.pszModule = proto->iface.m_szModuleName;
	queryResult.pszParent = p;
	queryResult.pItems = mir_alloc(sizeof(MUCCQUERYITEM) * lNode->numChild);
	memset(queryResult.pItems, 0, sizeof(MUCCQUERYITEM) * lNode->numChild);
	for (i=j=0; i<lNode->numChild; i++) {
		itemNode = lNode->child[i];
		if (!strcmp(itemNode->name, "i")) {
			queryResult.pItems[j].iCount = 0;
			if ((f = JabberXmlGetAttrValue(itemNode, "f")) != NULL) {
				queryResult.pItems[j].iCount = !strcmp(f, "3");
			}
			n = JabberXmlGetAttrValue(itemNode, "n");
			id = JabberXmlGetAttrValue(itemNode, "i");
			if (n != NULL && id != NULL) {
				queryResult.pItems[j].pszID =  JabberTextDecode(id);
				queryResult.pItems[j].pszName = JabberTextDecode(n);
				j++;
			}
		}
	}
	queryResult.iItemsNum = j;
	CallService(MS_MUCC_QUERY_RESULT, 0, (LPARAM) &queryResult);
	TlenMUCFreeQueryResult(&queryResult);
	mir_free(p);
}

void TlenIqResultChatRooms(TlenProtocol *proto, XmlNode *iqNode)
{
	XmlNode *lNode, *itemNode;
	char *id, *c, *n, *x, *p, *px, *pn;
	int i, j;
	MUCCQUERYRESULT queryResult;

	if ((lNode=JabberXmlGetChild(iqNode, "l")) == NULL) return;
	if ((p = JabberXmlGetAttrValue(iqNode, "p")) == NULL) return;
	pn = JabberXmlGetAttrValue(lNode, "n");
	if (pn == NULL) pn = "0";
	px = JabberXmlGetAttrValue(lNode, "x");
	if (px == NULL) px = "0";
	p = JabberTextDecode(p);
	queryResult.cbSize = sizeof (MUCCQUERYRESULT);
	queryResult.iType = MUCC_EVENT_QUERY_ROOMS;
	queryResult.pszModule = proto->iface.m_szModuleName;
	queryResult.pszParent = p;
	queryResult.pItems = mir_alloc(sizeof(MUCCQUERYITEM) * lNode->numChild);
	memset(queryResult.pItems, 0, sizeof(MUCCQUERYITEM) * lNode->numChild);
	queryResult.iPage = atoi(pn);
	queryResult.iLastPage = atoi(px)&2?1:0;
	for (i=j=0; i<lNode->numChild; i++) {
		itemNode = lNode->child[i];
		if (!strcmp(itemNode->name, "i")) {
			n = JabberXmlGetAttrValue(itemNode, "n");
			c = JabberXmlGetAttrValue(itemNode, "c");
			x = JabberXmlGetAttrValue(itemNode, "x");
			if ((id=JabberXmlGetAttrValue(itemNode, "i")) != NULL) {
				queryResult.pItems[j].pszID =  JabberTextDecode(id);
				queryResult.pItems[j].pszName = JabberTextDecode(n);
				queryResult.pItems[j].iCount = atoi(c);
				queryResult.pItems[j].dwFlags = atoi(x);
				j++;
			}
		}
	}
	queryResult.iItemsNum = j;
	CallService(MS_MUCC_QUERY_RESULT, 0, (LPARAM) &queryResult);
	TlenMUCFreeQueryResult(&queryResult);
	mir_free(p);
}
void TlenIqResultUserRooms(TlenProtocol *proto, XmlNode *iqNode)
{
	XmlNode *lNode, *itemNode;
	char *id, *n;
	int i, j;
	MUCCQUERYRESULT queryResult;
	if ((lNode=JabberXmlGetChild(iqNode, "l")) == NULL) return;
	queryResult.cbSize = sizeof (MUCCQUERYRESULT);
	queryResult.iType = MUCC_EVENT_QUERY_USER_ROOMS;
	queryResult.pszModule = proto->iface.m_szModuleName;
	queryResult.pItems = mir_alloc(sizeof(MUCCQUERYITEM) * lNode->numChild);
	memset(queryResult.pItems, 0, sizeof(MUCCQUERYITEM) * lNode->numChild);
	for (i=j=0; i<lNode->numChild; i++) {
		itemNode = lNode->child[i];
		if (!strcmp(itemNode->name, "i")) {
			n = JabberXmlGetAttrValue(itemNode, "n");
			id = JabberXmlGetAttrValue(itemNode, "i");
			if (n != NULL && id != NULL) {
				queryResult.pItems[j].pszID =  JabberTextDecode(id);
				queryResult.pItems[j].pszName = JabberTextDecode(n);
				j++;
			}
		}
	}
	queryResult.iItemsNum = j;
	CallService(MS_MUCC_QUERY_RESULT, 0, (LPARAM) &queryResult);
	TlenMUCFreeQueryResult(&queryResult);
}
void TlenIqResultUserNicks(TlenProtocol *proto, XmlNode *iqNode)
{
	XmlNode *lNode, *itemNode;
	char *n;
	int i, j;
	MUCCQUERYRESULT queryResult;
	if ((lNode=JabberXmlGetChild(iqNode, "l")) == NULL) return;
	queryResult.cbSize = sizeof (MUCCQUERYRESULT);
	queryResult.iType = MUCC_EVENT_QUERY_USER_NICKS;
	queryResult.pszModule = proto->iface.m_szModuleName;
	queryResult.pItems = mir_alloc(sizeof(MUCCQUERYITEM) * lNode->numChild);
	memset(queryResult.pItems, 0, sizeof(MUCCQUERYITEM) * lNode->numChild);
	for (i=j=0; i<lNode->numChild; i++) {
		itemNode = lNode->child[i];
		if (!strcmp(itemNode->name, "i")) {
			n = JabberXmlGetAttrValue(itemNode, "n");
			queryResult.pItems[j].pszID =  NULL;//JabberTextDecode(n);
			queryResult.pItems[j].pszName = JabberTextDecode(n);
			j++;
		}
	}
	queryResult.iItemsNum = j;
	CallService(MS_MUCC_QUERY_RESULT, 0, (LPARAM) &queryResult);
	TlenMUCFreeQueryResult(&queryResult);
}
void TlenIqResultChatRoomUsers(TlenProtocol *proto, XmlNode *iqNode)
{
	XmlNode *lNode, *itemNode;
	char *id, *n;
	int i, j;
	MUCCQUERYRESULT queryResult;
	if ((lNode=JabberXmlGetChild(iqNode, "l")) == NULL) return;
	if ((id=JabberXmlGetAttrValue(iqNode, "from")) == NULL) return;
	queryResult.cbSize = sizeof (MUCCQUERYRESULT);
	queryResult.iType = MUCC_EVENT_QUERY_USERS;
	queryResult.pszModule = proto->iface.m_szModuleName;
	queryResult.pszParent = id;
	queryResult.pItems = mir_alloc(sizeof(MUCCQUERYITEM) * lNode->numChild);
	memset(queryResult.pItems, 0, sizeof(MUCCQUERYITEM) * lNode->numChild);
	for (i=j=0; i<lNode->numChild; i++) {
		itemNode = lNode->child[i];
		if (!strcmp(itemNode->name, "i")) {
			id = JabberXmlGetAttrValue(itemNode, "i");
			if (id != NULL) {
				queryResult.pItems[j].pszID =  JabberTextDecode(id);
				n = JabberXmlGetAttrValue(itemNode, "n");
				if (n!=NULL) {
					queryResult.pItems[j].pszName = JabberTextDecode(n);
				}
				n = JabberXmlGetAttrValue(itemNode, "a");
				if (n!=NULL) {
					queryResult.pItems[j].pszNick = JabberTextDecode(n);
				}
				n = JabberXmlGetAttrValue(itemNode, "r");
				if (n!=NULL) {
					queryResult.pItems[j].pszText = JabberTextDecode(n);
				}
				n = JabberXmlGetAttrValue(itemNode, "e");
				if (n!=NULL) {
					queryResult.pItems[j].iCount = atoi(n);
				}
				n = JabberXmlGetAttrValue(itemNode, "s");
				if (n!=NULL) {
					queryResult.pItems[j].dwFlags = atoi(n);
				}
				j++;
			}
		}
	}
	queryResult.iItemsNum = j;
	CallService(MS_MUCC_QUERY_RESULT, 0, (LPARAM) &queryResult);
	TlenMUCFreeQueryResult(&queryResult);
}

void TlenIqResultRoomSearch(TlenProtocol *proto, XmlNode *iqNode)
{
	char *iqId, *id;
	JABBER_LIST_ITEM *item;
	iqId=JabberXmlGetAttrValue(iqNode, "id");
	item=JabberListGetItemPtr(proto, LIST_SEARCH, iqId);
	if ((id=JabberXmlGetAttrValue(iqNode, "i")) != NULL) {
		MUCCEVENT mucce;
		id = JabberTextDecode(id);
		mucce.cbSize = sizeof(MUCCEVENT);
		mucce.iType = MUCC_EVENT_JOIN;
		mucce.pszModule = proto->iface.m_szModuleName;
		mucce.pszID = id;
		mucce.pszName = id;
		if (item!=NULL) {
			mucce.pszName = item->roomName;
		}
		mucce.pszNick = NULL;
		mucce.dwFlags = MUCC_EF_ROOM_NICKNAMES;
		CallService(MS_MUCC_EVENT, 0, (LPARAM) &mucce);
		mir_free(id);
	}
	JabberListRemove(proto, LIST_SEARCH, iqId);
}

void TlenIqResultRoomInfo(TlenProtocol *proto, XmlNode *iqNode)
{
	char *id, *name, *group, *flags;
	if ((id=JabberXmlGetAttrValue(iqNode, "from")) != NULL) {
		if ((name=JabberXmlGetAttrValue(iqNode, "n")) != NULL) {
			MUCCEVENT mucce;
			group = JabberXmlGetAttrValue(iqNode, "cn");
			flags = JabberXmlGetAttrValue(iqNode, "x");
			id = JabberTextDecode(id);
			name = JabberTextDecode(name);
			mucce.cbSize = sizeof(MUCCEVENT);
			mucce.iType = MUCC_EVENT_ROOM_INFO;
			mucce.pszModule = proto->iface.m_szModuleName;
			mucce.pszID = id;
			mucce.pszName = name;
			mucce.dwFlags = atoi(flags);
			CallService(MS_MUCC_EVENT, 0, (LPARAM) &mucce);
			mir_free(id);
			mir_free(name);
		}
	}
}


typedef struct {
    TlenProtocol *proto;
    char *roomId;  
} MUCSENDQUERYTHREADDATA;

static void __cdecl TlenMUCCSendQueryResultThread(void *ptr)
{
	HANDLE hContact;
	MUCCQUERYRESULT queryResult;
	DBVARIANT dbv;
    MUCSENDQUERYTHREADDATA* threadData = (MUCSENDQUERYTHREADDATA*)ptr;
	queryResult.cbSize = sizeof (MUCCQUERYRESULT);
	queryResult.iType = MUCC_EVENT_QUERY_CONTACTS;
	queryResult.pszModule = threadData->proto->iface.m_szModuleName;
	queryResult.pszParent = threadData->roomId;
	queryResult.iItemsNum = 0;
	hContact = (HANDLE) CallService(MS_DB_CONTACT_FINDFIRST, 0, 0);
	while (hContact != NULL) {
		char *str = (char *) CallService(MS_PROTO_GETCONTACTBASEPROTO, (WPARAM) hContact, 0);
		if(str!=NULL && !strcmp(str, threadData->proto->iface.m_szModuleName)) {
			if (!DBGetContactSettingByte(hContact, threadData->proto->iface.m_szModuleName, "bChat", FALSE)) {
				if (!DBGetContactSetting(hContact, threadData->proto->iface.m_szModuleName, "jid", &dbv)) {
					if (strcmp(dbv.pszVal, "b73@tlen.pl")) {
						queryResult.iItemsNum++;
					}
					DBFreeVariant(&dbv);
				}
			}
		}
		hContact = (HANDLE) CallService(MS_DB_CONTACT_FINDNEXT, (WPARAM) hContact, 0);
	}
	queryResult.pItems = mir_alloc(sizeof(MUCCQUERYITEM) * queryResult.iItemsNum);
	memset(queryResult.pItems, 0, sizeof(MUCCQUERYITEM) * queryResult.iItemsNum);
	queryResult.iItemsNum = 0;
	hContact = (HANDLE) CallService(MS_DB_CONTACT_FINDFIRST, 0, 0);
	while (hContact != NULL) {
		char *baseProto = (char *) CallService(MS_PROTO_GETCONTACTBASEPROTO, (WPARAM) hContact, 0);
		if(baseProto!=NULL && !strcmp(baseProto, threadData->proto->iface.m_szModuleName)) {
			if (!DBGetContactSettingByte(hContact, threadData->proto->iface.m_szModuleName, "bChat", FALSE)) {
				if (!DBGetContactSetting(hContact, threadData->proto->iface.m_szModuleName, "jid", &dbv)) {
					if (strcmp(dbv.pszVal, "b73@tlen.pl")) {
						queryResult.pItems[queryResult.iItemsNum].pszID = mir_strdup(dbv.pszVal);
						queryResult.pItems[queryResult.iItemsNum].pszName = mir_strdup((char *) CallService(MS_CLIST_GETCONTACTDISPLAYNAME, (WPARAM) hContact, 0));
						queryResult.iItemsNum++;
					}
					DBFreeVariant(&dbv);
				}
			}
		}
		hContact = (HANDLE) CallService(MS_DB_CONTACT_FINDNEXT, (WPARAM) hContact, 0);
	}
	CallService(MS_MUCC_QUERY_RESULT, 0, (LPARAM) &queryResult);
	TlenMUCFreeQueryResult(&queryResult);
	mir_free(threadData->roomId);
    mir_free(threadData);
}


static int TlenMUCQueryContacts(TlenProtocol *proto, const char *roomId) {
    
    MUCSENDQUERYTHREADDATA *threadData = (MUCSENDQUERYTHREADDATA *)mir_alloc(sizeof(MUCSENDQUERYTHREADDATA));
    threadData->proto = proto;
    threadData->roomId = mir_strdup(roomId);
	JabberForkThread(TlenMUCCSendQueryResultThread, 0, (void *)threadData);
	return 1;
}


INT_PTR TlenMUCMenuHandleMUC(void *ptr, WPARAM wParam, LPARAM lParam)
{
	TlenProtocol *proto = (TlenProtocol *)ptr;
	if (!proto->isOnline) {
		return 1;
	}
	JabberSend(proto, "<p to='c' tp='c' id='"JABBER_IQID"%d'/>", JabberSerialNext(proto));
	/*
	MUCCEVENT *mucce;
	mucce = (MUCCEVENT *) mir_alloc (sizeof(MUCCEVENT));
	mucce->cbSize = sizeof(MUCCEVENT);
	mucce->iType = MUCC_EVENT_JOIN;
	mucce->dwFlags = 0;
	mucce->pszModule = iface.m_szModuleName;
	mucce->pszID = NULL;
	mucce->pszName = NULL;
	mucce->pszNick = NULL;
	CallService(MS_MUCC_EVENT, 0, (LPARAM) mucce);
	mir_free(mucce);
	*/
	return 0;
}

INT_PTR TlenMUCMenuHandleChats(void *ptr, WPARAM wParam, LPARAM lParam)
{
	MUCCWINDOW mucw;
	TlenProtocol *proto = (TlenProtocol *)ptr;
	if (!proto->isOnline) {
		return 1;
	}
	mucw.cbSize = sizeof(MUCCWINDOW);
	mucw.iType = MUCC_WINDOW_CHATLIST;
	mucw.pszModule = proto->iface.m_szModuleName;
	mucw.pszModuleName = proto->iface.m_szProtoName;
	CallService(MS_MUCC_NEW_WINDOW, 0, (LPARAM) &mucw);
	return 0;
}

INT_PTR TlenMUCContactMenuHandleMUC(void *ptr, WPARAM wParam, LPARAM lParam)
{
	HANDLE hContact;
	DBVARIANT dbv;
	JABBER_LIST_ITEM *item;
	TlenProtocol *proto = (TlenProtocol *)ptr;
	if (!proto->isOnline) {
		return 1;
	}
	if ((hContact=(HANDLE) wParam)!=NULL && proto->isOnline) {
		if (!DBGetContactSetting(hContact, proto->iface.m_szModuleName, "jid", &dbv)) {
			char serialId[32];
			sprintf(serialId, JABBER_IQID"%d", JabberSerialNext(proto));
			item = JabberListAdd(proto, LIST_INVITATIONS, serialId);
			item->nick = mir_strdup(dbv.pszVal);
			JabberSend(proto, "<p to='c' tp='c' id='%s'/>", serialId);
			DBFreeVariant(&dbv);
		}
	}
	return 0;
}