protocol.cpp

/*
    $Id: protocol_8cpp-source.html,v 1.1 2004/10/05 21:12:02 mentat Exp $

    GNU Messenger - The secure instant messenger
    Copyright (C) 1999-2001 Emil Styrke <emil@lysator.liu.se>
    Copyright (C) 2002-2004 Jesse Lovelace <jesse at aslogicsys dot com>

    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; either version 2 of the License, or
    (at your option) any later version.

    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 <list>

#include "gm/protocol.h"
#include "gm/manager.h"
#include "gm/basenetwork.h"

namespace GNUMessenger {

using namespace std;

Protocol::Protocol(const XMLNode &conf,ProtocolManager *manager,
                   const string &name="unnamedProto"):
  m_conf(conf), m_manager(manager), m_name(name), m_state(S_offline)
{
    if (m_manager) {
        m_manager->addProtocol(this);
    }
}

Protocol::~Protocol()
{
    for(list<Network *>::iterator it = m_nets.begin();
        it != m_nets.end(); it++) {
            if (m_manager)
                m_manager->removeNet(*it);
            else
                delete *it;
            *it = 0;
        }
}

void Protocol::setContacts(vector<Contact>& cnts)
{
    for (unsigned int i = 0; i < cnts.size(); i++) {
        cnts[i].setStatus(getProtocol(), Contact::Offline);
        m_buddies[formatId(cnts[i].getServerId(getProtocol()))] = cnts[i];
    }
    
}

void Protocol::handleData(Network *net, const VBuffer& data)
{   
    handleData(net, string((const char *)data.data(), data.size())); 
}

void Protocol::changeSettings(XMLNode& conf)
{
    m_conf = conf;
    reset();
}

void Protocol::eventLoggedIn()
{
    LOG_DEBUG("Protocol::eventLoggedIn()");
    map<string, Contact>::iterator it = m_buddies.begin();
    
    if (m_manager)
        m_manager->protoLoggedIn(getProtocol());

}

void Protocol::eventLoggedOut()
{
    LOG_DEBUG("Protocol::eventLoggedOut()");
    map<string, Contact>::iterator it = m_buddies.begin();
    for ( ;it != m_buddies.end(); it++)
       (it->second).setStatus(getProtocol(), Contact::Offline);
        
    if (m_manager)
        m_manager->protoLoggedOut(getProtocol());
}

void Protocol::eventRecvdMessageNotBuddy(const Contact &c, const string &message)
{
    LOG_DEBUG("Not buddy msg: " << message);

    if (m_manager != NULL)
        m_manager->protoRecvdMessageAnony(getProtocol(),c,message);
 
}

void Protocol::eventRecvdMessage(const Contact &c, const string &message)
{
    LOG_DEBUG("eventRecvdMessage: " << message);

    if (m_manager != NULL)
        m_manager->protoRecvdMessage(getProtocol(),c,message);
   
}

void Protocol::eventStatusChange(const Contact &c)
{
    if (m_manager)
        m_manager->protoStatusChange(getProtocol(),c);
    else
        LOG_THROW("eventStatusChange pointer is null", PointerError);
}

void Protocol::eventError(int err_no,const string &error)
{
    if (m_manager)
        m_manager->protoError(getProtocol(),err_no,error);
   }

void Protocol::eventStateChange(State state)
{
    m_state = state;
    if (m_manager)
        m_manager->protoStateChange(getProtocol(),state);
}

void Protocol::eventGotPubkey(const Contact& c, const string &key)
{
    if (m_manager)
        m_manager->protoGotPubkey(c,key);
}

void Protocol::eventGotInfo(const Contact& c, const string& info)
{
    if (m_manager)
        m_manager->protoGotInfo(c, info, getProtocol());
}

Network *Protocol::addNet()
{
    Network *n = m_manager->createNet(this);

    n->setOwner(this);
    m_nets.push_back(n);
    
    return n;
}

void Protocol::removeNet(Network *n)
{
    m_nets.remove(n);
    m_manager->removeNet(n);

}

void Protocol::eventGotContacts(const vector<buddy>& c)
{
    if (m_manager)
        m_manager->protoGotContacts(getProtocol(), c);
}

void Protocol::eventGotCustom(const XMLNode &n)
{
    if (m_manager)
        m_manager->protoCustom(getProtocol(),n);
}

unsigned long Protocol::getSentBytes() const
{
    unsigned long temp = 0;
    for(list<Network *>::const_iterator it = m_nets.begin();
        it != m_nets.end(); it++) {
            temp += (*it)->getSentBytes();
        }
    return temp;
}

unsigned long Protocol::getSentPackets() const
{
    unsigned long temp = 0;
    for(list<Network *>::const_iterator it = m_nets.begin();
        it != m_nets.end(); it++) {
            temp += (*it)->getSentPackets();
        }
    return temp;
}

unsigned long Protocol::getRecvBytes() const
{
    unsigned long temp = 0;
    for(list<Network *>::const_iterator it = m_nets.begin();
        it != m_nets.end(); it++) {
            temp += (*it)->getRecvBytes();
        }
    return temp;
}

unsigned long Protocol::getRecvPackets() const
{
    unsigned long temp = 0;
    for(list<Network *>::const_iterator it = m_nets.begin();
        it != m_nets.end(); it++) {
            temp += (*it)->getRecvPackets();
        }   
    return temp;
}

vector<string> Protocol::getRemoteIPs() const 
{
    vector<string> ips;
    for(list<Network *>::const_iterator it = m_nets.begin();
        it != m_nets.end(); it++) {
            ips.push_back((*it)->getRemoteIP());
        }   
    return ips;
}

} // !GNUMessenger
/*
    -----
    $Log: protocol.cpp,v $
    Revision 1.4  2004/10/04 05:14:20  mentat
    Adding info get support and HTTP.

    Revision 1.3  2004/10/03 18:39:40  mentat
    Merging in hash_map changes to TOC and getInfo methods.

    Revision 1.2.2.1  2004/10/03 18:36:03  mentat
    Added hash_map to toc protocol and working in getInfo methods.

    Revision 1.2  2004/10/03 15:22:57  mentat
    Fixed a pure virtual function error and improved TOC.

    Revision 1.1.1.1  2004/10/03 06:17:37  mentat
    Initial re-import.

    Revision 1.3  2003/04/13 18:43:58  mentat
    Heavy commits.

    Revision 1.2  2003/04/09 21:19:56  mentat
    Updating to compile.

    Revision 1.1  2003/03/02 16:19:05  mentat
    Importing new sources.



*/

---