/** 
* @file llpersistentnotificationstorage.cpp
* @brief Implementation of llpersistentnotificationstorage
* @author Stinson@lindenlab.com
*
* $LicenseInfo:firstyear=2012&license=viewerlgpl$
* Second Life Viewer Source Code
* Copyright (C) 2012, Linden Research, Inc.
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation;
* version 2.1 of the License only.
*
* This library 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
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
*
* Linden Research, Inc., 945 Battery Street, San Francisco, CA  94111  USA
* $/LicenseInfo$
*/


#include "llviewerprecompiledheaders.h"

#include "llpersistentnotificationstorage.h"

#include "llchannelmanager.h"
#include "llnotificationstorage.h"
#include "llscreenchannel.h"
#include "llscriptfloater.h"
#include "llviewermessage.h"

class LLResponderRegistry
{
public:

	static void registerResponders();

	static LLNotificationResponderInterface* createResponder(const std::string& notification_name, const LLSD& params);

protected:

private:
	template<typename RESPONDER_TYPE>
	static LLNotificationResponderInterface* create(const LLSD& params)
	{
		RESPONDER_TYPE* responder = new RESPONDER_TYPE();
		responder->fromLLSD(params);
		return responder;
	}

	typedef boost::function<LLNotificationResponderInterface* (const LLSD& params)> responder_constructor_t;

	static void add(const std::string& notification_name, const responder_constructor_t& ctr);

	typedef std::map<std::string, responder_constructor_t> build_map_t;

	static build_map_t sBuildMap;
};

LLPersistentNotificationStorage::LLPersistentNotificationStorage()
	: LLSingleton<LLPersistentNotificationStorage>()
	, LLNotificationStorage(gDirUtilp->getExpandedFilename(LL_PATH_PER_SL_ACCOUNT, "open_notifications.xml"))
{
}

LLPersistentNotificationStorage::~LLPersistentNotificationStorage()
{
}

static LLFastTimer::DeclareTimer FTM_SAVE_NOTIFICATIONS("Save Notifications");

void LLPersistentNotificationStorage::saveNotifications()
{
	LLFastTimer _(FTM_SAVE_NOTIFICATIONS);

	boost::intrusive_ptr<LLPersistentNotificationChannel> history_channel = boost::dynamic_pointer_cast<LLPersistentNotificationChannel>(LLNotifications::instance().getChannel("Persistent"));
	if (!history_channel)
	{
		return;
	}

	LLSD output = LLSD::emptyMap();
	LLSD& data = output["data"];

	for ( std::vector<LLNotificationPtr>::iterator it = history_channel->beginHistory(), end_it = history_channel->endHistory();
		it != end_it;
		++it)
	{
		LLNotificationPtr notification = *it;

		// After a notification was placed in Persist channel, it can become
		// responded, expired or canceled - in this case we are should not save it
		if(notification->isRespondedTo() || notification->isCancelled()
			|| notification->isExpired())
		{
			continue;
		}

		data.append(notification->asLLSD());
	}

	writeNotifications(output);
}

static LLFastTimer::DeclareTimer FTM_LOAD_NOTIFICATIONS("Load Notifications");

void LLPersistentNotificationStorage::loadNotifications()
{
	LLFastTimer _(FTM_LOAD_NOTIFICATIONS);
	LLResponderRegistry::registerResponders();

	LLNotifications::instance().getChannel("Persistent")->
		connectChanged(boost::bind(&LLPersistentNotificationStorage::onPersistentChannelChanged, this, _1));

	LLSD input;
	if (!readNotifications(input) ||input.isUndefined())
	{
		return;
	}

	LLSD& data = input["data"];
	if (data.isUndefined())
	{
		return;
	}

	using namespace LLNotificationsUI;
	LLScreenChannel* notification_channel = dynamic_cast<LLScreenChannel*>(LLChannelManager::getInstance()->
		findChannelByID(LLUUID(gSavedSettings.getString("NotificationChannelUUID"))));

	LLNotifications& instance = LLNotifications::instance();

	for (LLSD::array_const_iterator notification_it = data.beginArray();
		notification_it != data.endArray();
		++notification_it)
	{
		LLSD notification_params = *notification_it;
		LLNotificationPtr notification(new LLNotification(notification_params));

		LLNotificationResponderPtr responder(LLResponderRegistry::
			createResponder(notification_params["name"], notification_params["responder"]));
		notification->setResponseFunctor(responder);

		instance.add(notification);

		// hide script floaters so they don't confuse the user and don't overlap startup toast
		LLScriptFloaterManager::getInstance()->setFloaterVisible(notification->getID(), false);

		if(notification_channel)
		{
			// hide saved toasts so they don't confuse the user
			notification_channel->hideToast(notification->getID());
		}
	}
}

bool LLPersistentNotificationStorage::onPersistentChannelChanged(const LLSD& payload)
{
	// we ignore "load" messages, but rewrite the persistence file on any other
	const std::string sigtype = payload["sigtype"].asString();
	if ("load" != sigtype)
	{
		saveNotifications();
	}
	return false;
}

//////////////////////////////////////////////////////////////////////////
//////////////////////////////////////////////////////////////////////////
//////////////////////////////////////////////////////////////////////////

LLResponderRegistry::build_map_t LLResponderRegistry::sBuildMap;

void LLResponderRegistry::registerResponders()
{
	sBuildMap.clear();

	add("ObjectGiveItem", &create<LLOfferInfo>);
	add("UserGiveItem", &create<LLOfferInfo>);
}

LLNotificationResponderInterface* LLResponderRegistry::createResponder(const std::string& notification_name, const LLSD& params)
{
	build_map_t::const_iterator it = sBuildMap.find(notification_name);
	if(sBuildMap.end() == it)
	{
		return NULL;
	}
	responder_constructor_t ctr = it->second;
	return ctr(params);
}

void LLResponderRegistry::add(const std::string& notification_name, const responder_constructor_t& ctr)
{
	if(sBuildMap.find(notification_name) != sBuildMap.end())
	{
		llwarns << "Responder is already registered : " << notification_name << llendl;
		llassert(!"Responder already registered");
	}
	sBuildMap[notification_name] = ctr;
}

// EOF