X-Git-Url: https://git.sesse.net/?p=remoteglot;a=blobdiff_plain;f=remoteglot.pl;h=c6323870037adb08629e5f3aff0749a0c01a5ffe;hp=28bebd25cfcf57de6e1685b83b202e9c03ebb70f;hb=b85fa1c5d6ec02daaf4e615cb09af8a6895b20be;hpb=9dd7122b75bf598f16a18a70bc8b2eb519d0796b diff --git a/remoteglot.pl b/remoteglot.pl index 28bebd2..c632387 100755 --- a/remoteglot.pl +++ b/remoteglot.pl @@ -18,12 +18,18 @@ 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 $target = "GMCarlsen"; +my $engine_cmdline = "'./Deep Rybka 4 SSE42 x64'"; my $telltarget = undef; # undef to be silent my @tell_intervals = (5, 20, 60, 120, 240, 480, 960); # after each move my $uci_assume_full_compliance = 0; # dangerous :-) +my @masters = ( + 'Sesse', + 'Sessse', + 'Sesssse', + 'greatestguns', + 'beuki' +); # Program starts here $SIG{ALRM} = sub { output_screen(); }; @@ -44,7 +50,7 @@ $| = 1; select(STDOUT); # open the chess engine -my $pid = IPC::Open2::open2(*UCIREAD, *UCIWRITE, $engine); +my $engine = open_engine($engine_cmdline); my %uciinfo = (); my %uciid = (); my ($last_move, $last_tell); @@ -52,23 +58,12 @@ my $last_text = ''; my $last_told_text = ''; my ($pos_waiting, $pos_calculating); -uciprint("uci"); - -# gobble the options -while () { - /uciok/ && last; - handle_uci($_); -} - -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"); +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"); print "Chess engine ready.\n"; @@ -76,7 +71,7 @@ print "Chess engine ready.\n"; 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 +86,7 @@ print "FICS ready.\n"; while (1) { my $rin = ''; my $rout; - vec($rin, fileno(UCIREAD), 1) = 1; + vec($rin, fileno($engine->{'read'}), 1) = 1; vec($rin, fileno($t), 1) = 1; my ($nfound, $timeleft) = select($rout=$rin, undef, undef, 5.0); @@ -118,21 +113,21 @@ while (1) { # 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; } @@ -148,13 +143,28 @@ 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 = ; + if ($nfound > 0 && vec($rout, fileno($engine->{'read'}), 1) == 1) { + my $line = read_line($engine->{'read'}); handle_uci($line); $sleep = 0; @@ -170,6 +180,7 @@ sub handle_uci { chomp $line; $line =~ tr/\r//d; + $line =~ s/ / /g; # Sometimes needed for Zappa Mexico print UCILOG localtime() . " <= $line\n"; if ($line =~ /^info/) { my (@infos) = split / /, $line; @@ -185,8 +196,8 @@ sub handle_uci { } if ($line =~ /^bestmove/ && $uci_assume_full_compliance) { if (defined($pos_waiting)) { - uciprint("position fen " . $pos_waiting->{'fen'}); - uciprint("go infinite"); + uciprint($engine, "position fen " . $pos_waiting->{'fen'}); + uciprint($engine, "go infinite"); $pos_calculating = $pos_waiting; $pos_waiting = undef; @@ -292,6 +303,7 @@ sub style12_to_fen { $castling .= "k" if ($x[13] == 1); $castling .= "q" if ($x[14] == 1); $castling = "-" if ($castling eq ""); + # $castling = "-"; # chess960 $fen .= " "; $fen .= $castling; @@ -334,13 +346,15 @@ sub style12_to_fen { $fen .= $x[26]; $pos{'fen'} = $fen; + $pos{'move_num'} = $x[26]; + $pos{'last_move'} = $x[29]; return \%pos; } sub prettyprint_pv { my ($board, @pvs) = @_; - + if (scalar @pvs == 0 || !defined($pvs[0])) { return (); } @@ -357,7 +371,7 @@ sub prettyprint_pv { my $piece = substr($board->[$from_row], $from_col, 1); if ($piece eq '-') { - die "Invalid move"; + die "Invalid move $pv"; } # white short castling @@ -526,12 +540,22 @@ sub output_screen { return; } - my $text = ''; + 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($uciid{'name'})) { + $text .= ','; + } + } if (exists($uciid{'name'})) { - $text .= "Analysis by $uciid{'name'}:\n\n"; + $text .= " by $uciid{'name'}:\n\n"; } else { - $text .= "Analysis:\n\n"; + $text .= ":\n\n"; } return unless (exists($pos_calculating->{'board'})); @@ -542,7 +566,7 @@ sub output_screen { # specified. # if (exists($uciinfo{'pv1'}) && !exists($uciinfo{'pv2'})) { - for my $key qw(pv score_cp score_mate nodes nps depth seldepth tbhits) { + 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'}; } @@ -558,8 +582,12 @@ sub output_screen { $text .= " ($score)" if (defined($score)); my $tbhits = ''; - if (exists($uciinfo{'tbhits' . $mpv})) { - $tbhits = sprintf ", %u tbhits", $uciinfo{'tbhits' . $mpv}; + if (exists($uciinfo{'tbhits' . $mpv}) && $uciinfo{'tbhits' . $mpv} > 0) { + if ($uciinfo{'tbhits' . $mpv} == 1) { + $tbhits = ", 1 tbhit"; + } else { + $tbhits = sprintf ", %u tbhits", $uciinfo{'tbhits' . $mpv}; + } } if (exists($uciinfo{'nodes' . $mpv}) && exists($uciinfo{'nps' . $mpv}) && exists($uciinfo{'depth' . $mpv})) { @@ -583,8 +611,12 @@ sub output_screen { $text .= sprintf " %u nodes, %7u nodes/sec, depth %u ply", $uciinfo{'nodes'}, $uciinfo{'nps'}, $uciinfo{'depth'}; } - if (exists($uciinfo{'tbhits'})) { - $text .= sprintf ", %u Nalimov hits", $uciinfo{'tbhits'}; + if (exists($uciinfo{'tbhits'}) && $uciinfo{'tbhits'} > 0) { + if ($uciinfo{'tbhits'} == 1) { + $text .= ", one Nalimov hit"; + } else { + $text .= sprintf ", %u Nalimov hits", $uciinfo{'tbhits'}; + } } if (exists($uciinfo{'seldepth'})) { $text .= sprintf " (%u selective)", $uciinfo{'seldepth'}; @@ -592,6 +624,8 @@ sub output_screen { $text .= "\n\n"; } + #$text .= book_info($pos_calculating->{'fen'}, $pos_calculating->{'board'}, $pos_calculating->{'toplay'}); + if ($last_text ne $text) { print ""; # clear the screen print $text; @@ -845,8 +879,8 @@ sub can_reach { } sub uciprint { - my $msg = shift; - print UCIWRITE "$msg\n"; + my ($engine, $msg) = @_; + print { $engine->{'write'} } "$msg\n"; print UCILOG localtime() . " => $msg\n"; } @@ -893,3 +927,104 @@ sub long_score { return undef; } + +my %book_cache = (); +sub book_info { + my ($fen, $board, $toplay) = @_; + + if (exists($book_cache{$fen})) { + return $book_cache{$fen}; + } + + my $ret = `./booklook $fen`; + return "" if ($ret =~ /Not found/ || $ret eq ''); + + my @moves = (); + + for my $m (split /\n/, $ret) { + my ($move, $annotation, $win, $draw, $lose, $rating, $rating_div) = split /,/, $m; + + my $pmove; + if ($move eq '') { + $pmove = '(current)'; + } else { + ($pmove) = prettyprint_pv($board, $move); + $pmove .= $annotation; + } + + 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; + + my $percent; + if ($n == 0) { + $percent = " "; + } else { + $percent = sprintf "%4u%%", int(100.0 * $score / $n + 0.5); + } + + push @moves, [ $pmove, $n, $percent, $rating ]; + } + + @moves[1..$#moves] = sort { $b->[2] cmp $a->[2] } @moves[1..$#moves]; + + 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] + } + + return $text; +} + +sub open_engine { + my $cmdline = shift; + my ($uciread, $uciwrite); + my $pid = IPC::Open2::open2($uciread, $uciwrite, $cmdline); + + my $engine = { + pid => $pid, + read => $uciread, + write => $uciwrite + }; + + uciprint($engine, "uci"); + + # gobble the options + while (<$uciread>) { + /uciok/ && last; + handle_uci($_); + } + + return $engine; +} + +sub read_line { + my $fh = shift; + + # + # 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. + # + my $line = ''; + while ($line !~ /\n/) { + my $tmp; + my $ret = sysread $engine->{'read'}, $tmp, 1; + + if (!defined($ret)) { + next if ($!{EINTR}); + die "error in reading from the UCI engine: $!"; + } elsif ($ret == 0) { + die "EOF from UCI engine"; + } + + $line .= $tmp; + } + + $line =~ tr/\r\n//d; + return $line; +}