/*
* Copyright (c) 2008 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:  ?Description
*
*/

#include <errno.h>
#include "monitor.h"
#include "TestHarness.h"
#include "logger.h"

#include "commsserverendpoint.h"
#include "commsclientendpoint.h"
#include "commsmessage.h"
#include "echoserver.h"

using namespace java::comms;
using java::util::Monitor;

TEST_GROUP(Find)
{
    TEST_SETUP()
    {
        {
            CommsClientEndpoint client;
        }
    }

    TEST_TEARDOWN()
    {
    }
};

/**
 * Test find client endpoint
 * 1. Named endpoint exists
 * 2. Named endpoint does not exist
 * 3. Multiple named endpoints
 */

TEST(Find, FindClient)
{
    EchoServer server;
    CHECK(!server.start(IPC_ADDRESS_COMMS_MODULE_TEST));

    CommsMessage msg;
    CommsMessage receivedMsg;

    // 1. Named endpoint exists
    CommsClientEndpoint client(L"CommsModuleTest");
    CHECK(!client.connect(IPC_ADDRESS_COMMS_MODULE_TEST));

    CommsClientEndpoint* pClient = CommsClientEndpoint::find(L"CommsModuleTest");
    CHECK(pClient);

    CHECK(!client.send(msg));
    CHECK(!pClient->send(msg));

    CHECK(!pClient->disconnect());
    CHECK(!pClient->connect(IPC_ADDRESS_COMMS_MODULE_TEST));

    CHECK(!client.sendReceive(msg, receivedMsg, WAIT_FOR_EVER));
    CHECK(!pClient->sendReceive(msg, receivedMsg, WAIT_FOR_EVER));

    CHECK(!client.disconnect());

    // 2. Named endpoint does not exist
    pClient = CommsClientEndpoint::find(L"commsmoduletest");
    CHECK(!pClient);

    pClient = CommsClientEndpoint::find(L"");
    CHECK(!pClient);

    pClient = CommsClientEndpoint::find(L"CommsModuleTest ");
    CHECK(!pClient);

    {
        CommsClientEndpoint cli(L"clientendpoint");
        pClient = CommsClientEndpoint::find(L"clientendpoint");
        CHECK(pClient);
    }
    pClient = CommsClientEndpoint::find(L"clientendpoint");
    CHECK(!pClient);

    // 3. Multiple named endpoints
    CommsClientEndpoint client1(L"client1");
    CommsClientEndpoint client2(L"client2");
    CommsClientEndpoint client3(L"client3");

    pClient = CommsClientEndpoint::find(L"client1");
    CHECK(pClient);
    pClient = CommsClientEndpoint::find(L"client2");
    CHECK(pClient);
    pClient = CommsClientEndpoint::find(L"client3");
    CHECK(pClient);

    CHECK(!server.stop());
}


/**
 * Test find server endpoint
 * 1. Named endpoint exists
 * 2. Named endpoint does not exist
 * 3. Multiple named endpoints
 */

TEST(Find, FindServer)
{
    CommsMessage msg;
    CommsMessage receivedMsg;

    CommsClientEndpoint client;

    // 1. Named endpoint exists
    CommsServerEndpoint server(L"CommsModuleTest");
    CHECK(!server.start(IPC_ADDRESS_COMMS_MODULE_TEST));
    CHECK(!client.connect(IPC_ADDRESS_COMMS_MODULE_TEST));

    CommsServerEndpoint* pServer = CommsServerEndpoint::find(L"CommsModuleTest");
    CHECK(pServer);

    CHECK(!client.send(msg));
    CHECK(!pServer->stop());

    CHECK(client.send(msg) != 0);
    CHECK(!client.disconnect());

    CHECK(!pServer->start(IPC_ADDRESS_COMMS_MODULE_TEST));
    CHECK(!client.connect(IPC_ADDRESS_COMMS_MODULE_TEST));

    CHECK(!client.send(msg));
    CHECK(!server.stop());

    CHECK(client.send(msg) != 0);
    CHECK(!client.disconnect());

    // 2. Named endpoint does not exist
    pServer = CommsServerEndpoint::find(L"commsmoduletest");
    CHECK(!pServer);

    pServer = CommsServerEndpoint::find(L"");
    CHECK(!pServer);

    pServer = CommsServerEndpoint::find(L"CommsModuleTest ");
    CHECK(!pServer);

    {
        CommsServerEndpoint cli(L"serverendpoint");
        pServer = CommsServerEndpoint::find(L"serverendpoint");
        CHECK(pServer);
    }
    pServer = CommsServerEndpoint::find(L"serverendpoint");
    CHECK(!pServer);

    // 3. Multiple named endpoints
    CommsServerEndpoint server1(L"server1");
    CommsServerEndpoint server2(L"server2");
    CommsServerEndpoint server3(L"server3");

    pServer = CommsServerEndpoint::find(L"server1");
    CHECK(pServer);
    pServer = CommsServerEndpoint::find(L"server2");
    CHECK(pServer);
    pServer = CommsServerEndpoint::find(L"server3");
    CHECK(pServer);
}


/**
 * Server and client endpoint with same name
 * 1. Server and client endpoint with same name
 */

TEST(Find, FindSameName)
{
#ifdef __SYMBIAN32__
    EXPECT_N_LEAKS(2);
#else
    EXPECT_N_LEAKS(1);
#endif
    // 1. Server and client endpoint with same name
    CommsServerEndpoint server(L"hello world");
    CommsClientEndpoint client(L"hello world");

    CommsServerEndpoint* pServer = CommsServerEndpoint::find(L"hello world");
    CHECK(pServer);
    CommsClientEndpoint* pClient = CommsClientEndpoint::find(L"hello world");
    CHECK(pClient);
}