ircproxy  The Ultimate Cyborg

---

Channel.cc

Go to the documentation of this file.

// ircproxy -- An IRC bouncer.
//
//! @file Channel.cc
//! @brief This file contains the implementation of class Channel.
//
// Copyright (C) 2006, 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"
#endif

#include "Channel.h"
#include "MessageIn.h"
#include "keys.h"
#include "Identity.h"
#include "ClientSession.h"
#include "exceptions.h"

//! @brief Received a channel message.
//
// This function is called when a new message is received
// from the client with this channel as target.
void Channel::new_client_message_received(ClientMessageIn const& msg)
{
  DoutEntering(dc::debug, "Channel::new_client_message_received(" << msg << ") for target \"" << in_name(msg.client_session()) << "\".");

  using namespace keys;

  switch (msg.key())
  {
    case JOIN:
    {
      Prefix prefix(msg);
      ASSERT(prefix.empty() || prefix.get_nick()->is_me());
      ClientSession::joined_channels_type::iterator iter = identity().client_session().joined_channels().find(msg.param(0));
      if (iter == identity().client_session().joined_channels().end())
      {
        // Pass the JOIN on as-is for unknown channel.
        MessageOut msgout(default_priority(msg.key()));
        identity().server_session().queue_msg(msgout << prefix << msg.key() << msg.params(0));
      }
      else
        Dout(dc::warning, "Ignoring a JOIN for a channel that we are already on.");
      break;
    }
    case MODE:
    case PRIVMSG:
    case NOTICE:
    case PART:
    case CPRIVMSG:
    case CNOTICE:
    case KICK:
    case NAMES:
    case TOPIC:
    {
      // FIXME.
      // For now, just pass it to the server as-is.

      // Extract the prefix of the input message.
      Prefix prefix(msg);
      // Construct a message with default priority.
      MessageOut msgout(default_priority(msg.key()));
      // Pass the message to the server.
      identity().server_session().queue_msg(msgout << prefix << msg.key() << msg.params(0));
      break;
    }
  }
}

//! @brief Received a channel message.
//
// This function is called when a new message is received
// from the server with this channel as target.
void Channel::new_server_message_received(ServerMessageIn const& msg)
{
  DoutEntering(dc::debug, "Channel::new_server_message_received(" << msg << ") for target \"" << in_name(msg.server_session()) << "\".");

  using namespace keys;

  switch (msg.key())
  {
    case PART:
    {
      Prefix prefix(msg);
      boost::shared_ptr<Nick> nick(prefix.get_nick());
      MessageOut msgout(default_priority(msg.key()));
      identity().client_session().queue_msg(msgout << prefix << msg.key() << msg.params(0));
      if (nick->is_me())
        sub_channel(identity());
      else
        sub_joined_nick(nick);
      break;
    }
    case JOIN:
    {
      Prefix prefix(msg);
      boost::shared_ptr<Nick> nick(prefix.get_nick());
      boost::shared_ptr<Channel> channel = Target::serverside_get_channel(identity(), msg.param(0), false);
      MessageOut msgout(default_priority(msg.key()));
      identity().client_session().queue_msg(msgout << prefix << msg.key() << channel);
      Target::add_joined_nick(identity(), nick->in_name(msg.server_session()), channel);
      break;
    }
    case KICK:
    {
      Prefix prefix(msg);
      boost::shared_ptr<Channel> channel = Target::serverside_get_channel(identity(), msg.param(0), false);
      boost::shared_ptr<Nick> nick = Target::get_joined_nick(identity(), msg.param(1), channel);
      MessageOut msgout(default_priority(msg.key()));
      identity().client_session().queue_msg(msgout << prefix << msg.key() << channel << nick << msg.params(2));
      if (nick->is_me())
        sub_channel(identity());
      else
        sub_joined_nick(nick);
      break;
    }
    case PRIVMSG:
    {
      std::string prefix(msg.prefix_str());
      std::string::size_type pos = prefix.find('!');
      std::string text(msg.param(1));
      if (pos != std::string::npos)
      {
        ++pos;
        if (prefix[pos] == '~')
          ++pos;
      }
      if (pos != std::string::npos &&
          (prefix.substr(pos) == "carlo@10.11.0.4" || prefix.substr(pos) == "carlo@terp.frl" || prefix.substr(pos) == "carlo@aleric.users.undernet.org") &&
          text[0] == '!')
      {
        std::string::size_type command_end = text.find(' ');
        std::string argument;
        if (command_end != std::string::npos)
        {
          argument = text.substr(command_end + 1);
          --command_end;
        }
        std::string command = text.substr(1, command_end);
        boost::shared_ptr<Channel> channel = Target::serverside_get_channel(identity(), msg.param(0), false);
        MessageOut msgout(default_priority(PRIVMSG));
        if (command == "use_count")
        {
          if (!argument.empty())
          {
            try
            {
              boost::shared_ptr<Channel> channel2 = Target::serverside_get_channel(identity(), argument, false);
              identity().server_session().queue_msg(msgout << PRIVMSG << channel <<
                  ":channel2.use_count() =" << channel2.use_count());
            }
            catch (unknown_target& error)
            {
              Debug(edragon::caught(error));
              identity().server_session().queue_msg(msgout << PRIVMSG << channel << ":No such channel:" << argument);
            }
          }
          else
            identity().server_session().queue_msg(msgout << PRIVMSG << channel <<
                ":channel.use_count() =" << channel.use_count());
        }
        else
        {
          identity().server_session().queue_msg(msgout << PRIVMSG << channel <<
              ":No such command: \"" << JustInTimeCatenate(command) << JustInTimeCatenate("\""));
        }
      }
      /* FALL_THROUGH */
    }
    case MODE:
    case NOTICE:
    case NAMES:
    case TOPIC:
    default:
    {
      Dout(dc::warning, "Unhandled channel message " << msg << ". Passing to client as-is.");
      // Pass to client as-is.
      Prefix prefix(msg);
      MessageOut msgout(default_priority(msg.key()));
      identity().client_session().queue_msg(msgout << prefix << msg.key() << msg.params(0));
    }
  }
}

void Channel::sub_joined_nick(boost::shared_ptr<Nick> nick)
{
#if 0 // FIXME
  DoutEntering(dc::maps|dc::debug, "Channel::sub_joined_nick(" << nick << ") for " << *this);
  nick->sub_channel(*this);
  Channel::members_type::iterator iter = M_members.find(nick->serverside_name());
  ASSERT(iter != M_members.end());
  Dout(dc::maps, "Erasing " << nick->serverside_name() << " from members of " << *this);
  M_members.erase(iter);
#endif
}

---