trunk/modules/m_connect.c

/*
 *  ircd-hybrid: an advanced Internet Relay Chat Daemon(ircd).
 *  m_connect.c: Connects to a remote IRC server.
 *
 *  Copyright (C) 2002 by the past and present ircd coders, and others.
 *
 *  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
 *
 *  $Id$
 */

#include "stdinc.h"
#include "handlers.h"
#include "client.h"
#include "ircd.h"
#include "irc_string.h"
#include "numeric.h"
#include "fdlist.h"
#include "s_bsd.h"
#include "s_conf.h"
#include "s_log.h"
#include "s_serv.h"
#include "send.h"
#include "msg.h"
#include "parse.h"
#include "hash.h"
#include "modules.h"

static void mo_connect(struct Client *, struct Client *, int, char *[]);
static void ms_connect(struct Client *, struct Client *, int, char *[]);

struct Message connect_msgtab = {
  "CONNECT", 0, 0, 2, 0, MFLG_SLOW, 0,
  { m_unregistered, m_not_oper, ms_connect, m_ignore, mo_connect, m_ignore }
};

#ifndef STATIC_MODULES
void
_modinit(void)
{
  mod_add_cmd(&connect_msgtab);
}

void
_moddeinit(void)
{
  mod_del_cmd(&connect_msgtab);
}

const char *_version = "$Revision$";
#endif

/*
 * mo_connect - CONNECT command handler
 * 
 * Added by Jto 11 Feb 1989
 *
 * m_connect
 *      parv[0] = sender prefix
 *      parv[1] = servername
 *      parv[2] = port number
 *      parv[3] = remote server
 */
static void
mo_connect(struct Client *client_p, struct Client *source_p,
           int parc, char *parv[])
{
  int port;
  int tmpport;
  struct ConfItem *conf = NULL;
  struct AccessItem *aconf = NULL;
  const struct Client *target_p = NULL;

  if (EmptyString(parv[1]))
  {
    sendto_one(source_p, form_str(ERR_NEEDMOREPARAMS),
               me.name, source_p->name, "CONNECT");
    return;
  }

  if (parc > 3)
  {
    if (!IsOperRemote(source_p))
    {
      sendto_one(source_p, form_str(ERR_NOPRIVS),
                 me.name, source_p->name, "connect");
      return;
    }

    if (hunt_server(client_p, source_p, ":%s CONNECT %s %s :%s", 3,
                    parc, parv) != HUNTED_ISME)
      return;
  }

  if ((target_p = find_server(parv[1])))
  {
    sendto_one(source_p,
               ":%s NOTICE %s :Connect: Server %s already exists from %s.",
               me.name, source_p->name, parv[1], target_p->from->name);
    return;
  }

  /*
   * try to find the name, then host, if both fail notify ops and bail
   */
  if ((conf = find_matching_name_conf(SERVER_TYPE,
                                      parv[1], NULL, NULL, 0)) != NULL)
    aconf = (struct AccessItem *)map_to_conf(conf);
  else if ((conf = find_matching_name_conf(SERVER_TYPE,
                                           NULL, NULL, parv[1], 0)) != NULL)
    aconf = (struct AccessItem *)map_to_conf(conf);
  
  if (conf == NULL || aconf == NULL)
  {
    sendto_one(source_p,
               ":%s NOTICE %s :Connect: Host %s not listed in ircd.conf",
               me.name, source_p->name, parv[1]);
    return;
  }

  /* Get port number from user, if given. If not specified,
   * use the default form configuration structure. If missing
   * from there, then use the precompiled default.
   */
  tmpport = port = aconf->port;

  if (parc > 2 && !EmptyString(parv[2]))
  {
    if ((port = atoi(parv[2])) <= 0)
    {
      sendto_one(source_p, ":%s NOTICE %s :Connect: Illegal port number",
                 me.name, source_p->name);
      return;
    }
  }
  else if (port <= 0 && (port = PORTNUM) <= 0)
  {
    sendto_one(source_p, ":%s NOTICE %s :Connect: missing port number",
               me.name, source_p->name);
    return;
  }

  if (find_servconn_in_progress(conf->name))
  {
    sendto_one(source_p, ":%s NOTICE %s :Connect: a connection to %s "
               "is already in progress.", me.name, source_p->name, conf->name);
    return;
  }

  /*
   * Notify all operators about remote connect requests
   */
  ilog(L_TRACE, "CONNECT From %s : %s %s", 
       source_p->name, parv[1], parv[2] ? parv[2] : "");

  aconf->port = port;

  /* at this point we should be calling connect_server with a valid
   * C:line and a valid port in the C:line
   */
  if (serv_connect(aconf, source_p))
  {
    if (!ConfigServerHide.hide_server_ips && IsAdmin(source_p))
      sendto_one(source_p, ":%s NOTICE %s :*** Connecting to %s[%s].%d",
                 me.name, source_p->name, aconf->host,
                 conf->name, aconf->port);
    else
      sendto_one(source_p, ":%s NOTICE %s :*** Connecting to %s.%d",
                 me.name, source_p->name, conf->name, aconf->port);
  }
  else
  {
    sendto_one(source_p, ":%s NOTICE %s :*** Couldn't connect to %s.%d",
               me.name, source_p->name, conf->name, aconf->port);
  }

  /* client is either connecting with all the data it needs or has been
   * destroyed
   */
  aconf->port = tmpport;
}

