/* -*- mode: C++; tab-width: 4; c-basic-offset: 4; -*- */

/* AbiCollab- Code to enable the modification of remote documents.
 * Copyright (C) 2005 by Martin Sevior
 * Copyright (C) 2006,2007 by Marc Maurer <uwog@uwog.net>
 * Copyright (C) 2007 by One Laptop Per Child
 * Copyright (C) 2008-2009 by AbiSource Corporation B.V.
 *
 * 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 <string>

#include "ut_assert.h"
#include "ut_debugmsg.h"
#include "xap_App.h"
#include "xap_Frame.h"
#include "fv_View.h"
#include "xav_View.h"
#include "xav_Listener.h"
#include "fl_BlockLayout.h"
#include "pd_Document.h"
#include "ie_types.h"
#include "ev_Mouse.h"
#include "ut_types.h"
#include "ut_misc.h"
#include "ut_units.h"
#include "ap_Strings.h"
#include "xap_Prefs.h"
#include "ap_Frame.h"
#include "ut_path.h"

#ifdef WIN32
#define WIN32_LEAN_AND_MEAN
#include <windows.h>
#endif

#include <account/xp/AccountHandler.h>
#include <account/xp/Buddy.h>
#include <account/xp/SessionEvent.h>

#include <packet/xp/AbiCollab_Packet.h>

#include <plugin/xp/AbiCollab_Command.h>

#include "AbiCollab_Export.h"
#include "AbiCollab_Import.h"
#include "AbiCollab.h"
#include "AbiCollabSessionManager.h"
#include "DiskSessionRecorder.h"

ChangeAdjust::ChangeAdjust(const AbstractChangeRecordSessionPacket& packet, PT_DocPosition iRemoteDocPos, const UT_UTF8String& sRemoteDocUUID) 
	: m_pPacket(static_cast<const AbstractChangeRecordSessionPacket*>(packet.clone())),
	m_iLocalPos( m_pPacket->getPos() ),
	m_iRemoteDocPos(iRemoteDocPos),
	m_sRemoteDocUUID(sRemoteDocUUID)
{
}

ChangeAdjust::~ChangeAdjust()
{
	DELETEP(m_pPacket);
}

// Use this constructor to host a collaboration session
AbiCollab::AbiCollab(PD_Document* pDoc, 
						const UT_UTF8String& sSessionId, 
						AccountHandler* pAclAccount,
						bool bLocallyOwned)
	: EV_MouseListener(),
	m_pDoc(pDoc),
	m_Import(this, pDoc),
	m_Export(this, pDoc),
	m_pAclAccount(pAclAccount),
	m_iDocListenerId(0),
	m_bExportMasked(false),
	m_sId(sSessionId),
	m_pController(BuddyPtr()),
	m_bLocallyOwned(bLocallyOwned),
	m_pActivePacket(NULL),
	m_bIsReverting(false),
	m_pRecorder(NULL),
	m_bDoingMouseDrag(false),
	m_eTakeoveState(STS_NONE),
	m_bProposedController(false),
	m_pProposedController(BuddyPtr()),
	m_bSessionFlushed(false)
{
	// TODO: this can be made a lil' more efficient, as setDocument
	// will create import and export listeners, which is kinda useless
	// when there is no single collaborator yet
	_setDocument(pDoc);
	
	m_Import.masterInit();
	m_Export.masterInit();

#ifdef ABICOLLAB_RECORD_ALWAYS
	startRecording( new DiskSessionRecorder( this ) );
#endif
}

// Use this constructor to join a collaboration session
AbiCollab::AbiCollab(const UT_UTF8String& sSessionId,
						PD_Document* pDoc, 
						const UT_UTF8String& docUUID, 
						UT_sint32 iRev, 
						BuddyPtr pController,
						AccountHandler* pAclAccount,
						bool bLocallyOwned)
	: EV_MouseListener(),
	m_pDoc(pDoc),
	m_Import(this, pDoc),
	m_Export(this, pDoc),
	m_pAclAccount(pAclAccount),
	m_iDocListenerId(0),
	m_bExportMasked(false),
	m_sId(sSessionId),
	m_pController(pController),
	m_bLocallyOwned(bLocallyOwned),
	m_pActivePacket(NULL),
	m_bIsReverting(false),
	m_pRecorder(NULL),
	m_bDoingMouseDrag(false),
	m_eTakeoveState(STS_NONE),
	m_bProposedController(false),
	m_pProposedController(BuddyPtr()),
	m_bSessionFlushed(false)
{
	// TODO: this can be made a lil' more efficient, as setDocument
	// will create import and export listeners, which is kinda useless
	// when there is no single collaborator yet
	_setDocument(pDoc);

	m_Import.slaveInit(pController, iRev);
	m_Export.slaveInit(docUUID, iRev);

	// we will manually have to coalesce changerecords, as we will need
	// to be able to revert every individual changerecord for 
	// collision handling if the session controller tells us too
	pDoc->setCoalescingMask(true);

	addCollaborator(pController);
	
#ifdef ABICOLLAB_RECORD_ALWAYS
	startRecording( new DiskSessionRecorder( this ) );
#endif
}

AbiCollab::~AbiCollab(void)
{
	UT_DEBUGMSG(("AbiCollab::~AbiCollab()\n"));
	
	for (std::map<EV_Mouse*, UT_sint32>::iterator cit = m_mMouseListenerIds.begin(); cit != m_mMouseListenerIds.end(); cit++)
	{
		EV_Mouse* pMouse = (*cit).first;
		UT_sint32 iListenerId = (*cit).second;
		pMouse->unregisterListener(iListenerId);
	}
	m_mMouseListenerIds.clear();
	
	if (m_iDocListenerId != 0)
		m_pDoc->removeListener(m_iDocListenerId);
	m_iDocListenerId = 0;

	DELETEP(m_pRecorder);
}

void AbiCollab::removeCollaborator(BuddyPtr pCollaborator)
{
	UT_return_if_fail(pCollaborator);

	std::map<BuddyPtr, std::string>::iterator nit;
	for (std::map<BuddyPtr, std::string>::iterator it = m_vCollaborators.begin(); it != m_vCollaborators.end(); it = nit)
	{
		nit = it;
		nit++;
		
		BuddyPtr pBuddy = (*it).first;
		UT_continue_if_fail(pBuddy);
		if (pBuddy == pCollaborator)
		{
			_removeCollaborator(pBuddy, (*it).second);
			m_vCollaborators.erase(it);
		}
	}

	// check if we need to revoke the access rights of this collaborator; if so,
	// then his rights are revoked
	_checkRevokeAccess(pCollaborator);
}

void AbiCollab::_removeCollaborator(BuddyPtr pCollaborator, const std::string& docUUID)
{
	UT_DEBUGMSG(("AbiCollab::_removeCollaborator()\n"));
	UT_return_if_fail(pCollaborator);
	UT_return_if_fail(m_pDoc);

	// TODO: signal the removal of the buddy!!!
	// ...
	
	// remove this buddy from the import 'seen revision list'
	m_Import.getRemoteRevisions()[pCollaborator] = 0;

	// remove the caret belonging to this buddy
	m_pDoc->removeCaret(docUUID.c_str());
}

void AbiCollab::_checkRevokeAccess(BuddyPtr pCollaborator)
{
	UT_DEBUGMSG(("AbiCollab::_checkRevokeAccess()\n"));
	UT_return_if_fail(pCollaborator);
	UT_return_if_fail(isLocallyControlled());
	UT_return_if_fail(m_pAclAccount);

	// remove this buddy from the access control list if his access rights
	// are not persistent
	if (!pCollaborator->getHandler()->hasPersistentAccessControl())
	{
		for (std::vector<std::string>::iterator it = m_vAcl.begin(); it != m_vAcl.end(); it++)
		{
			if (pCollaborator->getDescriptor(false) == (*it))
			{
				UT_DEBUGMSG(("Dropping %s from the ACL\n", (*it).c_str()));
				m_vAcl.erase(it);
				break;
			}
		}
	}
}

void AbiCollab::addCollaborator(BuddyPtr pCollaborator)
{
	UT_DEBUGMSG(("AbiCollab::addCollaborator()\n"));
	UT_return_if_fail(pCollaborator)
	
	// check if this buddy is in the access control list if we are hosting 
	// this session
	if (isLocallyControlled())
	{
		AccountHandler* pAccount = pCollaborator->getHandler();
		UT_return_if_fail(pAccount);
		if (!pAccount->hasAccess(m_vAcl, pCollaborator))
		{
			UT_ASSERT(UT_NOT_IMPLEMENTED);
			return;
		}
	}
		
	// check for duplicates (as long as we assume a collaborator can only be part of a collaboration session once)
	std::map<BuddyPtr, std::string>::iterator it = m_vCollaborators.find(pCollaborator);
	if (it != m_vCollaborators.end())
	{
		UT_DEBUGMSG(("Attempting to add buddy '%s' twice to a collaboration session!", pCollaborator->getDescription().utf8_str()));
		UT_ASSERT_HARMLESS(UT_SHOULD_NOT_HAPPEN);
		return;
	}

	m_vCollaborators[pCollaborator] = ""; // will fill the remote document UUID later once we receive a packet from this buddy
}

void AbiCollab::setAcl(const std::vector<std::string> vAcl)
{
	UT_DEBUGMSG(("AbiCollab::setAcl()\n"));
	m_vAcl = vAcl;
}

void AbiCollab::_setDocument(PD_Document* pDoc)
{
	UT_DEBUGMSG(("AbiCollab::setDocument()\n"));
	UT_return_if_fail(pDoc);

	AbiCollabSessionManager* pManager = AbiCollabSessionManager::getManager();
	UT_return_if_fail(pManager);

	// assume clean state
	UT_return_if_fail(m_iDocListenerId==0);
	m_pDoc = pDoc;

	// register ourselves as a mouse listener to all frames showing this document
	for (UT_sint32 i = 0; i < XAP_App::getApp()->getFrameCount(); i++)
	{
		XAP_Frame* pFrame = XAP_App::getApp()->getFrame(i);
		UT_continue_if_fail(pFrame);

		if (pFrame->getCurrentDoc() == m_pDoc)
		{
			// this frame is showing our document, attach a mouse listener to it
			EV_Mouse* pMouse = pFrame->getMouse();
			if (pMouse)
				m_mMouseListenerIds[pMouse] = pMouse->registerListener(this);
		}
	}

	// add the new export listeners
	UT_uint32 lid = 0;
	pDoc->addListener(static_cast<PL_Listener *>(&m_Export), &lid);
	_setDocListenerId(lid);
	UT_DEBUGMSG(("Added document listener %d\n", lid));
}

void AbiCollab::_fillRemoteRev(Packet* pPacket, BuddyPtr pBuddy)
{
	UT_return_if_fail(pPacket);
	UT_return_if_fail(pBuddy);
	
	if (pPacket->getClassType() >= _PCT_FirstChangeRecord && pPacket->getClassType() <= _PCT_LastChangeRecord)
	{
		ChangeRecordSessionPacket* pSessionPacket = static_cast<ChangeRecordSessionPacket*>(pPacket);
		pSessionPacket->setRemoteRev(m_Import.getRemoteRevisions()[pBuddy]);
	}
	else if (pPacket->getClassType() == PCT_GlobSessionPacket)
	{
		GlobSessionPacket* pSessionPacket = static_cast<GlobSessionPacket*>(pPacket);
		const std::vector<SessionPacket*>& globPackets = pSessionPacket->getPackets();
		for (std::vector<SessionPacket*>::const_iterator cit = globPackets.begin(); cit != globPackets.end(); cit++)
		{
			SessionPacket* globPacket = *cit;
			UT_continue_if_fail(globPacket);
			_fillRemoteRev(globPacket, pBuddy);
		}
	}
}

/*!
 *	Send this packet. Note, the specified packet does still belong to the calling class.
 *	So if we want to store it (for masking), we HAVE to clone it first
 */
