/*

* Copyright (c) 2009 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: InstallOperation provides a way to launch and communicate

*              with Java Installer process

*

*/

#include "installoperation.h"

#include "logger.h"

#include "comms.h"

#include "commsmessage.h"

#include "javaprocessconstants.h"

#include "javasymbianoslayer.h"

using namespace java::debug;

using namespace java::util;

using namespace java::comms;

InstallOperation::InstallOperation()

{

    mInstaller.registerDefaultListener(this);

}

InstallOperation::~InstallOperation()

{

}

int InstallOperation::runJavaInstaller()

{

    JELOG2(EDebugApi);

    int rc = mInstaller.start(IPC_ADDRESS_JAVA_DEBUGAPI_C);

    if (!rc)

    {

        int waitCount = 5;

        do

        {

            // If install operation is done immediately after previous one then

            // it's possible that previous Java Installer process instance has not

            // exited yet.

            rc = startJavaInstaller();

            if (rc == KErrAlreadyExists)

            {

                LOG(EDebugApi, EInfo, "waiting java installer to exit");

                User::After(500000); // 0.5s

            }

            else

            {

                waitCount = 0;

            }

        }

        while (--waitCount > 0);

    }

    mInstaller.stop();

    if (rc)

    {

        ELOG1(EDebugApi, "runJavaInstaller() failed: rc=%d", rc);

    }

    return rc;

}

int InstallOperation::startJavaInstaller()

{

    JELOG2(EDebugApi);

    std::string args = java::runtime::JAVA_INSTALLER_STARTER_DLL;

    args += " poll -address=debugapi";

    std::auto_ptr<HBufC> cmdLine(stringToDes(args.c_str()));

    std::auto_ptr<HBufC> exe(stringToDes(java::runtime::JAVA_PROCESS));

    RProcess process;

    int rc = process.Create(exe->Des(), cmdLine->Des());

    if (KErrNone == rc)

    {

        // wait for JavaInstaller exit

        TRequestStatus status;

        process.Logon(status);

        process.Resume();

        User::WaitForRequest(status);

        rc = status.Int();

        process.Close();

    }

    LOG1(EDebugApi, EInfo,"javainstaller exit code: %d", rc);

    return rc;

}

/**

 * Communication with Java Installer is done asynchronously.

 * Following messages are used:

 *

 * Message Name        Id      Contents

 *

 * Get Next Operation  500     None

 *

 * Operation           501     int operation   (install = 0, uninstall = 1, exit = 2)

 *                             String url      (present if operation = install)

 *                             String uid      (present if operation = uninstall)

 *

 * Operation Result    502     int operation   (install = 0, uninstall = 1, exit = 2)

 *                             int result      (ok = 0, error codes are negative)

 *                             int uidCount    (present if operation = install, value = uids.length)

 *                             String[] uids   (present if operation = install)

 *                             String suiteUid (present if operation = install)

 */

void InstallOperation::processMessage(CommsMessage& aMessage)

{

    JELOG2(EDebugApi);

    switch (aMessage.getMessageId())

    {

    case GET_NEXT_OPERATION_MESSAGE_ID:

    {

        LOG(EDebugApi, EInfo, "GET_NEXT_OPERATION received");

        CommsMessage reply = getNextOperation();

        reply.replyTo(aMessage);

        reply.setMessageId(OPERATION_MESSAGE_ID);

        sendToJavaInstaller(reply);

    }

    break;

    case OPERATION_RESULT_MESSAGE_ID:

        LOG(EDebugApi, EInfo,"OPERATION_RESULT received");

        handleOperationResult(aMessage);

        break;

    default:

        WLOG1(EDebugApi, "Unknown message received: msgId = %d", aMessage.getMessageId());

        break;

    }

}

CommsMessage InstallOperation::getNextOperation()

{

    CommsMessage msg;

    msg << EXIT_OPERATION;

    LOG(EDebugApi, EInfo, "next operation is EXIT");

    return msg;

}

void InstallOperation::sendToJavaInstaller(CommsMessage& aMessage)

{

    int rc = mInstaller.send(aMessage);

    if (rc)

    {

        WLOG1(EDebugApi, "sendToJavaInstaller() failed: rc = %d", rc);

    }

}

void InstallOperation::handleOperationResult(CommsMessage& /*aMessage*/)

{

}