/[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!

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

Parent Directory | Revision Log | View Patch Patch

-revision 128 by dpavlin,
Mon May  8 12:00:43 2006 UTC
+revision 136 by dpavlin,
Tue May  9 14:03:36 2006 UTC
 Line 872 
 or in more verbose form
    my $node = new Search::HyperEstraier::Node(
          url => 'http://localhost:1978/node/test',
+         user => 'admin',
+         passwd => 'admin'
          debug => 1,
          croak_on_error => 1
    );
-Line 884 
 with following arguments:
+Line 886 
 with following arguments:
  URL to node
+ =item user
+ specify username for node server authentication
+ =item passwd
+ password for authentication
  =item debug
  dumps a B<lot> of debugging output
-Line 914 
 sub new {
+Line 924 
 sub new {
          if ($#_ == 0) {
                  $self->{url} = shift;
          } else {
-                 my $args = {@_};
                  %$self = ( %$self, @_ );
+                 $self->set_auth( $self->{user}, $self->{passwd} ) if ($self->{user});
                  warn "## Node debug on\n" if ($self->{debug});
          }
-Line 1690 
 sub links {
+Line 1700 
 sub links {
          return $self->{inform}->{links};
  }
+ =head2 master
+ Set actions on Hyper Estraier node master (C<estmaster> process)
+   $node->master(
+         action => 'sync'
+   );
+ All available actions are documented in
+ L<http://hyperestraier.sourceforge.net/nguide-en.html#protocol>
+ =cut
+ my $estmaster_rest = {
+         shutdown => {
+                 status => 202,
+         },
+         sync => {
+                 status => 202,
+         },
+         backup => {
+                 status => 202,
+         },
+         userlist => {
+                 status => 200,
+                 returns => [ qw/name passwd flags fname misc/ ],
+         },
+         useradd => {
+                 required => [ qw/name passwd flags/ ],
+                 optional => [ qw/fname misc/ ],
+                 status => 200,
+         },
+         userdel => {
+                 required => [ qw/name/ ],
+                 status => 200,
+         },
+         nodelist => {
+                 status => 200,
+                 returns => [ qw/name label doc_num word_num size/ ],
+         },
+         nodeadd => {
+                 required => [ qw/name/ ],
+                 optional => [ qw/label/ ],
+                 status => 200,
+         },
+         nodedel => {
+                 required => [ qw/name/ ],
+                 status => 200,
+         },
+         nodeclr => {
+                 required => [ qw/name/ ],
+                 status => 200,
+         },
+         nodertt => {
+                 status => 200,
+         },
+ };
+ sub master {
+         my $self = shift;
+         my $args = {@_};
+         # have action?
+         my $action = $args->{action} || croak "need action, available: ",
+                 join(", ",keys %{ $estmaster_rest });
+         # check if action is valid
+         my $rest = $estmaster_rest->{$action};
+         croak "action '$action' is not supported, available actions: ",
+                 join(", ",keys %{ $estmaster_rest }) unless ($rest);
+         croak "BUG: action '$action' needs return status" unless ($rest->{status});
+         my @args;
+         if ($rest->{required} || $rest->{optional}) {
+                 map {
+                         croak "need parametar '$_' for action '$action'" unless ($args->{$_});
+                         push @args, $_ . '=' . uri_escape( $args->{$_} );
+                 } ( @{ $rest->{required} } );
+                 map {
+                         push @args, $_ . '=' . uri_escape( $args->{$_} ) if ($args->{$_});
+                 } ( @{ $rest->{optional} } );
+         }
+         my $uri = new URI( $self->{url} );
+         my $resbody;
+         my $status = $self->shuttle_url(
+                 'http://' . $uri->host_port . '/master?action=' . $action ,
+                 'application/x-www-form-urlencoded',
+                 join('&', @args),
+                 \$resbody,
+,
+         ) or confess "shuttle_url failed";
+         if ($status == $rest->{status}) {
+                 if ($rest->{returns} && wantarray) {
+                         my @results;
+                         my $fields = $#{$rest->{returns}};
+                         foreach my $line ( split(/[\r\n]/,$resbody) ) {
+                                 my @e = split(/\t/, $line, $fields + 1);
+                                 my $row;
+                                 foreach my $i ( 0 .. $fields) {
+                                         $row->{ $rest->{returns}->[$i] } = $e[ $i ];
+                                 }
+                                 push @results, $row;
+                         }
+                         return @results;
+                 } elsif ($resbody) {
+                         chomp $resbody;
+                         return $resbody;
+                 } else {
+                         return 0E0;
+                 }
+         }
+         carp "expected status $rest->{status}, but got $status";
+         return undef;
+ }
  =head1 PRIVATE METHODS

 Legend:



Removed from v.128
 


changed lines


 
Added in v.136
 Legend:



Removed from v.128
 


changed lines


 
Added in v.136
-Removed from v.128
+Added in v.136

	ViewVC Help
Powered by ViewVC 1.1.26