--- trunk/Estraier.pm	2006/01/04 22:24:57	15
+++ trunk/Estraier.pm	2006/01/05 22:36:10	39
@@ -306,9 +306,83 @@
 
 package Search::Estraier::Condition;
 
+use Carp qw/confess croak/;
+
 use Search::Estraier;
 our @ISA = qw/Search::Estraier/;
 
+=head1 Search::Estraier::Condition
+
+=head2 new
+
+  my $cond = new Search::HyperEstraier::Condition;
+
+=cut
+
+sub new {
+	my $class = shift;
+	my $self = {};
+	bless($self, $class);
+
+	$self->{max} = -1;
+	$self->{options} = 0;
+
+	$self ? return $self : return undef;
+}
+
+=head2 set_phrase
+
+  $cond->set_phrase('search phrase');
+
+=cut
+
+sub set_phrase {
+	my $self = shift;
+	$self->{phrase} = $self->_s( shift );
+}
+
+=head2 add_attr
+
+  $cond->add_attr('@URI STRINC /~dpavlin/');
+
+=cut
+
+sub add_attr {
+	my $self = shift;
+	my $attr = shift || return;
+	push @{ $self->{attrs} }, $self->_s( $attr );
+}
+
+=head2 set_order
+
+  $cond->set_order('@mdate NUMD');
+
+=cut
+
+sub set_order {
+	my $self = shift;
+	$self->{order} = shift;
+}
+
+=head2 set_max
+
+  $cond->set_max(42);
+
+=cut
+
+sub set_max {
+	my $self = shift;
+	my $max = shift;
+	croak "set_max needs number" unless ($max =~ m/^\d+$/);
+	$self->{max} = $max;
+}
+
+=head2 set_options
+
+  $cond->set_options( SURE => 1 );
+
+=cut
+
 my $options = {
 	# check N-gram keys skipping by three
 	SURE => 1 << 0,
@@ -324,59 +398,202 @@
 	SIMPLE => 1 << 10,
 };
 
-=head1 Search::Estraier::Condition
+sub set_options {
+	my $self = shift;
+	my $option = shift;
+	confess "unknown option" unless ($options->{$option});
+	$self->{options} ||= $options->{$option};
+}
+
+=head2 phrase
+
+Return search phrase.
+
+  print $cond->phrase;
+
+=cut
+
+sub phrase {
+	my $self = shift;
+	return $self->{phrase};
+}
+
+=head2 order
+
+Return search result order.
+
+  print $cond->order;
+
+=cut
+
+sub order {
+	my $self = shift;
+	return $self->{order};
+}
+
+=head2 attrs
+
+Return search result attrs.
+
+  my @cond_attrs = $cond->attrs;
+
+=cut
+
+sub attrs {
+	my $self = shift;
+	#croak "attrs return array, not scalar" if (! wantarray);
+	return @{ $self->{attrs} };
+}
+
+=head2 max
+
+Return maximum number of results.
+
+  print $cond->max;
+
+C<-1> is returned for unitialized value, C<0> is unlimited.
+
+=cut
+
+sub max {
+	my $self = shift;
+	return $self->{max};
+}
+
+=head2 options
+
+Return options for this condition.
+
+  print $cond->options;
+
+Options are returned in numerical form.
+
+=cut
+
+sub options {
+	my $self = shift;
+	return $self->{options};
+}
+
+
+package Search::Estraier::ResultDocument;
+
+use Carp qw/croak/;
+
+#use Search::Estraier;
+#our @ISA = qw/Search::Estraier/;
+
+=head1 Search::Estraier::ResultDocument
 
 =head2 new
 
-  my $cond = new Search::HyperEstraier::Condition;
+  my $rdoc = new Search::HyperEstraier::ResultDocument(
+  	uri => 'http://localhost/document/uri/42',
+	attrs => {
+		foo => 1,
+		bar => 2,
+	},
+	snippet => 'this is a text of snippet'
+	keywords => 'this\tare\tkeywords'
+  );
 
 =cut
 
 sub new {
 	my $class = shift;
-	my $self = {};
+	my $self = {@_};
 	bless($self, $class);
 
+	foreach my $f (qw/uri attrs snippet keywords/) {
+		croak "missing $f for ResultDocument" unless defined($self->{$f});
+	}
+
 	$self ? return $self : return undef;
 }
 
+=head2 uri
 
-package Search::Estraier::Master;
+Return URI of result document
 
-use Carp;
+  print $rdoc->uri;
+
+=cut
+
+sub uri {
+	my $self = shift;
+	return $self->{uri};
+}
 
-=head1 Search::Estraier::Master
 