void AbiCollab::push(SessionPacket* pPacket)
{
	UT_DEBUGMSG(("AbiCollab::push()\n"));
	UT_return_if_fail(pPacket);

	if (m_bIsReverting)
	{
		UT_DEBUGMSG(("This packet was generated by a local revert triggerd in the import; dropping on the floor!\n"));
		return;
	}

	if (m_bExportMasked)
	{
		m_vecMaskedPackets.push_back(static_cast<SessionPacket*>(pPacket->clone())); // TODO: make this a shared ptr, so we don't need to clone the packet
		return;
	}

	if (!isLocallyControlled() && m_eTakeoveState != STS_NONE)
	{
		// TODO: revert ack packets should still go to old master
		// (or be dropped on the floor, as he probably is not even around anymore)
		UT_DEBUGMSG(("We're in the middle of a session takeover; holding on to the packet until the new master is ready"));
		m_vOutgoingQueue.push_back(static_cast<SessionPacket*>(pPacket->clone())); // TODO: make this a shared ptr, so we don't need to clone the packet
		return;
	}

	// record
	if (m_pRecorder)
		m_pRecorder->storeOutgoing( const_cast<const SessionPacket*>( pPacket ) );
		
	// TODO: this could go in the session manager
	UT_DEBUGMSG(("Pusing packet to %d collaborators\n", m_vCollaborators.size()));
	for (std::map<BuddyPtr, std::string>::iterator it = m_vCollaborators.begin(); it != m_vCollaborators.end(); it++)
	{
		BuddyPtr pCollaborator = (*it).first;
		UT_continue_if_fail(pCollaborator);

		UT_DEBUGMSG(("Pushing packet to collaborator with descriptor: %s\n", pCollaborator->getDescriptor(true).utf8_str()));
		AccountHandler* pHandler = pCollaborator->getHandler();
		UT_continue_if_fail(pHandler);

		// overwrite remote revision for this collaborator
		_fillRemoteRev(pPacket, pCollaborator);
		
		// send!
		bool res = pHandler->send(pPacket, pCollaborator);
		if (!res)
		{
			UT_DEBUGMSG(("Error sending a packet!\n"));
		}
	}
}

