1 # A Perl module for communicating with the MO Submit Server
2 # (c) 2007 Martin Mares <mj@ucw.cz>
10 use IO::Socket::SSL; # qw(debug3);
15 my $user = $ENV{"USER"} or die "Environment variable USER not set\n";
16 my $home = $ENV{"HOME"} or die "Environment variable HOME not set\n";
18 my $root = $ENV{"MO_ROOT"} or die "Environment variable MO_ROOT not set\n";
20 "Contest" => "CPSPC 2007",
21 "Server" => "kamzice.ms.mff.cuni.cz:8888",
22 "Key" => "$mo/key.pem", # Keys and certificates
23 "Cert" => "$mo/cert.pem",
24 "CACert" => "$mo/ca-cert.pem",
25 "Trace" => defined $ENV{"MO_SUBMIT_TRACE"},
27 # "History" => "$home/.history", # Keep submission history in this directory
28 "RefreshTimer" => 60000, # How often GUI sends STATUS commands [ms]
43 my ($self, $msg) = @_;
44 print STDERR "SUBMIT: $msg\n" if $self->{"Trace"};
48 my ($self, $msg) = @_;
49 print STDERR "ERROR: $msg\n" if $self->{"Trace"};
50 $self->{"error"} = $msg;
56 return defined $self->{"sk"};
61 if ($self->is_connected) {
63 $self->{"sk"} = undef;
64 $self->log("Disconnected");
71 $self->log("Connecting to submit server");
72 my $sk = new IO::Socket::INET(
73 PeerAddr => $self->{"Server"},
77 $self->err("Cannot connect to server: $!");
82 $self->err("Server failed to send a welcome message");
88 $self->err("Server rejected the connection: $z");
93 $self->log("Starting TLS");
94 $sk = IO::Socket::SSL->start_SSL(
96 SSL_version => 'TLSv1',
98 SSL_key_file => $self->{"Key"},
99 SSL_cert_file => $self->{"Cert"},
100 SSL_ca_file => $self->{"CACert"},
101 SSL_verify_mode => 3,
104 $self->err("Cannot establish TLS connection: " . IO::Socket::SSL::errstr());
110 $self->log("Logging in");
111 my $req = new Sherlock::Object("U" => $self->{"user"});
112 my $reply = $self->request($req);
113 my $err = $reply->get("-");
115 $self->err("Cannot log in: $err");
119 $self->log("Connected");
124 my ($self, $obj) = @_;
125 my $sk = $self->{"sk"};
126 $obj->write($sk); ### FIXME: Flushing
128 $self->err("Connection broken");
136 my ($self, $obj) = @_;
137 my $sk = $self->{"sk"};
138 my $reply = new Sherlock::Object;
139 if ($reply->read($sk)) {
142 $self->err("Connection broken");
148 my ($self, $fh, $size) = @_;
149 my $sk = $self->{"sk"};
151 my $l = ($size < 4096 ? $size : 4096);
153 if ($fh->read($buf, $l) != $l) {
154 $self->err("File shrunk during upload");
157 $sk->write($buf, $l);
159 $self->err("Connection broken");
167 sub local_submit($$$$$) {
168 my ($self, $task, $part, $ext, $filename) = @_;
169 my $hist = $self->{"History"};
170 -d $hist or mkdir $hist or return "Unable to create $hist: $!";
171 ### FIXME: Unfinished