+ parse_ids($engine, @ids);
+ }
+ if ($line =~ /^bestmove/) {
+ if ($primary) {
+ return if (!$remoteglotconf::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 } (@remoteglotconf::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;
+ my @uci_moves = ();
+ for my $move (@$moves) {
+ my ($from_row, $from_col, $to_row, $to_col, $promo) = $pos->parse_pretty_move($move);
+ push @uci_moves, Board::move_to_uci_notation($from_row, $from_col, $to_row, $to_col, $promo);
+ $pos = $pos->make_move($from_row, $from_col, $to_row, $to_col, $promo);
+ }
+ $pos->{'history'} = \@uci_moves;
+ $pos->{'pretty_history'} = $moves;
+ handle_position($pos);
+ }
+
+ $http_timer = AnyEvent->timer(after => 1.0, cb => sub {
+ AnyEvent::HTTP::http_get($url, sub {
+ handle_pgn(@_, $url);
+ });
+ });
+}
+
+sub handle_position {
+ my ($pos) = @_;
+
+ # if this is already in the queue, ignore it
+ return if (defined($pos_waiting) && $pos->fen() eq $pos_waiting->fen());
+
+ # if we're already chewing on this and there's nothing else in the queue,
+ # also ignore it
+ return if (!defined($pos_waiting) && defined($pos_calculating) &&
+ $pos->fen() eq $pos_calculating->fen());
+
+ # if we're already thinking on something, stop and wait for the engine
+ # to approve
+ if (defined($pos_calculating)) {
+ if (!defined($pos_waiting)) {
+ uciprint($engine, "stop");
+ }
+ if ($remoteglotconf::uci_assume_full_compliance) {
+ $pos_waiting = $pos;
+ } else {
+ uciprint($engine, "position fen " . $pos->fen());
+ uciprint($engine, "go infinite");
+ $pos_calculating = $pos;
+ }
+ } else {
+ # it's wrong just to give the FEN (the move history is useful,
+ # and per the UCI spec, we should really have sent "ucinewgame"),
+ # but it's easier
+ uciprint($engine, "position fen " . $pos->fen());
+ uciprint($engine, "go infinite");
+ $pos_calculating = $pos;