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");
72 $self->log("Connecting to submit server");
73 my $sk = new IO::Socket::INET(
74 PeerAddr => $self->{"Server"},
78 $self->err("Cannot connect to server: $!");
83 $self->err("Server failed to send a welcome message");
89 $self->err("Server rejected the connection: $z");
94 $self->log("Starting TLS");
95 $sk = IO::Socket::SSL->start_SSL(
97 SSL_version => 'TLSv1',
99 SSL_key_file => $self->{"Key"},
100 SSL_cert_file => $self->{"Cert"},
101 SSL_ca_file => $self->{"CACert"},
102 SSL_verify_mode => 3,
105 $self->err("Cannot establish TLS connection: " . IO::Socket::SSL::errstr());
112 $self->log("Logging in");
113 my $req = new Sherlock::Object("U" => $self->{"user"});
114 my $reply = $self->request($req);
115 my $err = $reply->get("-");
117 $self->err("Cannot log in: $err");
121 $self->log("Connected");
126 my ($self, $obj) = @_;
127 my $sk = $self->{"sk"};
128 ## $SIG{'PIPE'} = 'ignore';
133 $self->err("Connection broken");
140 my ($self, $obj) = @_;
141 my $sk = $self->{"sk"};
142 my $reply = new Sherlock::Object;
143 if ($reply->read($sk)) {
146 $self->err("Connection broken");
152 my ($self, $fh, $size) = @_;
153 my $sk = $self->{"sk"};
155 my $l = ($size < 4096 ? $size : 4096);
157 if ($fh->read($buf, $l) != $l) {
158 $self->err("File shrunk during upload");
161 $sk->write($buf, $l);
163 $self->err("Connection broken");
171 sub local_submit($$$$$) {
172 my ($self, $task, $part, $ext, $filename) = @_;
173 my $hist = $self->{"History"};
174 -d $hist or mkdir $hist or return "Unable to create $hist: $!";
175 ### FIXME: Unfinished