Perlbot/perlbuut-pastebin
1
0
Fork 0
mirror of https://github.com/perlbot/perlbuut-pastebin synced 2025-06-07 14:17:26 -04:00
Code Issues Releases Wiki Activity

Making it work mostly, need wireshark.

Browse source
This commit is contained in:
Ryan Voots 2017-07-28 02:05:15 -04:00
parent fae3e21403
commit 51e6094717
1 changed files with 50 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

70
lib/App/Model/Eval.pm
View file

@ -16,11 +16,31 @@ use Mojo::IOLoop;
has cfg => sub {App::Config::get_config('evalserver')};
our $id = 0; # global id count for evals
my %_futures;
sub _adopt_future {
my ($self, $id, $future) = @_;
$_futures{$id} = $future;
$future->on_ready(sub {
print "Cleaning up $id\n";
delete $_futures{$id};
})
}
sub get_eval {
my ($self, $paste_id, $code, $langs, $callback) = @_;
print "Entering\n";
if ($paste_id && (my $cached = $memd->get($paste_id))) { # TODO make this use sereal to store objects
if (@$langs == 1 && $langs->[0] eq "evalall") {
$langs = [qw/perl perl5.26 perl5.24 perl5.22 perl5.20 perl5.18 perl5.16 perl5.14 perl5.12 perl5.10 perl5.8 perl5.6/];
}
use Data::Dumper;
print "Languages! ", Dumper($langs);
if ($paste_id && (my $cached = $memd->get($paste_id))) {
$callback->($cached);
} else {
# connect to server
@ -34,7 +54,8 @@ sub get_eval {
for my $lang (@$langs) {
if ($lang eq 'text') {
next;
$callback->("");
return;
} else {
my $future = $self->async_eval($stream, $reader, $lang, $code);
$futures{$lang} = $future;
@ -42,11 +63,13 @@ sub get_eval {
$future->on_done(sub {
my ($out) = @_;
print "Future is done\n";
print "Future is done for $lang\n";
$output{$lang} = $out;
delete $futures{$lang};
print "remaining, ", Dumper(keys %futures);
if (!keys %futures) { # I'm the last one
print "Calling memset\n";
$memd->set($paste_id, \%output) if ($paste_id);
@ -79,6 +102,8 @@ sub async_eval {
my $future = Future::Mojo->new($loop);
my $seq = $id++;
$self->_adopt_future($seq, $future);
my $eval_obj = {language => $lang,
files => [
{filename => '__code', contents => $code, encoding => "utf8"}
@ -110,33 +135,38 @@ sub get_eval_reader {
print "Reading bytes\n";
$buf = $buf . $bytes;
my ($res, $message, $nbuf) = decode_message($buf);
$buf = $nbuf;
my ($res, $message, $nbuf);
do {
($res, $message, $nbuf) = decode_message($buf);
$buf = $nbuf;
if ($message) {
if ($message) {
my $type = ref ($message);
$type =~ s/^App::EvalServerAdvanced::Protocol:://;
my $type = ref ($message);
$type =~ s/^App::EvalServerAdvanced::Protocol:://;
my $seq = $message->sequence;
my $seq = $message->sequence;
if ($type eq 'Warning') {
push @{$warnings{$seq}}, $message->message;
} elsif ($type eq 'EvalResponse') {
print "Got eval response for $seq\n";
my $output = $message->get_contents;
if ($type eq 'Warning') {
push @{$warnings{$seq}}, $message->message;
} elsif ($type eq 'EvalResponse') {
print "Got eval response for $seq\n";
my $output = $message->get_contents;
my $warnings = join ' ', @{$warnings{$seq} || []};
my $warnings = join ' ', @{$warnings{$seq} || []};
$futures{$seq}->done($output);
print "Future is done: $output\n";
}
}
$futures{$seq}->done($output);
print "Future is done: $output\n";
}
};
print Dumper($res, length($buf));
} while ($res);
});
return sub {
print "WTF\n";
my ($seq, $future) = @_;
print "Registering $seq\n";
$futures{$seq} = $future;
}
}