+ 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'.");
+ fetch_pgn($url);
+ } elsif ($msg =~ /^stoppgn$/) {
+ $t->cmd("tell $who Stopping poll.");
+ $stop_pgn_fetch = 1;
+ $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";
+}
+
+# Starts periodic fetching of PGNs from the given URL.
+sub fetch_pgn {
+ my ($url) = @_;
+ AnyEvent::HTTP::http_get($url, sub {
+ handle_pgn(@_, $url);
+ });
+}
+
+my ($last_pgn_white, $last_pgn_black);
+my @last_pgn_uci_moves = ();
+my $pgn_hysteresis_counter = 0;
+
+sub handle_pgn {
+ my ($body, $header, $url) = @_;
+
+ if ($stop_pgn_fetch) {
+ $stop_pgn_fetch = 0;
+ $http_timer = undef;
+ return;
+ }
+
+ my $pgn = Chess::PGN::Parse->new(undef, $body);
+ if (!defined($pgn) || !$pgn->read_game() || $body !~ /^\[/) {
+ warn "Error in parsing PGN from $url\n";
+ } else {
+ eval {
+ $pgn->parse_game({ save_comments => 'yes' });
+ my $pos = Position->start_pos($pgn->white, $pgn->black);
+ my $moves = $pgn->moves;
+ my @uci_moves = ();
+ for my $move (@$moves) {
+ my $uci_move;
+ ($pos, $uci_move) = $pos->make_pretty_move($move);
+ push @uci_moves, $uci_move;
+ }
+ $pos->{'result'} = $pgn->result;
+ $pos->{'pretty_history'} = $moves;
+
+ extract_clock($pgn, $pos);
+
+ # Sometimes, PGNs lose a move or two for a short while,
+ # or people push out new ones non-atomically.
+ # Thus, if we PGN doesn't change names but becomes
+ # shorter, we mistrust it for a few seconds.
+ my $trust_pgn = 1;
+ if (defined($last_pgn_white) && defined($last_pgn_black) &&
+ $last_pgn_white eq $pgn->white &&
+ $last_pgn_black eq $pgn->black &&
+ scalar(@uci_moves) < scalar(@last_pgn_uci_moves)) {
+ if (++$pgn_hysteresis_counter < 3) {
+ $trust_pgn = 0;
+ }
+ }
+ if ($trust_pgn) {
+ $last_pgn_white = $pgn->white;
+ $last_pgn_black = $pgn->black;
+ @last_pgn_uci_moves = @uci_moves;
+ $pgn_hysteresis_counter = 0;
+ handle_position($pos);
+ }
+ };
+ if ($@) {
+ warn "Error in parsing moves from $url\n";
+ }
+ }
+
+ $http_timer = AnyEvent->timer(after => 1.0, cb => sub {
+ fetch_pgn($url);
+ });
+}
+
+sub handle_position {
+ my ($pos) = @_;
+ find_clock_start($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)) {
+ # Store the final data we have for this position in the history,
+ # with the precise clock information we just got from the new
+ # position. (Historic positions store the clock at the end of
+ # the position.)
+ #
+ # Do not output anything new to the main analysis; that's
+ # going to be obsolete really soon.
+ $pos_calculating->{'white_clock'} = $pos->{'white_clock'};
+ $pos_calculating->{'black_clock'} = $pos->{'black_clock'};
+ delete $pos_calculating->{'white_clock_target'};
+ delete $pos_calculating->{'black_clock_target'};
+ output_json(1);
+
+ 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;
+ }
+
+ if (defined($engine2)) {
+ if (defined($pos_calculating_second_engine)) {
+ uciprint($engine2, "stop");
+ } else {
+ uciprint($engine2, "position fen " . $pos->fen());
+ uciprint($engine2, "go infinite");
+ $pos_calculating_second_engine = $pos;
+ }
+ $engine2->{'info'} = {};
+ }
+
+ $engine->{'info'} = {};
+ $last_move = time;
+
+ schedule_tb_lookup();
+
+ #
+ # Output a command every move to note that we're
+ # still paying attention -- this is a good tradeoff,
+ # since if no move has happened in the last half
+ # hour, the analysis/relay has most likely stopped
+ # and we should stop hogging server resources.
+ #
+ $t->cmd("date");