X-Git-Url: https://arthur.barton.de/cgi-bin/gitweb.cgi?p=ngircd-alex.git;a=blobdiff_plain;f=src%2Fngircd%2Firc-write.c;h=526e2fb694bdf948ccf957f6fafb9a8ca5571d25;hp=1292e43c232a79a038c0549421eb9a5540aa505a;hb=904c8a4375cb9deed64007b06c6a7ba42313d93d;hpb=ca33cbda05902b0009058d369f88c0a7a43b1bbe diff --git a/src/ngircd/irc-write.c b/src/ngircd/irc-write.c index 1292e43c..526e2fb6 100644 --- a/src/ngircd/irc-write.c +++ b/src/ngircd/irc-write.c @@ -1,98 +1,232 @@ /* * ngIRCd -- The Next Generation IRC Daemon - * Copyright (c)2001,2002 by Alexander Barton (alex@barton.de) + * Copyright (c)2001-2013 Alexander Barton (alex@barton.de) and Contributors. * - * Dieses Programm ist freie Software. Sie koennen es unter den Bedingungen - * der GNU General Public License (GPL), wie von der Free Software Foundation - * herausgegeben, weitergeben und/oder modifizieren, entweder unter Version 2 - * der Lizenz oder (wenn Sie es wuenschen) jeder spaeteren Version. - * Naehere Informationen entnehmen Sie bitter der Datei COPYING. Eine Liste - * der an ngIRCd beteiligten Autoren finden Sie in der Datei AUTHORS. - * - * $Id: irc-write.c,v 1.2 2002/03/12 14:37:52 alex Exp $ - * - * irc-write.c: IRC-Texte und Befehle ueber Netzwerk versenden + * 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. + * Please read the file COPYING, README and AUTHORS for more information. */ - #include "portab.h" +/** + * @file + * Sending IRC commands over the network + */ + #include "imp.h" #include -#include +#ifdef PROTOTYPES +# include +#else +# include +#endif #include +#include #include "defines.h" +#include "conn-func.h" +#include "channel.h" #include "exp.h" #include "irc-write.h" +#define SEND_TO_USER 1 +#define SEND_TO_SERVER 2 -CHAR *Get_Prefix( CLIENT *Target, CLIENT *Client ); - +static const char *Get_Prefix PARAMS((CLIENT *Target, CLIENT *Client)); +static void cb_writeStrServersPrefixFlag PARAMS((CLIENT *Client, + CLIENT *Prefix, void *Buffer)); +static void Send_Marked_Connections PARAMS((CLIENT *Prefix, const char *Buffer)); -GLOBAL BOOLEAN IRC_WriteStrClient( CLIENT *Client, CHAR *Format, ... ) +/** + * Send an error message to a client and enforce a penalty time. + * + * @param Client The target client. + * @param Format Format string. + * @return CONNECTED or DISCONNECTED. + */ +#ifdef PROTOTYPES +GLOBAL bool +IRC_WriteErrClient( CLIENT *Client, const char *Format, ... ) +#else +GLOBAL bool +IRC_WriteErrClient( Client, Format, va_alist ) +CLIENT *Client; +const char *Format; +va_dcl +#endif { - CHAR buffer[1000]; - BOOLEAN ok = CONNECTED; + char buffer[1000]; va_list ap; - assert( Client != NULL ); - assert( Format != NULL ); + assert(Client != NULL); + assert(Format != NULL); - va_start( ap, Format ); - vsnprintf( buffer, 1000, Format, ap ); - va_end( ap ); +#ifdef PROTOTYPES + va_start(ap, Format); +#else + va_start(ap); +#endif + vsnprintf(buffer, 1000, Format, ap); + va_end(ap); + + IRC_SetPenalty(Client, 2); + return IRC_WriteStrClientPrefix(Client, Client_ThisServer(), + "%s", buffer); +} - /* an den Client selber */ - ok = IRC_WriteStrClientPrefix( Client, Client_ThisServer( ), buffer ); +/** + * Send a message to a client. + * + * @param Client The target client. + * @param Format Format string. + * @return CONNECTED or DISCONNECTED. + */ +#ifdef PROTOTYPES +GLOBAL bool +IRC_WriteStrClient( CLIENT *Client, const char *Format, ... ) +#else +GLOBAL bool +IRC_WriteStrClient( Client, Format, va_alist ) +CLIENT *Client; +const char *Format; +va_dcl +#endif +{ + char buffer[1000]; + va_list ap; - return ok; -} /* IRC_WriteStrClient */ + assert(Client != NULL); + assert(Format != NULL); +#ifdef PROTOTYPES + va_start(ap, Format); +#else + va_start(ap); +#endif + vsnprintf(buffer, 1000, Format, ap); + va_end(ap); -GLOBAL BOOLEAN IRC_WriteStrClientPrefix( CLIENT *Client, CLIENT *Prefix, CHAR *Format, ... ) + return IRC_WriteStrClientPrefix(Client, Client_ThisServer(), + "%s", buffer); +} + +/** + * Send a message to a client using a specific prefix. + * + * @param Client The target client. + * @param Prefix The prefix to use. + * @param Format Format string. + * @return CONNECTED or DISCONNECTED. + */ +#ifdef PROTOTYPES +GLOBAL bool +IRC_WriteStrClientPrefix(CLIENT *Client, CLIENT *Prefix, const char *Format, ...) +#else +GLOBAL bool +IRC_WriteStrClientPrefix(Client, Prefix, Format, va_alist) +CLIENT *Client; +CLIENT *Prefix; +const char *Format; +va_dcl +#endif { - /* Text an Clients, lokal bzw. remote, senden. */ + /* send text to local and remote clients */ - CHAR buffer[1000]; + char buffer[1000]; va_list ap; assert( Client != NULL ); assert( Format != NULL ); assert( Prefix != NULL ); +#ifdef PROTOTYPES va_start( ap, Format ); +#else + va_start( ap ); +#endif vsnprintf( buffer, 1000, Format, ap ); va_end( ap ); - return Conn_WriteStr( Client_Conn( Client_NextHop( Client )), ":%s %s", Get_Prefix( Client_NextHop( Client ), Prefix ), buffer ); -} /* IRC_WriteStrClientPrefix */ + return Conn_WriteStr(Client_Conn(Client_NextHop(Client)), ":%s %s", + Get_Prefix(Client_NextHop(Client), Prefix), buffer); +} - -GLOBAL BOOLEAN IRC_WriteStrChannel( CLIENT *Client, CHANNEL *Chan, BOOLEAN Remote, CHAR *Format, ... ) +/** + * Send a message to all client in a channel. + * + * The message is only sent once per remote server. + * + * @param Client The sending client, excluded while forwarding the message. + * @param Channel The target channel. + * @param Remote If not set, the message is sent to local clients only. + * @param Format Format string. + */ +#ifdef PROTOTYPES +GLOBAL void +IRC_WriteStrChannel(CLIENT *Client, CHANNEL *Chan, bool Remote, + const char *Format, ...) +#else +GLOBAL void +IRC_WriteStrChannel(Client, Chan, Remote, Format, va_alist) +CLIENT *Client; +CHANNEL *Chan; +bool Remote; +const char *Format; +va_dcl +#endif { - CHAR buffer[1000]; + char buffer[1000]; va_list ap; assert( Client != NULL ); assert( Format != NULL ); +#ifdef PROTOTYPES va_start( ap, Format ); +#else + va_start( ap ); +#endif vsnprintf( buffer, 1000, Format, ap ); va_end( ap ); - return IRC_WriteStrChannelPrefix( Client, Chan, Client_ThisServer( ), Remote, buffer ); -} /* IRC_WriteStrChannel */ - + IRC_WriteStrChannelPrefix(Client, Chan, Client_ThisServer(), + Remote, "%s", buffer); +} -GLOBAL BOOLEAN IRC_WriteStrChannelPrefix( CLIENT *Client, CHANNEL *Chan, CLIENT *Prefix, BOOLEAN Remote, CHAR *Format, ... ) +/** + * Send a message to all client in a channel using a specific prefix. + * + * The message is only sent once per remote server. + * + * @param Client The sending client, excluded while forwarding the message. + * @param Channel The target channel. + * @param Prefix The prefix to use. + * @param Remote If not set, the message is sent to local clients only. + * @param Format Format string. + */ +#ifdef PROTOTYPES +GLOBAL void +IRC_WriteStrChannelPrefix(CLIENT *Client, CHANNEL *Chan, CLIENT *Prefix, + bool Remote, const char *Format, ...) +#else +GLOBAL void +IRC_WriteStrChannelPrefix(Client, Chan, Prefix, Remote, Format, va_alist) +CLIENT *Client; +CHANNEL *Chan; +CLIENT *Prefix; +bool Remote; +const char *Format; +va_dcl +#endif { - BOOLEAN sock[MAX_CONNECTIONS], is_server[MAX_CONNECTIONS], ok = CONNECTED; - CHAR buffer[1000]; + char buffer[1000]; CL2CHAN *cl2chan; + CONN_ID conn; CLIENT *c; - INT s, i; va_list ap; assert( Client != NULL ); @@ -100,121 +234,231 @@ GLOBAL BOOLEAN IRC_WriteStrChannelPrefix( CLIENT *Client, CHANNEL *Chan, CLIENT assert( Prefix != NULL ); assert( Format != NULL ); +#ifdef PROTOTYPES va_start( ap, Format ); +#else + va_start( ap ); +#endif vsnprintf( buffer, 1000, Format, ap ); va_end( ap ); - for( i = 0; i < MAX_CONNECTIONS; i++ ) sock[i] = FALSE; + Conn_ClearFlags( ); - /* An alle Clients, die in den selben Channels sind. - * Dabei aber nur einmal je Remote-Server */ cl2chan = Channel_FirstMember( Chan ); - while( cl2chan ) - { + while(cl2chan) { c = Channel_GetClient( cl2chan ); - if( ! Remote ) - { - if( Client_Conn( c ) <= NONE ) c = NULL; - else if( Client_Type( c ) == CLIENT_SERVER ) c = NULL; + if (!Remote) { + if (Client_Conn(c) <= NONE) + c = NULL; + else if(Client_Type(c) == CLIENT_SERVER) + c = NULL; } - if( c ) c = Client_NextHop( c ); - - if( c && ( c != Client )) - { - /* Ok, anderer Client */ - s = Client_Conn( c ); - assert( s >= 0 ); - assert( s < MAX_CONNECTIONS ); - sock[s] = TRUE; - if( Client_Type( c ) == CLIENT_SERVER ) is_server[s] = TRUE; - else is_server[s] = FALSE; + if(c) + c = Client_NextHop(c); + + if(c && c != Client) { + /* Ok, another Client */ + conn = Client_Conn(c); + if (Client_Type(c) == CLIENT_SERVER) + Conn_SetFlag(conn, SEND_TO_SERVER); + else + Conn_SetFlag(conn, SEND_TO_USER); } - cl2chan = Channel_NextMember( Chan, cl2chan ); + cl2chan = Channel_NextMember(Chan, cl2chan); } + Send_Marked_Connections(Prefix, buffer); +} - /* Senden ... */ - for( i = 0; i < MAX_CONNECTIONS; i++ ) - { - if( sock[i] ) - { - if( is_server[i] ) ok = Conn_WriteStr( i, ":%s %s", Client_ID( Prefix ), buffer ); - else ok = Conn_WriteStr( i, ":%s %s", Client_Mask( Prefix ), buffer ); - if( ! ok ) break; - } - } - return ok; -} /* IRC_WriteStrChannelPrefix */ +/** + * Send a message to all the servers in the network. + * + * @param Client The sending client, excluded while forwarding the message. + * @param Format Format string. + */ +#ifdef PROTOTYPES +GLOBAL void +IRC_WriteStrServers(CLIENT *ExceptOf, const char *Format, ...) +#else +GLOBAL void +IRC_WriteStrServers(ExceptOf, Format, va_alist) +CLIENT *ExceptOf; +const char *Format; +va_dcl +#endif +{ + char buffer[1000]; + va_list ap; + + assert( Format != NULL ); + +#ifdef PROTOTYPES + va_start( ap, Format ); +#else + va_start( ap ); +#endif + vsnprintf( buffer, 1000, Format, ap ); + va_end( ap ); + IRC_WriteStrServersPrefix(ExceptOf, Client_ThisServer(), "%s", buffer); +} -GLOBAL VOID IRC_WriteStrServers( CLIENT *ExceptOf, CHAR *Format, ... ) +/** + * Send a message to all the servers in the network using a specific prefix. + * + * @param Client The sending client, excluded while forwarding the message. + * @param Prefix The prefix to use. + * @param Format Format string. + */ +#ifdef PROTOTYPES +GLOBAL void +IRC_WriteStrServersPrefix(CLIENT *ExceptOf, CLIENT *Prefix, + const char *Format, ...) +#else +GLOBAL void +IRC_WriteStrServersPrefix(ExceptOf, Prefix, Format, va_alist) +CLIENT *ExceptOf; +CLIENT *Prefix; +const char *Format; +va_dcl +#endif { - CHAR buffer[1000]; + char buffer[1000]; va_list ap; assert( Format != NULL ); + assert( Prefix != NULL ); +#ifdef PROTOTYPES va_start( ap, Format ); +#else + va_start( ap ); +#endif vsnprintf( buffer, 1000, Format, ap ); va_end( ap ); - /* an den Client selber */ - return IRC_WriteStrServersPrefix( ExceptOf, Client_ThisServer( ), buffer ); -} /* IRC_WriteStrServers */ + IRC_WriteStrServersPrefixFlag( ExceptOf, Prefix, '\0', "%s", buffer ); +} - -GLOBAL VOID IRC_WriteStrServersPrefix( CLIENT *ExceptOf, CLIENT *Prefix, CHAR *Format, ... ) +/** + * Send a message to all the servers in the network using a specific prefix + * and matching a "client flag". + * + * @param Client The sending client, excluded while forwarding the message. + * @param Prefix The prefix to use. + * @param Flag Client flag that must be set on the target. + * @param Format Format string. + */ +#ifdef PROTOTYPES +GLOBAL void +IRC_WriteStrServersPrefixFlag(CLIENT *ExceptOf, CLIENT *Prefix, char Flag, + const char *Format, ...) +#else +GLOBAL void +IRC_WriteStrServersPrefixFlag(ExceptOf, Prefix, Flag, Format, va_alist) +CLIENT *ExceptOf; +CLIENT *Prefix; +char Flag; +const char *Format; +va_dcl +#endif { - CHAR buffer[1000]; - CLIENT *c; + char buffer[1000]; va_list ap; - + assert( Format != NULL ); assert( Prefix != NULL ); +#ifdef PROTOTYPES va_start( ap, Format ); +#else + va_start( ap ); +#endif vsnprintf( buffer, 1000, Format, ap ); va_end( ap ); - - c = Client_First( ); - while( c ) - { - if(( Client_Type( c ) == CLIENT_SERVER ) && ( Client_Conn( c ) > NONE ) && ( c != Client_ThisServer( )) && ( c != ExceptOf )) - { - /* Ziel-Server gefunden */ - IRC_WriteStrClientPrefix( c, Prefix, buffer ); + + IRC_WriteStrServersPrefixFlag_CB(ExceptOf, Prefix, Flag, + cb_writeStrServersPrefixFlag, buffer); +} + +/** + * Send a message to all the servers in the network using a specific prefix + * and matching a "client flag" using a callback function. + * + * @param Client The sending client, excluded while forwarding the message. + * @param Prefix The prefix to use. + * @param Flag Client flag that must be set on the target. + * @param callback Callback function. + * @param Format Format string. + */ +GLOBAL void +IRC_WriteStrServersPrefixFlag_CB(CLIENT *ExceptOf, CLIENT *Prefix, char Flag, + void (*callback)(CLIENT *, CLIENT *, void *), void *cb_data) +{ + CLIENT *c; + + c = Client_First(); + while(c) { + if (Client_Type(c) == CLIENT_SERVER && Client_Conn(c) > NONE && + c != Client_ThisServer() && c != ExceptOf) { + /* Found a target server, do the flags match? */ + if (Flag == '\0' || Client_HasFlag(c, Flag)) + callback(c, Prefix, cb_data); } - c = Client_Next( c ); + c = Client_Next(c); } -} /* IRC_WriteStrServersPrefix */ - +} -GLOBAL BOOLEAN IRC_WriteStrRelatedPrefix( CLIENT *Client, CLIENT *Prefix, BOOLEAN Remote, CHAR *Format, ... ) +/** + * Send a message to all "related" clients. + * + * Related clients are the one that share one ore more channels with the client + * sending this message. + * + * The message is only sent once per remote server. + * + * @param Client The sending client, excluded while forwarding the message. + * @param Prefix The prefix to use. + * @param Remote If not set, the message is sent to local clients only. + * @param Format Format string. + */ +#ifdef PROTOTYPES +GLOBAL void +IRC_WriteStrRelatedPrefix(CLIENT *Client, CLIENT *Prefix, bool Remote, + const char *Format, ...) +#else +GLOBAL void +IRC_WriteStrRelatedPrefix(Client, Prefix, Remote, Format, va_alist) +CLIENT *Client; +CLIENT *Prefix; +bool Remote; +const char *Format; +va_dcl +#endif { - BOOLEAN sock[MAX_CONNECTIONS], is_server[MAX_CONNECTIONS], ok = CONNECTED; CL2CHAN *chan_cl2chan, *cl2chan; - CHAR buffer[1000]; + char buffer[1000]; CHANNEL *chan; + CONN_ID conn; va_list ap; CLIENT *c; - INT i, s; assert( Client != NULL ); assert( Prefix != NULL ); assert( Format != NULL ); +#ifdef PROTOTYPES va_start( ap, Format ); +#else + va_start( ap ); +#endif vsnprintf( buffer, 1000, Format, ap ); va_end( ap ); - /* initialisieren */ - for( i = 0; i < MAX_CONNECTIONS; i++ ) sock[i] = FALSE; + Conn_ClearFlags( ); - /* An alle Clients, die in einem Channel mit dem "Ausloeser" sind, - * den Text schicken. An Remote-Server aber jeweils nur einmal. */ chan_cl2chan = Channel_FirstChannelOf( Client ); while( chan_cl2chan ) { - /* Channel des Users durchsuchen */ chan = Channel_GetChannel( chan_cl2chan ); cl2chan = Channel_FirstMember( chan ); while( cl2chan ) @@ -229,43 +473,133 @@ GLOBAL BOOLEAN IRC_WriteStrRelatedPrefix( CLIENT *Client, CLIENT *Prefix, BOOLEA if( c && ( c != Client )) { - /* Ok, anderer Client */ - s = Client_Conn( c ); - assert( s >= 0 ); - assert( s < MAX_CONNECTIONS ); - sock[s] = TRUE; - if( Client_Type( c ) == CLIENT_SERVER ) is_server[s] = TRUE; - else is_server[s] = FALSE; + conn = Client_Conn( c ); + if( Client_Type( c ) == CLIENT_SERVER ) Conn_SetFlag( conn, SEND_TO_SERVER ); + else Conn_SetFlag( conn, SEND_TO_USER ); } cl2chan = Channel_NextMember( chan, cl2chan ); } - - /* naechsten Channel */ + chan_cl2chan = Channel_NextChannelOf( Client, chan_cl2chan ); } + Send_Marked_Connections(Prefix, buffer); +} /* IRC_WriteStrRelatedPrefix */ - /* Senden ... */ - for( i = 0; i < MAX_CONNECTIONS; i++ ) - { - if( sock[i] ) - { - if( is_server[i] ) ok = Conn_WriteStr( i, ":%s %s", Client_ID( Prefix ), buffer ); - else ok = Conn_WriteStr( i, ":%s %s", Client_Mask( Prefix ), buffer ); - if( ! ok ) break; +/** + * Send WALLOPS message. + * + * @param Client The sending client, excluded while forwarding the message. + * @param From The (remote) sender of the message. + * @param Format Format string. +*/ +#ifdef PROTOTYPES +GLOBAL void +IRC_SendWallops(CLIENT *Client, CLIENT *From, const char *Format, ...) +#else +GLOBAL void +IRC_SendWallops(Client, From, Format, va_alist ) +CLIENT *Client; +CLIENT *From; +const char *Format; +va_dcl +#endif +{ + va_list ap; + char msg[1000]; + CLIENT *to; + +#ifdef PROTOTYPES + va_start(ap, Format); +#else + va_start(ap); +#endif + vsnprintf(msg, 1000, Format, ap); + va_end(ap); + + for (to=Client_First(); to != NULL; to=Client_Next(to)) { + if (Client_Conn(to) == NONE) /* no local connection */ + continue; + + switch (Client_Type(to)) { + case CLIENT_USER: + if (Client_HasMode(to, 'w')) + IRC_WriteStrClientPrefix(to, From, + "WALLOPS :%s", msg); + break; + case CLIENT_SERVER: + if (to != Client) + IRC_WriteStrClientPrefix(to, From, + "WALLOPS :%s", msg); + break; } } - return ok; -} /* IRC_WriteStrRelatedPrefix */ - +} /* IRC_SendWallops */ -CHAR *Get_Prefix( CLIENT *Target, CLIENT *Client ) +/** + * Set a "penalty time" for an IRC client. + * + * Note: penalty times are never set for server links! + * + * @param Client The client. + * @param Seconds The additional "penalty time" to enforce. + */ +GLOBAL void +IRC_SetPenalty( CLIENT *Client, time_t Seconds ) { - assert( Target != NULL ); + CONN_ID c; + assert( Client != NULL ); + assert( Seconds > 0 ); + + if( Client_Type( Client ) == CLIENT_SERVER ) return; + + c = Client_Conn( Client ); + if (c > NONE) + Conn_SetPenalty(c, Seconds); +} /* IRC_SetPenalty */ - if( Client_Type( Target ) == CLIENT_SERVER ) return Client_ID( Client ); - else return Client_Mask( Client ); +static const char * +Get_Prefix(CLIENT *Target, CLIENT *Client) +{ + assert (Target != NULL); + assert (Client != NULL); + + if (Client_Type(Target) == CLIENT_SERVER) + return Client_ID(Client); + else + return Client_MaskCloaked(Client); } /* Get_Prefix */ +static void +cb_writeStrServersPrefixFlag(CLIENT *Client, CLIENT *Prefix, void *Buffer) +{ + IRC_WriteStrClientPrefix(Client, Prefix, "%s", Buffer); +} /* cb_writeStrServersPrefixFlag */ + +/** + * Send a message to all marked connections using a specific prefix. + * + * @param Prefix The prefix to use. + * @param Buffer The message to send. + */ +static void +Send_Marked_Connections(CLIENT *Prefix, const char *Buffer) +{ + CONN_ID conn; + + assert(Prefix != NULL); + assert(Buffer != NULL); + + conn = Conn_First(); + while (conn != NONE) { + if (Conn_Flag(conn) == SEND_TO_SERVER) + Conn_WriteStr(conn, ":%s %s", + Client_ID(Prefix), Buffer); + else if (Conn_Flag(conn) == SEND_TO_USER) + Conn_WriteStr(conn, ":%s %s", + Client_MaskCloaked(Prefix), Buffer); + conn = Conn_Next(conn); + } +} /* -eof- */