X-Git-Url: https://git.sesse.net/?p=remoteglot;a=blobdiff_plain;f=remoteglot.pl;h=371c837e3b760192a76c555bc4bed278c8cfe6a0;hp=28bebd25cfcf57de6e1685b83b202e9c03ebb70f;hb=04b8054fd4578a7df332271d314833342d5e7d28;hpb=9dd7122b75bf598f16a18a70bc8b2eb519d0796b diff --git a/remoteglot.pl b/remoteglot.pl index 28bebd2..371c837 100755 --- a/remoteglot.pl +++ b/remoteglot.pl @@ -13,20 +13,29 @@ use Net::Telnet; use FileHandle; use IPC::Open2; use Time::HiRes; +use JSON::XS; +require 'Position.pm'; use strict; use warnings; # Configuration my $server = "freechess.org"; -my $target = "22"; -# my $engine = "/usr/games/toga2"; -my $engine = "wine Rybkav2.3.2a.mp.w32.exe"; -my $telltarget = undef; # undef to be silent -my @tell_intervals = (5, 20, 60, 120, 240, 480, 960); # after each move +my $target = "GMCarlsen"; +my $engine_cmdline = "'./Deep Rybka 4 SSE42 x64'"; +my $engine2_cmdline = "./stockfish_13111119_x64_modern_sse42"; # undef for none my $uci_assume_full_compliance = 0; # dangerous :-) +my $update_max_interval = 1.0; +my @masters = ( + 'Sesse', + 'Sessse', + 'Sesssse', + 'greatestguns', + 'beuki' +); # Program starts here -$SIG{ALRM} = sub { output_screen(); }; +$SIG{ALRM} = sub { output(); }; +my $latest_update = undef; $| = 1; @@ -44,39 +53,36 @@ $| = 1; select(STDOUT); # open the chess engine -my $pid = IPC::Open2::open2(*UCIREAD, *UCIWRITE, $engine); -my %uciinfo = (); -my %uciid = (); -my ($last_move, $last_tell); +my $engine = open_engine($engine_cmdline, 'E1'); +my $engine2 = open_engine($engine2_cmdline, 'E2'); +my $last_move; my $last_text = ''; -my $last_told_text = ''; -my ($pos_waiting, $pos_calculating); - -uciprint("uci"); - -# gobble the options -while () { - /uciok/ && last; - handle_uci($_); +my ($pos_waiting, $pos_calculating, $pos_calculating_second_engine); + +uciprint($engine, "setoption name UCI_AnalyseMode value true"); +# uciprint($engine, "setoption name NalimovPath value /srv/tablebase"); +uciprint($engine, "setoption name NalimovUsage value Rarely"); +uciprint($engine, "setoption name Hash value 1024"); +# uciprint($engine, "setoption name MultiPV value 2"); +uciprint($engine, "ucinewgame"); + +if (defined($engine2)) { + uciprint($engine2, "setoption name UCI_AnalyseMode value true"); + # uciprint($engine2, "setoption name NalimovPath value /srv/tablebase"); + uciprint($engine2, "setoption name NalimovUsage value Rarely"); + uciprint($engine2, "setoption name Hash value 1024"); + uciprint($engine2, "setoption name Threads value 8"); + uciprint($engine2, "setoption name MultiPV value 500"); + uciprint($engine2, "ucinewgame"); } -uciprint("setoption name UCI_AnalyseMode value true"); -# uciprint("setoption name Preserve Analysis value true"); -uciprint("setoption name NalimovPath value c:\\nalimov"); -uciprint("setoption name NalimovUsage value Rarely"); -uciprint("setoption name Hash value 1024"); -uciprint("setoption name MultiPV value 3"); -# uciprint("setoption name Contempt value 1000"); -# uciprint("setoption name Outlook value Ultra Optimistic"); -uciprint("ucinewgame"); - print "Chess engine ready.\n"; # now talk to FICS my $t = Net::Telnet->new(Timeout => 10, Prompt => '/fics% /'); $t->input_log(\*FICSLOG); $t->open($server); -$t->print("guest"); +$t->print("SesseBOT"); $t->waitfor('/Press return to enter the server/'); $t->cmd(""); @@ -91,7 +97,10 @@ print "FICS ready.\n"; while (1) { my $rin = ''; my $rout; - vec($rin, fileno(UCIREAD), 1) = 1; + vec($rin, fileno($engine->{'read'}), 1) = 1; + if (defined($engine2)) { + vec($rin, fileno($engine2->{'read'}), 1) = 1; + } vec($rin, fileno($t), 1) = 1; my ($nfound, $timeleft) = select($rout=$rin, undef, undef, 5.0); @@ -104,39 +113,50 @@ while (1) { chomp $line; $line =~ tr/\r//d; if ($line =~ /^<12> /) { - my $pos = style12_to_fen($line); + my $pos = Position->new($line); # if this is already in the queue, ignore it - next if (defined($pos_waiting) && $pos->{'fen'} eq $pos_waiting->{'fen'}); + next 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 next if (!defined($pos_waiting) && defined($pos_calculating) && - $pos->{'fen'} eq $pos_calculating->{'fen'}); + $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("stop"); + uciprint($engine, "stop"); } if ($uci_assume_full_compliance) { $pos_waiting = $pos; } else { - uciprint("position fen " . $pos->{'fen'}); - uciprint("go infinite"); + 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("position fen " . $pos->{'fen'}); - uciprint("go infinite"); + uciprint($engine, "position fen " . $pos->fen()); + uciprint($engine, "go infinite"); $pos_calculating = $pos; } - %uciinfo = (); + 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; # @@ -148,87 +168,135 @@ while (1) { # $t->cmd("date"); } + 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"; + } else { + $t->cmd("tell $who Couldn't understand '$msg', sorry."); + } + } #print "FICS: [$line]\n"; $sleep = 0; } # any fun on the UCI channel? - if ($nfound > 0 && vec($rout, fileno(UCIREAD), 1) == 1) { - my $line = ; - handle_uci($line); + if ($nfound > 0 && vec($rout, fileno($engine->{'read'}), 1) == 1) { + my @lines = read_lines($engine); + for my $line (@lines) { + next if $line =~ /(upper|lower)bound/; + handle_uci($engine, $line, 1); + } $sleep = 0; - # don't update too often - Time::HiRes::alarm(0.2); + output(); + } + if (defined($engine2) && $nfound > 0 && vec($rout, fileno($engine2->{'read'}), 1) == 1) { + my @lines = read_lines($engine2); + for my $line (@lines) { + next if $line =~ /(upper|lower)bound/; + handle_uci($engine2, $line, 0); + } + $sleep = 0; + + output(); } sleep $sleep; } sub handle_uci { - my ($line) = @_; + my ($engine, $line, $primary) = @_; chomp $line; $line =~ tr/\r//d; - print UCILOG localtime() . " <= $line\n"; + $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(@infos); + parse_infos($engine, @infos); } if ($line =~ /^id/) { my (@ids) = split / /, $line; shift @ids; - parse_ids(@ids); + parse_ids($engine, @ids); } - if ($line =~ /^bestmove/ && $uci_assume_full_compliance) { - if (defined($pos_waiting)) { - uciprint("position fen " . $pos_waiting->{'fen'}); - uciprint("go infinite"); + 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; + $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; } } } sub parse_infos { - my (@x) = @_; + my ($engine, @x) = @_; my $mpv = ''; + my $info = $engine->{'info'}; + + # Search for "multipv" first of all, since e.g. Stockfish doesn't put it first. + for my $i (0..$#x - 1) { + if ($x[$i] =~ 'multipv') { + $mpv = $x[$i + 1]; + next; + } + } + while (scalar @x > 0) { if ($x[0] =~ 'multipv') { + # Dealt with above + shift @x; shift @x; - $mpv = shift @x; next; } if ($x[0] =~ /^(currmove|currmovenumber|cpuload)$/) { my $key = shift @x; my $value = shift @x; - $uciinfo{$key} = $value; + $info->{$key} = $value; next; } if ($x[0] =~ /^(depth|seldepth|hashfull|time|nodes|nps|tbhits)$/) { my $key = shift @x; my $value = shift @x; - $uciinfo{$key . $mpv} = $value; + $info->{$key . $mpv} = $value; next; } if ($x[0] eq 'score') { shift @x; - delete $uciinfo{'score_cp' . $mpv}; - delete $uciinfo{'score_mate' . $mpv}; + delete $info->{'score_cp' . $mpv}; + delete $info->{'score_mate' . $mpv}; while ($x[0] =~ /^(cp|mate|lowerbound|upperbound)$/) { if ($x[0] eq 'cp') { shift @x; - $uciinfo{'score_cp' . $mpv} = shift @x; + $info->{'score_cp' . $mpv} = shift @x; } elsif ($x[0] eq 'mate') { shift @x; - $uciinfo{'score_mate' . $mpv} = shift @x; + $info->{'score_mate' . $mpv} = shift @x; } else { shift @x; } @@ -236,7 +304,7 @@ sub parse_infos { next; } if ($x[0] eq 'pv') { - $uciinfo{'pv' . $mpv} = [ @x[1..$#x] ]; + $info->{'pv' . $mpv} = [ @x[1..$#x] ]; last; } if ($x[0] eq 'string' || $x[0] eq 'UCI_AnalyseMode' || $x[0] eq 'setting' || $x[0] eq 'contempt') { @@ -251,13 +319,13 @@ sub parse_infos { } sub parse_ids { - my (@x) = @_; + my ($engine, @x) = @_; while (scalar @x > 0) { if ($x[0] =~ /^(name|author)$/) { my $key = shift @x; my $value = join(' ', @x); - $uciid{$key} = $value; + $engine->{'id'}{$key} = $value; last; } @@ -266,166 +334,54 @@ sub parse_ids { } } -sub style12_to_fen { - my $str = shift; - my %pos = (); - my (@x) = split / /, $str; - - $pos{'board'} = [ @x[1..8] ]; - $pos{'toplay'} = $x[9]; - - # the board itself - my (@board) = @x[1..8]; - for my $rank (0..7) { - $board[$rank] =~ s/(-+)/length($1)/ge; - } - my $fen = join('/', @board); - - # white/black to move - $fen .= " "; - $fen .= lc($x[9]); - - # castling - my $castling = ""; - $castling .= "K" if ($x[11] == 1); - $castling .= "Q" if ($x[12] == 1); - $castling .= "k" if ($x[13] == 1); - $castling .= "q" if ($x[14] == 1); - $castling = "-" if ($castling eq ""); - $fen .= " "; - $fen .= $castling; - - # en passant - my $ep = "-"; - if ($x[10] != -1) { - my $col = $x[10]; - my $nep = (qw(a b c d e f g h))[$col]; - - if ($x[9] eq 'B') { - $nep .= "3"; - } else { - $nep .= "6"; - } - - # - # Showing the en passant square when actually no capture can be made - # seems to confuse at least Rybka. Thus, check if there's actually - # a pawn of the opposite side that can do the en passant move, and if - # not, just lie -- it doesn't matter anyway. I'm unsure what's the - # "right" thing as per the standard, though. - # - if ($x[9] eq 'B') { - $ep = $nep if ($col > 0 && substr($pos{'board'}[4], $col-1, 1) eq 'p'); - $ep = $nep if ($col < 7 && substr($pos{'board'}[4], $col+1, 1) eq 'p'); - } else { - $ep = $nep if ($col > 0 && substr($pos{'board'}[3], $col-1, 1) eq 'P'); - $ep = $nep if ($col < 7 && substr($pos{'board'}[3], $col+1, 1) eq 'P'); - } - } - $fen .= " "; - $fen .= $ep; - - # half-move clock - $fen .= " "; - $fen .= $x[15]; - - # full-move clock - $fen .= " "; - $fen .= $x[26]; - - $pos{'fen'} = $fen; - - return \%pos; -} - sub prettyprint_pv { my ($board, @pvs) = @_; - + if (scalar @pvs == 0 || !defined($pvs[0])) { return (); } - - my @nb = @$board; my $pv = shift @pvs; - my $from_col = ord(substr($pv, 0, 1)) - ord('a'); - my $from_row = 7 - (ord(substr($pv, 1, 1)) - ord('1')); - my $to_col = ord(substr($pv, 2, 1)) - ord('a'); - my $to_row = 7 - (ord(substr($pv, 3, 1)) - ord('1')); + my $from_col = col_letter_to_num(substr($pv, 0, 1)); + my $from_row = row_letter_to_num(substr($pv, 1, 1)); + my $to_col = col_letter_to_num(substr($pv, 2, 1)); + my $to_row = row_letter_to_num(substr($pv, 3, 1)); + my $promo = substr($pv, 4, 1); - my $pretty; - my $piece = substr($board->[$from_row], $from_col, 1); + my $nb = $board->make_move($from_row, $from_col, $to_row, $to_col, $promo); + my $piece = $board->[$from_row][$from_col]; if ($piece eq '-') { - die "Invalid move"; + die "Invalid move $pv"; } # white short castling if ($pv eq 'e1g1' && $piece eq 'K') { - # king - substr($nb[7], 4, 1, '-'); - substr($nb[7], 6, 1, $piece); - - # rook - substr($nb[7], 7, 1, '-'); - substr($nb[7], 5, 1, 'R'); - - return ('0-0', prettyprint_pv(\@nb, @pvs)); + return ('0-0', prettyprint_pv($nb, @pvs)); } # white long castling if ($pv eq 'e1c1' && $piece eq 'K') { - # king - substr($nb[7], 4, 1, '-'); - substr($nb[7], 2, 1, $piece); - - # rook - substr($nb[7], 0, 1, '-'); - substr($nb[7], 3, 1, 'R'); - - return ('0-0-0', prettyprint_pv(\@nb, @pvs)); + return ('0-0-0', prettyprint_pv($nb, @pvs)); } # black short castling if ($pv eq 'e8g8' && $piece eq 'k') { - # king - substr($nb[0], 4, 1, '-'); - substr($nb[0], 6, 1, $piece); - - # rook - substr($nb[0], 7, 1, '-'); - substr($nb[0], 5, 1, 'r'); - - return ('0-0', prettyprint_pv(\@nb, @pvs)); + return ('0-0', prettyprint_pv($nb, @pvs)); } # black long castling if ($pv eq 'e8c8' && $piece eq 'k') { - # king - substr($nb[0], 4, 1, '-'); - substr($nb[0], 2, 1, $piece); - - # rook - substr($nb[0], 0, 1, '-'); - substr($nb[0], 3, 1, 'r'); - - return ('0-0-0', prettyprint_pv(\@nb, @pvs)); + return ('0-0-0', prettyprint_pv($nb, @pvs)); } + my $pretty; + # check if the from-piece is a pawn if (lc($piece) eq 'p') { # attack? if ($from_col != $to_col) { $pretty = substr($pv, 0, 1) . 'x' . substr($pv, 2, 2); - - # en passant? - if (substr($board->[$to_row], $to_col, 1) eq '-') { - if ($piece eq 'p') { - substr($nb[$to_row + 1], $to_col, 1, '-'); - } else { - substr($nb[$to_row - 1], $to_col, 1, '-'); - } - } } else { $pretty = substr($pv, 2, 2); @@ -448,23 +404,23 @@ sub prettyprint_pv { my $num_total = 0; for my $col (0..7) { for my $row (0..7) { - next unless (substr($board->[$row], $col, 1) eq $piece); - ++$num_total if (can_reach($board, $piece, $row, $col, $to_row, $to_col)); + next unless ($board->[$row][$col] eq $piece); + ++$num_total if ($board->can_reach($piece, $row, $col, $to_row, $to_col)); } } # see how many of these pieces from the given row could go here my $num_row = 0; for my $col (0..7) { - next unless (substr($board->[$from_row], $col, 1) eq $piece); - ++$num_row if (can_reach($board, $piece, $from_row, $col, $to_row, $to_col)); + next unless ($board->[$from_row][$col] eq $piece); + ++$num_row if ($board->can_reach($piece, $from_row, $col, $to_row, $to_col)); } # and same for columns my $num_col = 0; for my $row (0..7) { - next unless (substr($board->[$row], $from_col, 1) eq $piece); - ++$num_col if (can_reach($board, $piece, $row, $from_col, $to_row, $to_col)); + next unless ($board->[$row][$from_col] eq $piece); + ++$num_col if ($board->can_reach($piece, $row, $from_col, $to_row, $to_col)); } # see if we need to disambiguate @@ -479,31 +435,48 @@ sub prettyprint_pv { } # attack? - if (substr($board->[$to_row], $to_col, 1) ne '-') { + if ($board->[$to_row][$to_col] ne '-') { $pretty .= 'x'; } $pretty .= substr($pv, 2, 2); } - # update the board - substr($nb[$from_row], $from_col, 1, '-'); - substr($nb[$to_row], $to_col, 1, $piece); - - if (in_mate(\@nb)) { + if ($nb->in_mate()) { $pretty .= '#'; - } elsif (in_check(\@nb) ne 'none') { + } elsif ($nb->in_check() ne 'none') { $pretty .= '+'; } - - return ($pretty, prettyprint_pv(\@nb, @pvs)); + return ($pretty, prettyprint_pv($nb, @pvs)); } -sub output_screen { +sub output { #return; - + return if (!defined($pos_calculating)); + # Don't update too often. + my $age = Time::HiRes::tv_interval($latest_update); + if ($age < $update_max_interval) { + Time::HiRes::alarm($update_max_interval + 0.01 - $age); + return; + } + + my $info = $engine->{'info'}; + + # + # Some programs _always_ report MultiPV, even with only one PV. + # In this case, we simply use that data as if MultiPV was never + # specified. + # + if (exists($info->{'pv1'}) && !exists($info->{'pv2'})) { + for my $key (qw(pv score_cp score_mate nodes nps depth seldepth tbhits)) { + if (exists($info->{$key . '1'})) { + $info->{$key} = $info->{$key . '1'}; + } + } + } + # # Check the PVs first. if they're invalid, just wait, as our data # is most likely out of sync. This isn't a very good solution, as @@ -511,385 +484,400 @@ sub output_screen { # eval { my $dummy; - if (exists($uciinfo{'pv'})) { - $dummy = prettyprint_pv($pos_calculating->{'board'}, @{$uciinfo{'pv'}}); + if (exists($info->{'pv'})) { + $dummy = prettyprint_pv($pos_calculating->{'board'}, @{$info->{'pv'}}); } my $mpv = 1; - while (exists($uciinfo{'pv' . $mpv})) { - $dummy = prettyprint_pv($pos_calculating->{'board'}, @{$uciinfo{'pv' . $mpv}}); + while (exists($info->{'pv' . $mpv})) { + $dummy = prettyprint_pv($pos_calculating->{'board'}, @{$info->{'pv' . $mpv}}); ++$mpv; } }; if ($@) { - %uciinfo = (); + $engine->{'info'} = {}; return; } - my $text = ''; + output_screen(); + output_json(); + $latest_update = [Time::HiRes::gettimeofday]; +} + +sub output_screen { + my $info = $engine->{'info'}; + my $id = $engine->{'id'}; + + my $text = 'Analysis'; + if ($pos_calculating->{'last_move'} ne 'none') { + if ($pos_calculating->{'toplay'} eq 'W') { + $text .= sprintf ' after %u. ... %s', ($pos_calculating->{'move_num'}-1), $pos_calculating->{'last_move'}; + } else { + $text .= sprintf ' after %u. %s', $pos_calculating->{'move_num'}, $pos_calculating->{'last_move'}; + } + if (exists($id->{'name'})) { + $text .= ','; + } + } - if (exists($uciid{'name'})) { - $text .= "Analysis by $uciid{'name'}:\n\n"; + if (exists($id->{'name'})) { + $text .= " by $id->{'name'}:\n\n"; } else { - $text .= "Analysis:\n\n"; + $text .= ":\n\n"; } return unless (exists($pos_calculating->{'board'})); - # - # Some programs _always_ report MultiPV, even with only one PV. - # In this case, we simply use that data as if MultiPV was never - # specified. - # - if (exists($uciinfo{'pv1'}) && !exists($uciinfo{'pv2'})) { - for my $key qw(pv score_cp score_mate nodes nps depth seldepth tbhits) { - if (exists($uciinfo{$key . '1'}) && !exists($uciinfo{$key})) { - $uciinfo{$key} = $uciinfo{$key . '1'}; - } - } - } - - if (exists($uciinfo{'pv1'}) && exists($uciinfo{'pv2'})) { + if (exists($info->{'pv1'}) && exists($info->{'pv2'})) { # multi-PV my $mpv = 1; - while (exists($uciinfo{'pv' . $mpv})) { + while (exists($info->{'pv' . $mpv})) { $text .= sprintf " PV%2u", $mpv; - my $score = short_score(\%uciinfo, $pos_calculating, $mpv); + my $score = short_score($info, $pos_calculating, $mpv); $text .= " ($score)" if (defined($score)); my $tbhits = ''; - if (exists($uciinfo{'tbhits' . $mpv})) { - $tbhits = sprintf ", %u tbhits", $uciinfo{'tbhits' . $mpv}; + if (exists($info->{'tbhits' . $mpv}) && $info->{'tbhits' . $mpv} > 0) { + if ($info->{'tbhits' . $mpv} == 1) { + $tbhits = ", 1 tbhit"; + } else { + $tbhits = sprintf ", %u tbhits", $info->{'tbhits' . $mpv}; + } } - if (exists($uciinfo{'nodes' . $mpv}) && exists($uciinfo{'nps' . $mpv}) && exists($uciinfo{'depth' . $mpv})) { + if (exists($info->{'nodes' . $mpv}) && exists($info->{'nps' . $mpv}) && exists($info->{'depth' . $mpv})) { $text .= sprintf " (%5u kn, %3u kn/s, %2u ply$tbhits)", - $uciinfo{'nodes' . $mpv} / 1000, $uciinfo{'nps' . $mpv} / 1000, $uciinfo{'depth' . $mpv}; + $info->{'nodes' . $mpv} / 1000, $info->{'nps' . $mpv} / 1000, $info->{'depth' . $mpv}; } $text .= ":\n"; - $text .= " " . join(', ', prettyprint_pv($pos_calculating->{'board'}, @{$uciinfo{'pv' . $mpv}})) . "\n"; + $text .= " " . join(', ', prettyprint_pv($pos_calculating->{'board'}, @{$info->{'pv' . $mpv}})) . "\n"; $text .= "\n"; ++$mpv; } } else { # single-PV - my $score = long_score(\%uciinfo, $pos_calculating, ''); + my $score = long_score($info, $pos_calculating, ''); $text .= " $score\n" if defined($score); - $text .= " PV: " . join(', ', prettyprint_pv($pos_calculating->{'board'}, @{$uciinfo{'pv'}})); + $text .= " PV: " . join(', ', prettyprint_pv($pos_calculating->{'board'}, @{$info->{'pv'}})); $text .= "\n"; - if (exists($uciinfo{'nodes'}) && exists($uciinfo{'nps'}) && exists($uciinfo{'depth'})) { + if (exists($info->{'nodes'}) && exists($info->{'nps'}) && exists($info->{'depth'})) { $text .= sprintf " %u nodes, %7u nodes/sec, depth %u ply", - $uciinfo{'nodes'}, $uciinfo{'nps'}, $uciinfo{'depth'}; + $info->{'nodes'}, $info->{'nps'}, $info->{'depth'}; + } + if (exists($info->{'seldepth'})) { + $text .= sprintf " (%u selective)", $info->{'seldepth'}; } - if (exists($uciinfo{'tbhits'})) { - $text .= sprintf ", %u Nalimov hits", $uciinfo{'tbhits'}; + if (exists($info->{'tbhits'}) && $info->{'tbhits'} > 0) { + if ($info->{'tbhits'} == 1) { + $text .= ", one Syzygy hit"; + } else { + $text .= sprintf ", %u Syzygy hits", $info->{'tbhits'}; + } } - if (exists($uciinfo{'seldepth'})) { - $text .= sprintf " (%u selective)", $uciinfo{'seldepth'}; + $text .= "\n\n"; + } + + #$text .= book_info($pos_calculating->fen(), $pos_calculating->{'board'}, $pos_calculating->{'toplay'}); + + my @refutation_lines = (); + if (defined($engine2)) { + for (my $mpv = 1; $mpv < 500; ++$mpv) { + my $info = $engine2->{'info'}; + last if (!exists($info->{'pv' . $mpv})); + eval { + my $pv = $info->{'pv' . $mpv}; + + my $pretty_move = join('', prettyprint_pv($pos_calculating_second_engine->{'board'}, $pv->[0])); + my @pretty_pv = prettyprint_pv($pos_calculating_second_engine->{'board'}, @$pv); + if (scalar @pretty_pv > 5) { + @pretty_pv = @pretty_pv[0..4]; + push @pretty_pv, "..."; + } + my $key = $pretty_move; + my $line = sprintf(" %-6s %6s %3s %s", + $pretty_move, + short_score($info, $pos_calculating_second_engine, $mpv, 0), + "d" . $info->{'depth' . $mpv}, + join(', ', @pretty_pv)); + push @refutation_lines, [ $key, $line ]; + }; } - $text .= "\n\n"; } + if ($#refutation_lines >= 0) { + $text .= "Shallow search of all legal moves:\n\n"; + for my $line (sort { $a->[0] cmp $b->[0] } @refutation_lines) { + $text .= $line->[1] . "\n"; + } + $text .= "\n\n"; + } + if ($last_text ne $text) { print ""; # clear the screen print $text; $last_text = $text; } +} - # Now construct the tell text, if any - return if (!defined($telltarget)); - - my $tell_text = ''; +sub output_json { + my $info = $engine->{'info'}; + + my $json = {}; + $json->{'position'} = $pos_calculating->to_json_hash(); + $json->{'id'} = $engine->{'id'}; + $json->{'score'} = long_score($info, $pos_calculating, ''); + + $json->{'nodes'} = $info->{'nodes'}; + $json->{'nps'} = $info->{'nps'}; + $json->{'depth'} = $info->{'depth'}; + $json->{'tbhits'} = $info->{'tbhits'}; + $json->{'seldepth'} = $info->{'seldepth'}; + + # single-PV only for now + $json->{'pv_uci'} = $info->{'pv'}; + $json->{'pv_pretty'} = [ prettyprint_pv($pos_calculating->{'board'}, @{$info->{'pv'}}) ]; + + my %refutation_lines = (); + my @refutation_lines = (); + if (defined($engine2)) { + for (my $mpv = 1; $mpv < 500; ++$mpv) { + my $info = $engine2->{'info'}; + my $pretty_move = ""; + my @pretty_pv = (); + last if (!exists($info->{'pv' . $mpv})); + + eval { + my $pv = $info->{'pv' . $mpv}; + my $pretty_move = join('', prettyprint_pv($pos_calculating->{'board'}, $pv->[0])); + my @pretty_pv = prettyprint_pv($pos_calculating->{'board'}, @$pv); + $refutation_lines{$pv->[0]} = { + sort_key => $pretty_move, + depth => $info->{'depth' . $mpv}, + score_sort_key => score_sort_key($info, $pos_calculating, $mpv, 0), + pretty_score => short_score($info, $pos_calculating, $mpv, 0), + pretty_move => $pretty_move, + pv_pretty => \@pretty_pv, + }; + $refutation_lines{$pv->[0]}->{'pv_uci'} = $pv; + }; + } + } + $json->{'refutation_lines'} = \%refutation_lines; + + open my $fh, ">/srv/analysis.sesse.net/www/analysis.json.tmp" + or return; + print $fh JSON::XS::encode_json($json); + close $fh; + rename("/srv/analysis.sesse.net/www/analysis.json.tmp", "/srv/analysis.sesse.net/www/analysis.json"); +} - if (exists($uciid{'name'})) { - $tell_text .= "Analysis by $uciid{'name'} -- see http://analysis.sesse.net/ for more information\n"; - } else { - $tell_text .= "Computer analysis -- http://analysis.sesse.net/ for more information\n"; - } +sub uciprint { + my ($engine, $msg) = @_; + print { $engine->{'write'} } "$msg\n"; + print UCILOG localtime() . " $engine->{'tag'} => $msg\n"; +} - if (exists($uciinfo{'pv1'}) && exists($uciinfo{'pv2'})) { - # multi-PV - my $mpv = 1; - while (exists($uciinfo{'pv' . $mpv})) { - $tell_text .= sprintf " PV%2u", $mpv; - my $score = short_score(\%uciinfo, $pos_calculating, $mpv); - $tell_text .= " ($score)" if (defined($score)); +sub short_score { + my ($info, $pos, $mpv, $invert) = @_; - if (exists($uciinfo{'depth' . $mpv})) { - $tell_text .= sprintf " (%2u ply)", $uciinfo{'depth' . $mpv}; - } + $invert //= 0; + if ($pos->{'toplay'} eq 'B') { + $invert = !$invert; + } - $tell_text .= ": "; - $tell_text .= join(', ', prettyprint_pv($pos_calculating->{'board'}, @{$uciinfo{'pv' . $mpv}})); - $tell_text .= "\n"; - ++$mpv; + if (defined($info->{'score_mate' . $mpv})) { + if ($invert) { + return sprintf "M%3d", -$info->{'score_mate' . $mpv}; + } else { + return sprintf "M%3d", $info->{'score_mate' . $mpv}; } } else { - # single-PV - my $score = long_score(\%uciinfo, $pos_calculating, ''); - $tell_text .= " $score\n" if defined($score); - $tell_text .= " PV: " . join(', ', prettyprint_pv($pos_calculating->{'board'}, @{$uciinfo{'pv'}})); - if (exists($uciinfo{'depth'})) { - $tell_text .= sprintf " (depth %u ply)", $uciinfo{'depth'}; + if (exists($info->{'score_cp' . $mpv})) { + my $score = $info->{'score_cp' . $mpv} * 0.01; + if ($score == 0) { + return " 0.00"; + } + if ($invert) { + $score = -$score; + } + return sprintf "%+5.2f", $score; } - $tell_text .= "\n"; } - # see if a new tell is called for -- it is if the delay has expired _and_ - # this is not simply a repetition of the last one - if ($last_told_text ne $tell_text) { - my $now = time; - for my $iv (@tell_intervals) { - last if ($now - $last_move < $iv); - next if ($last_tell - $last_move >= $iv); - - for my $line (split /\n/, $tell_text) { - $t->print("tell $telltarget [$target] $line"); - } + return undef; +} - $last_told_text = $text; - $last_tell = $now; +sub score_sort_key { + my ($info, $pos, $mpv, $invert) = @_; - last; + if (defined($info->{'score_mate' . $mpv})) { + if ($invert) { + return 99999 - $info->{'score_mate' . $mpv}; + } else { + return -(99999 - $info->{'score_mate' . $mpv}); + } + } else { + if (exists($info->{'score_cp' . $mpv})) { + my $score = $info->{'score_cp' . $mpv}; + if ($invert) { + $score = -$score; + } + return $score; } } + + return undef; } -sub find_kings { - my $board = shift; - my ($wkr, $wkc, $bkr, $bkc); +sub long_score { + my ($info, $pos, $mpv) = @_; - for my $row (0..7) { - for my $col (0..7) { - my $piece = substr($board->[$row], $col, 1); - if ($piece eq 'K') { - ($wkr, $wkc) = ($row, $col); - } elsif ($piece eq 'k') { - ($bkr, $bkc) = ($row, $col); + if (defined($info->{'score_mate' . $mpv})) { + my $mate = $info->{'score_mate' . $mpv}; + if ($pos->{'toplay'} eq 'B') { + $mate = -$mate; + } + if ($mate > 0) { + return sprintf "White mates in %u", $mate; + } else { + return sprintf "Black mates in %u", -$mate; + } + } else { + if (exists($info->{'score_cp' . $mpv})) { + my $score = $info->{'score_cp' . $mpv} * 0.01; + if ($score == 0) { + return "Score: 0.00"; } + if ($pos->{'toplay'} eq 'B') { + $score = -$score; + } + return sprintf "Score: %+5.2f", $score; } } - return ($wkr, $wkc, $bkr, $bkc); + return undef; } -sub in_mate { - my $board = shift; - my $check = in_check($board); - return 0 if ($check eq 'none'); +my %book_cache = (); +sub book_info { + my ($fen, $board, $toplay) = @_; - # try all possible moves for the side in check - for my $row (0..7) { - for my $col (0..7) { - my $piece = substr($board->[$row], $col, 1); - next if ($piece eq '-'); + if (exists($book_cache{$fen})) { + return $book_cache{$fen}; + } - if ($check eq 'white') { - next if ($piece eq lc($piece)); - } else { - next if ($piece eq uc($piece)); - } + my $ret = `./booklook $fen`; + return "" if ($ret =~ /Not found/ || $ret eq ''); - for my $dest_row (0..7) { - for my $dest_col (0..7) { - next if ($row == $dest_row && $col == $dest_col); - next unless (can_reach($board, $piece, $row, $col, $dest_row, $dest_col)); + my @moves = (); - my @nb = @$board; - substr($nb[$row], $col, 1, '-'); - substr($nb[$dest_row], $dest_col, 1, $piece); + for my $m (split /\n/, $ret) { + my ($move, $annotation, $win, $draw, $lose, $rating, $rating_div) = split /,/, $m; - my $new_check = in_check(\@nb); - return 0 if ($new_check ne $check && $new_check ne 'both'); - } - } + my $pmove; + if ($move eq '') { + $pmove = '(current)'; + } else { + ($pmove) = prettyprint_pv($board, $move); + $pmove .= $annotation; } - } - - # nothing to do; mate - return 1; -} - -sub in_check { - my $board = shift; - my ($black_check, $white_check) = (0, 0); - my ($wkr, $wkc, $bkr, $bkc) = find_kings($board); - - # check all pieces for the possibility of threatening the two kings - for my $row (0..7) { - for my $col (0..7) { - my $piece = substr($board->[$row], $col, 1); - next if ($piece eq '-'); + my $score; + if ($toplay eq 'W') { + $score = 1.0 * $win + 0.5 * $draw + 0.0 * $lose; + } else { + $score = 0.0 * $win + 0.5 * $draw + 1.0 * $lose; + } + my $n = $win + $draw + $lose; - if (uc($piece) eq $piece) { - # white piece - $black_check = 1 if (can_reach($board, $piece, $row, $col, $bkr, $bkc)); - } else { - # black piece - $white_check = 1 if (can_reach($board, $piece, $row, $col, $wkr, $wkc)); - } + my $percent; + if ($n == 0) { + $percent = " "; + } else { + $percent = sprintf "%4u%%", int(100.0 * $score / $n + 0.5); } - } - if ($black_check && $white_check) { - return 'both'; - } elsif ($black_check) { - return 'black'; - } elsif ($white_check) { - return 'white'; - } else { - return 'none'; + push @moves, [ $pmove, $n, $percent, $rating ]; } -} -sub can_reach { - my ($board, $piece, $from_row, $from_col, $to_row, $to_col) = @_; + @moves[1..$#moves] = sort { $b->[2] cmp $a->[2] } @moves[1..$#moves]; - # can't eat your own piece - my $dest_piece = substr($board->[$to_row], $to_col, 1); - if ($dest_piece ne '-') { - return 0 if (($piece eq lc($piece)) == ($dest_piece eq lc($dest_piece))); + my $text = "Book moves:\n\n Perf. N Rating\n\n"; + for my $m (@moves) { + $text .= sprintf " %-10s %s %6u %4s\n", $m->[0], $m->[2], $m->[1], $m->[3] } - if (lc($piece) eq 'k') { - return (abs($from_row - $to_row) <= 1 && abs($from_col - $to_col) <= 1); - } - if (lc($piece) eq 'r') { - return 0 unless ($from_row == $to_row || $from_col == $to_col); - - # check that there's a clear passage - if ($from_row == $to_row) { - if ($from_col > $to_col) { - ($to_col, $from_col) = ($from_col, $to_col); - } - - for my $c (($from_col+1)..($to_col-1)) { - my $middle_piece = substr($board->[$to_row], $c, 1); - return 0 if ($middle_piece ne '-'); - } - - return 1; - } else { - if ($from_row > $to_row) { - ($to_row, $from_row) = ($from_row, $to_row); - } + return $text; +} - for my $r (($from_row+1)..($to_row-1)) { - my $middle_piece = substr($board->[$r], $to_col, 1); - return 0 if ($middle_piece ne '-'); - } +sub open_engine { + my ($cmdline, $tag) = @_; - return 1; - } - } - if (lc($piece) eq 'b') { - return 0 unless (abs($from_row - $to_row) == abs($from_col - $to_col)); + return undef if (!defined($cmdline)); - my $dr = ($to_row - $from_row) / abs($to_row - $from_row); - my $dc = ($to_col - $from_col) / abs($to_col - $from_col); + my ($uciread, $uciwrite); + my $pid = IPC::Open2::open2($uciread, $uciwrite, $cmdline); - my $r = $from_row + $dr; - my $c = $from_col + $dc; + my $engine = { + pid => $pid, + read => $uciread, + readbuf => '', + write => $uciwrite, + info => {}, + ids => {}, + tag => $tag, + }; - while ($r != $to_row) { - my $middle_piece = substr($board->[$r], $c, 1); - return 0 if ($middle_piece ne '-'); - - $r += $dr; - $c += $dc; - } + uciprint($engine, "uci"); - return 1; - } - if (lc($piece) eq 'n') { - my $diff_r = abs($from_row - $to_row); - my $diff_c = abs($from_col - $to_col); - return 1 if ($diff_r == 2 && $diff_c == 1); - return 1 if ($diff_r == 1 && $diff_c == 2); - return 0; - } - if ($piece eq 'q') { - return (can_reach($board, 'r', $from_row, $from_col, $to_row, $to_col) || - can_reach($board, 'b', $from_row, $from_col, $to_row, $to_col)); - } - if ($piece eq 'Q') { - return (can_reach($board, 'R', $from_row, $from_col, $to_row, $to_col) || - can_reach($board, 'B', $from_row, $from_col, $to_row, $to_col)); - } - if ($piece eq 'p') { - # black pawn - if ($to_col == $from_col && $to_row == $from_row + 1) { - return ($dest_piece eq '-'); - } - if (abs($to_col - $from_col) == 1 && $to_row == $from_row + 1) { - return ($dest_piece ne '-'); - } - return 0; - } - if ($piece eq 'P') { - # white pawn - if ($to_col == $from_col && $to_row == $from_row - 1) { - return ($dest_piece eq '-'); - } - if (abs($to_col - $from_col) == 1 && $to_row == $from_row - 1) { - return ($dest_piece ne '-'); - } - return 0; + # gobble the options + while (<$uciread>) { + /uciok/ && last; + handle_uci($engine, $_); } - # unknown piece - return 0; + return $engine; } -sub uciprint { - my $msg = shift; - print UCIWRITE "$msg\n"; - print UCILOG localtime() . " => $msg\n"; -} +sub read_lines { + my $engine = shift; -sub short_score { - my ($uciinfo, $pos, $mpv) = @_; + # + # Read until we've got a full line -- if the engine sends part of + # a line and then stops we're pretty much hosed, but that should + # never happen. + # + while ($engine->{'readbuf'} !~ /\n/) { + my $tmp; + my $ret = sysread $engine->{'read'}, $tmp, 4096; - if (defined($uciinfo{'score_mate' . $mpv})) { - return sprintf "M%3d", $uciinfo{'score_mate' . $mpv}; - } else { - if (exists($uciinfo{'score_cp' . $mpv})) { - my $score = $uciinfo{'score_cp' . $mpv} * 0.01; - if ($pos->{'toplay'} eq 'B') { - $score = -$score; - } - return sprintf "%+5.2f", $score; + if (!defined($ret)) { + next if ($!{EINTR}); + die "error in reading from the UCI engine: $!"; + } elsif ($ret == 0) { + die "EOF from UCI engine"; } + + $engine->{'readbuf'} .= $tmp; } - return undef; + # Blah. + my @lines = (); + while ($engine->{'readbuf'} =~ s/^([^\n]*)\n//) { + my $line = $1; + $line =~ tr/\r\n//d; + push @lines, $line; + } + return @lines; } -sub long_score { - my ($uciinfo, $pos, $mpv) = @_; - - if (defined($uciinfo{'score_mate' . $mpv})) { - my $mate = $uciinfo{'score_mate' . $mpv}; - if ($pos->{'toplay'} eq 'B') { - $mate = -$mate; - } - if ($mate > 0) { - return sprintf "White mates in %u", $mate; - } else { - return sprintf "Black mates in %u", -$mate; - } - } else { - if (exists($uciinfo{'score_cp' . $mpv})) { - my $score = $uciinfo{'score_cp' . $mpv} * 0.01; - if ($pos->{'toplay'} eq 'B') { - $score = -$score; - } - return sprintf "Score: %+5.2f", $score; - } - } +sub col_letter_to_num { + return ord(shift) - ord('a'); +} - return undef; +sub row_letter_to_num { + return 7 - (ord(shift) - ord('1')); } +