/[Search-Estraier]/trunk/lib/Search/Estraier.pm
This is repository of my old source code which isn't updated any more. Go to git.rot13.org for current projects!
ViewVC logotype

Diff of /trunk/lib/Search/Estraier.pm

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 51 by dpavlin, Fri Jan 6 13:19:50 2006 UTC revision 52 by dpavlin, Fri Jan 6 14:10:29 2006 UTC
# Line 1172  sub search { Line 1172  sub search {
1172          croak "cond mush be Search::Estraier::Condition, not '$cond->isa'" unless ($cond->isa('Search::Estraier::Condition'));          croak "cond mush be Search::Estraier::Condition, not '$cond->isa'" unless ($cond->isa('Search::Estraier::Condition'));
1173          croak "depth needs number, not '$depth'" unless ($depth =~ m/^\d+$/);          croak "depth needs number, not '$depth'" unless ($depth =~ m/^\d+$/);
1174    
1175            my $resbody;
1176    
1177            my $rv = $self->shuttle_url( $self->{url} . '/search',
1178                    'text/x-estraier-draft',
1179                    $self->cond_to_query( $cond ),
1180                    \$resbody,
1181            );
1182            return if ($rv != 200);
1183    
1184            my (@docs, $hints);
1185    
1186            my @lines = split(/\n/, $resbody);
1187            return unless (@lines);
1188    
1189            my $border = $lines[0];
1190            my $isend = 0;
1191            my $lnum = 1;
1192    
1193            while ( $lnum <= $#lines ) {
1194                    my $line = $lines[$lnum];
1195                    $lnum++;
1196    
1197                    #warn "## $line\n";
1198                    if ($line && $line =~ m/^\Q$border\E(:END)*$/) {
1199                            $isend = $1;
1200                            last;
1201                    }
1202    
1203                    if ($line =~ /\t/) {
1204                            my ($k,$v) = split(/\t/, $line, 2);
1205                            $hints->{$k} = $v;
1206                    }
1207            }
1208    
1209            my $snum = $lnum;
1210    
1211            while( ! $isend && $lnum <= $#lines ) {
1212                    my $line = $lines[$lnum];
1213                    $lnum++;
1214    
1215                    if ($line && $line =~ m/^\Q$border\E/) {
1216                            if ($lnum > $snum) {
1217                                    my $rdattrs;
1218                                    my $rdvector;
1219                                    my $rdsnippet;
1220                                    
1221                                    my $rlnum = $snum;
1222                                    while ($rlnum < $lnum - 1 ) {
1223                                            #my $rdline = $self->_s($lines[$rlnum]);
1224                                            my $rdline = $lines[$rlnum];
1225                                            $rlnum++;
1226                                            last unless ($rdline);
1227                                            if ($rdline =~ /^%/) {
1228                                                    $rdvector = $1 if ($rdline =~ /^%VECTOR\t(.+)$/);
1229                                            } else {
1230                                                    $rdattrs->{$1} = {$2} if ($line =~ /^(.+)=(.+)$/);
1231                                            }
1232                                    }
1233                                    while($rlnum < $lnum - 1) {
1234                                            my $rdline = $lines[$rlnum];
1235                                            $rlnum++;
1236                                            $rdsnippet .= "$rdline\n";
1237                                    }
1238                                    if (my $rduri = $rdattrs->{'@uri'}) {
1239                                            push @docs, new Search::Estraier::ResultDocument(
1240                                                    uri => $rduri,
1241                                                    attrs => $rdattrs,
1242                                                    snippet => $rdsnippet,
1243                                                    keywords => $rdvector,
1244                                            );
1245                                    }
1246                            }
1247                            $snum = $lnum;
1248                            #warn "### $line\n";
1249                            $isend = 1 if ($line =~ /:END$/);
1250                    }
1251    
1252                    if (! $isend) {
1253                            warn "received result doesn't have :END\n$resbody";
1254                            return;
1255                    }
1256            }
1257    
1258            if (! $isend) {
1259                    warn "received result doesn't have :END\n$resbody";
1260                    return;
1261            }
1262                                            
1263    
1264            return new Search::Estraier::NodeResult( docs => \@docs, hints => $hints );
1265  }  }
1266    
1267    
# Line 1228  sub cond_to_query { Line 1317  sub cond_to_query {
1317  This is method which uses C<IO::Socket::INET> to communicate with Hyper Estraier node  This is method which uses C<IO::Socket::INET> to communicate with Hyper Estraier node
1318  master.  master.
1319    
1320    my $rv = shuttle_url( $url, $content_type, \$req_body, \$resbody );    my $rv = shuttle_url( $url, $content_type, $req_body, \$resbody );
1321    
1322  C<$resheads> and C<$resbody> booleans controll if response headers and/or response  C<$resheads> and C<$resbody> booleans controll if response headers and/or response
1323  body will be saved within object.  body will be saved within object.
Legend:
Removed from v.51  
changed lines
  Added in v.52
  ViewVC Help
Powered by ViewVC 1.1.26