/*
 * ms_connect - CONNECT command handler
 * 
 * Added by Jto 11 Feb 1989
 *
 * m_connect
 *      parv[0] = sender prefix
 *      parv[1] = servername
 *      parv[2] = port number
 *      parv[3] = remote server
 */
static void
ms_connect(struct Client *client_p, struct Client *source_p,
           int parc, char *parv[])
{
  int port;
  int tmpport;
  struct ConfItem *conf = NULL;
  struct AccessItem *aconf = NULL;
  const struct Client *target_p = NULL;

  if (hunt_server(client_p, source_p,
                  ":%s CONNECT %s %s :%s", 3, parc, parv) != HUNTED_ISME)
    return;

  if (*parv[1] == '\0')
  {
    sendto_one(source_p, form_str(ERR_NEEDMOREPARAMS),
               me.name, source_p->name, "CONNECT");
    return;
  }

  if ((target_p = find_server(parv[1])))
  {
    sendto_one(source_p,
               ":%s NOTICE %s :Connect: Server %s already exists from %s.",
               me.name, source_p->name, parv[1], target_p->from->name);
    return;
  }

  /*
   * try to find the name, then host, if both fail notify ops and bail
   */
  if ((conf = find_matching_name_conf(SERVER_TYPE,
                                      parv[1], NULL, NULL, 0)) != NULL)
    aconf = map_to_conf(conf);
  else if ((conf = find_matching_name_conf(SERVER_TYPE,
                                           NULL, NULL, parv[1], 0)) != NULL)
    aconf = map_to_conf(conf);

  if (conf == NULL || aconf == NULL)
  {
    sendto_one(source_p,
               ":%s NOTICE %s :Connect: Host %s not listed in ircd.conf",
               me.name, source_p->name, parv[1]);
    return;
  }

  /* Get port number from user, if given. If not specified,
   * use the default form configuration structure. If missing
   * from there, then use the precompiled default.
   */
  tmpport = port = aconf->port;

  if (parc > 2 && !EmptyString(parv[2]))
  {
    port = atoi(parv[2]);

    /* if someone sends port 0, and we have a config port.. use it */
    if (port == 0 && aconf->port)
      port = aconf->port;
    else if (port <= 0)
    {
      sendto_one(source_p, ":%s NOTICE %s :Connect: Illegal port number",
                 me.name, source_p->name);
      return;
    }
  }
  else if (port <= 0 && (port = PORTNUM) <= 0)
  {
    sendto_one(source_p, ":%s NOTICE %s :Connect: missing port number",
               me.name, source_p->name);
    return;
  }

  if (find_servconn_in_progress(conf->name))
  {
    sendto_one(source_p, ":%s NOTICE %s :Connect: a connection to %s "
               "is already in progress.", me.name, source_p->name, conf->name);
    return;
  }

  /*
   * Notify all operators about remote connect requests
   */
  sendto_wallops_flags(UMODE_WALLOP, &me, "Remote CONNECT %s %d from %s",
                       parv[1], port, source_p->name);
  sendto_server(NULL, NULL, NOCAPS, NOCAPS,
                ":%s WALLOPS :Remote CONNECT %s %d from %s",
                me.name, parv[1], port, source_p->name);

  ilog(L_TRACE, "CONNECT From %s : %s %d", 
       source_p->name, parv[1], port);

  aconf->port = port;

  /*
   * At this point we should be calling connect_server with a valid
   * C:line and a valid port in the C:line
   */
  if (serv_connect(aconf, source_p))
    sendto_one(source_p, ":%s NOTICE %s :*** Connecting to %s.%d",
               me.name, source_p->name, conf->name, aconf->port);
  else
    sendto_one(source_p, ":%s NOTICE %s :*** Couldn't connect to %s.%d",
               me.name, source_p->name, conf->name, aconf->port);
  /*
   * Client is either connecting with all the data it needs or has been
   * destroyed
   */
  aconf->port = tmpport;
}

