// SMRemoteTargetApp.cpp

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

#include <OS.h>

#include "SMRemoteTargetApp.h"
#include "SMLooper.h"

// debugging
//#define DBG(x) x
#define DBG(x)
#define OUT     printf

int
main(int argc, char **argv)
{
DBG(OUT("REMOTE: main()\n"));
        assert(argc > 1);
        const char *portName = argv[1];
        bool preferred = (argc > 2 && !strcmp(argv[2], "preferred"));
        // create local port
        port_id localPort = create_port(5, "SMRemoteTargetApp port");
        assert(localPort >= 0);
DBG(OUT("REMOTE: local port created\n"));
        // create looper/handler
        SMHandler *handler = NULL;
        SMLooper *looper = new SMLooper;
        looper->Run();
        if (!preferred) {
                handler = new SMHandler;
                assert(looper->Lock());
                looper->AddHandler(handler);
                looper->Unlock();
        }
DBG(OUT("REMOTE: looper/handler created\n"));
        // find remote port
DBG(OUT("REMOTE: find remote port `%s'\n", portName));
        port_id remotePort = find_port(portName);
        assert(remotePort >= 0);
DBG(OUT("REMOTE: found remote port\n"));
        // send init message
        smrt_init initData;
        initData.port = localPort;
        initData.messenger = BMessenger(handler, looper);
        assert(write_port(remotePort, SMRT_INIT, &initData, sizeof(smrt_init))
                   == B_OK);
DBG(OUT("REMOTE: init message sent\n"));
        // loop until quit message
        bool running = true;
        while (running) {
                char buffer[sizeof(smrt_get_ready)];
                int32 code;
                ssize_t readSize = read_port(localPort, &code, buffer, sizeof(buffer));
                if (readSize < 0)
                        running = readSize;
DBG(OUT("REMOTE: read port: %.4s\n", (char*)&code));
                switch (code) {
                        case SMRT_GET_READY:
                        {
DBG(OUT("REMOTE: SMRT_GET_READY\n"));
                                assert(readSize == sizeof(smrt_get_ready));
                                smrt_get_ready &data = *(smrt_get_ready*)buffer;
                                looper->SetReplyDelay(data.reply_delay);
                                looper->BlockUntil(data.unblock_time);
DBG(OUT("REMOTE: SMRT_GET_READY done\n"));
                                break;
                        }
                        case SMRT_DELIVERY_SUCCESS_REQUEST:
                        {
DBG(OUT("REMOTE: SMRT_DELIVERY_SUCCESS_REQUEST\n"));
                                assert(readSize == 0);
                                smrt_delivery_success data;
                                data.success = looper->DeliverySuccess();
                                assert(write_port(remotePort, SMRT_DELIVERY_SUCCESS_REPLY,
                                                                  &data, sizeof(smrt_delivery_success))
                                           == B_OK);
DBG(OUT("REMOTE: SMRT_DELIVERY_SUCCESS_REQUEST done\n"));
                                break;
                        }
                        case SMRT_QUIT:
DBG(OUT("REMOTE: QUIT\n"));
                        default:
if (code != SMRT_QUIT)
DBG(OUT("REMOTE: UNKNOWN COMMAND!\n"));
                                running = false;
                                break;
                }
        }
        // delete looper/handler
        if (looper) {
                looper->Lock();
                if (handler) {
                        looper->RemoveHandler(handler);
                        delete handler;
                }
                looper->Quit();
        }
DBG(OUT("REMOTE: looper/handler deleted\n"));
        // delete local port
        delete_port(localPort);
DBG(OUT("REMOTE: main() done\n"));
        return 0;
}