In development, doesn't work currently

diff --git a/irc/rc2irc.php b/irc/rc2irc.php
new file mode 100644 (file)
index 0000000..41d6b15
--- /dev/null
+++ b/irc/rc2irc.php
@@ -0,0 +1,192 @@
+<?
+
+$ircNick = "wikipedia_rc";
+$rooms = array("en" => 1, "fr" => 1, "de" => 1);
+$ircServer = "irc.freenode.net"
+$ircSockName = "tcp://$ircServer";
+$ircPort = 6667;
+$minDelay = 0.5;
+$ircReadTimeout = 200000; # us
+$ircWriteTimeout = 30; # s
+$fmB = chr(2);
+$fmU = chr(31);
+$queueId = 337055475;
+$maxMessageSize = 16384;
+
+#-----------------------------------------------------------------------------
+
+# Get queue
+
+$ircPassword = mt_rand(0xffffffff);
+$hostname = getenv('SERVER_NAME');
+
+$queue = msg_get_queue($queueId);
+
+if ( !$queue ) {
+       print "Could not open RC message queue\n";
+       exit;
+}
+emptyQueue( $queue );
+
+# Initialise the IRC connection
+$sockIRC = fsockopen( $ircSockName, $ircPort );
+if ( !$sockIRC ) {
+       print "Could not open IRC connection\n";
+       exit;
+}
+stream_set_timeout($sockIRC, 0, $ircWriteTimeout);
+
+fwrite( $sockIRC, 
+       "PASS $ircPassword\r\n" .
+       "NICK $ircNick\r\n" . 
+       "USER recentchanges $hostname $ircServer Wikipedia RC->IRC bot\r\n"
+);
+
+foreach ( $rooms as $room => $v ) {
+       joinRoom( $sockIRC, $room );
+}
+
+$readObjs = array( $sockIRC, $queue );
+
+# Main input loop
+$die = false;
+while ( !$die ) {
+       # RC input
+       $msgType = 0;
+       $entry = false;
+       if (!msg_receive($queue, 0, $msgType, $maxMessageSize, $entry, true, MSG_IPC_NOWAIT)) {
+               $entry = false;
+       }
+       if (is_array( $entry )) {
+               $out = getIrcOutput( $sockIRC, $entry );
+               fwrite( $sockIRC, $out );
+       }
+       
+       # IRC input
+       stream_set_timeout($sockIRC, 0, $ircReadTimeout);
+       $line = rtrim(fgets( $sockIRC ));
+       stream_set_timeout($sockIRC, 0, $ircWriteTimeout);
+       if ( $line ) {
+               $die = processIrcInput( $sockIRC, $line );
+       }
+}
+exit();
+
+#--------------------------------------------------------------
+function delayMin()
+{
+       static $lastTime = 0;
+       global $minDelay;
+       if ( !$lastTime ) {
+               $lastTime = getMicroTime();
+       }
+       $curTime = getMicroTime();
+       $timeDifference = $curTime - $lastTime;
+       if ( $timeDifference < $minDelay ) {
+               usleep( ($minDelay - $timeDifference) *1000000 );
+       }
+       $lastTime = $curTime;
+}
+
+function getMicroTime()
+{
+       list($usec, $sec) = explode(" ",microtime()); 
+       return ((float)$usec + (float)$sec); 
+}
+
+function getIrcOutput( $socket, $in )
+{
+       global $rooms;
+       
+       delayMin();
+       $bad = array("\n", "\r");
+       $empty = array("", "");
+       $comment =  $in['comment'];
+       $title = $in['prefixedDBkey'];
+       $user = $in['userText'];
+       $lastid = IntVal($in['lastOldid']);
+       $flag = ($in['minor'] ? "M" : "") . ($in['new'] ? "N" : "");
+       $lang = $in['lang'];
+       if ( $lang == "w" ) {
+               $lang = "en";
+       }
+       
+       if ( !array_key_exists( $rooms, $lang ) ) {
+               return "";
+       }
+       $room = "#{$lang}rc.wikipedia";
+               
+       if ( $in['new'] ) {
+               $url = "http://$lang.wikipedia.org/wiki/" . urlencode($title);
+       } else {
+               $url = "http://$lang.wikipedia.org/w/wiki.phtml?title=" . urlencode($title) .
+                       "&diff=0&oldid=$lastid";
+       }
+       $spaceTitle = str_replace("_", " ", $title);
+       
+       $beep = "";
+       if ( $patterns ) {
+               foreach ( $patterns as $pattern ) {
+                       if ( preg_match( $pattern, $comment ) ) {
+                               $beep = chr(7);
+                               break;
+                       }
+               }
+       }
+       if ( $comment !== "" ) {
+               $comment = "($comment)";
+       }
+       
+       $fullString = str_replace($bad, $empty, 
+               "$beep$fmB$spaceTitle$fmB   $flag   $url   $user $comment");
+       $fullString = "PRIVMSG $room :$fullString\r\n";
+       return $fullString;
+}
+
+function joinRoom( $sock, $room )
+{
+       global $rooms;
+       $rooms[$room] = 1;
+       fwrite( $sock, "JOIN #{$room}rc.wikipedia\r\n" );
+}
+
+function partRoom( $sock, $room ) 
+{
+       global $rooms;
+       unset( $rooms[$room] );
+       fwrite( $sock, "PART #{$room}rc.wikipedia\r\n" );
+}
+
+function processIrcInput( $sock, $line )
+{
+       global $rooms;
+       
+       $die = false;
+       $args = explode( " ", $line );
+       
+       if ( $args[0] == "PING" ) {
+               fwrite( $sock, "PONG {$args[1]}\r\n" );
+       } elseif ( $args[0]{0} == ":" ) {
+               $name = array_shift( $args );
+               $name = substr($name, 1);
+               $cmd = array_shift( $args );
+               if ( $cmd == "PRIVMSG" ) {
+                       $msgRoom = array_shift( $args );
+                       if ( $args[0] == "die" ) {
+                               $die = true;
+                       } elseif ( $args[0] == "join" ) {
+                               joinRoom( $args[1] );
+                       } elseif ( $args[0] == "part" ) {
+                               partRoom( $args[1] );
+                       }
+               }
+       }
+}
+
+function emptyQueue( $id )
+{
+       while ( msg_receive($queue, 0, $msgType, $maxMessageSize, $entry, true, MSG_IPC_NOWAIT));
+}
+       
+?>
+