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" => "localhost: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"},
26 "History" => "$home/.history", # Keep submission history in this directory
27 "RefreshTimer" => 5000, # How often GUI sends STATUS commands [ms]
41 my ($self, $msg) = @_;
42 print STDERR "SUBMIT: $msg\n" if $self->{"Trace"};
46 my ($self, $msg) = @_;
47 print STDERR "ERROR: $msg\n" if $self->{"Trace"};
48 $self->{"error"} = $msg;
54 return defined $self->{"sk"};
59 if ($self->is_connected) {
61 $self->{"sk"} = undef;
62 $self->log("Disconnected");
69 $self->log("Connecting to submit server");
70 my $sk = new IO::Socket::INET(
71 PeerAddr => $self->{"Server"},
75 $self->err("Cannot connect to server: $!");
80 $self->err("Server failed to send a welcome message");
86 $self->err("Server rejected the connection: $z");
91 $self->log("Starting TLS");
92 $sk = IO::Socket::SSL->start_SSL(
94 SSL_version => 'TLSv1',
96 SSL_key_file => $self->{"Key"},
97 SSL_cert_file => $self->{"Cert"},
98 SSL_ca_file => $self->{"CACert"},
102 $self->err("Cannot establish TLS connection: " . IO::Socket::SSL::errstr());
108 $self->log("Logging in");
109 my $req = new Sherlock::Object("U" => $self->{"user"});
110 my $reply = $self->request($req);
111 my $err = $reply->get("-");
113 $self->err("Cannot log in: $err");
117 $self->log("Connected");
122 my ($self, $obj) = @_;
123 my $sk = $self->{"sk"};
124 $obj->write($sk); ### FIXME: Flushing
126 $self->err("Connection broken");
134 my ($self, $obj) = @_;
135 my $sk = $self->{"sk"};
136 my $reply = new Sherlock::Object;
137 if ($reply->read($sk)) {
140 $self->err("Connection broken");
146 my ($self, $fh, $size) = @_;
147 my $sk = $self->{"sk"};
149 my $l = ($size < 4096 ? $size : 4096);
151 if ($fh->read($buf, $l) != $l) {
152 $self->err("File shrunk during upload");
155 $sk->write($buf, $l);
157 $self->err("Connection broken");
165 sub local_submit($$$$$) {
166 my ($self, $task, $part, $ext, $filename) = @_;
167 my $hist = $self->{"History"};
168 -d $hist or mkdir $hist or return "Unable to create $hist: $!";
169 ### FIXME: Unfinished