/*
 * Copyright 2001-2015, Haiku, Inc.
 * Distributed under the terms of the MIT license.
 *
 * Authors:
 *              DarkWyrm <bpmagic@columbus.rr.com>
 *              Axel Dörfler, axeld@pinc-software.de
 *              Stephan Aßmus <superstippi@gmx.de>
 *              Christian Packmann
 *              Julian Harnath <julian.harnath@rwth-aachen.de>
 */
#include "TestServerLoopAdapter.h"

#include "Desktop.h"
#include "ServerConfig.h"
#include "ServerProtocol.h"

#include <PortLink.h>

#include <stdio.h>

//#define DEBUG_SERVER
#ifdef DEBUG_SERVER
#       include <stdio.h>
#       define STRACE(x) printf x
#else
#       define STRACE(x) ;
#endif


TestServerLoopAdapter::TestServerLoopAdapter(const char* signature,
        const char*, port_id, bool, status_t* outError)
        :
        MessageLooper("test-app_server"),
        fMessagePort(_CreatePort())
{
        fLink.SetReceiverPort(fMessagePort);
        *outError = B_OK;
}


TestServerLoopAdapter::~TestServerLoopAdapter()
{
}


status_t
TestServerLoopAdapter::Run()
{
        rename_thread(find_thread(NULL), "picasso");
        _message_thread((void*)this);
        return B_OK;
}


void
TestServerLoopAdapter::_DispatchMessage(int32 code,
        BPrivate::LinkReceiver& link)
{
        switch (code) {
                case AS_GET_DESKTOP:
                {
                        port_id replyPort = 0;
                        link.Read<port_id>(&replyPort);

                        int32 userID = -1;
                        link.Read<int32>(&userID);

                        char* targetScreen = NULL;
                        link.ReadString(&targetScreen);

                        int32 version = -1;
                        link.Read<int32>(&version);

                        BMessage message(AS_GET_DESKTOP);
                        message.AddInt32("user", userID);
                        message.AddInt32("version", version);
                        message.AddString("target", targetScreen);
                        MessageReceived(&message);

                        // AppServer will try to send a reply, we just let that fail
                        // since we can find out the port by getting the desktop instance
                        // ourselves

                        Desktop* desktop = _FindDesktop(userID, targetScreen);
                        free(targetScreen);

                        BPrivate::LinkSender reply(replyPort);
                        if (desktop != NULL) {
                                reply.StartMessage(B_OK);
                                reply.Attach<port_id>(desktop->MessagePort());
                        } else
                        reply.StartMessage(B_ERROR);

                        reply.Flush();

                        break;
                }

                case B_QUIT_REQUESTED:
                {
                        QuitRequested();
                        break;
                }

                default:
                        STRACE(("Server::MainLoop received unexpected code %" B_PRId32 " "
                                "(offset %" B_PRId32 ")\n", code, code - SERVER_TRUE));
                        break;
        }
}


port_id
TestServerLoopAdapter::_CreatePort()
{
        port_id port = create_port(DEFAULT_MONITOR_PORT_SIZE, SERVER_PORT_NAME);
        if (port < B_OK)
                debugger("test-app_server could not create message port");
        return port;
}