connection.h

Go to the documentation of this file.

/*       +------------------------------------+
 *       | Inspire Internet Relay Chat Daemon |
 *       +------------------------------------+
 *
 *  Inspire is copyright (C) 2002-2004 ChatSpike-Dev.
 *                       E-mail:
 *                <brain@chatspike.net>
 *                <Craig@chatspike.net>
 *     
 * Written by Craig Edwards, Craig McLure, and others.
 * This program is free but copyrighted software; see
 *            the file COPYING for details.
 *
 * ---------------------------------------------------
 */

#include "inspircd_config.h"
#include "base.h"
#include <string>
#include <map>
#include <sys/types.h>
#include <sys/socket.h>
#include <netdb.h>
#include <netinet/in.h>
#include <unistd.h>
#include <errno.h>
#include <time.h>
#include <vector>
#include <deque>
#include <sstream>

#ifndef __CONNECTION_H__
#define __CONNECTION_H__

#define STATE_DISCONNECTED      0
#define STATE_CONNECTED         1
#define STATE_SYNC              2
#define STATE_NOAUTH_INBOUND    3
#define STATE_NOAUTH_OUTBOUND   4
#define STATE_SERVICES          5

class ircd_connector : public Extensible
{
 private:
        sockaddr_in addr;
        
        int fd;
        
        std::string servername;
        
        std::string description;
        
        char state;
        
        bool SetHostAddress(char* host, int port);

        std::string version;

 public:

        std::string ircdbuffer;

 
        char host[MAXBUF];

        int port;
        
        std::vector<std::string> routes;
        

        bool MakeOutboundConnection(char* newhost, int newport);
        
        std::string GetServerName();
        
        void SetServerName(std::string serv);
        
        int GetDescriptor();
        
        void SetDescriptor(int fd);
        
        int GetState();
        
        void SetState(int state);
        
        char* GetServerIP();
        
        std::string GetDescription();
        
        void SetDescription(std::string desc);
        
        int GetServerPort();
        
        void SetServerPort(int p);
        
        bool SetHostAndPort(char* newhost, int newport);
        
        void CloseConnection();

        void AddBuffer(std::string a);

        bool BufferIsComplete();

        void ClearBuffer();

        std::string GetBuffer();

        void SetVersionString(std::string newversion);

        std::string GetVersionString();
};


class connection : public Extensible
{
 public:
        int fd;
        
        char host[160];
        
        char ip[16];
        
        long bytes_in;

        long bytes_out;

        long cmds_in;

        long cmds_out;

        bool haspassed;

        int port;
        
        char registered;
        
        time_t lastping;
        
        time_t signon;
        
        time_t idle_lastmsg;
        
        time_t nping;
        
        std::vector<ircd_connector> connectors;
        
        connection();
        
        bool CreateListener(char* host, int p);
        
        bool BeginLink(char* targethost, int port, char* password, char* servername, int myport);
        
        bool MeshCookie(char* targethost, int port, unsigned long cookie, char* servername);
        
        void TerminateLink(char* targethost);
        
        bool SendPacket(char *message, const char* host);
        
        bool RecvPacket(std::deque<std::string> &messages, char* host);
        
        ircd_connector* FindHost(std::string host);
        
        bool AddIncoming(int fd,char* targethost, int sourceport);
        
};


#endif

---