ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/ermyth/modules/protocol/ptlink.C
Revision: 1.5
Committed: Wed Sep 5 11:23:15 2007 UTC (19 years ago) by pippijn
Content type: text/plain
Branch: MAIN
Changes since 1.4: +3 -3 lines
Log Message:
removed GPLed code and put license back to BSD

File Contents

# User Rev Content
1 pippijn 1.1 /*
2 pippijn 1.4 * Copyright © 2003-2004 E. Will et al.
3     * Copyright © 2005-2006 Atheme Development Group
4 pippijn 1.2 * Rights to this code are documented in doc/pod/license.pod.
5 pippijn 1.1 *
6     * This file contains protocol support for ptlink ircd.
7     *
8 pippijn 1.5 * $Id: ptlink.C,v 1.4 2007-08-28 17:08:11 pippijn Exp $
9 pippijn 1.1 */
10    
11     #include "atheme.h"
12     #include <account/mynick.h>
13     #include "uplink.h"
14     #include "pmodule.h"
15     #include "protocol/ptlink.h"
16    
17 pippijn 1.5 static char const rcsid[] = "$Id: ptlink.C,v 1.4 2007-08-28 17:08:11 pippijn Exp $";
18 pippijn 1.1
19     /* *INDENT-OFF* */
20    
21 pippijn 1.4 namespace protocol
22 pippijn 1.1 {
23 pippijn 1.4 static ircd_t PTLink = {
24     "PTLink IRCd", /* IRCd name */
25     "$", /* TLD Prefix, used by Global. */
26     false, /* Whether or not we use IRCNet/TS6 UID */
27     false, /* Whether or not we use RCOMMAND */
28     false, /* Whether or not we support channel owners. */
29     true, /* Whether or not we support channel protection. */
30     true, /* Whether or not we support halfops. */
31     false, /* Whether or not we use P10 */
32     true, /* Whether or not we use vHosts. */
33     0, /* Oper-only cmodes */
34     0, /* Integer flag for owner channel flag. */
35     CMODE_PROTECT, /* Integer flag for protect channel flag. */
36     CMODE_HALFOP, /* Integer flag for halfops. */
37     "+", /* Mode we set for owner. */
38     "+a", /* Mode we set for protect. */
39     "+h", /* Mode we set for halfops. */
40     PROTOCOL_PTLINK, /* Protocol type */
41     0, /* Permanent cmodes */
42     "b", /* Ban-like cmodes */
43     0, /* Except mchar */
44     0, /* Invex mchar */
45     0 /* Flags */
46     };
47    
48     struct ptlink_handler : handler
49     {
50     ptlink_handler ();
51     virtual ~ptlink_handler ();
52    
53     virtual unsigned int server_login (void);
54     virtual void introduce_nick (user_t *u);
55     virtual void invite_sts (user_t *source, user_t *target, channel_t *channel);
56     virtual void quit_sts (user_t *u, char const * const reason);
57     virtual void wallops_sts (char const * const text);
58     virtual void join_sts (channel_t *c, user_t *u, bool isnew, char const * const modes);
59     virtual void kick (char const * const from, char const * const channel, char const * const to, char const * const reason);
60     virtual void privmsg (char const * const from, char const * const target, char const * const fmt, ...);
61     virtual void notice_user_sts (user_t *from, user_t *target, char const * const text);
62     virtual void notice_global_sts (user_t *from, char const * const mask, char const * const text);
63     virtual void notice_channel_sts (user_t *from, channel_t *target, char const * const text);
64     virtual void numeric_sts (char const * const from, int numeric, char const * const target, char const * const fmt, ...);
65     virtual void skill (char const * const from, char const * const nick, char const * const fmt, ...);
66     virtual void part_sts (channel_t *c, user_t *u);
67     virtual void kline_sts (char const * const server, char const * const user, char const * const host, long duration, char const * const reason);
68     virtual void unkline_sts (char const * const server, char const * const user, char const * const host);
69     virtual void topic_sts (channel_t *c, char const * const setter, time_t ts, time_t prevts, char const * const topic);
70     virtual void mode_sts (char const * const sender, channel_t *target, char const * const modes);
71     virtual void ping_sts (void);
72     virtual void ircd_on_login (char const * const origin, char const * const user, char const * const wantedhost);
73     virtual bool ircd_on_logout (char const * const origin, char const * const user, char const * const wantedhost);
74     virtual void jupe (char const * const server, char const * const reason);
75     virtual void sethost_sts (char const * const source, char const * const target, char const * const host);
76     };
77    
78     static cmode_t ptlink_mode_list[] = {
79     { 'i', CMODE_INVITE },
80     { 'm', CMODE_MOD },
81     { 'n', CMODE_NOEXT },
82     { 'p', CMODE_PRIV },
83     { 's', CMODE_SEC },
84     { 't', CMODE_TOPIC },
85     { 'c', CMODE_NOCOLOR },
86     { 'q', CMODE_NOQUIT },
87     { 'd', CMODE_NOREPEAT },
88     { 'B', CMODE_NOBOTS },
89     { 'C', CMODE_SSLONLY },
90     { 'K', CMODE_KNOCK },
91     { 'N', CMODE_STICKY },
92     { 'R', CMODE_REGONLY },
93     { 'S', CMODE_NOSPAM },
94     { '\0', 0 }
95     };
96    
97     static bool check_flood(char const * const , channel_t *, mychan_t *, user_t *, myuser_t *);
98    
99 pippijn 1.5 static extmode_t ptlink_ignore_mode_list[] = {
100 pippijn 1.4 { 'f', check_flood },
101     { '\0', 0 }
102     };
103    
104     static cmode_t ptlink_status_mode_list[] = {
105     { 'a', CMODE_PROTECT},
106     { 'o', CMODE_OP },
107     { 'h', CMODE_HALFOP},
108     { 'v', CMODE_VOICE },
109     { '\0', 0 }
110     };
111    
112     static cmode_t ptlink_prefix_mode_list[] = {
113     { '.', CMODE_PROTECT},
114     { '@', CMODE_OP },
115     { '%', CMODE_HALFOP},
116     { '+', CMODE_VOICE },
117     { '\0', 0 }
118     };
119    
120     /* *INDENT-ON* */
121    
122     static bool
123     check_flood (char const * const value, channel_t *c, mychan_t *mc, user_t *u, myuser_t *mu)
124     {
125     char const *p = value;
126     char const *arg2 = NULL;
127    
128     while (*p != '\0')
129     {
130     if (*p == ':')
131     {
132     if (arg2 != NULL)
133     return false;
134     arg2 = p + 1;
135     }
136     else if (!isdigit (*p))
137     return false;
138     p++;
139     }
140     if (arg2 == NULL)
141     return false;
142     if (p - arg2 > 2 || arg2 - value - 1 > 2 || atoi (value) <= 1 || !atoi (arg2))
143     return false;
144     return true;
145     }
146    
147     /* login to our uplink */
148     unsigned int
149     ptlink_handler::server_login (void)
150     {
151     int ret;
152    
153     ret = sts ("PASS %s :TS", curr_uplink->pass);
154     if (ret == 1)
155     return 1;
156    
157     me.bursting = true;
158    
159     sts ("CAPAB :QS PTS4");
160     sts ("SERVER %s 1 " PACKAGE_NAME "-%s :%s", me.name, version, me.desc);
161     sts ("SVINFO 10 3 0 :%ld", NOW);
162    
163     services_init ();
164    
165     return 0;
166     }
167    
168     /* introduce a client */
169     void
170     ptlink_handler::introduce_nick (user_t *u)
171     {
172     sts ("NICK %s 1 %ld +%sp %s %s %s %s :%s", u->nick, u->ts, "io", u->user, u->host, u->host, me.name, u->gecos);
173     }
174    
175     /* invite a user to a channel */
176     void
177     ptlink_handler::invite_sts (user_t *sender, user_t *target, channel_t *channel)
178     {
179     sts (":%s INVITE %s %s", sender->nick, target->nick, channel->name);
180     }
181    
182     void
183     ptlink_handler::quit_sts (user_t *u, char const * const reason)
184     {
185     if (!me.connected)
186     return;
187    
188     sts (":%s QUIT :%s", u->nick, reason);
189     }
190    
191     /* WALLOPS wrapper */
192     void
193     ptlink_handler::wallops_sts (char const * const text)
194     {
195     sts (":%s WALLOPS :%s", me.name, text);
196     }
197    
198     /* join a channel */
199     void
200     ptlink_handler::join_sts (channel_t *c, user_t *u, bool isnew, char const * const modes)
201     {
202     if (isnew)
203     sts (":%s SJOIN %ld %s %s :@%s", me.name, c->ts, c->name, modes, u->nick);
204     else
205     sts (":%s SJOIN %ld %s + :@%s", me.name, c->ts, c->name, u->nick);
206     }
207    
208     /* kicks a user from a channel */
209     void
210     ptlink_handler::kick (char const * const from, char const * const channel, char const * const to, char const * const reason)
211     {
212     channel_t *chan = channel_find (channel);
213     user_t *user = user_find (to);
214    
215     if (!chan || !user)
216     return;
217    
218     sts (":%s KICK %s %s :%s", from, channel, to, reason);
219    
220     chanuser_delete (chan, user);
221     }
222    
223     /* PRIVMSG wrapper */
224     void
225     ptlink_handler::privmsg (char const * const from, char const * const target, char const * const fmt, ...)
226     {
227     va_list ap;
228     char buf[BUFSIZE];
229    
230     va_start (ap, fmt);
231     vsnprintf (buf, BUFSIZE, fmt, ap);
232     va_end (ap);
233    
234     sts (":%s PRIVMSG %s :%s", from, target, buf);
235     }
236    
237     /* NOTICE wrapper */
238     void
239     ptlink_handler::notice_user_sts (user_t *from, user_t *target, char const * const text)
240     {
241     sts (":%s NOTICE %s :%s", from ? from->nick : me.name, target->nick, text);
242     }
243    
244     void
245     ptlink_handler::notice_global_sts (user_t *from, char const * const mask, char const * const text)
246     {
247     sts (":%s NOTICE %s%s :%s", from ? from->nick : me.name, ircd->tldprefix, mask, text);
248     }
249    
250     void
251     ptlink_handler::notice_channel_sts (user_t *from, channel_t *target, char const * const text)
252     {
253     sts (":%s NOTICE %s :%s", from ? from->nick : me.name, target->name, text);
254     }
255    
256     /* numeric wrapper */
257     void
258     ptlink_handler::numeric_sts (char const * const from, int numeric, char const * const target, char const * const fmt, ...)
259     {
260     va_list ap;
261     char buf[BUFSIZE];
262    
263     va_start (ap, fmt);
264     vsnprintf (buf, BUFSIZE, fmt, ap);
265     va_end (ap);
266    
267     sts (":%s %d %s %s", from, numeric, target, buf);
268     }
269    
270     /* KILL wrapper */
271     void
272     ptlink_handler::skill (char const * const from, char const * const nick, char const * const fmt, ...)
273     {
274     va_list ap;
275     char buf[BUFSIZE];
276    
277     va_start (ap, fmt);
278     vsnprintf (buf, BUFSIZE, fmt, ap);
279     va_end (ap);
280    
281     sts (":%s KILL %s :%s!%s!%s (%s)", from, nick, from, from, from, buf);
282     }
283    
284     /* PART wrapper */
285     void
286     ptlink_handler::part_sts (channel_t *c, user_t *u)
287     {
288     sts (":%s PART %s", u->nick, c->name);
289     }
290    
291     /* server-to-server KLINE wrapper */
292     void
293     ptlink_handler::kline_sts (char const * const server, char const * const user, char const * const host, long duration, char const * const reason)
294     {
295     if (!me.connected)
296     return;
297    
298     /* we don't know the real setter here :( */
299     sts (":%s GLINE %s@%s %ld %s :%s", opersvs.nick, user, host, duration, opersvs.nick, reason);
300     }
301    
302     /* server-to-server UNKLINE wrapper */
303     void
304     ptlink_handler::unkline_sts (char const * const server, char const * const user, char const * const host)
305     {
306     if (!me.connected)
307     return;
308    
309     sts (":%s UNGLINE %s@%s", opersvs.nick, user, host);
310     }
311    
312     /* topic wrapper */
313     void
314     ptlink_handler::topic_sts (channel_t *c, char const * const setter, time_t ts, time_t prevts, char const * const topic)
315     {
316     if (!me.connected || !c)
317     return;
318    
319     sts (":%s TOPIC %s %s %ld :%s", chansvs.nick, c->name, setter, ts, topic);
320     }
321    
322     /* mode wrapper */
323     void
324     ptlink_handler::mode_sts (char const * const sender, channel_t *target, char const * const modes)
325     {
326     if (!me.connected)
327     return;
328    
329     sts (":%s MODE %s %s", sender, target->name, modes);
330     }
331    
332     /* ping wrapper */
333     void
334     ptlink_handler::ping_sts (void)
335     {
336     if (!me.connected)
337     return;
338    
339     sts ("PING :%s", me.name);
340     }
341    
342     /* protocol-specific stuff to do on login */
343     void
344     ptlink_handler::ircd_on_login (char const * const origin, char const * const user, char const * const wantedhost)
345     {
346     user_t *u = user_find (origin);
347    
348     if (!me.connected || u == NULL)
349     return;
350    
351     /* Can only do this for nickserv, and can only record identified
352     * state if logged in to correct nick, sorry -- jilles
353     */
354     if (should_reg_umode (u))
355     sts (":%s SVSMODE %s +r", me.name, origin);
356     }
357    
358     /* protocol-specific stuff to do on login */
359     bool
360     ptlink_handler::ircd_on_logout (char const * const origin, char const * const user, char const * const wantedhost)
361     {
362     if (!me.connected)
363     return false;
364    
365     if (!nicksvs.no_nick_ownership)
366     sts (":%s SVSMODE %s -r", me.name, origin);
367    
368 pippijn 1.1 return false;
369 pippijn 1.4 }
370    
371     void
372     ptlink_handler::jupe (char const * const server, char const * const reason)
373     {
374     if (!me.connected)
375     return;
376    
377     server_delete (server);
378     sts (":%s SQUIT %s :%s", opersvs.nick, server, reason);
379     sts (":%s SERVER %s 2 " PACKAGE_NAME "-%s-jupe :%s", me.name, server, version, reason);
380     }
381    
382     void
383     ptlink_handler::sethost_sts (char const * const source, char const * const target, char const * const host)
384     {
385     user_t *tu = user_find (target);
386    
387     if (!tu)
388     return;
389    
390     sts (":%s NEWMASK %s :%s", me.name, host, tu->nick);
391     }
392    
393     static void
394     m_topic (sourceinfo_t *si, int parc, char *parv[])
395     {
396     channel_t *c = channel_find (parv[0]);
397    
398     if (!c)
399     return;
400    
401     /* Our uplink is trying to change the topic during burst,
402     * and we have already set a topic. Assume our change won.
403     * -- jilles */
404     if (si->s != NULL && si->s->uplink == me.me && !(si->s->flags & SF_EOB) && c->topic != NULL)
405     return;
406    
407     handle_topic_from (si, c, parv[1], atol (parv[2]), parv[3]);
408     }
409    
410     static void
411     m_ping (sourceinfo_t *si, int parc, char *parv[])
412     {
413     /* reply to PING's */
414     sts (":%s PONG %s %s", me.name, me.name, parv[0]);
415     }
416    
417     static void
418     m_pong (sourceinfo_t *si, int parc, char *parv[])
419     {
420     server_t *s;
421    
422     /* someone replied to our PING */
423     if (!parv[0])
424     return;
425     s = server_find (parv[0]);
426     if (s == NULL)
427     return;
428     handle_eob (s);
429    
430     if (irccasecmp (me.actual, parv[0]))
431     return;
432    
433     me.uplinkpong = NOW;
434    
435     /* -> :test.projectxero.net PONG test.projectxero.net :shrike.malkier.net */
436     if (me.bursting)
437 pippijn 1.1 {
438 pippijn 1.4 #ifdef HAVE_GETTIMEOFDAY
439     e_time (burstime, &burstime);
440    
441     slog (LG_INFO, "m_pong(): finished synching with uplink (%d %s)", (tv2ms (&burstime) > 1000) ? (tv2ms (&burstime) / 1000) : tv2ms (&burstime), (tv2ms (&burstime) > 1000) ? "s" : "ms");
442    
443     wallops ("Finished synching to network in %d %s.", (tv2ms (&burstime) > 1000) ? (tv2ms (&burstime) / 1000) : tv2ms (&burstime), (tv2ms (&burstime) > 1000) ? "s" : "ms");
444     #else
445     slog (LG_INFO, "m_pong(): finished synching with uplink");
446     wallops ("Finished synching to network.");
447     #endif
448    
449     me.bursting = false;
450 pippijn 1.1 }
451 pippijn 1.4 }
452    
453     static void
454     m_privmsg (sourceinfo_t *si, int parc, char *parv[])
455     {
456     if (parc != 2)
457 pippijn 1.1 return;
458 pippijn 1.4
459     handle_message (si, parv[0], false, parv[1]);
460     }
461    
462     static void
463     m_notice (sourceinfo_t *si, int parc, char *parv[])
464     {
465     if (parc != 2)
466 pippijn 1.1 return;
467 pippijn 1.4
468     handle_message (si, parv[0], true, parv[1]);
469     }
470    
471     static void
472     m_sjoin (sourceinfo_t *si, int parc, char *parv[])
473     {
474     /* -> :proteus.malkier.net SJOIN 1073516550 #shrike +tn :@sycobuny @+rakaur */
475    
476     channel_t *c;
477     unsigned int userc;
478     char *userv[256];
479     unsigned int i;
480     time_t ts;
481    
482     /* :origin SJOIN ts chan modestr [key or limits] :users */
483     c = channel_find (parv[1]);
484     ts = atol (parv[0]);
485    
486     if (!c)
487     {
488     slog (LG_DEBUG, "m_sjoin(): new channel: %s", parv[1]);
489     c = channel_add (parv[1], ts, si->s);
490     }
491    
492     if (ts < c->ts)
493     {
494     chanuser_t *cu;
495     node_t *n;
496    
497     /* the TS changed. a TS change requires the following things
498     * to be done to the channel: reset all modes to nothing, remove
499     * all status modes on known users on the channel (including ours),
500     * and set the new TS.
501     */
502    
503     clear_simple_modes (c);
504    
505     LIST_FOREACH (n, c->members.head)
506     {
507     cu = (chanuser_t *) n->data;
508     if (cu->user->server == me.me)
509     {
510     /* it's a service, reop */
511     sts (":%s PART %s :Reop", cu->user->nick, c->name);
512     sts (":%s SJOIN %ld %s + :@%s", me.name, ts, c->name, cu->user->nick);
513     cu->modes = CMODE_OP;
514     }
515     else
516     cu->modes = 0;
517     }
518    
519     slog (LG_DEBUG, "m_sjoin(): TS changed for %s (%ld -> %ld)", c->name, c->ts, ts);
520    
521     c->ts = ts;
522     c->callback.tschange (c);
523     }
524    
525     channel_mode (NULL, c, parc - 3, parv + 2);
526    
527     userc = sjtoken (parv[parc - 1], ' ', userv);
528    
529     for (i = 0; i < userc; i++)
530     chanuser_add (c, userv[i]);
531    
532     if (c->nummembers == 0 && !(c->modes & ircd->perm_mode))
533     channel_delete (c);
534     }
535    
536     static void
537     m_part (sourceinfo_t *si, int parc, char *parv[])
538     {
539     int chanc;
540     char *chanv[256];
541     int i;
542    
543     chanc = sjtoken (parv[0], ',', chanv);
544     for (i = 0; i < chanc; i++)
545     {
546     slog (LG_DEBUG, "m_part(): user left channel: %s -> %s", si->su->nick, chanv[i]);
547    
548     chanuser_delete (channel_find (chanv[i]), si->su);
549     }
550     }
551    
552     static void
553     m_nick (sourceinfo_t *si, int parc, char *parv[])
554     {
555     server_t *s;
556     user_t *u;
557     bool realchange;
558    
559     /* got the right number of args for an introduction? */
560     if (parc == 9)
561     {
562     s = server_find (parv[7]);
563     if (!s)
564     {
565     slog (LG_DEBUG, "m_nick(): new user on nonexistant server: %s", parv[6]);
566     return;
567     }
568    
569     slog (LG_DEBUG, "m_nick(): new user on `%s': %s", s->name, parv[0]);
570    
571     u = user_add (parv[0], parv[4], parv[5], parv[6], NULL, NULL, parv[8], s, atoi (parv[0]));
572    
573     user_mode (u, parv[3]);
574    
575     /* Ok, we have the user ready to go.
576     * Here's the deal -- if the user's SVID is before
577     * the start time, and not 0, then check to see
578     * if it's a registered account or not.
579     *
580     * If it IS registered, deal with that accordingly,
581     * via handle_burstlogin(). --nenolod
582     */
583     /* Changed to just check umode +r for now -- jilles */
584     /* This is ok because this ircd clears +r on nick changes
585     * -- jilles */
586     if (strchr (parv[3], 'r'))
587     handle_burstlogin (u, NULL);
588    
589     handle_nickchange (u);
590     }
591    
592     /* if it's only 2 then it's a nickname change */
593     else if (parc == 2)
594     {
595     if (!si->su)
596     {
597     slog (LG_DEBUG, "m_nick(): server trying to change nick: %s", si->s != NULL ? si->s->name : "<none>");
598     return;
599     }
600    
601     slog (LG_DEBUG, "m_nick(): nickname change from `%s': %s", si->su->nick, parv[0]);
602    
603     realchange = irccasecmp (si->su->nick, parv[0]);
604    
605     user_changenick (si->su, parv[0], atoi (parv[1]));
606    
607     /* fix up +r if necessary -- jilles */
608     if (realchange && should_reg_umode (si->su))
609     /* changed nick to registered one, reset +r */
610     sts (":%s SVSMODE %s +r", me.name, parv[0]);
611    
612     handle_nickchange (si->su);
613     }
614     else
615     {
616     int i;
617     slog (LG_DEBUG, "m_nick(): got NICK with wrong number of params");
618    
619     for (i = 0; i < parc; i++)
620     slog (LG_DEBUG, "m_nick(): parv[%d] = %s", i, parv[i]);
621     }
622     }
623    
624     static void
625     m_quit (sourceinfo_t *si, int parc, char *parv[])
626     {
627     slog (LG_DEBUG, "m_quit(): user leaving: %s", si->su->nick);
628    
629     /* user_delete() takes care of removing channels and so forth */
630     user_delete (si->su);
631     }
632    
633     static void
634     m_mode (sourceinfo_t *si, int parc, char *parv[])
635     {
636     if (*parv[0] == '#')
637     channel_mode (NULL, channel_find (parv[0]), parc - 1, &parv[1]);
638     else
639     user_mode (user_find (parv[0]), parv[1]);
640     }
641    
642     static void
643     m_kick (sourceinfo_t *si, int parc, char *parv[])
644     {
645     user_t *u = user_find (parv[1]);
646     channel_t *c = channel_find (parv[0]);
647    
648     /* -> :rakaur KICK #shrike rintaun :test */
649     slog (LG_DEBUG, "m_kick(): user was kicked: %s -> %s", parv[1], parv[0]);
650    
651     if (!u)
652     {
653     slog (LG_DEBUG, "m_kick(): got kick for nonexistant user %s", parv[1]);
654     return;
655     }
656    
657     if (!c)
658     {
659     slog (LG_DEBUG, "m_kick(): got kick in nonexistant channel: %s", parv[0]);
660     return;
661     }
662    
663     if (!chanuser_find (c, u))
664     {
665     slog (LG_DEBUG, "m_kick(): got kick for %s not in %s", u->nick, c->name);
666     return;
667     }
668    
669     chanuser_delete (c, u);
670    
671     /* if they kicked us, let's rejoin */
672     if (is_internal_client (u))
673     {
674     slog (LG_DEBUG, "m_kick(): %s got kicked from %s; rejoining", u->nick, parv[0]);
675     join (parv[0], u->nick);
676     }
677     }
678    
679     static void
680     m_kill (sourceinfo_t *si, int parc, char *parv[])
681     {
682     handle_kill (si, parv[0], parc > 1 ? parv[1] : "<No reason given>");
683     }
684    
685     static void
686     m_squit (sourceinfo_t *si, int parc, char *parv[])
687     {
688     slog (LG_DEBUG, "m_squit(): server leaving: %s from %s", parv[0], parv[1]);
689     server_delete (parv[0]);
690     }
691    
692     static void
693     m_server (sourceinfo_t *si, int parc, char *parv[])
694     {
695     server_t *s;
696    
697     slog (LG_DEBUG, "m_server(): new server: %s", parv[0]);
698     s = handle_server (si, parv[0], NULL, atoi (parv[1]), parv[2]);
699    
700     if (s != NULL && s->uplink != me.me)
701     {
702     /* elicit PONG for EOB detection; pinging uplink is
703     * already done elsewhere -- jilles
704     */
705     sts (":%s PING %s %s", me.name, me.name, s->name);
706     }
707     }
708    
709     static void
710     m_stats (sourceinfo_t *si, int parc, char *parv[])
711     {
712     handle_stats (si->su, parv[0][0]);
713     }
714    
715     static void
716     m_admin (sourceinfo_t *si, int parc, char *parv[])
717     {
718     handle_admin (si->su);
719     }
720    
721     static void
722     m_version (sourceinfo_t *si, int parc, char *parv[])
723     {
724     handle_version (si->su);
725     }
726    
727     static void
728     m_info (sourceinfo_t *si, int parc, char *parv[])
729     {
730     handle_info (si->su);
731     }
732    
733     static void
734     m_whois (sourceinfo_t *si, int parc, char *parv[])
735     {
736     handle_whois (si->su, parv[1]);
737     }
738    
739     static void
740     m_trace (sourceinfo_t *si, int parc, char *parv[])
741     {
742     handle_trace (si->su, parv[0], parc >= 2 ? parv[1] : NULL);
743     }
744    
745     static void
746     m_away (sourceinfo_t *si, int parc, char *parv[])
747     {
748     handle_away (si->su, parc >= 1 ? parv[0] : NULL);
749     }
750    
751     static void
752     m_join (sourceinfo_t *si, int parc, char *parv[])
753     {
754     chanuser_t *cu;
755     node_t *n, *tn;
756    
757     /* JOIN 0 is really a part from all channels */
758     if (parv[0][0] == '0')
759     {
760     LIST_FOREACH_SAFE (n, tn, si->su->channels.head)
761     {
762     cu = (chanuser_t *) n->data;
763     chanuser_delete (cu->chan, si->su);
764     }
765     }
766     }
767    
768     static void
769     m_pass (sourceinfo_t *si, int parc, char *parv[])
770     {
771     if (strcmp (curr_uplink->pass, parv[0]))
772     {
773     slog (LG_INFO, "m_pass(): password mismatch from uplink; aborting");
774     runflags |= RF_SHUTDOWN;
775     }
776     }
777    
778     static void
779     m_error (sourceinfo_t *si, int parc, char *parv[])
780     {
781     slog (LG_INFO, "m_error(): error from server: %s", parv[0]);
782     }
783    
784     static void
785     m_newmask (sourceinfo_t *si, int parc, char *parv[])
786     {
787     user_t *target;
788     char *p;
789    
790     target = parc >= 2 ? user_find (parv[1]) : si->su;
791     if (target == NULL)
792 pippijn 1.1 return;
793 pippijn 1.4 p = strchr (parv[0], '@');
794     if (p != NULL)
795 pippijn 1.1 {
796 pippijn 1.4 strlcpy (target->vhost, p + 1, sizeof target->vhost);
797     if ((size_t) (p - parv[0]) < sizeof target->user && p > parv[0])
798     {
799     memcpy (target->user, parv[0], p - parv[0]);
800     target->user[p - parv[0]] = '\0';
801     }
802 pippijn 1.1 }
803 pippijn 1.4 else
804     strlcpy (target->vhost, parv[0], sizeof target->vhost);
805     slog (LG_DEBUG, "m_newmask(): %s -> %s@%s", target->nick, target->user, target->vhost);
806     }
807    
808     static void
809     m_motd (sourceinfo_t *si, int parc, char *parv[])
810     {
811     handle_motd (si->su);
812     }
813    
814     static void
815     nick_group (mynick_t *mn, myuser_t *mu, sourceinfo_t *si)
816     {
817     user_t *u;
818    
819     if (si->su != NULL && !irccasecmp (si->su->nick, mn->nick))
820     u = si->su;
821     else
822     u = user_find_named (mn->nick);
823    
824     if (u != NULL && should_reg_umode (u))
825     sts (":%s SVSMODE %s +r", me.name, u->nick);
826     }
827    
828     static void
829     nick_ungroup (mynick_t *mn, myuser_t *mu, sourceinfo_t *si)
830     {
831     user_t *u;
832    
833     if (si->su != NULL && !irccasecmp (si->su->nick, mn->nick))
834     u = si->su;
835     else
836     u = user_find_named (mn->nick);
837    
838     if (u != NULL && !nicksvs.no_nick_ownership)
839     sts (":%s SVSMODE %s -r", me.name, u->nick);
840     }
841    
842     static pcommand_t const pcommands[] = {
843     { "PING", m_ping, 1, MSRC_USER | MSRC_SERVER },
844     { "PONG", m_pong, 1, MSRC_SERVER },
845     { "PRIVMSG", m_privmsg, 2, MSRC_USER },
846     { "NOTICE", m_notice, 2, MSRC_UNREG | MSRC_USER | MSRC_SERVER },
847     { "SJOIN", m_sjoin, 4, MSRC_SERVER },
848     { "NJOIN", m_sjoin, 2, MSRC_USER | MSRC_SERVER },
849     { "PART", m_part, 1, MSRC_USER },
850     { "NICK", m_nick, 2, MSRC_USER | MSRC_SERVER },
851     { "NNICK", m_nick, 2, MSRC_USER | MSRC_SERVER },
852     { "QUIT", m_quit, 1, MSRC_USER },
853     { "MODE", m_mode, 2, MSRC_USER | MSRC_SERVER },
854     { "KICK", m_kick, 2, MSRC_USER | MSRC_SERVER },
855     { "KILL", m_kill, 1, MSRC_USER | MSRC_SERVER },
856     { "SQUIT", m_squit, 1, MSRC_USER | MSRC_SERVER },
857     { "SERVER", m_server, 3, MSRC_UNREG | MSRC_SERVER },
858     { "STATS", m_stats, 2, MSRC_USER },
859     { "ADMIN", m_admin, 1, MSRC_USER },
860     { "VERSION", m_version, 1, MSRC_USER },
861     { "INFO", m_info, 1, MSRC_USER },
862     { "WHOIS", m_whois, 2, MSRC_USER },
863     { "TRACE", m_trace, 1, MSRC_USER },
864     { "AWAY", m_away, 0, MSRC_USER },
865     { "JOIN", m_join, 1, MSRC_USER },
866     { "PASS", m_pass, 1, MSRC_UNREG },
867     { "ERROR", m_error, 1, MSRC_UNREG | MSRC_SERVER },
868     { "TOPIC", m_topic, 4, MSRC_USER | MSRC_SERVER },
869     { "NEWMASK", m_newmask, 1, MSRC_USER | MSRC_SERVER },
870     { "MOTD", m_motd, 1, MSRC_USER },
871     };
872    
873     ptlink_handler::ptlink_handler ()
874     {
875     mode_list = ptlink_mode_list;
876     ignore_mode_list = ptlink_ignore_mode_list;
877     status_mode_list = ptlink_status_mode_list;
878     prefix_mode_list = ptlink_prefix_mode_list;
879    
880     ircd = &PTLink;
881    
882     pcommand_add (&pcommands);
883    
884     mynick_t::callback.group.attach (nick_group);
885     mynick_t::callback.ungroup.attach (nick_ungroup);
886     }
887    
888     ptlink_handler::~ptlink_handler ()
889     {
890     mode_list = NULL;
891     ignore_mode_list = NULL;
892     status_mode_list = NULL;
893     prefix_mode_list = NULL;
894    
895     ircd = NULL;
896    
897     mynick_t::callback.group.detach (nick_group);
898     mynick_t::callback.ungroup.detach (nick_ungroup);
899    
900     pcommand_delete (&pcommands);
901     }
902     }
903    
904     #define FACREG_TYPE protocol::ptlink_handler
905     #define FACREG_TYPE_NAME "ptlink"
906     #define FACREG_INTERFACE_TYPE protocol::handler
907     #include <ermyth/factory_reg.h>