X-Git-Url: http://mj.ucw.cz/gitweb/?a=blobdiff_plain;ds=inline;f=submit%2FMO%2FSubmit.pm;h=bae8b5f34ab1150a702360a66ff1ed0324794564;hb=fc6c3a5af5a07a8d6f658d66fd74746ae186aa11;hp=3491d81c7f1cea4c88aa701e4bc1ce99d8098d77;hpb=3043ffa0cb666e509d5b07e479ead4792fbf722d;p=eval.git diff --git a/submit/MO/Submit.pm b/submit/MO/Submit.pm index 3491d81..bae8b5f 100644 --- a/submit/MO/Submit.pm +++ b/submit/MO/Submit.pm @@ -9,19 +9,29 @@ use warnings; use IO::Socket::INET; use IO::Socket::SSL; # qw(debug3); use Sherlock::Object; +use POSIX; sub new($) { + my $user = $ENV{"USER"} or die "Environment variable USER not set\n"; + my $home = $ENV{"HOME"} or die "Environment variable HOME not set\n"; + my $mo = "$home/.mo"; + my $root = $ENV{"MO_ROOT"} or die "Environment variable MO_ROOT not set\n"; my $self = { - "Server" => "localhost:8888", - "Key" => "client-key.pem", - "Cert" => "client-cert.pem", - "CACert" => "ca-cert.pem", - "Trace" => 0, - "user" => "testuser", + "Contest" => "CPSPC 2007", + "Server" => "kamzice.ms.mff.cuni.cz:8888", + "Key" => "$mo/key.pem", # Keys and certificates + "Cert" => "$mo/cert.pem", + "CACert" => "$mo/ca-cert.pem", + "Trace" => defined $ENV{"MO_SUBMIT_TRACE"}, + "Checks" => 1, + "AllowOverride" => 1, +# "History" => "$home/.history", # Keep submission history in this directory + "RefreshTimer" => 60000, # How often GUI sends STATUS commands [ms] + "root" => $root, + "user" => $user, "sk" => undef, "error" => undef, }; - # FIXME: Read config file return bless $self; } @@ -32,7 +42,7 @@ sub DESTROY($) { sub log($$) { my ($self, $msg) = @_; - print STDERR "LOG: $msg\n" if $self->{"Trace"}; + print STDERR "SUBMIT: $msg\n" if $self->{"Trace"}; } sub err($$) { @@ -59,6 +69,7 @@ sub disconnect($) { sub connect($) { my $self = shift @_; $self->disconnect; + $self->log("Connecting to submit server"); my $sk = new IO::Socket::INET( PeerAddr => $self->{"Server"}, @@ -86,9 +97,9 @@ sub connect($) { $sk, SSL_version => 'TLSv1', SSL_use_cert => 1, - SSL_key_file => "client-key.pem", - SSL_cert_file => "client-cert.pem", - SSL_ca_file => "ca-cert.pem", + SSL_key_file => $self->{"Key"}, + SSL_cert_file => $self->{"Cert"}, + SSL_ca_file => $self->{"CACert"}, SSL_verify_mode => 3, ); if (!defined $sk) { @@ -97,6 +108,7 @@ sub connect($) { } } $self->{"sk"} = $sk; + $sk->autoflush(0); $self->log("Logging in"); my $req = new Sherlock::Object("U" => $self->{"user"}); @@ -114,12 +126,14 @@ sub connect($) { sub request($$) { my ($self, $obj) = @_; my $sk = $self->{"sk"}; - $obj->write($sk); ### FIXME: Flushing + ## $SIG{'PIPE'} = 'ignore'; + $obj->write($sk); + print $sk "\n"; + $sk->flush(); if ($sk->error) { $self->err("Connection broken"); return undef; } - print $sk "\n"; return $self->reply; } @@ -155,4 +169,11 @@ sub send_file($$$) { return $self->reply; } +sub local_submit($$$$$) { + my ($self, $task, $part, $ext, $filename) = @_; + my $hist = $self->{"History"}; + -d $hist or mkdir $hist or return "Unable to create $hist: $!"; + ### FIXME: Unfinished +} + 1;