/*
* Copyright (c) 2007-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:
 *
*/

#include <string>
#include <unistd.h>
#include <errno.h>

#ifdef __SYMBIAN32__
#include <spawn.h>
#else
#include <stdio.h>
#endif //__SYMBIAN32__


#include "logger.h"
#include "comms.h"
#include "rtcmessages.h"
#include "coremessages.h"

#include "testserver.h"

using namespace java::comms;
using namespace java::captain;


TestServer::TestServer()
{
}

TestServer::~TestServer()
{
}

int TestServer::start()
{
    mJavaCaptain.registerDefaultListener(this);
    mJavaInstaller.registerDefaultListener(this);
    stopJavaCaptain();
    int rc = mJavaCaptain.start(IPC_ADDRESS_JAVA_CAPTAIN_C);

    if (!rc)
    {
        startTckRunner();
        rc = mJavaInstaller.connect(IPC_ADDRESS_JAVA_TCK_RUNNER_C);

        while (rc != 0)
        {
            // tck runner is not up yet
            sleep(1);
            WLOG(ETckRunner, "waiting for tckrunner...");
            rc = mJavaInstaller.connect(IPC_ADDRESS_JAVA_TCK_RUNNER_C);
        }
    }
    else
    {
        ELOG1(ETckRunner, "Unable to create Java Captain endpoint %d. Is Java Captain running?", rc);
    }
    return rc;
}

int TestServer::stop()
{
    stopTckRunner();
    mJavaCaptain.unregisterDefaultListener(this);
    mJavaInstaller.unregisterDefaultListener(this);
    int rc1 = mJavaCaptain.stop();
    int rc2 = mJavaInstaller.disconnect();
    return rc1 + rc2;
}


void TestServer::processMessage(CommsMessage& aMessage)
{
    switch (aMessage.getMessageId())
    {
    case MSG_ID_OPERATION:
    {
        int oper;
        string urlOrUid;
        aMessage >> oper >> urlOrUid;

        CommsMessage msg;
        msg.replyTo(aMessage);
        msg.setMessageId(MSG_ID_OPERATION_RESULT);
        int status = 0;
        msg << oper << status << 1 << urlOrUid;
        mJavaInstaller.send(msg);
    }
    break;

    case RTC_MSG_ID_LAUNCH_APPLICATION_REQ:
    {
        string rtc, uid;
        int option, type;
        aMessage >> uid >> type >> option >> rtc;

        CommsMessage msg;
        msg.replyTo(aMessage);
        msg.setMessageId(RTC_MSG_ID_APPLICATION_TERMINATED_IND);
        int status = 0;
        if (uid.compare("fail") == 0)
        {
            status = -1;
        }
        msg << uid << status;
        mJavaCaptain.send(msg);

        mLaunchReqs.push(uid);
    }
    break;

    default:
        LOG1(ETckRunner, EInfo, "Unknown message= %d", aMessage.getMessageId());
        break;
    }
}

int TestServer::startTckRunner()
{
    int rc = 0;
    int pid = 0;

    char* av[4];
    int index = 0;
    av[index++] = "tckrunner";
    av[index++] = "unittest";
    av[index++] = "unittest:\\\\tckrunner_tester";
    av[index] = NULL;

#ifdef __SYMBIAN32__
    rc = posix_spawn(&pid, "tckrunner", NULL, NULL, av, NULL);
#else
    if (!(pid = fork()))
    {
        rc = execvp("tckrunner", av);
        if (rc == -1)
        {
            rc = errno;
        }
    }
#endif // __SYMBIAN32__

    if (rc)
    {
        ELOG3(ETckRunner, "%s failed, %s - errno=%d", __PRETTY_FUNCTION__, strerror(rc), rc);
    }
    return rc;
}


int TestServer::stopTckRunner()
{
    CommsMessage msg;
    msg.setMessageId(MSG_ID_OPERATION_RESULT);
    int status = 0;
    msg << OPERATION_EXIT << status;
    int rc = mJavaInstaller.send(msg);
    while (rc == 0)
    {
        sleep(1);
        WLOG(ETckRunner, "waiting tckrunner to exit...");
        rc = mJavaInstaller.send(msg);
    }
    return rc;
}

void TestServer::stopJavaCaptain()
{
    CommsMessage message;
    message.setModuleId(PLUGIN_ID_JAVACAPTAIN_CORE_C);
    message.setMessageId(CORE_MSG_ID_STOP_JAVACAPTAIN);
    CommsClientEndpoint comms;
    comms.connect(IPC_ADDRESS_JAVA_CAPTAIN_C);
    int rc = comms.send(message);
    while (rc == 0)
    {
        sleep(1);
        WLOG(ETckRunner, "waiting JavaCaptain to exit...");
        rc = comms.send(message);
    }
    comms.disconnect();
}