Index: openssl/apps/tsget |
=================================================================== |
--- openssl/apps/tsget (revision 0) |
+++ openssl/apps/tsget (revision 0) |
@@ -0,0 +1,196 @@ |
+#!/usr/bin/perl -w |
+# Written by Zoltan Glozik <zglozik@stones.com>. |
+# Copyright (c) 2002 The OpenTSA Project. All rights reserved. |
+$::version = '$Id: tsget,v 1.1.2.2 2009/09/07 17:57:02 steve Exp $'; |
+ |
+use strict; |
+use IO::Handle; |
+use Getopt::Std; |
+use File::Basename; |
+use WWW::Curl::Easy; |
+ |
+use vars qw(%options); |
+ |
+# Callback for reading the body. |
+sub read_body { |
+ my ($maxlength, $state) = @_; |
+ my $return_data = ""; |
+ my $data_len = length ${$state->{data}}; |
+ if ($state->{bytes} < $data_len) { |
+ $data_len = $data_len - $state->{bytes}; |
+ $data_len = $maxlength if $data_len > $maxlength; |
+ $return_data = substr ${$state->{data}}, $state->{bytes}, $data_len; |
+ $state->{bytes} += $data_len; |
+ } |
+ return $return_data; |
+} |
+ |
+# Callback for writing the body into a variable. |
+sub write_body { |
+ my ($data, $pointer) = @_; |
+ ${$pointer} .= $data; |
+ return length($data); |
+} |
+ |
+# Initialise a new Curl object. |
+sub create_curl { |
+ my $url = shift; |
+ |
+ # Create Curl object. |
+ my $curl = WWW::Curl::Easy::new(); |
+ |
+ # Error-handling related options. |
+ $curl->setopt(CURLOPT_VERBOSE, 1) if $options{d}; |
+ $curl->setopt(CURLOPT_FAILONERROR, 1); |
+ $curl->setopt(CURLOPT_USERAGENT, "OpenTSA tsget.pl/" . (split / /, $::version)[2]); |
+ |
+ # Options for POST method. |
+ $curl->setopt(CURLOPT_UPLOAD, 1); |
+ $curl->setopt(CURLOPT_CUSTOMREQUEST, "POST"); |
+ $curl->setopt(CURLOPT_HTTPHEADER, |
+ ["Content-Type: application/timestamp-query", |
+ "Accept: application/timestamp-reply,application/timestamp-response"]); |
+ $curl->setopt(CURLOPT_READFUNCTION, \&read_body); |
+ $curl->setopt(CURLOPT_HEADERFUNCTION, sub { return length($_[0]); }); |
+ |
+ # Options for getting the result. |
+ $curl->setopt(CURLOPT_WRITEFUNCTION, \&write_body); |
+ |
+ # SSL related options. |
+ $curl->setopt(CURLOPT_SSLKEYTYPE, "PEM"); |
+ $curl->setopt(CURLOPT_SSL_VERIFYPEER, 1); # Verify server's certificate. |
+ $curl->setopt(CURLOPT_SSL_VERIFYHOST, 2); # Check server's CN. |
+ $curl->setopt(CURLOPT_SSLKEY, $options{k}) if defined($options{k}); |
+ $curl->setopt(CURLOPT_SSLKEYPASSWD, $options{p}) if defined($options{p}); |
+ $curl->setopt(CURLOPT_SSLCERT, $options{c}) if defined($options{c}); |
+ $curl->setopt(CURLOPT_CAINFO, $options{C}) if defined($options{C}); |
+ $curl->setopt(CURLOPT_CAPATH, $options{P}) if defined($options{P}); |
+ $curl->setopt(CURLOPT_RANDOM_FILE, $options{r}) if defined($options{r}); |
+ $curl->setopt(CURLOPT_EGDSOCKET, $options{g}) if defined($options{g}); |
+ |
+ # Setting destination. |
+ $curl->setopt(CURLOPT_URL, $url); |
+ |
+ return $curl; |
+} |
+ |
+# Send a request and returns the body back. |
+sub get_timestamp { |
+ my $curl = shift; |
+ my $body = shift; |
+ my $ts_body; |
+ local $::error_buf; |
+ |
+ # Error-handling related options. |
+ $curl->setopt(CURLOPT_ERRORBUFFER, "::error_buf"); |
+ |
+ # Options for POST method. |
+ $curl->setopt(CURLOPT_INFILE, {data => $body, bytes => 0}); |
+ $curl->setopt(CURLOPT_INFILESIZE, length(${$body})); |
+ |
+ # Options for getting the result. |
+ $curl->setopt(CURLOPT_FILE, \$ts_body); |
+ |
+ # Send the request... |
+ my $error_code = $curl->perform(); |
+ my $error_string; |
+ if ($error_code != 0) { |
+ my $http_code = $curl->getinfo(CURLINFO_HTTP_CODE); |
+ $error_string = "could not get timestamp"; |
+ $error_string .= ", http code: $http_code" unless $http_code == 0; |
+ $error_string .= ", curl code: $error_code"; |
+ $error_string .= " ($::error_buf)" if defined($::error_buf); |
+ } else { |
+ my $ct = $curl->getinfo(CURLINFO_CONTENT_TYPE); |
+ if (lc($ct) ne "application/timestamp-reply" |
+ && lc($ct) ne "application/timestamp-response") { |
+ $error_string = "unexpected content type returned: $ct"; |
+ } |
+ } |
+ return ($ts_body, $error_string); |
+ |
+} |
+ |
+# Print usage information and exists. |
+sub usage { |
+ |
+ print STDERR "usage: $0 -h <server_url> [-e <extension>] [-o <output>] "; |
+ print STDERR "[-v] [-d] [-k <private_key.pem>] [-p <key_password>] "; |
+ print STDERR "[-c <client_cert.pem>] [-C <CA_certs.pem>] [-P <CA_path>] "; |
+ print STDERR "[-r <file:file...>] [-g <EGD_socket>] [<request>]...\n"; |
+ exit 1; |
+} |
+ |
+# ---------------------------------------------------------------------- |
+# Main program |
+# ---------------------------------------------------------------------- |
+ |
+# Getting command-line options (default comes from TSGET environment variable). |
+my $getopt_arg = "h:e:o:vdk:p:c:C:P:r:g:"; |
+if (exists $ENV{TSGET}) { |
+ my @old_argv = @ARGV; |
+ @ARGV = split /\s+/, $ENV{TSGET}; |
+ getopts($getopt_arg, \%options) or usage; |
+ @ARGV = @old_argv; |
+} |
+getopts($getopt_arg, \%options) or usage; |
+ |
+# Checking argument consistency. |
+if (!exists($options{h}) || (@ARGV == 0 && !exists($options{o})) |
+ || (@ARGV > 1 && exists($options{o}))) { |
+ print STDERR "Inconsistent command line options.\n"; |
+ usage; |
+} |
+# Setting defaults. |
+@ARGV = ("-") unless @ARGV != 0; |
+$options{e} = ".tsr" unless defined($options{e}); |
+ |
+# Processing requests. |
+my $curl = create_curl $options{h}; |
+undef $/; # For reading whole files. |
+REQUEST: foreach (@ARGV) { |
+ my $input = $_; |
+ my ($base, $path) = fileparse($input, '\.[^.]*'); |
+ my $output_base = $base . $options{e}; |
+ my $output = defined($options{o}) ? $options{o} : $path . $output_base; |
+ |
+ STDERR->printflush("$input: ") if $options{v}; |
+ # Read request. |
+ my $body; |
+ if ($input eq "-") { |
+ # Read the request from STDIN; |
+ $body = <STDIN>; |
+ } else { |
+ # Read the request from file. |
+ open INPUT, "<" . $input |
+ or warn("$input: could not open input file: $!\n"), next REQUEST; |
+ $body = <INPUT>; |
+ close INPUT |
+ or warn("$input: could not close input file: $!\n"), next REQUEST; |
+ } |
+ |
+ # Send request. |
+ STDERR->printflush("sending request") if $options{v}; |
+ |
+ my ($ts_body, $error) = get_timestamp $curl, \$body; |
+ if (defined($error)) { |
+ die "$input: fatal error: $error\n"; |
+ } |
+ STDERR->printflush(", reply received") if $options{v}; |
+ |
+ # Write response. |
+ if ($output eq "-") { |
+ # Write to STDOUT. |
+ print $ts_body; |
+ } else { |
+ # Write to file. |
+ open OUTPUT, ">", $output |
+ or warn("$output: could not open output file: $!\n"), next REQUEST; |
+ print OUTPUT $ts_body; |
+ close OUTPUT |
+ or warn("$output: could not close output file: $!\n"), next REQUEST; |
+ } |
+ STDERR->printflush(", $output written.\n") if $options{v}; |
+} |
+$curl->cleanup(); |
+WWW::Curl::Easy::global_cleanup(); |