bool AbiCollab::push(SessionPacket* pPacket, BuddyPtr collaborator)
{
	UT_return_val_if_fail(pPacket, false);
	UT_return_val_if_fail(collaborator, false);
	AccountHandler* pHandler = collaborator->getHandler();
	UT_return_val_if_fail(pHandler, false);
	
	// record
	if (m_pRecorder)
		m_pRecorder->storeOutgoing(const_cast<const SessionPacket*>( pPacket ), collaborator);

	// overwrite remote revision for this collaborator
	_fillRemoteRev(pPacket, collaborator);
	
	// send!
	bool res = pHandler->send(pPacket, collaborator);
	if (!res)
	{
		UT_DEBUGMSG(("Error sending a packet to collaborator %s!\n", collaborator->getDescription().utf8_str()));
	}

	return res;
}

void AbiCollab::maskExport()
{
	m_bExportMasked = true;
	m_vecMaskedPackets.clear();
}

const std::vector<SessionPacket*>& AbiCollab::unmaskExport()
{
	m_bExportMasked = false;
	return m_vecMaskedPackets;
}

void AbiCollab::import(SessionPacket* pPacket, BuddyPtr collaborator)
{
	UT_DEBUGMSG(("AbiCollab::import()\n"));
	UT_return_if_fail(pPacket);
	
	if (m_bDoingMouseDrag)
	{
		// we block incoming packets while dragging the mouse; this prevents 
		// scary race conditions from occuring, like importing a 'delete image' packet
		// when you are just dragging said image around
		UT_DEBUGMSG(("We are currently dragging something around; deferring packet import until after the release!\n"));
		m_vIncomingQueue.push_back(
					std::make_pair(static_cast<SessionPacket*>(pPacket->clone()), collaborator));
		return;
	}

	// record the incoming packet
	if (m_pRecorder)
		m_pRecorder->storeIncoming(pPacket, collaborator);

	// execute an alternative packet handling path when this session is being 
	// taken over by another collaborator
	if (AbstractSessionTakeoverPacket::isInstanceOf(*pPacket))
	{
		AbstractSessionTakeoverPacket* astp = static_cast<AbstractSessionTakeoverPacket*>(pPacket);
		bool res = _handleSessionTakeover(astp, collaborator);
		if (!res)
		{
			// TODO: implement/handle an offending collaborator
			UT_ASSERT_HARMLESS(UT_SHOULD_NOT_HAPPEN);
		}
		return;
	}

	/*
	Session packets are only allowed to come in from a collaborator when:

	1. no session takeover is in progress, or 
	2a. if this session is a slave: always
	2b. if this session is a master: until the collaborator has responded to a 
		SessionTakeoverRequest from us with a SessionTakeoverAck packet
	*/

	// TODO: implement/handle an offending collaborator
	UT_return_if_fail(
				(m_eTakeoveState == STS_NONE) ||
				(!isLocallyControlled()) ||
				(isLocallyControlled() && m_eTakeoveState == STS_SENT_TAKEOVER_REQUEST && !_hasAckedSessionTakeover(collaborator))
			);

	// import the packet; note that it might be denied due to collisions
	maskExport();
	if (AbstractChangeRecordSessionPacket::isInstanceOf(*pPacket))
		m_pActivePacket = static_cast<const AbstractChangeRecordSessionPacket*>(pPacket);
	m_vCollaborators[collaborator] = pPacket->getDocUUID().utf8_str(); // FIXME: this is redunant after we set this the first time
	m_Import.import(*pPacket, collaborator);
	m_pActivePacket = NULL;
	const std::vector<SessionPacket*>& maskedPackets = unmaskExport();
	
	if (isLocallyControlled() && maskedPackets.size() > 0)
	{
		UT_DEBUGMSG(("Forwarding message (%u packets) from %s\n", maskedPackets.size(), collaborator->getDescription().utf8_str()));
		
		// It seems we are in the center of a collaboration session.
		// It's our duty to reroute the packets to the other collaborators
		for (std::map<BuddyPtr, std::string>::iterator it = m_vCollaborators.begin(); it != m_vCollaborators.end(); it++)
		{
			// send all masked packets during import to everyone, except to the
			// person who initialy sent us the packet
			BuddyPtr pBuddy = (*it).first;
			UT_continue_if_fail(pBuddy);
			if (pBuddy != collaborator)
			{
				UT_DEBUGMSG(("Forwarding message from %s to %s\n", collaborator->getDescription().utf8_str(), pBuddy->getDescription().utf8_str()));
				for (std::vector<SessionPacket*>::const_iterator cit = maskedPackets.begin(); cit != maskedPackets.end(); cit++)
				{
					SessionPacket* maskedPacket = (*cit);
					push(maskedPacket, pBuddy);
				}
			}
		}
	}
}

