/*
 * psclientmsghandler.cpp by Keith Fulton <keith@paqrat.com>
 *
 * Copyright (C) 2001 Atomic Blue (info@planeshift.it, http://www.atomicblue.org) 
 *
 *
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License
 * as published by the Free Software Foundation (version 2 of the License)
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
 *
 */
#include <psconfig.h>

#include <iutil/objreg.h>
#include <iutil/eventq.h>
#include <csutil/event.h>
#include <csutil/eventnames.h>

#include "net/netbase.h"
#include "net/clientmsghandler.h"

psClientMsgHandler::psClientMsgHandler()
{
    // no special code needed right now
    scfiEventHandler = NULL;
    object_reg = NULL;
}

psClientMsgHandler::~psClientMsgHandler()
{
    if (scfiEventHandler)
    {
        csRef<iEventQueue> queue = CS_QUERY_REGISTRY(object_reg, iEventQueue);
        if (queue)
            queue->RemoveListener(scfiEventHandler);
        scfiEventHandler->DecRef();
    }    
}

bool psClientMsgHandler::Initialize(NetBase* nb, iObjectRegistry* object_reg)
{
    // Create and register inbound queue
    if (!MsgHandler::Initialize(nb))
        return false;

    psClientMsgHandler::object_reg = object_reg;

    // This hooks our HandleEvent function into main application event loop
    csRef<iEventQueue> queue = CS_QUERY_REGISTRY(object_reg, iEventQueue);
    if (!queue)
        return false;
    scfiEventHandler = new EventHandler(this);

    csEventID esub[] = { 
      csevFrame (object_reg),
      CS_EVENTLIST_END 
    };
    queue->RegisterListener(scfiEventHandler, esub);

    return true;
}

bool psClientMsgHandler::HandleEvent(iEvent &ev)
{
    if (!netbase->IsReady())
        return false;
    
    return DispatchQueue();
}

bool psClientMsgHandler::DispatchQueue()
{
    /* 
     * If called, it publishes (and therefore handles
     * all the messages in the inbound queue before returning.
     */
    csRef<MsgEntry> msg;

    while( (msg = queue->Get()) )
    {
        Publish(msg);
        /* Destroy this message.  Note that Msghandler normally does this in the 
         * Run() loop for the server.
         */
        // don't forget to release the packet
        msg = NULL;
    }
    
    return false;  // this function should not eat the event
}