/*
* 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:  Main
*
*/


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

#include "javacommonutils.h"
#include "comms.h"
#include "commsclientendpoint.h"
#include "commslistener.h"
#include "monitor.h"

#include "rtcmessages.h"

#include "testuids.h"

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

CommsClientEndpoint comms;
Monitor*            monitor;
Uid                 uid;

class rtCommsListener : public CommsListener
{
public:
    void processMessage(CommsMessage& message)
    {
        switch (message.getMessageId())
        {
        case RTC_MSG_ID_TERMINATE_APPLICATION_REQ:
            printf("TERMINATE_REQ received, triggering monitor\n");
            monitor->notify();
            break;
        }
    }
};

static void sendRunningInd();
static void sendTerminatedInd();
static void sendGetRuntimeAttributes();

void runtime(const int& uSecDelayBeforeRunningInd,
             const int& numOfRunningInds,
             const bool& getRuntimeAttributes,
             const bool& immediateExit,
             const bool& obeyTerminateReqs,
             const int& numOfTerminateInds,
             const bool& stayRunning)
{
    if (uSecDelayBeforeRunningInd > 0)
    {
        usleep(uSecDelayBeforeRunningInd);
    }

    for (int runInds = 0 ; runInds < numOfRunningInds ; runInds++)
    {
        sendRunningInd();
    }

    if (getRuntimeAttributes)
    {
        sendGetRuntimeAttributes();
    }

    if (!immediateExit)
    {
        do
        {
            monitor->wait();
        }
        while (!obeyTerminateReqs);
    }

    for (int termInds = 0; termInds < numOfTerminateInds ; termInds++)
    {
        sendTerminatedInd();
    }

    if (stayRunning)
    {
        while (true)
        {
            monitor->wait();
        }
    }
}

int main(int ac, char** av)
{
    monitor = Monitor::createMonitor();

    rtCommsListener listener;
    comms.registerDefaultListener(&listener);
    comms.connect(IPC_ADDRESS_JAVA_CAPTAIN_C);

    printf("we have liftoff\n");

    for (int i = 0 ; i<ac ; ++i)
    {
        printf("%d:%s ", i, av[i]);
    }
    printf("\n");

    uid = Uid(java::util::JavaCommonUtils::utf8ToWstring(av[3]));
    printf("%s used for launching\n", av[3]);

    bool getRuntimeAttributes = false;
    if (ac > 4 && (std::string(av[4]) == "-debug"))
    {
        printf("getRuntimeAttributes -> true\n");
        getRuntimeAttributes = true;
    }

// startup sequence : running_ind 1x
// runtime behaviour: stays running
// exit sequence    : sends terminate_ind 1x -> exits
//const Uid uid_normal1(L"normal1");
    if (uid == uid_normal1 ||
            uid == uid_push1)
    {
        runtime(500000, // uSecDelayBeforeRunningInd
                1,      // numOfRunningInds
                getRuntimeAttributes,
                false,  // immediateExit
                true,   // obeyTerminateReqs
                1,      // numOfTerminateInds
                false); // stayRunning
    }

// startup sequence : running_ind 2x (no delay in between)
// runtime behaviour: stays running
// exit sequence    : sends terminate_ind 1x -> exits
//const Uid uid_normal2(L"normal2");
    else if (uid == uid_normal2)
    {
        runtime(500000, // uSecDelayBeforeRunningInd
                2,      // numOfRunningInds
                getRuntimeAttributes,
                false,  // immediateExit
                true,   // obeyTerminateReqs
                1,      // numOfTerminateInds
                false); // stayRunning
    }

// startup sequence : running_ind 2x (no delay)
// runtime behaviour: stays running
// exit sequence    : sends terminate_ind 2x (no delay) -> exits
//const Uid uid_normal3(L"normal3");
    else if (uid == uid_normal3)
    {
        runtime(500000, //uSecDelayBeforeRunningInd
                2,      // numOfRunningInds
                getRuntimeAttributes,
                false,  // immediateExit
                true,   // obeyTerminateReqs
                2,      // numOfTerminateInds
                false); // stayRunning
    }
// startup sequence : running_ind 1x no delay
// runtime behaviour: stays running
// exit sequence    : sends terminate_ind 1x -> exits
//const Uid uid_normal1(L"normal4");
    else if (uid == uid_normal4)
    {
        runtime(0,      // uSecDelayBeforeRunningInd
                1,      // numOfRunningInds
                getRuntimeAttributes,
                false,  // immediateExit
                true,   // obeyTerminateReqs
                1,      // numOfTerminateInds
                false); // stayRunning
    }

// startup sequence : running_ind 1x
// runtime behaviour: stays running
// exit sequence    : sends nothing -> stays running
    else if (uid == uid_wont_terminate1)
    {
        runtime(500000, // uSecDelayBeforeRunningInd
                1,      // numOfRunningInds
                getRuntimeAttributes,
                false,  // immediateExit
                false,  // obeyTerminateReqs
                0,      // numOfTerminateInds
                true);  // stayRunning
    }

// startup sequence : running_ind 1x
// runtime behaviour: stays running
// exit sequence    : sends terminate_ind but stays running
    else if (uid == uid_wont_terminate2)
    {
        runtime(500000, // uSecDelayBeforeRunningInd
                1,      // numOfRunningInds
                getRuntimeAttributes,
                false,  // immediateExit
                false,  // obeyTerminateReqs
                1,      // numOfTerminateInds
                true);  // stayRunning
    }

// startup sequence : running_ind 0x
// runtime behaviour: exit immediately
// exit sequence    : sends terminate_ind 1x -> exits
//const Uid uid_premature_exit1(L"premature_exit1");
    else if (uid == uid_premature_exit1)
    {
        runtime(500000, //uSecDelayBeforeRunningInd
                0,      // numOfRunningInds
                getRuntimeAttributes,
                true,  // immediateExit
                true,  // obeyTerminateReqs
                1,      // numOfTerminateInds
                false);  // stayRunning
    }

// startup sequence : running_ind 1x
// runtime behaviour: exit immediately
// exit sequence    : sends terminate_ind 1x -> exits
//const Uid uid_premature_exit2(L"premature_exit2");
    else if (uid == uid_premature_exit2)
    {
        runtime(500000, //uSecDelayBeforeRunningInd
                1,      // numOfRunningInds
                getRuntimeAttributes,
                true,  // immediateExit
                true,  // obeyTerminateReqs
                1,      // numOfTerminateInds
                false);  // stayRunning
    }

// startup sequence : running_ind 1x
// runtime behaviour: exit immediately
// exit sequence    : sends nothing -> exits
//const Uid uid_premature_exit3(L"premature_exit3");
    else if (uid == uid_premature_exit3)
    {
        runtime(500000, //uSecDelayBeforeRunningInd
                1,      // numOfRunningInds
                getRuntimeAttributes,
                true,  // immediateExit
                true,  // obeyTerminateReqs
                0,      // numOfTerminateInds
                false);  // stayRunning
    }

    comms.disconnect();

    delete monitor;

    puts("Exiting");

    return 0;
}

void sendRunningInd()
{
    CommsMessage msg;
    setApplicationRunningIndParams(msg, uid, 0);
    comms.send(msg);
}

void sendTerminatedInd()
{
    CommsMessage msg;
    setApplicationTerminatedIndParams(msg, uid, 0);
    comms.send(msg);
}

void sendGetRuntimeAttributes()
{
    CommsMessage msg;
    setGetExtraArguments(msg);
    comms.send(msg);
}