void AbiCollab::addChangeAdjust(ChangeAdjust* pAdjust)
{
	UT_return_if_fail(pAdjust);

	if (m_bIsReverting)
	{
		UT_DEBUGMSG(("This changeadjust was generated by a local revert triggerd in the import; dropping on the floor!\n"));
		return;
	}

	m_Export.getAdjusts()->addItem(pAdjust);
}

void AbiCollab::initiateSessionTakeover(BuddyPtr pNewMaster)
{
	UT_return_if_fail(pNewMaster);
	UT_DEBUGMSG(("AbiCollab::initiateSessionTakeover() - pNewMaster: %s\n", pNewMaster->getDescriptor(true).utf8_str()));

	AbiCollabSessionManager* pManager = AbiCollabSessionManager::getManager();
	UT_return_if_fail(pManager);

	// this could lead to us never exiting; add a timeout or something somewhere :)
	pManager->beginAsyncOperation(this);

	// NOTE: we only allow slaves in the session takeover process
	// that are on the same account as the proposed master is. The
	// others are dropped from the session. At least for now.
	// TODO: implement me
	
	// reset any old session takeover state
	m_bProposedController = false;
	m_pProposedController = pNewMaster;
	m_vApprovedReconnectBuddies.clear();
	m_mAckedSessionTakeoverBuddies.clear();
	m_bSessionFlushed = false;
	if (m_vOutgoingQueue.size() > 0)
		UT_ASSERT_HARMLESS(UT_SHOULD_NOT_HAPPEN);
	m_vOutgoingQueue.clear();

	// send a SessionTakeoverRequest packet to the new master
	std::vector<std::string> buddyIdentifiers;
	for (std::map<BuddyPtr, std::string>::iterator it = m_vCollaborators.begin(); it != m_vCollaborators.end(); it++)
	{
		BuddyPtr pBuddy = (*it).first;
		UT_continue_if_fail(pBuddy);
		if (pNewMaster != pBuddy)
			buddyIdentifiers.push_back(pBuddy->getDescriptor(true).utf8_str());
	}
	SessionTakeoverRequestPacket strp_promote(m_sId, m_pDoc->getDocUUIDString(), true, buddyIdentifiers);
	pNewMaster->getHandler()->send(&strp_promote, pNewMaster);

	// send a SessionTakeoverRequest packet to the other slaves (if any)
	buddyIdentifiers.clear();
	buddyIdentifiers.push_back(pNewMaster->getDescriptor(true).utf8_str());
	SessionTakeoverRequestPacket strp_normal(m_sId, m_pDoc->getDocUUIDString(), false, buddyIdentifiers);
	for (std::map<BuddyPtr, std::string>::iterator it = m_vCollaborators.begin(); it != m_vCollaborators.end(); it++)
	{
		BuddyPtr pBuddy = (*it).first;
		UT_continue_if_fail(pBuddy);
		if (pNewMaster != pBuddy)
			pBuddy->getHandler()->send(&strp_normal, pBuddy);
	}

	m_eTakeoveState = STS_SENT_TAKEOVER_REQUEST;
}