-Controll node master. This requires user with administration priviledges.
+=head2 attr_names
+
+Returns array with attribute names from result document object.
+
+  my @attrs = $rdoc->attr_names;
 
 =cut
 
-{
-	package RequestAgent;
-	our @ISA = qw(LWP::UserAgent);
+sub attr_names {
+	my $self = shift;
+	croak "attr_names return array, not scalar" if (! wantarray);
+	return sort keys %{ $self->{attrs} };
+}
 
-	sub new { 
-		my $self = LWP::UserAgent::new(@_);
-		$self->agent("Search-Estraier/$Search::Estraer::VERSION");
-		$self;
-	}
+=head2 attr
 
-	sub get_basic_credentials {
-		my($self, $realm, $uri) = @_;
-#		return ($user, $password);
-	}
+Returns value of an attribute.
+
+  my $value = $rdoc->attr( 'attribute' );
+
+=cut
+
+sub attr {
+	my $self = shift;
+	my $name = shift || return;
+	return $self->{attrs}->{ $name };
 }
 
+=head2 snippet
 
+Return snippet from result document
 
-=head2 new
+  print $rdoc->snippet;
 
-Create new connection to node master.
+=cut
+
+sub snippet {
+	my $self = shift;
+	return $self->{snippet};
+}
+
+=head2 keywords
 
-  my $master = new Search::Estraier::Master(
-	url => 'http://localhost:1978',
-	user => 'admin',
-	passwd => 'admin',
+Return keywords from result document
+
+  print $rdoc->keywords;
+
+=cut
+
+sub keywords {
+	my $self = shift;
+	return $self->{keywords};
+}
+
+
+package Search::Estraier::NodeResult;
+
+use Carp qw/croak/;
+
+#use Search::Estraier;
+#our @ISA = qw/Search::Estraier/;
+
+=head1 Search::Estraier::NodeResult
+
+=head2 new
+
+  my $res = new Search::HyperEstraier::NodeResult(
+  	docs => @array_of_rdocs,
+	hits => %hash_with_hints,
   );
 
 =cut
@@ -386,14 +603,284 @@
 	my $self = {@_};
 	bless($self, $class);
 
-	foreach my $p (qw/url user passwd/) {
-		croak "need $p" unless ($self->{$p});
+	foreach my $f (qw/docs hints/) {
+		croak "missing $f for ResultDocument" unless defined($self->{$f});
+	}
+
+	$self ? return $self : return undef;
+}
+
+=head2 doc_num
+
+Return number of documents
+
+  print $res->doc_num;
+
+=cut
+
+sub doc_num {
+	my $self = shift;
+	return $#{$self->{docs}};
+}
+
+=head2 get_doc
+
+Return single document
+
+  my $doc = $res->get_doc( 42 );
+
+Returns undef if document doesn't exist.
+
+=cut
+
+sub get_doc {
+	my $self = shift;
+	my $num = shift;
+	croak "expect number as argument" unless ($num =~ m/^\d+$/);
+	return undef if ($num < 0 || $num > $self->{docs});
+	return $self->{docs}->[$num];
+}
+
+=head2 hint
+
+Return specific hint from results.
+
+  print $rec->hint( 'VERSION' );
+
+Possible hints are: C<VERSION>, C<NODE>, C<HIT>, C<HINT#n>, C<DOCNUM>, C<WORDNUM>,
+C<TIME>, C<LINK#n>, C<VIEW>.
+
+=cut
+
+sub hint {
+	my $self = shift;
+	my $key = shift || return;
+	return $self->{hints}->{$key};
+}
+
+
+package Search::Estraier::Node;
+
+use Carp qw/carp croak/;
+use URI;
+use MIME::Base64;
+use IO::Socket::INET;
+
+=head1 Search::Estraier::Node
+
+=head2 new
+
+  my $node = new Search::HyperEstraier::Node;
+
+=cut
+
+sub new {
+	my $class = shift;
+	my $self = {
+		pxport => -1,
+		timeout => 0,	# this used to be -1
+		dnum => -1,
+		wnum => -1,
+		size => -1.0,
+		wwidth => 480,
+		hwidth => 96,
+		awidth => 96,
+		status => -1,
+	};
+	bless($self, $class);
+
+	if (@_) {
+		$self->{debug} = 1;
+		warn "## Node debug on\n";
 	}
 
 	$self ? return $self : return undef;
 }
 
+=head2 set_url
+
+Specify URL to node server
+
+  $node->set_url('http://localhost:1978');
+
+=cut
+
+sub set_url {
+	my $self = shift;
+	$self->{url} = shift;
+}
+
+=head2 set_proxy
 
+Specify proxy server to connect to node server
+
+  $node->set_proxy('proxy.example.com', 8080);
+
+=cut
+
+sub set_proxy {
+	my $self = shift;
+	my ($host,$port) = @_;
+	croak "proxy port must be number" unless ($port =~ m/^\d+$/);
+	$self->{pxhost} = $host;
+	$self->{pxport} = $port;
+}
+
+=head2 set_timeout
+
+Specify timeout of connection in seconds
+
+  $node->set_timeout( 15 );
+
+=cut
+
+sub set_timeout {
+	my $self = shift;
+	my $sec = shift;
+	croak "timeout must be number" unless ($sec =~ m/^\d+$/);
+	$self->{timeout} = $sec;
+}
+
+=head2 set_auth
+
+Specify name and password for authentication to node server.
+
+  $node->set_auth('clint','eastwood');
+
+=cut
+
+sub set_auth {
+	my $self = shift;
+	my ($login,$passwd) = @_;
+	$self->{auth} = encode_base64( "$login:$passwd" );
+}
+
+=head2 status
+
+Return status code of last request.
+
+  print $res->status;
+
+C<-1> means connection failure.
+
+=cut
+
+sub status {
+	my $self = shift;
+	return $self->{status};
+}
+
+=head2 shuttle_url
+
+This is method which uses C<IO::Socket::INET> to communicate with Hyper Estraier node
+master.
+
+  my $rv = shuttle_url( $url, $content_type, \$req_body, \$resbody );
+
+C<$resheads> and C<$resbody> booleans controll if response headers and/or response
+body will be saved within object.
+
+=cut
+
+sub shuttle_url {
+	my $self = shift;
+
+	my ($url, $content_type, $reqbody, $resbody) = @_;
+
+	my $status = -1;
+
+	warn "## $url\n";
+
+	$url = new URI($url);
+	if (
+			!$url || !$url->scheme || !$url->scheme eq 'http' ||
+			!$url->host || !$url->port || $url->port < 1
+		) {
+		carp "can't parse $url\n";
+		return -1;
+	}
+
+	my ($host,$port,$query) = ($url->host, $url->port, $url->path);
+
+	if ($self->{pxhost}) {
+		($host,$port) = ($self->{pxhost}, $self->{pxport});
+		$query = "http://$host:$port/$query";
+	}
+
+	$query .= '?' . $url->query if ($url->query && ! $reqbody);
+
+	my $headers;
+
+	if ($reqbody) {
+		$headers .= "POST $query HTTP/1.0\r\n";
+	} else {
+		$headers .= "GET $query HTTP/1.0\r\n";
+	}
+
+	$headers .= "Host: $url->host:$url->port\r\n";
+	$headers .= "Connection: close\r\n";
+	$headers .= "User-Agent: Search-Estraier/$Search::Estraier::VERSION\r\n";
+	$headers .= "Content-Type $content_type\r\n";
+	$headers .= "Authorization: Basic $self->{auth}\r\n";
+	my $len = 0;
+	{
+		use bytes;
+		$len = length($reqbody) if ($reqbody);
+	}
+	$headers .= "Content-Length: $len\r\n";
+	$headers .= "\r\n";
+
+	my $sock = IO::Socket::INET->new(
+		PeerAddr	=> $host,
+		PeerPort	=> $port,
+		Proto		=> 'tcp',
+		Timeout		=> $self->{timeout} || 90,
+	);
+
+	if (! $sock) {
+		carp "can't open socket to $host:$port";
+		return -1;
+	}
+
+	warn "## headers:\n$headers\n" if ($self->{debug});
+
+	print $sock $headers or
+		carp "can't send headers to network:\n$headers\n" and return -1;
+
+	if ($reqbody) {
+		warn "## request body:\n$headers\n" if ($self->{debug});
+		print $sock $$reqbody or
+			carp "can't send request body to network:\n$$reqbody\n" and return -1;
+	}
+
+	my $line = <$sock>;
+	chomp($line);
+	my ($schema, $res_status, undef) = split(/  */, $line, 3);
+	return if ($schema !~ /^HTTP/ || ! $res_status);
+
+	$status = $res_status;
+	warn "## response status: $res_status\n" if ($self->{debug});
+
+	# skip rest of headers
+	$line = <$sock>;
+	while ($line) {
+		$line = <$sock>;
+		$line =~ s/[\r\n]+$//;
+		warn "## ", $line || 'NULL', " ##\n";
+	};
+
+	# read body
+	$len = 0;
+	do {
+		$len = read($sock, my $buf, 8192);
+		$$resbody .= $buf if ($resbody);
+	} while ($len);
+
+	
+	warn "## response body:\n$$resbody\n" if ($self->{debug});
+
+	return $status;
+}
 
 ###