-while (1) {
- my $rin = '';
- vec($rin, fileno(UCIREAD), 1) = 1;
- vec($rin, fileno($t), 1) = 1;
-
- my ($nfound, $timeleft) = select($rin, undef, undef, 5.0);
- my $sleep = 1.0;
-
- while (1) {
- my $line = $t->getline(Timeout => 0, errmode => 'return');
- last if (!defined($line));
-
- chomp $line;
- $line =~ tr/\r//d;
- if ($line =~ /^<12> /) {
- my $fen = style12_to_fen($line);
- print UCIWRITE "stop\n";
- print UCIWRITE "position fen $fen\n";
- print UCIWRITE "go infinite\n";
- #print "stop\n";
- #print "position fen $fen\n";
- #print "go infinite\n";
- }
- #print "FICS: [$line]\n";
- $sleep = 0;
+
+my $ev1 = AnyEvent->io(
+ fh => fileno($t),
+ poll => 'r',
+ cb => sub { # what callback to execute
+ while (1) {
+ my $line = $t->getline(Timeout => 0, errmode => 'return');
+ return if (!defined($line));
+
+ chomp $line;
+ $line =~ tr/\r//d;
+ handle_fics($line);
+ }
+ }
+);
+# Engine events have already been set up by Engine.pm.
+EV::run;
+
+sub handle_uci {
+ my ($engine, $line, $primary) = @_;
+
+ $line =~ s/ / /g; # Sometimes needed for Zappa Mexico
+ print UCILOG localtime() . " $engine->{'tag'} <= $line\n";
+ if ($line =~ /^info/) {
+ my (@infos) = split / /, $line;
+ shift @infos;
+
+ parse_infos($engine, @infos);
+ }
+ if ($line =~ /^id/) {
+ my (@ids) = split / /, $line;
+ shift @ids;
+
+ parse_ids($engine, @ids);
+ }
+ if ($line =~ /^bestmove/) {
+ if ($primary) {
+ return if (!$uci_assume_full_compliance);
+ if (defined($pos_waiting)) {
+ uciprint($engine, "position fen " . $pos_waiting->fen());
+ uciprint($engine, "go infinite");
+
+ $pos_calculating = $pos_waiting;
+ $pos_waiting = undef;
+ }
+ } else {
+ $engine2->{'info'} = {};
+ my $pos = $pos_waiting // $pos_calculating;
+ uciprint($engine2, "position fen " . $pos->fen());
+ uciprint($engine2, "go infinite");
+ $pos_calculating_second_engine = $pos;
+ }
+ }
+ output();
+}
+
+sub handle_fics {
+ my $line = shift;
+ if ($line =~ /^<12> /) {
+ handle_position(Position->new($line));
+ }
+ if ($line =~ /^([A-Za-z]+)(?:\([A-Z]+\))* tells you: (.*)$/) {
+ my ($who, $msg) = ($1, $2);
+
+ next if (grep { $_ eq $who } (@masters) == 0);
+
+ if ($msg =~ /^fics (.*?)$/) {
+ $t->cmd("tell $who Executing '$1' on FICS.");
+ $t->cmd($1);
+ } elsif ($msg =~ /^uci (.*?)$/) {
+ $t->cmd("tell $who Sending '$1' to the engine.");
+ print { $engine->{'write'} } "$1\n";
+ } elsif ($msg =~ /^pgn (.*?)$/) {
+ my $url = $1;
+ $t->cmd("tell $who Starting to poll '$url'.");
+ AnyEvent::HTTP::http_get($url, sub {
+ handle_pgn(@_, $url);
+ });
+ } elsif ($msg =~ /^stoppgn$/) {
+ $t->cmd("tell $who Stopping poll.");
+ $http_timer = undef;
+ } elsif ($msg =~ /^quit$/) {
+ $t->cmd("tell $who Bye bye.");
+ exit;
+ } else {
+ $t->cmd("tell $who Couldn't understand '$msg', sorry.");
+ }
+ }
+ #print "FICS: [$line]\n";
+}
+
+sub handle_pgn {
+ my ($body, $header, $url) = @_;
+ my $pgn = Chess::PGN::Parse->new(undef, $body);
+ if (!defined($pgn) || !$pgn->read_game()) {
+ warn "Error in parsing PGN from $url\n";
+ } else {
+ $pgn->quick_parse_game;
+ my $pos = Position->start_pos($pgn->white, $pgn->black);
+ my $moves = $pgn->moves;
+ for my $move (@$moves) {
+ my ($from_row, $from_col, $to_row, $to_col, $promo) = $pos->parse_pretty_move($move);
+ $pos = $pos->make_move($from_row, $from_col, $to_row, $to_col, $promo);
+ }
+ handle_position($pos);