--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/javaextensions/midprms_db/tsrc/rmsplugin/src/testrmsextensionplugin.cpp	Tue Apr 27 16:30:29 2010 +0300
@@ -0,0 +1,334 @@
+/*
+* Copyright (c) 2010 Nokia Corporation and/or its subsidiary(-ies).
+* All rights reserved.
+* This component and the accompanying materials are made available
+* under the terms of "Eclipse Public License v1.0"
+* which accompanies this distribution, and is available
+* at the URL "http://www.eclipse.org/legal/epl-v10.html".
+*
+* Initial Contributors:
+* Nokia Corporation - initial contribution.
+*
+* Contributors:
+*
+* Description: RmsExtensionPlugin unit tests
+*
+*/
+
+#include <string>
+#include "TestHarness.h"
+#include "javacommonutils.h"
+#include "commsmessage.h"
+#include "comms.h"
+
+#include "rmsextensionplugin.h"
+
+using namespace java::rms;
+using namespace java::util;
+
+class TestRmsExtensionPlugin : public RmsExtensionPlugin
+{
+public:
+    TestRmsExtensionPlugin() : mRecordChangeMsgs(0), mListenerCountMsgs(0) {};
+    virtual ~TestRmsExtensionPlugin() {};
+
+    using RmsExtensionPlugin::addListener;
+    using RmsExtensionPlugin::removeListener;
+    using RmsExtensionPlugin::notifyListeners;
+    using RmsExtensionPlugin::sendListenerCount;
+    using RmsExtensionPlugin::createListenerCountMsg;
+    virtual int send(CommsMessage& aMessage)
+    {
+        int msgId = aMessage.getMessageId();
+        int rc = 0;
+        switch (msgId)
+        {
+        case MSG_ID_RECORD_CHANGE:
+            mRecordChangeMsgs++;
+            break;
+        case MSG_ID_LISTENER_COUNT:
+            mListenerCountMsgs++;
+            break;
+        default:
+            rc = aMessage.getMessageId();
+        }
+        return rc;
+    };
+
+    using RmsExtensionPlugin::mListeners;
+    using RmsExtensionPlugin::listenersIterator;
+    int mRecordChangeMsgs;
+    int mListenerCountMsgs;
+};
+
+TEST_GROUP(TestMethods)
+{
+    TEST_SETUP()
+    {
+    }
+
+    TEST_TEARDOWN()
+    {
+    }
+};
+
+TEST(TestMethods, addRemoveListener)
+{
+    TestRmsExtensionPlugin rms;
+    CHECK(rms.mListeners.size() == 0);
+
+    rms.addListener("aaa", 1);
+    CHECK(rms.mListeners.size() == 1);
+
+    TestRmsExtensionPlugin::listenersIterator iter = rms.mListeners.find("aaa");
+    CHECK(iter->second.size() == 1);
+
+    rms.removeListener("aaa", 1);
+    CHECK(rms.mListeners.size() == 0);
+}
+
+TEST(TestMethods, addSameListener)
+{
+    TestRmsExtensionPlugin rms;
+    CHECK(rms.mListeners.size() == 0);
+
+    rms.addListener("aaa", 1);
+    rms.addListener("aaa", 1);
+    rms.addListener("aaa", 1);
+    CHECK(rms.mListeners.size() == 1);
+
+    TestRmsExtensionPlugin::listenersIterator iter = rms.mListeners.find("aaa");
+    CHECK(iter->second.size() == 3);
+
+    rms.removeListener("aaa", 1);
+    iter = rms.mListeners.find("aaa");
+    CHECK(iter->second.size() == 2);
+
+    rms.removeListener("aaa", 1);
+    rms.removeListener("aaa", 1);
+    CHECK(iter->second.size() == 0);
+}
+
+TEST(TestMethods, manyListenersOneName)
+{
+    TestRmsExtensionPlugin rms;
+    CHECK(rms.mListeners.size() == 0);
+
+    // multiple listeners for one name
+    for (int i = 0; i < 10; i++)
+    {
+        rms.addListener("aaa", i);
+    }
+    CHECK(rms.mListeners.size() == 1);
+    TestRmsExtensionPlugin::listenersIterator iter = rms.mListeners.find("aaa");
+    CHECK(iter->second.size() == 10);
+
+    for (int i = 0; i < 10; i++)
+    {
+        CHECK(iter->second.at(i) == i);
+    }
+
+    for (int i = 0; i < 10; i++)
+    {
+        rms.removeListener("aaa", i);
+    }
+    CHECK(rms.mListeners.size() == 0);
+}
+
+TEST(TestMethods, manyListenersManyNames)
+{
+    TestRmsExtensionPlugin rms;
+    CHECK(rms.mListeners.size() == 0);
+
+    // multiple listeners for many names
+    for (int i = 0; i < 10; i++)
+    {
+        for (int j = 0; j < 10; j++)
+        {
+            rms.addListener(JavaCommonUtils::intToString(i), j);
+        }
+    }
+    CHECK(rms.mListeners.size() == 10);
+
+
+    for (int i = 0; i < 10; i++)
+    {
+        TestRmsExtensionPlugin::listenersIterator iter = rms.mListeners.find(JavaCommonUtils::intToString(i));
+        CHECK(iter->second.size() == 10);
+        for (int j = 0; j < 10; j++)
+        {
+            CHECK(iter->second.at(j) == j);
+        }
+    }
+
+    for (int i = 0; i < 10; i++)
+    {
+        for (int j = 0; j < 10; j++)
+        {
+            rms.removeListener(JavaCommonUtils::intToString(i), j);
+        }
+    }
+    CHECK(rms.mListeners.size() == 0);
+}
+
+TEST(TestMethods, removeNonExistingListener)
+{
+    TestRmsExtensionPlugin rms;
+    CHECK(rms.mListeners.size() == 0);
+
+    // no such name
+    rms.removeListener("aaa", 1);
+    CHECK(rms.mListeners.size() == 0);
+
+    // no listener
+    rms.addListener("aaa", 1);
+    rms.removeListener("aaa", 2);
+    CHECK(rms.mListeners.size() == 1);
+    TestRmsExtensionPlugin::listenersIterator iter = rms.mListeners.find("aaa");
+    CHECK(iter->second.size() == 1);
+    rms.removeListener("aaa", 1);
+    CHECK(rms.mListeners.size() == 0);
+}
+
+TEST(TestMethods, notifyListeners)
+{
+    TestRmsExtensionPlugin rms;
+    CHECK(rms.mRecordChangeMsgs == 0);
+
+    CommsMessage msg;
+    msg.setSender(0);
+    msg.setMessageId(MSG_ID_RECORD_CHANGE);
+
+    rms.addListener("aaa", 1);
+    rms.addListener("aaa", 2);
+
+    rms.notifyListeners("aaa", msg);
+    CHECK(rms.mRecordChangeMsgs == 2);
+}
+
+TEST(TestMethods, noListeners)
+{
+    TestRmsExtensionPlugin rms;
+
+    CommsMessage msg;
+    msg.setSender(0);
+    msg.setMessageId(MSG_ID_RECORD_CHANGE);
+
+    rms.notifyListeners("aaa", msg);
+    CHECK(rms.mRecordChangeMsgs == 0);
+
+    rms.addListener("aaa", 1);
+    rms.addListener("aaa", 2);
+    rms.addListener("bbb", 1);
+
+    rms.notifyListeners("ccc", msg);
+    CHECK(rms.mRecordChangeMsgs == 0);
+
+    msg.setSender(1);
+    rms.notifyListeners("bbb", msg);
+    CHECK(rms.mRecordChangeMsgs == 0);
+
+    TestRmsExtensionPlugin::listenersIterator iter = rms.mListeners.find("aaa");
+    CHECK(iter->second.size() == 2);
+
+    iter = rms.mListeners.find("bbb");
+    CHECK(iter->second.size() == 1);
+}
+
+TEST(TestMethods, sendFails)
+{
+    TestRmsExtensionPlugin rms;
+
+    CommsMessage msg;
+    msg.setSender(0);
+    msg.setMessageId(-1);
+
+    rms.addListener("aaa", 1);
+    rms.addListener("aaa", 2);
+
+    TestRmsExtensionPlugin::listenersIterator iter = rms.mListeners.find("aaa");
+    CHECK(iter->second.size() == 2);
+
+    rms.notifyListeners("aaa", msg);
+    CHECK(rms.mListeners.size() == 0);
+}
+
+TEST(TestMethods, processMessage)
+{
+    CommsMessage addMsg;
+    addMsg.setSender(1);
+    addMsg.setMessageId(MSG_ID_LISTENER_CHANGE);
+    addMsg << "aaa" << ADD_LISTENER;
+
+    CommsMessage removeMsg;
+    removeMsg.setSender(1);
+    removeMsg.setMessageId(MSG_ID_LISTENER_CHANGE);
+    removeMsg << "aaa" << REMOVE_LISTENER;
+
+    CommsMessage recordMsg;
+    recordMsg.setSender(0);
+    recordMsg.setMessageId(MSG_ID_RECORD_CHANGE);
+    recordMsg << "aaa";
+
+    TestRmsExtensionPlugin rms;
+    // add listener
+    rms.processMessage(addMsg);
+    TestRmsExtensionPlugin::listenersIterator iter = rms.mListeners.find("aaa");
+    CHECK(iter->second.size() == 1);
+    CHECK(rms.mListenerCountMsgs == 1);
+
+    // record modified
+    rms.processMessage(recordMsg);
+    CHECK(rms.mRecordChangeMsgs == 1);
+
+    // remove listener
+    rms.processMessage(removeMsg);
+    CHECK(rms.mListeners.size() == 0);
+}
+
+TEST(TestMethods, unknownMessage)
+{
+    CommsMessage dummy;
+    dummy.setMessageId(666);
+
+    TestRmsExtensionPlugin rms;
+    rms.processMessage(dummy);
+    CHECK(rms.mRecordChangeMsgs == 0);
+    CHECK(rms.mListeners.size() == 0);
+}
+
+TEST(TestMethods, createListenerCountMsg)
+{
+
+    TestRmsExtensionPlugin rms;
+    CommsMessage msg = rms.createListenerCountMsg("aaa", 3);
+
+    std::string name;
+    int count;
+    msg >> name >> count;
+
+    CHECK(msg.getMessageId() == MSG_ID_LISTENER_COUNT);
+    CHECK(msg.getModuleId() == PLUGIN_ID_RMS_C);
+    CHECK(name == "aaa");
+    CHECK(count == 3);
+}
+
+TEST(TestMethods, sendListenerCount)
+{
+    TestRmsExtensionPlugin rms;
+    rms.addListener("aaa", 1);
+    rms.addListener("aaa", 2);
+    CHECK(rms.mListenerCountMsgs == 0);
+
+    CommsMessage dummy;
+    // invalid name
+    rms.sendListenerCount("bbb", dummy);
+    CHECK(rms.mListenerCountMsgs == 0);
+
+    // valid name
+    rms.sendListenerCount("aaa", dummy);
+    CHECK(rms.mListenerCountMsgs == 2);
+}
+
+
+