[S'enregister] - [S'identifier]
gheop wall

IRC Bot

Perl
par Iris (07/11/06)
/me test encore.
Cacher les numéros de lignes
  1. #!/usr/bin/perl -w
  2.  
  3. use strict;
  4. use IO::Socket;
  5. use IO::Select;
  6.  
  7. my $version = 0.2;
  8. my $inbytes = 0;
  9. my $outbytes = 0;
  10. #my @queue; #bah ué c pas encore fait XD
  11. my $cfg = "bot.cfg"; #le fichier de conf
  12. my %opts;
  13. our $sock;
  14. my $fh;
  15. my $buffer = '';
  16. my $ping = 0;
  17.  
  18.  
  19. &readconf;
  20. require Update;
  21. &Update::update($version) if ($opts{checkupdates});
  22.  
  23. #require Parse;
  24. #require Send;
  25.  
  26. CONNECT:
  27. &connect;
  28. my $sel = IO::Select->new($sock);
  29. my $compteur = time;
  30. my $timer = time;
  31. &send("PASS $opts{botpass}");&send("NICK $opts{botnick}");
  32. &send("USER $opts{botuser} 0 0 :$opts{botrealname}");
  33.  
  34. while (1)
  35. {
  36.     my($readable) = IO::Select->select($sel,undef,undef,0.5);
  37.     if (defined($readable))
  38.     {
  39. 	$timer = time;
  40. 	$fh = $readable->[0];
  41.  
  42.  
  43. 	my $buffer2;
  44.         $fh->recv($buffer2,512,0);
  45.         if (length($buffer2))
  46. 	{
  47. 	    $buffer .= $buffer2;
  48.      	    while (index($buffer,"\n") != -1)
  49.  	    {
  50. 		my $line = substr($buffer,0,index($buffer,"\n")+1);
  51. 		$buffer = substr($buffer,length($line));
  52. 		$inbytes = parse($line, $inbytes, $outbytes, $compteur, $cfg, %opts);
  53. 	    }
  54.         }
  55. 	else
  56. 	{
  57. 	    &reconnect;
  58. 	}
  59.     }
  60.     else
  61.     {
  62. 	select(undef,undef,undef,1);
  63. 	&reconnect if (time - $opts{timer} > $timer);
  64.     }
  65. }
  66.  
  67. sub reconnect
  68. {
  69.   close($fh);
  70.   $sel->remove($fh);
  71. #  undef(@queue);
  72.   undef($sock);
  73.   &affich("Deconnecte. $opts{reconnect_wait}s avant la reconnection...", 3);
  74.   sleep($opts{reconnect_wait});
  75.   goto CONNECT;
  76. }
  77.  
  78.  
  79. sub parse
  80. {
  81.     my($in) = shift;
  82.     $inbytes += length($in);
  83.     $in =~ s/[\r\n]//g;
  84.     my @arg = split(/\s/,$in);
  85.     &parse_affich($in);
  86.  
  87.  
  88.     if (lc($arg[0]) eq 'ping')
  89.     {
  90. 	$ping++;
  91. 	if($ping == 100)
  92. 	{
  93. 	    ;
  94. 	}
  95. 	&send("PONG $arg[1]");
  96.     }
  97.     elsif ($arg[1] && $arg[1] eq '376')
  98.     {
  99. 	&send("MODE $opts{botnick} +BT-s");
  100. 	&send("JOIN $_") for(@{$opts{chans}});
  101.     }
  102.     elsif ($arg[1] && lc($arg[1]) eq 'kick')
  103.     {
  104. 	&send("JOIN $arg[2]");
  105.     }
  106.     elsif(defined($arg[3]))
  107.     {
  108. 	if ($arg[0] =~ /^$opts{mask}$/)
  109. 	{
  110. 	    if ($arg[3] =~ /^:!reconnect/)
  111. 	    {
  112. 		&send("QUIT :$opts{quit}");
  113. 		&reconnect;
  114. 	    }
  115. 	    elsif ($arg[3] =~ /^:!quit/)
  116. 	    {
  117. 		&send("QUIT :$opts{quit}");
  118. 		sleep(2);
  119. 		exit (0);
  120. 	    }
  121. 	    elsif ($arg[3] =~ /^:!stats/)
  122. 	    {
  123. 		&send("PRIVMSG $arg[2] :recu : $inbytes octets | envoye : $outbytes octets");
  124. 	    }
  125. 	    elsif ($arg[3] =~ /^:!join/ && defined($arg[4]))
  126. 	    {
  127. 		&send("JOIN $arg[4]");
  128. 		if(open(FD,">>$cfg")) {print FD "\nchan=$arg[4]";}
  129. 		else {&affich("Impossible d'ouvrir $cfg en ecriture", 2); }
  130. 		close(FD);
  131. 		push(@{$opts{chans}},$arg[4]);
  132. 	    }
  133. 	    elsif ($arg[3] =~ /^:act$/ && defined($arg[4]))
  134. 	    {
  135. 		$in =~ /^:.*?:.*?\s+?.*?\s+?(.*)$/;
  136. 		&send("PRIVMSG $arg[4] :\001ACTION $1\001");
  137. 	    }
  138. 	    elsif ($arg[3] =~ /^:say$/ && defined($arg[4]))
  139. 	    {
  140. 		$in =~ /^:.*?:.*?\s+?.*?\s+?(.*)$/;
  141. 		&send("PRIVMSG $arg[4] :$1");
  142. 	    }
  143. 	    elsif ($arg[3] =~ /^:raw$/ && defined($arg[4]))
  144. 	    {
  145. 		$in =~ /^:.*?:.*?\s+?(.*)$/;
  146. 		&send("$1");
  147. 	    }
  148. 	    elsif (lc($arg[3]) eq ":ame" && defined($arg[4]))
  149. 	    {
  150. 		$in =~ /^:.*?:.*?\s+?(.*)$/;
  151. 		&send("PRIVMSG $_ :\001ACTION $1\001") for(@{$opts{chans}});;
  152. 	    }
  153. 	    elsif (lc($arg[3]) eq ":amsg" && defined($arg[4]))
  154. 	    {
  155. 		$in =~ /^:.*?:.*?\s+?(.*)$/;
  156. 		&send("PRIVMSG $_ :$1") for(@{$opts{chans}});;
  157. 	    }
  158. 	    elsif (lc($arg[3]) eq ":!logout" )
  159. 	    {
  160. 		$arg[0] =~ /^:(.*?)!.*$/;
  161. 		&send("PRIVMSG $1 :Bye Master :'(");
  162. 		$opts{mask} = "";
  163. 	    }
  164. 	}
  165. 	if ($arg[4] && lc($arg[3]) eq ":identify"
  166. 	    && $arg[4] eq $opts{adminpass})
  167. 	{
  168. 	    $arg[0] =~ /^.*?!(.*)$/;
  169. 	    $opts{mask} = ".*!$1";
  170. 	    $arg[0] =~ /^:(.*?)!.*$/;
  171. 	    &send("PRIVMSG $1 :Hello master =) I'm here to serve you !");
  172. 	}
  173. 	elsif (lc($arg[3]) eq ":!tps")
  174. 	{
  175. 	    my $diff = time - $compteur;
  176. 	    my $d = int($diff / (3600*24));
  177. 	    my $h = int(($diff - $d*3600*24) / 3600);
  178. 	    my $m = int(($diff - $h*3600)/60);
  179. 	    my $s = int($diff- $h*3600 - $m*60);
  180. 	    &send("PRIVMSG $arg[2] :J'suis connecté depuis".($d)?("$d jours"):("")."$h heures $m minutes $s secondes.");
  181. 	}
  182.     }
  183. }
  184.  
  185. sub send
  186. {
  187.     my($text) = @_;
  188.     if ($sock)
  189.     {
  190. 	print $sock "$text\r\n";
  191. 	$outbytes += length($text) + 2;
  192. 	print "\033[35m-> $text\033[m\n";
  193.     }
  194.     else
  195.     {
  196. #	undef(@queue);
  197. 	print "\$sock n'est pas writeable\n";
  198. 	return;
  199.     }
  200. }
  201.  
  202. sub	notice {
  203.     my ($p, $m) = @_;
  204.     while (length($m)) {
  205. 	&send('NOTICE $p :'.substr($m, 0, 450));
  206. 	substr($m, 0, 450) = '';
  207.     }
  208. }
  209. sub parse_affich
  210. {
  211.     my($in) = shift;
  212.     my @arg = split(/\s/,$in);
  213.     my ($hour, $min,$sec) = (localtime)[2,1,0];
  214.     printf("\033[43m\033[30m%02d:%02d:%02d\033[m\033[m ", $hour, $min,$sec);
  215.     $in =~ s/['\001''\377']//g;
  216.     if ($arg[1] && ($arg[1] =~ /^\d+$/ ||
  217. 		    ($arg[1] eq 'NOTICE' && $arg[2] && $arg[2] eq 'AUTH')))
  218.     {
  219. 	$in =~ /^:.*?\s.*?\s.*?\s:?(.*)/;
  220. 	print "$1\n";
  221.     }
  222.     elsif ($arg[1] && lc($arg[1]) eq "privmsg")
  223.     {
  224. 	$in =~ /:(.*?)!.*?:(.*)$/;
  225. 	if (lc($arg[2]) eq lc($opts{botnick}))
  226. 	{
  227. 	    print "\a\033[35mPV\033[m \033[34m$1\033[m $2\033[m\n";
  228. 	}
  229. 	else
  230. 	{
  231. 	    print "\033[32m$arg[2]\033[m \033[34m$1\033[m $2\n";
  232. 	}
  233.     }
  234.     elsif ($arg[1] && lc($arg[1]) eq "quit")
  235.     {
  236. 	$in =~ /:(.*?)!.*?:(.*)$/;
  237. 	print "\033[35m* $1 a quitté ($2)\033[m\n";
  238.     }
  239.     else
  240.     {
  241. 	print "\033[32m<- $in\033[m\n";
  242.     }
  243. }
  244.  
  245. sub readconf
  246. {
  247.     open(I,"<$cfg") || die "Can't read $cfg: $!\n";
  248.     chomp (my @lines = (<I>));
  249.     close I;
  250.     foreach (@lines)
  251.     {
  252. 	next() if $_ =~ /^#/;
  253. 	$_ =~ s/[\r\n]//g;
  254. 	$_ =~ s/^\s+//g;
  255. 	next() if !length($_);
  256. 	my ($key,$val) = split(/=/,$_,2);
  257. 	$key = lc($key);
  258. 	if (lc($val) eq "on" || lc($val) eq "yes") { $val = 1; }
  259. 	elsif (lc($val) eq "off" || lc($val) eq "no") { $val = 0; }
  260. 	if ($key eq "chan") { push(@{$opts{chans}},$val); }
  261. 	elsif ($key eq "server") { push(@{$opts{servers}},$val); }
  262. 	else { $opts{$key} = $val; }
  263.     }
  264. }
  265.  
  266. sub connect
  267. {
  268.     while (!$sock)
  269.     {
  270. 	print "\nConnection a $opts{servers}->[0]...\n";
  271. 	my %sockinfo = (PeerAddr => $opts{servers}->[0],
  272. 			PeerPort => 6667);
  273. 	$sock = IO::Socket::INET->new(%sockinfo) or
  274. 	    print "ERREUR : Impossible de se connecter: $!\n";
  275. 	push(@{$opts{servers}},shift(@{$opts{servers}})) if (!$sock);
  276.     }
  277.     print "Connecté!\n";
  278. }
  279.