void AbiCollab::startRecording( SessionRecorderInterface* pRecorder )
{
	UT_return_if_fail(pRecorder);
	
	const UT_GenericVector<ChangeAdjust *>* pExpAdjusts = m_Export.getAdjusts();
	UT_return_if_fail(pExpAdjusts);

	 // FIXME: fill this properly
	UT_sint32 iAuthorId = -1;
	UT_ASSERT_HARMLESS(UT_NOT_IMPLEMENTED);
	
	// create initial document packet to recorder
	// so the recorder knows the initial state
	// serialize entire document into string
	JoinSessionRequestResponseEvent jsre(getSessionId(), iAuthorId);
	if (AbiCollabSessionManager::serializeDocument(m_pDoc, jsre.m_sZABW, false /* no base64 */) == UT_OK)
	{
		// set more document properties
		if (!isLocallyControlled())
		{
			UT_ASSERT_HARMLESS(pExpAdjusts->getItemCount() > 0);
			jsre.m_iRev = (pExpAdjusts->getItemCount() > 0 ? pExpAdjusts->getNthItem(pExpAdjusts->getItemCount()-1)->getLocalRev() : 0);
		}
		else
			jsre.m_iRev = m_pDoc->getCRNumber();
		jsre.m_sDocumentId = m_pDoc->getDocUUIDString();
		if (m_pDoc->getFilename())
			jsre.m_sDocumentName = UT_go_basename_from_uri(m_pDoc->getFilename());
				
		// store pointer
		m_pRecorder = pRecorder;
		m_pRecorder->storeOutgoing( &jsre );
	}
	else
	{
		UT_ASSERT(UT_SHOULD_NOT_HAPPEN);
	}
}

