//-----------------------------------------------------------------------------
//
//	ValueStore.cpp
//
//	Container for Value objects
//
//	Copyright (c) 2010 Mal Lansell <openzwave@lansell.org>
//
//	SOFTWARE NOTICE AND LICENSE
//
//	This file is part of OpenZWave.
//
//	OpenZWave 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, either version 3 of the License,
//	or (at your option) any later version.
//
//	OpenZWave 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 OpenZWave.  If not, see <http://www.gnu.org/licenses/>.
//
//-----------------------------------------------------------------------------

#include "value_classes/ValueStore.h"
#include "value_classes/Value.h"
#include "Manager.h"
#include "Notification.h"
#include "Localization.h"
#include "platform/Log.h"

namespace OpenZWave
{
	namespace Internal
	{
		namespace VC
		{

//-----------------------------------------------------------------------------
// <ValueStore::ValueStore>
// Destructor
//-----------------------------------------------------------------------------
			ValueStore::~ValueStore()
			{
				map<uint32, Value*>::iterator it = m_values.begin();
				while (!m_values.empty())
				{
					ValueID const& valueId = it->second->GetID();
					RemoveValue(valueId.GetValueStoreKey());
					it = m_values.begin();
				}
			}

//-----------------------------------------------------------------------------
// <ValueStore::AddValue>
// Add a value to the store
//-----------------------------------------------------------------------------
			bool ValueStore::AddValue(Value* _value)
			{
				if (!_value)
				{
					return false;
				}

				uint32 key = _value->GetID().GetValueStoreKey();
				map<uint32, Value*>::iterator it = m_values.find(key);
				if (it != m_values.end())
				{
					// There is already a value in the store with this key, so we give up.
					return false;
				}

				m_values[key] = _value;
				_value->AddRef();

				// Notify the watchers of the new value and Check our GetChangeVerified Flag
				if (Driver* driver = Manager::Get()->GetDriver(_value->GetID().GetHomeId()))
				{
					Node *node = driver->GetNodeUnsafe(_value->GetID().GetNodeId());
					if (node) {
						Internal::CC::CommandClass *cc = node->GetCommandClass(_value->GetID().GetCommandClassId());
						if (cc) {
							if (cc->m_com.GetFlagBool(COMPAT_FLAG_VERIFYCHANGED, _value->GetID().GetIndex())) {
								Log::Write(LogLevel_Info, _value->GetID().GetNodeId(), "Setting VerifiedChanged Flag on Value %d for CC %s", _value->GetID().GetIndex(), cc->GetCommandClassName().c_str());
								_value->SetChangeVerified(true);
							}
							if (cc->m_com.GetFlagBool(COMPAT_FLAG_NO_REFRESH_AFTER_SET, _value->GetID().GetIndex())) {
								Log::Write(LogLevel_Info, _value->GetID().GetNodeId(), "Setting NoRefreshAfterSet Flag on Value %d for CC %s", _value->GetID().GetIndex(), cc->GetCommandClassName().c_str());
								_value->SetRefreshAfterSet(false);
							}
						}
					}
					Notification* notification = new Notification(Notification::Type_ValueAdded);
					notification->SetValueId(_value->GetID());
					driver->QueueNotification(notification);
				}

				return true;
			}

//-----------------------------------------------------------------------------
// <ValueStore::RemoveValue>
// Remove a value from the store
//-----------------------------------------------------------------------------
			bool ValueStore::RemoveValue(uint32 const& _key)
			{
				map<uint32, Value*>::iterator it = m_values.find(_key);
				if (it != m_values.end())
				{
					Value* value = it->second;
					ValueID const& valueId = value->GetID();

					// First notify the watchers
					if (Driver* driver = Manager::Get()->GetDriver(valueId.GetHomeId()))
					{
						Notification* notification = new Notification(Notification::Type_ValueRemoved);
						notification->SetValueId(valueId);
						driver->QueueNotification(notification);
					}

					// Now release and remove the value from the store
					int32 references = value->Release();
					if (references > 0)
						Log::Write(LogLevel_Warning, "Value Not Deleted - Still in use %d times: CC: %d - %s - %s - %d", references, valueId.GetCommandClassId(), valueId.GetTypeAsString().c_str(), value->GetLabel().c_str(), value->GetID());
					else
						Log::Write(LogLevel_Debug, "Value Deleted");
					m_values.erase(it);

					return true;
				}

				// Value not found in the store
				return false;
			}

////-----------------------------------------------------------------------------
//// <ValueStore::RemoveValue>
//// Remove a value from the store
////-----------------------------------------------------------------------------
//bool ValueStore::RemoveValue
//(
//	ValueID const& _id
//)

//-----------------------------------------------------------------------------
// <ValueStore::RemoveCommandClassValues>
// Remove all the values associated with a command class from the store
//-----------------------------------------------------------------------------
			void ValueStore::RemoveCommandClassValues(uint8 const _commandClassId)
			{
				map<uint32, Value*>::iterator it = m_values.begin();
				while (it != m_values.end())
				{
					Value* value = it->second;
					ValueID const& valueId = value->GetID();
					if (_commandClassId == valueId.GetCommandClassId())
					{
						// The value belongs to the specified command class

						// First notify the watchers
						if (Driver* driver = Manager::Get()->GetDriver(valueId.GetHomeId()))
						{
							Notification* notification = new Notification(Notification::Type_ValueRemoved);
							notification->SetValueId(valueId);
							driver->QueueNotification(notification);
						}

						// Now release and remove the value from the store
						value->Release();
						it = m_values.erase(it);
					}
					else
					{
						++it;
					}
				}
			}

//-----------------------------------------------------------------------------
// <ValueStore::GetValue>
// Get a value from the store
//-----------------------------------------------------------------------------
			Value* ValueStore::GetValue(uint32 const& _key) const
			{
				Value* value = NULL;

				map<uint32, Value*>::const_iterator it = m_values.find(_key);
				if (it != m_values.end())
				{
					value = it->second;
					if (value)
					{
						// Add a reference to the value.  The caller must
						// call Release on the value when they are done with it.
						value->AddRef();
					}
				}

				return value;
			}

		} // namespace VC
	} // namespace Internal
} // namespace OpenZWave