Revision:	971
Committed:	Sun Aug 2 23:27:42 2009 UTC (16 years ago) by michael
Content type:	text/x-csrc
Original Path:	*ircd-hybrid-7.2/modules/m_connect.c*
File size:	8843 byte(s)
Log Message:	- cleanup m_connect() while reviewing: remove useless MyConnect() test in mo_connect(). - Fix possible core in mo_connect() in case if there is a ConfItem that doesn't have an AccessItem mapped.
#	User	Rev	Content
1	adx	30	/*
2			* ircd-hybrid: an advanced Internet Relay Chat Daemon(ircd).
3			* m_connect.c: Connects to a remote IRC server.
4			*
5			* Copyright (C) 2002 by the past and present ircd coders, and others.
6			*
7			* This program is free software; you can redistribute it and/or modify
8			* it under the terms of the GNU General Public License as published by
9			* the Free Software Foundation; either version 2 of the License, or
10			* (at your option) any later version.
11			*
12			* This program is distributed in the hope that it will be useful,
13			* but WITHOUT ANY WARRANTY; without even the implied warranty of
14			* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15			* GNU General Public License for more details.
16			*
17			* You should have received a copy of the GNU General Public License
18			* along with this program; if not, write to the Free Software
19			* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
20			* USA
21			*
22	knight	31	* $Id$
23	adx	30	*/
24
25			#include "stdinc.h"
26			#include "handlers.h"
27			#include "client.h"
28			#include "ircd.h"
29			#include "irc_string.h"
30			#include "numeric.h"
31			#include "fdlist.h"
32			#include "s_bsd.h"
33			#include "s_conf.h"
34			#include "s_log.h"
35			#include "s_serv.h"
36			#include "send.h"
37			#include "msg.h"
38			#include "parse.h"
39			#include "hash.h"
40			#include "modules.h"
41
42	michael	971	static void mo_connect(struct Client , struct Client , int, char *[]);
43			static void ms_connect(struct Client , struct Client , int, char *[]);
44	adx	30
45			struct Message connect_msgtab = {
46			"CONNECT", 0, 0, 2, 0, MFLG_SLOW, 0,
47	michael	971	{ m_unregistered, m_not_oper, ms_connect, m_ignore, mo_connect, m_ignore }
48	adx	30	};
49
50			#ifndef STATIC_MODULES
51			void
52			_modinit(void)
53			{
54			mod_add_cmd(&connect_msgtab);
55			}
56
57			void
58			_moddeinit(void)
59			{
60			mod_del_cmd(&connect_msgtab);
61			}
62
63	knight	31	const char *_version = "$Revision$";
64	adx	30	#endif
65
66			/*
67			* mo_connect - CONNECT command handler
68			*
69			* Added by Jto 11 Feb 1989
70			*
71			* m_connect
72			* parv[0] = sender prefix
73			* parv[1] = servername
74			* parv[2] = port number
75			* parv[3] = remote server
76			*/
77			static void
78	michael	971	mo_connect(struct Client client_p, struct Client source_p,
79			int parc, char *parv[])
80	adx	30	{
81			int port;
82			int tmpport;
83			struct ConfItem *conf = NULL;
84			struct AccessItem *aconf = NULL;
85	michael	971	const struct Client *target_p = NULL;
86	adx	30
87	michael	971	if (EmptyString(parv[1]))
88	adx	30	{
89	michael	971	sendto_one(source_p, form_str(ERR_NEEDMOREPARAMS),
90			me.name, source_p->name, "CONNECT");
91	adx	30	return;
92			}
93
94	michael	971	if (parc > 3)
95			{
96			if (!IsOperRemote(source_p))
97			{
98			sendto_one(source_p, form_str(ERR_NOPRIVS),
99			me.name, source_p->name, "connect");
100			return;
101			}
102	adx	30
103	michael	971	if (hunt_server(client_p, source_p, ":%s CONNECT %s %s :%s", 3,
104			parc, parv) != HUNTED_ISME)
105			return;
106	adx	30	}
107
108			if ((target_p = find_server(parv[1])))
109			{
110			sendto_one(source_p,
111			":%s NOTICE %s :Connect: Server %s already exists from %s.",
112			me.name, source_p->name, parv[1], target_p->from->name);
113			return;
114			}
115
116			/*
117			* try to find the name, then host, if both fail notify ops and bail
118			*/
119			if ((conf = find_matching_name_conf(SERVER_TYPE,
120			parv[1], NULL, NULL, 0)) != NULL)
121			aconf = (struct AccessItem *)map_to_conf(conf);
122			else if ((conf = find_matching_name_conf(SERVER_TYPE,
123			NULL, NULL, parv[1], 0)) != NULL)
124			aconf = (struct AccessItem *)map_to_conf(conf);
125
126	michael	971	if (conf == NULL \|\| aconf == NULL)
127	adx	30	{
128			sendto_one(source_p,
129			":%s NOTICE %s :Connect: Host %s not listed in ircd.conf",
130			me.name, source_p->name, parv[1]);
131			return;
132			}
133	michael	971
134	adx	30	/* Get port number from user, if given. If not specified,
135			* use the default form configuration structure. If missing
136			* from there, then use the precompiled default.
137			*/
138			tmpport = port = aconf->port;
139
140			if (parc > 2 && !EmptyString(parv[2]))
141			{
142			if ((port = atoi(parv[2])) <= 0)
143			{
144			sendto_one(source_p, ":%s NOTICE %s :Connect: Illegal port number",
145			me.name, source_p->name);
146			return;
147			}
148			}
149			else if (port <= 0 && (port = PORTNUM) <= 0)
150			{
151			sendto_one(source_p, ":%s NOTICE %s :Connect: missing port number",
152			me.name, source_p->name);
153			return;
154			}
155
156			if (find_servconn_in_progress(conf->name))
157			{
158			sendto_one(source_p, ":%s NOTICE %s :Connect: a connection to %s "
159			"is already in progress.", me.name, source_p->name, conf->name);
160			return;
161			}
162
163			/*
164			* Notify all operators about remote connect requests
165			*/
166			ilog(L_TRACE, "CONNECT From %s : %s %s",
167			source_p->name, parv[1], parv[2] ? parv[2] : "");
168
169			aconf->port = port;
170
171			/* at this point we should be calling connect_server with a valid
172			* C:line and a valid port in the C:line
173			*/
174			if (serv_connect(aconf, source_p))
175			{
176			if (!ConfigServerHide.hide_server_ips && IsAdmin(source_p))
177			sendto_one(source_p, ":%s NOTICE %s :*** Connecting to %s[%s].%d",
178			me.name, source_p->name, aconf->host,
179			conf->name, aconf->port);
180			else
181			sendto_one(source_p, ":%s NOTICE %s :*** Connecting to %s.%d",
182			me.name, source_p->name, conf->name, aconf->port);
183			}
184			else
185			{
186			sendto_one(source_p, ":%s NOTICE %s :*** Couldn't connect to %s.%d",
187			me.name, source_p->name, conf->name, aconf->port);
188			}
189
190			/* client is either connecting with all the data it needs or has been
191			* destroyed
192			*/
193			aconf->port = tmpport;
194			}
195
196			/*
197			* ms_connect - CONNECT command handler
198			*
199			* Added by Jto 11 Feb 1989
200			*
201			* m_connect
202			* parv[0] = sender prefix
203			* parv[1] = servername
204			* parv[2] = port number
205			* parv[3] = remote server
206			*/
207			static void
208			ms_connect(struct Client client_p, struct Client source_p,
209			int parc, char *parv[])
210			{
211			int port;
212			int tmpport;
213			struct ConfItem *conf = NULL;
214			struct AccessItem *aconf = NULL;
215	michael	971	const struct Client *target_p = NULL;
216	adx	30
217			if (hunt_server(client_p, source_p,
218			":%s CONNECT %s %s :%s", 3, parc, parv) != HUNTED_ISME)
219			return;
220
221			if (*parv[1] == '\0')
222			{
223			sendto_one(source_p, form_str(ERR_NEEDMOREPARAMS),
224			me.name, source_p->name, "CONNECT");
225			return;
226			}
227
228			if ((target_p = find_server(parv[1])))
229			{
230			sendto_one(source_p,
231			":%s NOTICE %s :Connect: Server %s already exists from %s.",
232			me.name, source_p->name, parv[1], target_p->from->name);
233			return;
234			}
235
236			/*
237			* try to find the name, then host, if both fail notify ops and bail
238			*/
239			if ((conf = find_matching_name_conf(SERVER_TYPE,
240			parv[1], NULL, NULL, 0)) != NULL)
241	michael	971	aconf = map_to_conf(conf);
242	adx	30	else if ((conf = find_matching_name_conf(SERVER_TYPE,
243			NULL, NULL, parv[1], 0)) != NULL)
244	michael	971	aconf = map_to_conf(conf);
245	adx	30
246	michael	971	if (conf == NULL \|\| aconf == NULL)
247	adx	30	{
248			sendto_one(source_p,
249			":%s NOTICE %s :Connect: Host %s not listed in ircd.conf",
250			me.name, source_p->name, parv[1]);
251			return;
252			}
253
254			/* Get port number from user, if given. If not specified,
255			* use the default form configuration structure. If missing
256			* from there, then use the precompiled default.
257			*/
258			tmpport = port = aconf->port;
259
260			if (parc > 2 && !EmptyString(parv[2]))
261			{
262			port = atoi(parv[2]);
263
264			/* if someone sends port 0, and we have a config port.. use it */
265			if (port == 0 && aconf->port)
266			port = aconf->port;
267			else if (port <= 0)
268			{
269			sendto_one(source_p, ":%s NOTICE %s :Connect: Illegal port number",
270			me.name, source_p->name);
271			return;
272			}
273			}
274			else if (port <= 0 && (port = PORTNUM) <= 0)
275			{
276			sendto_one(source_p, ":%s NOTICE %s :Connect: missing port number",
277			me.name, source_p->name);
278			return;
279			}
280
281			if (find_servconn_in_progress(conf->name))
282			{
283			sendto_one(source_p, ":%s NOTICE %s :Connect: a connection to %s "
284			"is already in progress.", me.name, source_p->name, conf->name);
285			return;
286			}
287
288			/*
289			* Notify all operators about remote connect requests
290			*/
291			sendto_wallops_flags(UMODE_WALLOP, &me, "Remote CONNECT %s %d from %s",
292			parv[1], port, source_p->name);
293	michael	885	sendto_server(NULL, NULL, NOCAPS, NOCAPS,
294	adx	30	":%s WALLOPS :Remote CONNECT %s %d from %s",
295			me.name, parv[1], port, source_p->name);
296
297			ilog(L_TRACE, "CONNECT From %s : %s %d",
298			source_p->name, parv[1], port);
299
300			aconf->port = port;
301
302	michael	885	/*
303			* At this point we should be calling connect_server with a valid
304	adx	30	* C:line and a valid port in the C:line
305			*/
306			if (serv_connect(aconf, source_p))
307			sendto_one(source_p, ":%s NOTICE %s :*** Connecting to %s.%d",
308			me.name, source_p->name, conf->name, aconf->port);
309			else
310			sendto_one(source_p, ":%s NOTICE %s :*** Couldn't connect to %s.%d",
311			me.name, source_p->name, conf->name, aconf->port);
312	michael	885	/*
313			* Client is either connecting with all the data it needs or has been
314	adx	30	* destroyed
315			*/
316			aconf->port = tmpport;
317			}
318