File Coverage

blib/lib/GoXML/XQI.pm

Criterion	Covered	Total	%
statement	15	77	19.4
branch	0	36	0.0
condition	0	7	0.0
subroutine	5	11	45.4
pod	0	4	0.0
total	20	135	14.8

package GoXML::XQI;

# (c)1999 XML Global Technologies, Inc.
# All Rights Reserved.
# Author: Matthew MacKenzie

use strict;
use IO::Handle;
use Socket;
use Carp;
use vars qw($VERSION @ISA @EXPORT @EXPORT_OK);

require Exporter;

@ISA = qw(Exporter AutoLoader);
$VERSION = '1.1.4';

sub new {
	my($class) = shift;
	my($self) = {};
	bless($self,$class);
	$self->_init(@_);
	return($self);
}

sub _init {
	my($self) = shift;
	if (@_) {
		my(%extra) = @_;
		@$self{keys %extra} = values %extra;
	}
}


sub Query {
	my($self) = shift;
	my(%info) = @_;

	my($sock) = _socket($self);

	my($q) = "\n\n \n";

	croak "You must supply a keyword\n" unless $info{KEYWORD};

	$q .= "  $info{KEYWORD}\n" .
	      "   $info{TAG}\n" .
	      "   $info{CATEGORY}\n" .
	      " \n\n";

	if ($self->{VERBOSE}) {
		$self->verbose("Now making Query to $self->{HOST}:$self->{PORT}..\n***$q***");
	}
	print $sock $q;

	if ($self->{VERBOSE}) {
		$self->verbose("Request sent, returning filehandle.");
	}
	return($sock);
}

sub Submit {
	my $self = shift;
	my %info = @_;
	my $sock = _socket($self);

        my $q = "\n\n \n";

	if (!($info{HREF} && $info{DESCRIPTION})) {
		croak "You need to supply the HREF or DESCRIPTION.\n";
	}
	if (!$info{CATEGORY}) {
		$info{CATEGORY} = 8;
	}

	$q .= "  $info{HREF}\n" .
	      "  $info{DESCRIPTION}\n" .
              "  $info{CATEGORY}\n" .
	      " \n\n";

	if ($self->{VERBOSE}) {
                $self->verbose("Sending Resource..\nDetails:\n$q");
	}

        print $sock $q;

        if ($self->{VERBOSE}) {
                $self->verbose("Resource sent, processing answer..");
        }
	my ($resp) = '';

	while (<$sock>) {
		$resp .= $_;
		last if $_ =~ m!!i;
	}

	if ($resp =~ /QUEUED/) {
		if ($self->{VERBOSE}) {
			$self->verbose("Resource addition suceeded.\nDetails:\n$resp");
		}
		return(1);
	}
	else {
		if ($self->{VERBOSE}) {
                        $self->verbose("Resource addition failed.");
			if ($resp =~ m!DUPLICATE!) {
				$self->verbose("\t-The resource submitted has already been indexed or queued.");
                	}
		}

		return(0);
	}
}

sub _socket {
	my($self) = shift;
        my($remote) = $self->{HOST} || 'www.goxml.com';
        my($port) = $self->{PORT} || '5910';
        my($iaddr,$paddr,$proto,$line);
        $iaddr = inet_aton($remote) or croak ($!);
        $paddr = sockaddr_in($port, $iaddr) or croak ($!);
        $proto = getprotobyname('tcp') or croak ("$!");
        socket(SOCK, PF_INET, SOCK_STREAM, $proto) or croak ($!);
        connect(SOCK, $paddr) or croak ($!);
        autoflush SOCK 1;
        return(\*SOCK);
}

sub verbose {
	my($self) = shift;
	my($msg) = shift;
	print STDERR $msg,"\n";
}

1;
__END__