X-Git-Url: http://git.indexdata.com/?p=irspy-moved-to-github.git;a=blobdiff_plain;f=lib%2FZOOM%2FIRSpy%2FConnection.pm;h=7a90cc94a0e0f06ef6970b1ac20a72514fe138c6;hp=0ad9c2b05015f0cb58061c018c8e38a6553d07b3;hb=07305e911c91ad0c3773493aa6ee11a9b0043483;hpb=1722445073349b59388d81952fff2334b6cbbf96 diff --git a/lib/ZOOM/IRSpy/Connection.pm b/lib/ZOOM/IRSpy/Connection.pm index 0ad9c2b..7a90cc9 100644 --- a/lib/ZOOM/IRSpy/Connection.pm +++ b/lib/ZOOM/IRSpy/Connection.pm @@ -1,4 +1,4 @@ -# $Id: Connection.pm,v 1.6 2006-10-25 15:43:43 mike Exp $ +# $Id: Connection.pm,v 1.11 2007-03-15 11:37:30 mike Exp $ package ZOOM::IRSpy::Connection; @@ -9,6 +9,9 @@ use warnings; use ZOOM; our @ISA = qw(ZOOM::Connection); +use ZOOM::IRSpy::Record; +use ZOOM::IRSpy::Utils qw(cql_target render_record); + use ZOOM::IRSpy::Task::Connect; use ZOOM::IRSpy::Task::Search; use ZOOM::IRSpy::Task::Retrieve; @@ -26,24 +29,40 @@ Keeping the private data in these objects removes the need for ugly mappings in the IRSpy object itself; adding the methods makes the application code cleaner. -The constructor takes an additional first argument, a reference to the -IRSpy object that it is associated with. +The constructor takes an two additional leading arguments: a reference +to the IRSpy object that it is associated with, and the target ID of +the connection. =cut sub create { my $class = shift(); my $irspy = shift(); + my $target = shift(); my $this = $class->SUPER::create(@_); + $this->option(host => $target); $this->{irspy} = $irspy; - $this->{record} = undef; $this->{tasks} = []; + my $query = cql_target($target); + my $rs = $irspy->{conn}->search(new ZOOM::Query::CQL($query)); + my $n = $rs->size(); + $this->log("irspy", "query '$query' found $n records"); + my $zeerex; + $zeerex = render_record($rs, 0, "zeerex") if $n > 0; + $this->{record} = new ZOOM::IRSpy::Record($this, $target, $zeerex); + return $this; } +sub destroy { + my $this = shift(); + $this->SUPER::destroy(@_); +} + + sub irspy { my $this = shift(); return $this->{irspy}; @@ -107,8 +126,8 @@ sub irspy_connect { my $this = shift(); my($udata, $options, %cb) = @_; - my $task = new ZOOM::IRSpy::Task::Connect($this, $udata, $options, %cb); - $this->add_task($task); + $this->add_task(new ZOOM::IRSpy::Task::Connect + ($this, $udata, $options, %cb)); } @@ -116,9 +135,8 @@ sub irspy_search_pqf { my $this = shift(); my($query, $udata, $options, %cb) = @_; - my $task = new ZOOM::IRSpy::Task::Search($query, - $this, $udata, $options, %cb); - $this->add_task($task); + $this->add_task(new ZOOM::IRSpy::Task::Search + ($query, $this, $udata, $options, %cb)); } @@ -126,9 +144,8 @@ sub irspy_rs_record { my $this = shift(); my($rs, $index0, $udata, $options, %cb) = @_; - my $task = new ZOOM::IRSpy::Task::Retrieve($rs, $index0, - $this, $udata, $options, %cb); - $this->add_task($task); + $this->add_task(new ZOOM::IRSpy::Task::Retrieve + ($rs, $index0, $this, $udata, $options, %cb)); } @@ -143,6 +160,14 @@ sub add_task { } +sub render { + my $this = shift(); + return ref($this) . "(" . $this->option("host") . ")"; +} + +use overload '""' => \&render; + + =head1 SEE ALSO ZOOM::IRSpy