/* libobby - Network text editing library
 * Copyright (C) 2005, 2006 0x539 dev group
 *
 * 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., 675 Mass Ave, Cambridge, MA 02139, USA.
 */

#include "jupiter_server.hpp"

#if 0
obby::jupiter_server::jupiter_server(document& doc)
 : m_document(doc), m_undo(doc)
{
}

obby::jupiter_server::~jupiter_server()
{
	for(client_map::iterator iter = m_clients.begin();
	    iter != m_clients.end();
	    ++ iter)
	{
		delete iter->second;
	}
}

void obby::jupiter_server::client_add(const user& client)
{
	if(m_clients.find(&client) != m_clients.end() )
		throw std::logic_error("obby::jupiter_server::client_add");

	m_clients[&client] = new jupiter_algorithm;
}

void obby::jupiter_server::client_remove(const user& client)
{
	client_map::iterator iter = m_clients.find(&client);
	if(iter == m_clients.end() )
		throw std::logic_error("obby::jupiter_server::client_remove");

	delete iter->second;
	m_clients.erase(iter);
}

void obby::jupiter_server::local_op(const operation& op, const user* from)
{
	// Apply locally
	op.apply(m_document, from);
	// Tell undo manager
	m_undo.local_op(op, from);
	// Delegate to clients
	for(client_map::iterator iter = m_clients.begin();
	    iter != m_clients.end();
	    ++ iter)
	{
		// Get resulting record
		std::auto_ptr<record> rec = iter->second->local_op(op);
		// Emit corresponding signal
		m_signal_record.emit(*rec, *iter->first, from);
	}
}

void obby::jupiter_server::remote_op(const record& rec, const user* from)
{
	// Find client from which the record comes from
	client_map::iterator iter = m_clients.find(from);
	if(iter == m_clients.end() )
		throw std::logic_error("obby::jupiter_server::remote_op");

	// Transform operation
	std::auto_ptr<operation> op = iter->second->remote_op(rec);
	// Apply to local document
	op->apply(m_document, from);
	// Tell undo manager
	m_undo.remote_op(*op, from);

	// Delegate to other clients
	for(iter = m_clients.begin(); iter != m_clients.end(); ++ iter)
	{
		// Not the client who sent the record
		if(iter->first != from)
		{
			// Generate record for this client
			std::auto_ptr<record> rec = iter->second->local_op(*op);
			// Emit remote signal
			m_signal_record.emit(*rec, *iter->first, from);
		}
	}
}

void obby::jupiter_server::undo_op(const user* from)
{
	// Get operatioln from undo manager
	std::auto_ptr<operation> op = m_undo.undo();
	// Apply locally
	op->apply(m_document, from);
	// Delegate to clients
	for(client_map::iterator iter = m_clients.begin();
	    iter != m_clients.end();
	    ++ iter)
	{
		// Get resulting record
		std::auto_ptr<record> rec = iter->second->local_op(*op);
		// Emit corresponding signal
		m_signal_record.emit(*rec, *iter->first, from);
	}
}

obby::jupiter_server::signal_record_type
obby::jupiter_server::record_event() const
{
	return m_signal_record;
}
#endif