X-Git-Url: http://dxcluster.org/gitweb/gitweb.cgi?a=blobdiff_plain;f=cmd%2Fshow%2Fdb0sdx.pl;h=64c6f3bfdf585534d552a6ffbdb0717c6eabfa30;hb=refs%2Fheads%2Fstaging;hp=c90ecf976215f810ed64f30c520437509ee6dd3b;hpb=3fc0f2823c2505b08730286880ad8738963bca17;p=spider.git

diff --git a/cmd/show/db0sdx.pl b/cmd/show/db0sdx.pl
index c90ecf97..64c6f3bf 100644
--- a/cmd/show/db0sdx.pl
+++ b/cmd/show/db0sdx.pl
@@ -2,85 +2,94 @@
 # Query the DB0SDX QSL server for a callsign
 #
 # Copyright (c) 2003 Dirk Koopman G1TLH
+# Modified Dec 9, 2004 for new website and xml schema by David Spoelstra N9KT
+# and tidied up by me (Dirk)
+#
 #
-# $Id$
 #
 
-my ($self, $line) = @_;
-my $call = $self->call;
-my @out;
+sub on_disc
+{
+	my $conn = shift;
+	my $dxchan = shift;
+	my @out;
 
-$line = uc $line;
-return (1, $self->msg('e24')) unless $Internet::allow;
-return (1, "SHOW/DB0SDX <callsign>, e.g. SH/DB0SDX ea7wa") unless $line && is_callsign($line);
-my $target = 'dotnet.grossmann.com';
-my $port = 80;
-my $cmdprompt = '/query->.*$/';
+#	$DB::single = 1;
+	
+	dbg("db0sdx in: $conn->{sdxin}") if isdbg('db0sdx');
 
-my($info, $t);
-                                    
-$t = new Net::Telnet;
+	my ($info) = $conn->{sdxin} =~ m|<qslinfoResult>([^<]*)</qslinfoResult>|;
+#	dbg("db0sdx info: $info");
+	my $prefix = $conn->{prefix} || '';
+	
+	my @in = split /[\r\n]/, $info if $info;
+	if (@in && $in[0]) {
+#		dbg("db0sdx: in qsl");
+		push @out, map {"$prefix$_"} @in;
+	} else {
+#		dbg("db0sdx: in fault");
+		($info) = $conn->{sdxin} =~ m|<faultstring>([^<]*)</faultstring>|;
+		push @out, "$prefix$info" if $info;
+		push @out, $dxchan->msg('e3', 'DB0SDX', $conn->{sdxline}) unless @out;		
+	}
+	$dxchan->send(@out);
+}
+
+sub process
+{
+	my $conn = shift;
+	my $msg = shift;
+
+#	$DB::single = 1;
+	
+	$conn->{sdxin} .= "$msg\n";
+	
+	dbg("db0sdx in: $conn->{sdxin}") if isdbg('db0sdx');
+}
 
-dbg("db0sdx: contacting $target:$port") if isdbg('db0sdx');
-$info =  $t->open(Host    => $target,
-		  Port    => $port,
-		  Timeout => 15);
+sub handle
+{
+	my ($self, $line) = @_;
+	my $call = $self->call;
+	my @out;
 
-if (!$info) {
-	push @out, $self->msg('e18', 'DB0SDX Database server');
-} else {
+	$line = uc $line;
+	return (1, $self->msg('e24')) unless $Internet::allow;
+	return (1, "SHOW/DB0SDX <callsign>, e.g. SH/DB0SDX ea7wa") unless $line && is_callsign($line);
+	my $target = $Internet::db0sdx_url || 'www.qslinfo.de';
+	my $path = $Internet::db0sdx_path || '/qslinfo';
+	my $suffix = $Internet::db0sdx_suffix || '.asmx';
+	my $port = 80;
 
-	dbg("db0sdx: connected to $target:$port") if isdbg('db0sdx');
+	dbg("db0sdx: contacting $target:$port") if isdbg('db0sdx');
 
 	my $s = qq(<?xml version="1.0" encoding="utf-8"?>
 <soap:Envelope xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/">
   <soap:Body>
-    <qslinfo xmlns="http://dotnet.grossmann.com/qslinfo">
+    <qslinfo xmlns="http://$target">
       <callsign>$line</callsign>
+      <ClientInformation>DXSpider V$main::version B$main::build ($call\@$main::mycall)</ClientInformation>
     </qslinfo>
   </soap:Body>
-</soap:Envelope>
-);
+</soap:Envelope>);
+#	$s .= "\n";
+	my $lth = length($s);
 	
-
-	my $lth = length($s)+7;
-	
-	dbg("db0sdx out: $s") if isdbg('db0sdx');
-	
-	$t->print("POST /qslinfo/qslinfo.asmx HTTP/1.0");
-	$t->print("Host: dotnet.grossmann.com");
-	$t->print("Content-Type: text/xml; charset=utf-8");
-	$t->print("Content-Length: $lth");
-	$t->print("Connection: Close");
-	$t->print("SOAPAction: \"http://dotnet.grossmann.com/qslinfo/qslinfo\"");
-	$t->print("");
-	$t->put($s);
-
-	my $in;
-	
-	while (my $result = eval { $t->getline(Timeout => 30) } || $@) {
-		if ($@) {
-			push @out, $self->msg('e18', 'DB0SDX Server');
-			last;
-		} else {
-			$in .= $result;
-		}
-	}
-
- 	dbg("db0sdx in: $in") if isdbg('db0sdx');
-	
-	# Log the lookup
 	Log('call', "$call: show/db0sdx $line");
-	$t->close;
-
-	my ($info) = $in =~ m|<qslinfoResult>([^<]*)</qslinfoResult>|;
-	my @in = split /[\r\n]/, $info if $info;
-	if (@in && $in[0]) {
-		push @out, @in;
+	my $conn = AsyncMsg->post($self, $target, "$path$suffix", prefix => 'sdx> ', filter => \&process,
+							 'Content-Type' => 'text/xml; charset=utf-8',
+							 'Content-Length' => $lth,
+							  Connection => 'Close',
+							  SOAPAction => qq{"http://$target$path"},
+							  data => $s,
+							  on_disc => \&on_disc);
+	
+	if ($conn) {
+		$conn->{sdxline} = $line;
+		push @out, $self->msg('m21', "show/db0sdx");
 	} else {
-		($info) = $in =~ m|<faultstring>([^<]*)</faultstring>|;
-		push @out, $info if $info;
-		push @out, $self->msg('e3', 'DB0SDX', $line) unless @out;		
+		push @out, $self->msg('e18', 'DB0SDX Database server');
 	}
+
+	return (1, @out);
 }
-return (1, @out);