void AbiCollab::stopRecording()
{
	DELETEP(m_pRecorder);
}

void AbiCollab::signalMouse(EV_EditBits eb, UT_sint32 /*xPos*/, UT_sint32 /*yPos*/)
{
	switch (eb & EV_EMO__MASK__)
	{
		case EV_EMO_DRAG:
			// check if we have at least one mouse button down, otherwise this is just a move:
			// AbiWord's event framework is a bit weird, in that it qualifies a move without
			// any buttons as a mouse drag as well
			switch (eb & EV_EMB__MASK__) 
			{
				case EV_EMB_BUTTON0: // no buttons down, not a real drag
					break;
				default:
					UT_DEBUGMSG(("AbiCollab: Mouse drag!\n"));
					m_bDoingMouseDrag = true;
					break;
			}
			break;
		case EV_EMO_DOUBLEDRAG:
			UT_DEBUGMSG(("AbiCollab: Mouse doubledrag!\n"));
			m_bDoingMouseDrag = true;
			break;
		case EV_EMO_RELEASE:
			UT_DEBUGMSG(("AbiCollab: Mouse drag release\n"));
			_releaseMouseDrag();
			break;
		case EV_EMO_DOUBLERELEASE:
			UT_DEBUGMSG(("AbiCollab: Mouse doubledrag release\n"));
			_releaseMouseDrag();
			break;
	}
}

void AbiCollab::removeMouse(EV_Mouse* pMouse)
{
	UT_return_if_fail(pMouse);
	m_mMouseListenerIds.erase(pMouse);
}

void AbiCollab::_releaseMouseDrag()
{
	m_bDoingMouseDrag = false;

	for (std::vector<std::pair<SessionPacket*, BuddyPtr> >::iterator it = m_vIncomingQueue.begin(); it !=  m_vIncomingQueue.end(); it++)
	{
		std::pair<SessionPacket*, BuddyPtr>& pair = *it;
		UT_continue_if_fail(pair.first && pair.second);
		
		if (pair.first && pair.second)
			import(pair.first, pair.second);

		DELETEP(pair.first);
	}
	m_vIncomingQueue.clear();
}

