]> git.donarmstrong.com Git - infobot.git/blob - src/Process.pl
- modified db_mysql to allow eleet usage of dbSet
[infobot.git] / src / Process.pl
1 ###
2 ### Process.pl: Kevin Lenzo 1997-1999
3 ###
4
5 #
6 # process the incoming message
7 #
8
9 if (&IsParam("useStrict")) { use strict; }
10
11 sub process {
12     $learnok    = 0;    # Able to learn?
13     $talkok     = 0;    # Able to yap?
14     $force_public_reply = 0;
15     $literal    = 0;
16
17     return 'X'                  if $who eq $ident;      # self-message.
18     return 'addressedother set' if ($addressedother);
19
20     $talkok     = ($param{'addressing'} =~ /^OPTIONAL$/i or $addressed);
21     $learnok    = ($param{'learn'}      =~ /^HUNGRY$/i   or $addressed);
22
23     &shmFlush();                # hack.
24
25     # check if we have our head intact.
26     if ($lobotomized) {
27         if ($addressed and IsFlag("o") eq "o") {
28             my $delta_time      = time() - ($cache{lobotomy}{$who} || 0);
29             &msg($who, "give me an unlobotomy.") if ($delta_time > 60*60);
30             $cache{lobotomy}{$who} = time();
31         }
32         return 'LOBOTOMY';
33     }
34
35     # talkMethod.
36     if ($param{'talkMethod'} =~ /^PRIVATE$/i) {
37         if ($msgType =~ /public/ and $addressed) {
38             &msg($who, "sorry. i'm in 'PRIVATE' talkMethod mode ".
39                   "while you sent a message to me ${msgType}ly.");
40
41             return 'TALKMETHOD';
42         }
43     }
44
45     # join, must be done before outsider checking.
46     if ($message =~ /^join(\s+(.*))?\s*$/i) {
47         return 'join: not addr' unless ($addressed);
48
49         $2 =~ /^($mask{chan})(,(\S+))?/;
50         my($thischan, $key) = (lc $1, $3);
51         my $chankey     = lc $thischan;
52         $chankey        .= " $key"      if (defined $key);
53
54         if ($thischan eq "") {
55             &help("join");
56             return;
57         }
58
59         if (&IsFlag("o") ne "o") {
60             if (!exists $chanconf{$thischan}) {
61                 &msg($who, "I am not allowed to join $thischan.");
62                 return;
63             }
64
65             if (&validChan($thischan)) {
66                 &msg($who,"warn: I'm already on $thischan, joining  anyway...");
67 #               return;
68             }
69         }
70         $cache{join}{$thischan} = $who; # used for on_join self.
71
72         &joinchan($chankey);
73         &status("JOIN $chankey <$who>");
74         &msg($who, "joining $chankey");
75
76         return;
77     }
78
79     # 'identify'
80     if ($msgType =~ /private/ and $message =~ s/^identify//i) {
81         $message =~ s/^\s+|\s+$//g;
82         my @array = split / /, $message;
83
84         if ($who =~ /^_default$/i) {
85             &pSReply("you are too eleet.");
86             return;
87         }
88
89         if (!scalar @array or scalar @array > 2) {
90             &help("identify");
91             return;
92         }
93
94         my $do_nick = $array[1] || $who;
95
96         if (!exists $users{$do_nick}) {
97             &pSReply("nick $do_nick is not in user list.");
98             return;
99         }
100
101         my $crypt = $users{$do_nick}{PASS};
102         if (!defined $crypt) {
103             &pSReply("user $do_nick has no passwd set.");
104             return;
105         }
106
107         if (!&ckpasswd($array[0], $crypt)) {
108             &pSReply("invalid passwd for $do_nick.");
109             return;
110         }
111
112         my $mask = "*!$user@".&makeHostMask($host);
113         ### TODO: prevent adding multiple dupe masks?
114         ### TODO: make &addHostMask() CMD?
115         &pSReply("Added $mask for $do_nick...");
116         $users{$do_nick}{HOSTS}{$mask} = 1;
117
118         return;
119     }
120
121     # 'pass'
122     if ($msgType =~ /private/ and $message =~ s/^pass//i) {
123         $message =~ s/^\s+|\s+$//g;
124         my @array = split / /, $message;
125
126         if ($who =~ /^_default$/i) {
127             &pSReply("you are too eleet.");
128             return;
129         }
130
131         if (scalar @array != 1) {
132             &help("pass");
133             return;
134         }
135
136         # todo: use &getUser()?
137         my $first       = (scalar keys %users) ? 1 : 0;
138         if (!exists $users{$who} and !$first) {
139             &pSReply("nick $who is not in user list.");
140             return;
141         }
142
143         if ($first) {
144             &pSReply("first time user... adding you as master.");
145             $users{$who}{FLAGS} = "mrsteon";
146         }
147
148         my $crypt = $users{$who}{PASS};
149         if (defined $crypt) {
150             &pSReply("user $who already has pass set.");
151             return;
152         }
153
154         if (!defined $host) {
155             &WARN("pass: host == NULL.");
156             return;
157         }
158
159         if (!scalar keys %{ $users{$who}{HOSTS} }) {
160             my $mask = "*!$user@".&makeHostMask($host);
161             &pSReply("added mask $mask to $who.");
162             $users{$who}{HOSTS}{$mask}  = 1;
163         }
164
165         $crypt                  = &mkcrypt($array[0]);
166         $users{$who}{PASS}      = $crypt;
167         &pSReply("new pass for $who, crypt $crypt.");
168
169         return;
170     }
171
172     # allowOutsiders.
173     if (&IsParam("disallowOutsiders") and $msgType =~ /private/i) {
174         my $found = 0;
175
176         foreach (keys %channels) {
177             next unless (&IsNickInChan($who,$_));
178
179             $found++;
180             last;
181         }
182
183         if (!$found and scalar(keys %channels)) {
184             &status("OUTSIDER <$who> $message");
185             return 'OUTSIDER';
186         }
187     }
188
189     # override msgType.
190     if ($msgType =~ /public/ and $message =~ s/^\+//) {
191         &status("Process: '+' flag detected; changing reply to public");
192         $msgType = 'public';
193         $who     = $chan;       # major hack to fix &msg().
194         $force_public_reply++;
195         # notice is still NOTICE but to whole channel => good.
196     }
197
198     # User Processing, for all users.
199     if ($addressed) {
200         my $retval;
201         return 'returned from pCH'   if &parseCmdHook("main",$message);
202
203         $retval = &userCommands();
204         return unless (defined $retval);
205         return if ($retval eq $noreply);
206     }
207
208     ###
209     # once useless messages have been parsed out, we match them.
210     ###
211
212     # confused? is this for infobot communications?
213     foreach (keys %{ $lang{'confused'} }) {
214         my $y = $_;
215
216         next unless ($message =~ /^\Q$y\E\s*/);
217         return 'CONFUSO';
218     }
219
220     # hello. [took me a while to fix this. -xk]
221     if ($orig{message} =~ /^(\Q$ident\E\S?[:, ]\S?)?\s*(h(ello|i( there)?|owdy|ey|ola))( \Q$ident\E)?\s*$/i) {
222         return '' unless ($talkok);
223
224         # 'mynick: hi' or 'hi mynick' or 'hi'.
225         &status("somebody said hello");
226
227         # 50% chance of replying to a random greeting when not addressed
228         if (!defined $5 and $addressed == 0 and rand() < 0.5) {
229             &status("not returning unaddressed greeting");
230             return;
231         }
232
233         # customized random message.
234         my $tmp = (rand() < 0.5) ? ", $who" : "";
235         &performStrictReply(&getRandom(keys %{ $lang{'hello'} }) . $tmp);
236         return;
237     }
238
239     # greetings.
240     if ($message =~ /how (the hell )?are (ya|you)( doin\'?g?)?\?*$/) {
241         my $reply = &getRandom(keys %{ $lang{'howareyou'} });
242
243         &performReply($reply);
244         
245         return;
246     }
247
248     # praise.
249     if ($message =~ /you (rock|rewl|rule|are so+ coo+l)/ ||
250         $message =~ /(good (bo(t|y)|g([ui]|r+)rl))|(bot( |\-)?snack)/i)
251     {
252         return 'praise: no addr' unless ($addressed);
253
254         &status("random praise detected");
255
256         my $tmp = (rand() < 0.5) ? "thanks $who " : "";
257         &performStrictReply($tmp.":)");
258
259         return;
260     }
261
262     # thanks.
263     if ($message =~ /^than(ks?|x)( you)?( \S+)?/i) {
264         return 'thank: no addr' unless ($message =~ /$ident/ or $talkok);
265
266         &performReply( &getRandom(keys %{ $lang{'welcome'} }) );
267         return;
268     }
269
270     ###
271     ### bot commands...
272     ###
273
274     if ($message =~ s/^literal\s+//i) {
275         &status("literal ask of '$message'.");
276         $literal = 1;
277     }
278
279     # karma. set...
280     if ($message =~ /^(\S+)(--|\+\+)\s*$/ and $addressed) {
281         return '' unless (&hasParam("karma"));
282
283         my($term,$inc) = (lc $1,$2);
284
285         if ($msgType !~ /public/i) {
286             &msg($who, "karma must be done in public!");
287             return;
288         }
289
290         if (lc $term eq lc $who) {
291             &msg($who, "please don't karma yourself");
292             return;
293         }
294
295         my $karma = &dbGet("stats", "counter", "nick='$term' and type='karma'") || 0;
296         if ($inc eq '++') {
297             $karma++;
298         } else {
299             $karma--;
300         }
301
302         &dbSet("stats", 
303                 { nick => $term, type => "karma" },
304                 { counter => $karma }
305         );
306
307         return;
308     }
309
310     # here's where the external routines get called.
311     # if they return anything but null, that's the "answer".
312     if ($addressed) {
313         if ( &parseCmdHook("extra",$message) ) {
314             return 'DID SOMETHING IN PCH.';
315         }
316
317         my $er = &Modules();
318         if (!defined $er) {
319             return 'SOMETHING 1';
320         }
321
322         if (0 and $addrchar) {
323             &msg($who, "I don't trust people to use the core commands while addressing me in a short-cut way.");
324             return;
325         }
326     }
327
328     if (&IsParam("factoids") and $param{'DBType'} =~ /^(mysql|pg|postgres|dbm)/i) {
329         &FactoidStuff();
330     } elsif ($param{'DBType'} =~ /^none$/i) {
331         return "NO FACTOIDS.";
332     } else {
333         &ERROR("INVALID FACTOID SUPPORT? ($param{'DBType'})");
334         &shutdown();
335         exit 0;
336     }
337 }
338
339 sub FactoidStuff {
340     # inter-infobot.
341     if ($msgType =~ /private/ and $message =~ s/^:INFOBOT://) {
342         ### identification.
343         &status("infobot <$nuh> identified") unless $bots{$nuh};
344         $bots{$nuh} = $who;
345
346         ### communication.
347
348         # query.
349         if ($message =~ /^QUERY (<.*?>) (.*)/) {        # query.
350             my ($target,$item) = ($1,$2);
351             $item =~ s/[.\?]$//;
352
353             &status(":INFOBOT:QUERY $who: $message");
354
355             if ($_ = &getFactoid($item)) {
356                 &msg($who, ":INFOBOT:REPLY $target $item =is=> $_");
357             }
358
359             return 'INFOBOT QUERY';
360         } elsif ($message =~ /^REPLY <(.*?)> (.*)/) {   # reply.
361             my ($target,$item) = ($1,$2);
362
363             &status(":INFOBOT:REPLY $who: $message");
364
365             my ($lhs,$mhs,$rhs) = $item =~ /^(.*?) =(.*?)=> (.*)/;
366
367             if ($param{'acceptUrl'} !~ /REQUIRE/ or $rhs =~ /(http|ftp|mailto|telnet|file):/) {
368                 &msg($target, "$who knew: $lhs $mhs $rhs");
369
370                 # "are" hack :)
371                 $rhs = "<REPLY> are" if ($mhs eq "are");
372                 &setFactInfo($lhs, "factoid_value", $rhs);
373             }
374
375             return 'INFOBOT REPLY';
376         } else {
377             &ERROR(":INFOBOT:UNKNOWN $who: $message");
378             return 'INFOBOT UNKNOWN';
379         }
380     }
381
382     # factoid forget.
383     if ($message =~ s/^forget\s+//i) {
384         return 'forget: no addr' unless ($addressed);
385
386         my $faqtoid = $message;
387         if ($faqtoid eq "") {
388             &help("forget");
389             return;
390         }
391
392         $faqtoid =~ tr/A-Z/a-z/;
393         my $result = &getFactoid($faqtoid);
394
395         if (defined $result) {
396             my $author  = &getFactInfo($faqtoid, "created_by");
397             my $count   = &getFactInfo($faqtoid, "requested_count") || 0;
398             my $limit   = &getChanConfDefault("factoidPreventForgetLimit", 
399                                 0, $chan);
400
401             if (IsFlag("r") ne "r") {
402                 &msg($who, "you don't have access to remove factoids");
403                 return;
404             }
405
406             return 'locked factoid' if (&IsLocked($faqtoid) == 1);
407
408             # factoidPreventForgetLimit:
409             if ($limit and $count > $limit and (&IsFlag("o") ne "o")) {
410                 &msg($who, "will not delete '$faqtoid', count > limit ($count > $limit)");
411                 return;
412             }
413
414             if (&IsParam("factoidDeleteDelay") or &IsChanConf("factoidDeleteDelay")) {
415                 if ($faqtoid =~ / #DEL#$/ and !&IsFlag("o")) {
416                     &msg($who, "cannot delete it ($faqtoid).");
417                     return;
418                 }
419
420                 &status("forgot (safe delete): <$who> '$faqtoid' =is=> '$result'");
421                 ### TODO: check if the "backup" exists and overwrite it
422                 my $check = &getFactoid("$faqtoid #DEL#");
423
424                 if (!defined $check or $check =~ /^\s*$/) {
425                     if ($faqtoid !~ / #DEL#$/) {
426                         my $new = $faqtoid." #DEL#";
427                         &DEBUG("Process: backing up $faqtoid to '$new'.");
428
429                         # this looks weird but does it work?
430                         &setFactInfo($faqtoid, "factoid_key", $new);
431                         &setFactInfo($new, "modified_by", $who);
432                         &setFactInfo($new, "modified_time", time());
433
434                     } else {
435                         &status("not backing up $faqtoid.");
436                     }
437
438                 } else {
439                     &status("forget: not overwriting backup!");
440                 }
441
442             } else {
443                 &status("forget: <$who> '$faqtoid' =is=> '$result'");
444             }
445             &delFactoid($faqtoid);
446
447             &performReply("i forgot $faqtoid");
448
449             $count{'Update'}++;
450         } else {
451             &performReply("i didn't have anything called '$faqtoid'");
452         }
453
454         return;
455     }
456
457     # factoid unforget/undelete.
458     if ($message =~ s/^un(forget|delete)\s+//i) {
459         return 'unforget: no addr' unless ($addressed);
460
461         my $i = 0;
462         $i++ if (&IsParam("factoidDeleteDelay"));
463         $i++ if (&IsChanConf("factoidDeleteDelay"));
464         if (!$i) {
465             &performReply("safe delete has been disable so what is there to undelete?");
466             return;
467         }
468
469         my $faqtoid = $message;
470         if ($faqtoid eq "") {
471             &help("undelete");
472             return;
473         }
474
475         $faqtoid =~ tr/A-Z/a-z/;
476         my $result = &getFactoid($faqtoid." #DEL#");
477         my $check  = &getFactoid($faqtoid);
478
479         if (!defined $result) {
480             &performReply("i didn't have anything ('$faqtoid') to undelete.");
481             return;
482         }
483
484         if (defined $check) {
485             &performReply("cannot undeleted '$faqtoid' because it already exists?");
486             return;
487         }
488
489         &setFactInfo($faqtoid." #DEL#", "factoid_key", $faqtoid);
490
491         ### delete info. modified_ isn't really used.
492         &setFactInfo($faqtoid, "modified_by",  "");
493         &setFactInfo($faqtoid, "modified_time", 0);
494
495         &performReply("Successfully recovered '$faqtoid'.  Have fun now.");
496
497         $count{'Undelete'}++;
498
499         return;
500     }
501
502     # factoid locking.
503     if ($message =~ /^((un)?lock)(\s+(.*))?\s*?$/i) {
504         return 'lock: no addr 2' unless ($addressed);
505
506         my $function = lc $1;
507         my $faqtoid  = lc $4;
508
509         if ($faqtoid eq "") {
510             &help($function);
511             return;
512         }
513
514         if (&getFactoid($faqtoid) eq "") {
515             &msg($who, "factoid \002$faqtoid\002 does not exist");
516             return;
517         }
518
519         if ($function eq "lock") {
520             # strongly requested by #debian on 19991028. -xk
521             if (1 and $faqtoid !~ /^\Q$who\E$/i and &IsFlag("o") ne "o") {
522                 &msg($who,"sorry, locking cannot be used since it can be abused unneccesarily.");
523                 &status("Replace 1 with 0 in Process.pl#~324 for locking support.");
524                 return;
525             }
526
527             &CmdLock($faqtoid);
528         } else {
529             &CmdUnLock($faqtoid);
530         }
531
532         return;
533     }
534
535     # factoid rename.
536     if ($message =~ s/^rename(\s+|$)//) {
537         return 'rename: no addr' unless ($addressed);
538
539         if ($message eq "") {
540             &help("rename");
541             return;
542         }
543
544         if ($message =~ /^'(.*)'\s+'(.*)'$/) {
545             my($from,$to) = (lc $1, lc $2);
546
547             my $result = &getFactoid($from);
548             if (defined $result) {
549                 my $author = &getFactInfo($from, "created_by");
550
551                 if (&IsFlag("m") or $author =~ /^\Q$who\E\!/i) {
552                     &msg($who, "It's not yours to modify.");
553                     return;
554                 }
555
556                 if ($_ = &getFactoid($to)) {
557                     &performReply("destination factoid already exists.");
558                     return;
559                 }
560
561                 &setFactInfo($from,"factoid_key",$to);
562
563                 &status("rename: <$who> '$from' is now '$to'");
564                 &performReply("i renamed '$from' to '$to'");
565             } else {
566                 &performReply("i didn't have anything called '$from'");
567             }
568         } else {
569             &msg($who,"error: wrong format. ask me about 'help rename'.");
570         }
571
572         return;
573     }
574
575     # factoid substitution. (X =~ s/A/B/FLAG)
576     if ($message =~ m|^(.*?)\s+=~\s+s([/,#])(.+?)\2(.*?)\2([a-z]*);?\s*$|) {
577         my ($faqtoid,$delim,$op,$np,$flags) = (lc $1, $2, $3, $4, $5);
578         return 'subst: no addr' unless ($addressed);
579
580         # incorrect format.
581         if ($np =~ /$delim/) {
582             &msg($who,"looks like you used the delimiter too many times. You may want to use a different delimiter, like ':' or '#'.");
583             return;
584         }
585
586         # success.
587         if (my $result = &getFactoid($faqtoid)) {
588             return 'subst: locked' if (&IsLocked($faqtoid) == 1);
589             my $was = $result;
590
591             if (($flags eq "g" && $result =~ s/\Q$op/$np/gi) || $result =~ s/\Q$op/$np/i) {
592                 if (length $result > $param{'maxDataSize'}) {
593                     &performReply("that's too long");
594                     return;
595                 }
596                 &setFactInfo($faqtoid, "factoid_value", $result);
597                 &status("update: '$faqtoid' =is=> '$result'; was '$was'");
598                 &performReply("OK");
599             } else {
600                 &performReply("that doesn't contain '$op'");
601             }
602         } else {
603             &performReply("i didn't have anything called '$faqtoid'");
604         }
605
606         return;
607     }
608
609     # Fix up $message for question.
610     my $question = $message;
611     for ($question) {
612         # fix the string.
613         s/^hey([, ]+)where/where/i;
614         s/\s+\?$/?/;
615         s/whois/who is/ig;
616         s/where can i find/where is/i;
617         s/how about/where is/i;
618         s/ da / the /ig;
619
620         # clear the string of useless words.
621         s/^(stupid )?q(uestion)?:\s+//i;
622         s/^(does )?(any|ne)(1|one|body) know //i;
623
624         s/^[uh]+m*[,\.]* +//i;
625
626         s/^well([, ]+)//i;
627         s/^still([, ]+)//i;
628         s/^(gee|boy|golly|gosh)([, ]+)//i;
629         s/^(well|and|but|or|yes)([, ]+)//i;
630
631         s/^o+[hk]+(a+y+)?([,. ]+)//i;
632         s/^g(eez|osh|olly)([,. ]+)//i;
633         s/^w(ow|hee|o+ho+)([,. ]+)//i;
634         s/^heya?,?( folks)?([,. ]+)//i;
635     }
636
637     if ($addressed and $message =~ s/^no([, ]+)(\Q$ident\E\,+)?\s*//i) {
638         $correction_plausible = 1;
639         &status("correction is plausible, initial negative and nick deleted ($&)") if ($param{VERBOSITY});
640     } else {
641         $correction_plausible = 0;
642     }
643
644     my $result = &doQuestion($question);
645     if (!defined $result or $result eq $noreply) {
646         return 'result from doQ undef.';
647     }
648
649     if (defined $result and $result !~ /^0?$/) {        # question.
650         &status("question: <$who> $message");
651         $count{'Question'}++;
652     } elsif (&IsChanConf("perlMath") > 0 and $addressed) { # perl math.
653         &loadMyModule("perlMath");
654         my $newresult = &perlMath();
655
656         if (defined $newresult and $newresult ne "") {
657             $cmdstats{'Maths'}++;
658             $result = $newresult;
659             &status("math: <$who> $message => $result");
660         }
661     }
662
663     if ($result !~ /^0?$/) {
664         &performStrictReply($result);
665         return;
666     }
667
668     # why would a friendly bot get passed here?
669     if (&IsParam("friendlyBots")) {
670         return if (grep lc($_) eq lc($who), split(/\s+/, $param{'friendlyBots'}));
671     }
672
673     # do the statement.
674     if (!defined &doStatement($message)) {
675         return;
676     }
677
678     return unless ($addressed);
679
680     if (length $message > 64) {
681         &status("unparseable-moron: $message");
682 #       &performReply( &getRandom(keys %{ $lang{'moron'} }) );
683         $count{'Moron'}++;
684
685         &performReply("You are moron #".$count{'Moron'}."!");
686         return;
687     }
688
689     &status("unparseable: $message");
690     &performReply( &getRandom(keys %{ $lang{'dunno'} }) );
691     $count{'Dunno'}++;
692 }
693
694 1;