/*
* 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:  Comms server, part of OMJ S60 preinstaller process
 *
*/


#include <iostream>
#include <unistd.h>

#include "comms.h"
#include "logger.h"
#include "javasymbianoslayer.h"
#include "preinstallcommsserver.h"

using namespace java::comms;
using namespace std;

PreinstallCommsServer::PreinstallCommsServer() : mRunning(0)
{
}

PreinstallCommsServer::~PreinstallCommsServer()
{
    mJadFiles.clear();
}

void PreinstallCommsServer::setJadFiles(RPointerArray<HBufC> &aJadFiles)
{
    JELOG2(EJavaPreinstaller);

    // jad index will contain the number of valid jad file urls
    mJadIndex = 0;
    // clear the old jad file paths if any
    mJadFiles.clear();

    int nPointers = aJadFiles.Count();
    mJadFiles.reserve(nPointers);

    // index is decremented because mJadIndex will also be decremented when
    // installing -> total effect is that jad files will be given to
    // Java Installer in the original order
    for (int i = nPointers - 1; i > -1; i--)
    {
        HBufC* pBuf = aJadFiles[i];

        if (NULL == pBuf)
        {
            // skip this NULL pointer
            continue;
        }

        TPtr16 ptrName(pBuf->Des());
        // Convert each HBufC to std:wstring before adding to mJadFiles
        mJadFiles.push_back(std::wstring(desToWstring(ptrName)));
        mJadIndex++;
    }

    LOG1(EJavaPreinstaller, EInfo, "PreinstallCommsServer: number of Jad files = %d", mJadIndex);
}

int PreinstallCommsServer::start()
{
    LOG(EJavaPreinstaller, EInfo,
        "PreinstallCommsServer:start called");

    if (mRunning == 0)
    {
        mRunning = 1;
        mComms.registerDefaultListener(this);
        return mComms.start(IPC_ADDRESS_JAVA_PREINSTALLER_C);
    }
    else
    {
        WLOG(EJavaPreinstaller,
             "PreinstallCommsServer:start called but server is already running");
        return 0;
    }
}

int PreinstallCommsServer::stop()
{
    if (mRunning > 0)
    {
        mRunning = 0;
        mComms.unregisterDefaultListener(this);
        return mComms.stop();
    }
    else
    {
        return 0;
    }
}

/**
 * Communicates with Java Installer. The 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)
 */
void PreinstallCommsServer::processMessage(CommsMessage& aMessage)
{
    LOG1(EJavaPreinstaller, EInfo, "processMessage, sender    = %d", aMessage.getSender());
    LOG1(EJavaPreinstaller, EInfo, "processMessage, messageId = %d", aMessage.getMessageId());
    LOG1(EJavaPreinstaller, EInfo, "processMessage, messageRef= %d", aMessage.getMessageRef());

    switch (aMessage.getMessageId())
    {
    case GET_NEXT_OPERATION_MESSAGE_ID:
    {
        // Java Installer asks for the next install operation.
        // Reply with 'Operation' message.

        CommsMessage reply;
        reply.replyTo(aMessage);

        reply.setMessageId(OPERATION_MESSAGE_ID);

        mJadIndex--;
        if (mJadIndex <= -1)
        {
            // all Jad files have been handled, ask Java Installer to exit
            reply << EXIT_OPERATION;

            // Java Installer sends reply to 'exit' message and then
            // it exits which causes the completion of the CSilentMIDletInstall active object
        }
        else
        {
            // ask Java Installer to install next
            reply << INSTALL_OPERATION << mJadFiles[mJadIndex];
        }

        // Ignore possible error code returned by send() because Comms
        // logs the error situations
        mComms.send(reply);
    }
    break;

    case OPERATION_RESULT_MESSAGE_ID:
    {
        // Log the result of the operation. Preinstaller does not need
        // the Uids of the installed Java Applications so they are not
        // parsed.
        int operation;
        int result;

        aMessage >> operation >> result;

        LOG2(EJavaPreinstaller, EInfo,
             "PreinstallCommsServer: operation = %d, result = %d", operation, result);
    }
    break;

    default:
    {
        // Unknown message. Ignore it.
        WLOG1(EJavaPreinstaller,
              "PreinstallCommsServer: Unknown message received. Msg Id = %d",
              aMessage.getMessageId());
    }
    break;
    }
}