bool AbiCollab::_handleSessionTakeover(AbstractSessionTakeoverPacket* pPacket, BuddyPtr collaborator)
{
	UT_DEBUGMSG(("AbiCollab::_handleSessionTakeover()\n"));
	UT_return_val_if_fail(pPacket, false);
	UT_return_val_if_fail(collaborator, false);

	AbiCollabSessionManager* pManager = AbiCollabSessionManager::getManager();
	UT_return_val_if_fail(pManager, false);

	switch (m_eTakeoveState)
	{
		case STS_NONE:
			{
				// we only accept a SessionTakeoverRequest or MasterChangeRequest packet
				UT_return_val_if_fail(pPacket->getClassType() == PCT_SessionTakeoverRequestPacket, false);
				// we can only allow such a packet from the controller
				UT_return_val_if_fail(m_pController == collaborator, false);

				// handle the SessionTakeoverRequestPacket packet
				m_pProposedController = BuddyPtr();
				m_vApprovedReconnectBuddies.clear();
				SessionTakeoverRequestPacket* strp = static_cast<SessionTakeoverRequestPacket*>(pPacket);
				m_bProposedController = strp->promote();
				if (m_bProposedController)
				{
					for (std::vector<std::string>::const_iterator cit = strp->getBuddyIdentifiers().begin(); cit != strp->getBuddyIdentifiers().end(); cit++)
						m_vApprovedReconnectBuddies[*cit] = false;
				}
				else
				{
					UT_return_val_if_fail(strp->getBuddyIdentifiers().size() == 1, false);
					BuddyPtr pBuddy = pManager->constructBuddy(strp->getBuddyIdentifiers()[0], collaborator);
					UT_return_val_if_fail(pBuddy, false);
					m_pProposedController = pBuddy;
				}

				// inform the master that we received the takeover request
				SessionTakeoverAckPacket stap(m_sId, m_pDoc->getDocUUIDString());
				collaborator->getHandler()->send(&stap, collaborator);

				m_eTakeoveState = STS_SENT_TAKEOVER_ACK;
				return true;
			}
			return false;
		case STS_SENT_TAKEOVER_REQUEST:
			{
				// we only accept SessionTakeoverAck packets
				UT_return_val_if_fail(pPacket->getClassType() == PCT_SessionTakeoverAckPacket, false);
				// we can only receive SessionTakeoverAck packets when we are the master
				UT_return_val_if_fail(!m_pController, false);
				// we should have a proposed master
				UT_return_val_if_fail(m_pProposedController, false);
				// a slave should only ack once
				UT_return_val_if_fail(!_hasAckedSessionTakeover(collaborator), false);

				// handle the SessionTakeoverAck packet
				m_mAckedSessionTakeoverBuddies[collaborator] = true;

				// check if every slave has acknowledged the session takeover
				// TODO: handle dropouts
				if (m_vCollaborators.size() == 1 ||
					m_mAckedSessionTakeoverBuddies.size() == m_vCollaborators.size())
				{
					// ... our tour of duty is done
					_shutdownAsMaster();
					m_eTakeoveState = STS_NONE;
					return true;
				}
			}

			return true;
		case STS_SENT_TAKEOVER_ACK:
			// we only accept a SessionFlushed or SessionReconnectRequest packet
			UT_return_val_if_fail(
						pPacket->getClassType() == PCT_SessionFlushedPacket ||
						pPacket->getClassType() == PCT_SessionReconnectRequestPacket,
						false
					);

			if (pPacket->getClassType() == PCT_SessionReconnectRequestPacket)
			{
				// we only accept a SessionReconnectRequest when we are the proposed master
				UT_return_val_if_fail(m_bProposedController, false);

				// we only allow an incoming SessionReconnectRequest packet from a buddy 
				// that is in the buddy list we received from the master, and we didn't receive
				// such a packet from him before
				bool allow = false;
				for (std::map<std::string, bool>::iterator it = m_vApprovedReconnectBuddies.begin(); it != m_vApprovedReconnectBuddies.end(); it++)
				{
					// TODO: is it a good idea to compare descriptors with full session information?
					if ((*it).first == collaborator->getDescriptor(true) && (*it).second == false)
					{
						(*it).second = true;
						allow = true;
						break;
					}
				}
				UT_return_val_if_fail(allow, false);

				// handle the SessionReconnectRequest packet
				addCollaborator(collaborator);
				_checkRestartAsMaster();

				return true;
			}
			else if (pPacket->getClassType() == PCT_SessionFlushedPacket)
			{
				// we can only allow a SessionFlushed packet from the controller
				UT_return_val_if_fail(m_pController == collaborator, false);

				// handle the SessionFlushed packet
				m_bSessionFlushed = true;

				if (m_bProposedController)
				{
					// as far we we're concerned now, the old master is dead
					_becomeMaster();

					_checkRestartAsMaster();
					return true;
				}
				else
				{
					// as far we we're concerned now, the old master is dead
					_switchMaster();

					// inform the new master that we want to rejoin the session
					SessionReconnectRequestPacket srrp(m_sId, m_pDoc->getDocUUIDString());
					m_pProposedController->getHandler()->send(&srrp, m_pProposedController);

					m_eTakeoveState = STS_SENT_SESSION_RECONNECT_REQUEST;
				}

				return true;
			}

			return false;
		case STS_SENT_SESSION_RECONNECT_REQUEST:
			{
				// we only accept a SessionReconnectAck packet
				UT_return_val_if_fail(pPacket->getClassType() == PCT_SessionReconnectAckPacket, false);
				// we only accept said packet when we are a slave
				UT_return_val_if_fail(m_pController, false);
				// we only accept said packet when we are not the proposed master
				UT_return_val_if_fail(!m_bProposedController, false);
				// we only accept said packet from the proposed master
				UT_return_val_if_fail(m_pProposedController == collaborator, false);

				// handle the SessionReconnectAck packet
				SessionReconnectAckPacket* srap = static_cast<SessionReconnectAckPacket*>(pPacket);
				// Nuke the current collaboration state, and restart with the
				// given revision from the proposed master
				UT_return_val_if_fail(_restartAsSlave(srap->getDocUUID(), srap->getRev()), false);
			}
			return true;
		default:
			UT_ASSERT_HARMLESS(UT_SHOULD_NOT_HAPPEN);
			break;
	}

	return false;
}

bool AbiCollab::_hasAckedSessionTakeover(BuddyPtr collaborator)
{
	std::map<BuddyPtr, bool>::iterator it = m_mAckedSessionTakeoverBuddies.find(collaborator);
	if (it == m_mAckedSessionTakeoverBuddies.end())
		return false;
	return (*it).second;
}

bool AbiCollab::_allSlavesAckedSessionTakeover()
{
	// FIXME: what happens when someone leaves during the session takeover
	// process? We should probably add a timeout, or some other signal to
	// not make us wait forever
	return (m_vCollaborators.size() == 0) || 
		(m_mAckedSessionTakeoverBuddies.size() == m_vCollaborators.size() - 1 /* the proposed new master should not ack */);
}

