ircproxy  The Ultimate Cyborg

---

ServerSessionInput.cc

Go to the documentation of this file.

// ircproxy -- An IRC bouncer.
//
//! @file ServerSessionInput.cc
//! @brief This file contains the implementation of class ServerSessionInput.
//
// Copyright (C) 2005 - 2007 by
//
// Carlo Wood, Run on IRC <carlo@alinoe.com>
// RSA-1024 0x624ACAD5 1997-01-26                    Sign & Encrypt
// Fingerprint16 = 32 EC A7 B6 AC DB 65 A6  F6 F6 55 DD 1C DC FF 61
//
// This file may be distributed under the terms of the Q Public License
// version 1.0 as appearing in the file LICENSE.QPL included in the
// packaging of this file.

#ifndef USE_PCH
#include "sys.h"
#include "debug.h"
#include <libcwd/buf2str.h>
#endif

#include "Application.h"
#include "ServerSession.h"
#ifdef CWDEBUG
#include "ServerConnection.h"
#endif

//! Constructor (see libcw).
ServerSessionInput::ServerSessionInput(input_buffer_ct* ibuf) : read_input_tct<text>(ibuf), M_current_msg(static_cast<ServerSession*>(this))
{
}

/*! @brief Decode message \a msg_block as received from server.
 *
 * This function is called when a new, complete IRC message has
 * been received from the IRC server connected to the associated socket.
 */
void ServerSessionInput::decode(msg_block_ct msg_block)
{
#ifdef CWDEBUG
  // Suppress PING related messages if requested.
  bool is_ping = (msg_block.get_size() >= 5 && strncmp(msg_block.get_start(), "PING ", 5) == 0 && Application::instance().suppress_ping());
  Debug(if (is_ping) libcw_do.off());

  // Set the global variable debug::secondary_connection, if needed.
  debug::SecondaryConnection dummy(dynamic_cast<ServerSession*>(this)->server_connection().secondary_connection());
#endif

  DoutEntering(dc::serverinput, "ServerSessionInput::decode(\"" << buf2str(msg_block.get_start(), msg_block.get_size()) << "\")");

  // Initialize M_current_msg for decoding purposes.
  M_current_msg.init(msg_block);

  // Pass it on.
  new_message_received(M_current_msg);

  // Turn debugging on again if needed.
  Debug(if (is_ping) libcwd::libcw_do.on());
}

---