void AbiCollab::_switchMaster()
{
	UT_DEBUGMSG(("AbiCollab::_switchMaster()\n"));
	UT_return_if_fail(!m_bProposedController);
	UT_return_if_fail(m_pProposedController);

	m_pController = m_pProposedController;
	m_vCollaborators.clear();
	addCollaborator(m_pController);
}

void AbiCollab::_becomeMaster()
{
	UT_DEBUGMSG(("AbiCollab::_becomeMaster()\n"));
	UT_return_if_fail(m_bProposedController);

	// remove the old master from our buddy list and make ourselves the master
	std::map<BuddyPtr, std::string>::iterator it = m_vCollaborators.find(m_pController);
	if (it != m_vCollaborators.end())
	{
		m_vCollaborators.erase(it);
	}
	else
	{
		UT_ASSERT_HARMLESS(UT_SHOULD_NOT_HAPPEN); // i think ;)
	}
	m_pController = BuddyPtr();
}

bool AbiCollab::_restartAsSlave(const UT_UTF8String& sDocUUID, UT_sint32 iRev)
{
	UT_DEBUGMSG(("AbiCollab::_restartAsSlave() - iRev: %d\n", iRev));
	UT_return_val_if_fail(m_pController, false);

	m_Import.slaveInit(m_pController, iRev);
	m_Export.slaveInit(sDocUUID, iRev);

	m_eTakeoveState = STS_NONE;

	_pushOutgoingQueue();

	return true;
}

void AbiCollab::_shutdownAsMaster()
{
	UT_DEBUGMSG(("AbiCollab::_shutdownAsMaster()\n"));
	UT_return_if_fail(m_pController == BuddyPtr());
	UT_return_if_fail(!m_bProposedController);

	AbiCollabSessionManager* pManager = AbiCollabSessionManager::getManager();
	UT_return_if_fail(pManager);

	// the session takeover is complete; inform everyone that all session data
	// is flushed, and that everyone should talk to the new master from now on
	SessionFlushedPacket sfp(m_sId, m_pDoc->getDocUUIDString());
	for (std::map<BuddyPtr, std::string>::iterator it = m_vCollaborators.begin(); it != m_vCollaborators.end(); it++)
	{
		BuddyPtr pBuddy = (*it).first;
		UT_continue_if_fail(pBuddy);
		pBuddy->getHandler()->send(&sfp, pBuddy);
	}

	// session takeover is done as far as the leaving session contoller is concerned
	pManager->endAsyncOperation(this);
}

bool AbiCollab::_allSlavesReconnected()
{
	UT_DEBUGMSG(("AbiCollab::_allSlavesReconnected()\n"));
	for (std::map<std::string, bool>::const_iterator cit = m_vApprovedReconnectBuddies.begin(); cit != m_vApprovedReconnectBuddies.end(); cit++)
	{
		if (!(*cit).second)
			return false;
	}
	return true;
}

void AbiCollab::_checkRestartAsMaster()
{
	UT_DEBUGMSG(("AbiCollab::_checkRestartAsMaster()\n"));

	// Check if every buddy has reconnected; if not, then we
	// should wait a bit around before restarting as master.
	// If everyone has reconnected AND the master has informed us
	// that the old session is flushed (ie. there won't be coming any
	// ChangeRecords from the old master anymore), then we can restart as master
	// TODO: handle dropouts
	if (m_bSessionFlushed && _allSlavesReconnected())
		_restartAsMaster();
}

void AbiCollab::_restartAsMaster()
{
	UT_DEBUGMSG(("AbiCollab::_restartAsMaster()\n"));

	m_Import.masterInit();
	m_Export.masterInit();

	// the session controller will never have to revert individual changerecords,
	// so we can re-enable changerecord coalescing
	// FIXME: enable this
	//pDoc->setCoalescingMask(true);

	// inform everyone that we can restart this session
	SessionReconnectAckPacket srap(m_sId, m_pDoc->getDocUUIDString(), m_pDoc->getCRNumber());
	for (std::map<BuddyPtr, std::string>::iterator it = m_vCollaborators.begin(); it != m_vCollaborators.end(); it++)
	{
		BuddyPtr pBuddy = (*it).first;
		UT_continue_if_fail(pBuddy);

		AccountHandler* pHandler = pBuddy->getHandler();
		UT_continue_if_fail(pHandler);

		pHandler->send(&srap, pBuddy);
	}

	// we're the master now!
	m_eTakeoveState = STS_NONE;

	_pushOutgoingQueue();
}

void AbiCollab::_pushOutgoingQueue()
{
	UT_DEBUGMSG(("AbiCollab::_pushOutgoingQueue() - %d packets queued\n", m_vOutgoingQueue.size()));

	for (std::vector<SessionPacket*>::iterator it = m_vOutgoingQueue.begin(); it != m_vOutgoingQueue.end(); it++)
		push(*it);

	m_vOutgoingQueue.clear();
}