Many more tests -- still not complete as resultset_records() doesn't work.
[ZOOM-Perl-moved-to-github.git] / lib / ZOOM.pm
index a75c407..3cd252a 100644 (file)
@@ -1,4 +1,4 @@
-# $Id: ZOOM.pm,v 1.8 2005-10-19 13:53:35 mike Exp $
+# $Id: ZOOM.pm,v 1.10 2005-10-31 15:10:49 mike Exp $
 
 use strict;
 use warnings;
@@ -7,11 +7,6 @@ use Net::Z3950::ZOOM;
 
 package ZOOM;
 
-sub diag_str {
-    my($code) = @_;
-    return Net::Z3950::ZOOM::diag_str($code);
-}
-
 
 # Member naming convention: hash-element names which begin with an
 # underscore represent underlying ZOOM-C object descriptors; those
@@ -45,6 +40,11 @@ sub TIMEOUT { Net::Z3950::ZOOM::ERROR_TIMEOUT }
 sub UNSUPPORTED_PROTOCOL { Net::Z3950::ZOOM::ERROR_UNSUPPORTED_PROTOCOL }
 sub UNSUPPORTED_QUERY { Net::Z3950::ZOOM::ERROR_UNSUPPORTED_QUERY }
 sub INVALID_QUERY { Net::Z3950::ZOOM::ERROR_INVALID_QUERY }
+# The following are added specifically for this OO interface
+sub CREATE_QUERY { 20001 }
+sub QUERY_CQL { 20002 }
+sub QUERY_PQF { 20003 }
+sub SORTBY { 20004 }
 
 # The "Event" package contains constants returned by last_event()
 package ZOOM::Event;
@@ -59,6 +59,33 @@ sub RECV_APDU { Net::Z3950::ZOOM::EVENT_RECV_APDU }
 sub RECV_RECORD { Net::Z3950::ZOOM::EVENT_RECV_RECORD }
 sub RECV_SEARCH { Net::Z3950::ZOOM::EVENT_RECV_SEARCH }
 
+# ----------------------------------------------------------------------------
+
+package ZOOM;
+
+sub diag_str {
+    my($code) = @_;
+
+    # Special cases for error specific to the OO layer
+    if ($code == ZOOM::Error::CREATE_QUERY) {
+       return "can't create query object";
+    } elsif ($code == ZOOM::Error::QUERY_CQL) {
+       return "can't set CQL query";
+    } elsif ($code == ZOOM::Error::QUERY_PQF) {
+       return "can't set prefix query";
+    } elsif ($code == ZOOM::Error::SORTBY) {
+       return "can't set sort-specification";
+    }
+
+    return Net::Z3950::ZOOM::diag_str($code);
+}
+
+### More of the ZOOM::Exception instantiations should use this
+sub _oops {
+    my($code, $addinfo) = @_;
+
+    die new ZOOM::Exception($code, diag_str($code), $addinfo);
+}
 
 # ----------------------------------------------------------------------------
 
@@ -179,6 +206,30 @@ sub set_int {
     Net::Z3950::ZOOM::options_set_int($this->_opts(), $key, $value);
 }
 
+#   ###        Feel guilty.  Feel very, very guilty.  I've not been able to
+#      get the callback memory-management right in "ZOOM.xs", with
+#      the result that the values of $function and $udata passed into
+#      this function, which are on the stack, have sometimes been
+#      freed by the time they're used by __ZOOM_option_callback(),
+#      with hilarious results.  To avoid this, I copy the values into
+#      module-scoped globals, and pass _those_ into the extension
+#      function.  To avoid overwriting those globals by subsequent
+#      calls, I keep all the old ones, pushed onto the @_function and
+#      @_udata arrays, which means that THIS FUNCTION LEAKS MEMORY
+#      LIKE IT'S GOING OUT OF FASHION.  Not nice.  One day, I should
+#      fix this, but for now there's more important fish to fry.
+#
+my(@_function, @_udata);
+sub set_callback {
+    my $o1 = shift();
+    my($function, $udata) = @_;
+
+    push @_function, $function;
+    push @_udata, $udata;
+    Net::Z3950::ZOOM::options_set_callback($o1->_opts(),
+                                          $_function[-1], $_udata[-1]);
+}
+
 sub destroy {
     my $this = shift();
 
@@ -224,7 +275,7 @@ sub _conn {
     my $this = shift();
 
     my $_conn = $this->{_conn};
-    die "{_conn} undefined: has this ResultSet been destroy()ed?"
+    die "{_conn} undefined: has this Connection been destroy()ed?"
        if !defined $_conn;
 
     return $_conn;
@@ -291,12 +342,12 @@ sub option_binary {
     return $oldval;
 }
 
-
-sub search_pqf {
+sub search {
     my $this = shift();
     my($query) = @_;
 
-    my $_rs = Net::Z3950::ZOOM::connection_search_pqf($this->_conn(), $query);
+    my $_rs = Net::Z3950::ZOOM::connection_search($this->_conn(),
+                                                 $query->_query());
     my($errcode, $errmsg, $addinfo) = (undef, "dummy", "dummy");
     $errcode = Net::Z3950::ZOOM::connection_error($this->_conn(),
                                                  $errmsg, $addinfo);
@@ -305,6 +356,19 @@ sub search_pqf {
     return _new ZOOM::ResultSet($this, $query, $_rs);
 }
 
+sub search_pqf {
+    my $this = shift();
+    my($pqf) = @_;
+
+    my $_rs = Net::Z3950::ZOOM::connection_search_pqf($this->_conn(), $pqf);
+    my($errcode, $errmsg, $addinfo) = (undef, "dummy", "dummy");
+    $errcode = Net::Z3950::ZOOM::connection_error($this->_conn(),
+                                                 $errmsg, $addinfo);
+    die new ZOOM::Exception($errcode, $errmsg, $addinfo) if $errcode;
+
+    return _new ZOOM::ResultSet($this, $pqf, $_rs);
+}
+
 sub destroy {
     my $this = shift();
 
@@ -315,6 +379,77 @@ sub destroy {
 
 # ----------------------------------------------------------------------------
 
+package ZOOM::Query;
+
+sub new {
+    my $class = shift();
+    die "You can't create $class objects: it's a virtual base class";
+}
+
+sub _query {
+    my $this = shift();
+
+    my $_query = $this->{_query};
+    die "{_query} undefined: has this Query been destroy()ed?"
+       if !defined $_query;
+
+    return $_query;
+}
+
+sub sortby {
+    my $this = shift();
+    my($sortby) = @_;
+
+    Net::Z3950::ZOOM::query_sortby($this->_query(), $sortby) == 0
+       or ZOOM::_oops(ZOOM::Error::SORTBY, $sortby);
+}
+
+sub destroy {
+    my $this = shift();
+
+    Net::Z3950::ZOOM::query_destroy($this->_query());
+    $this->{_query} = undef;
+}
+
+
+package ZOOM::Query::CQL;
+our @ISA = qw(ZOOM::Query);
+
+sub new {
+    my $class = shift();
+    my($string) = @_;
+
+    my $q = Net::Z3950::ZOOM::query_create()
+       or ZOOM::_oops(ZOOM::Error::CREATE_QUERY);
+    Net::Z3950::ZOOM::query_cql($q, $string) == 0
+       or ZOOM::_oops(ZOOM::Error::QUERY_CQL, $string);
+
+    return bless {
+       _query => $q,
+    }, $class;
+}
+
+
+package ZOOM::Query::PQF;
+our @ISA = qw(ZOOM::Query);
+
+sub new {
+    my $class = shift();
+    my($string) = @_;
+
+    my $q = Net::Z3950::ZOOM::query_create()
+       or ZOOM::_oops(ZOOM::Error::CREATE_QUERY);
+    Net::Z3950::ZOOM::query_prefix($q, $string) == 0
+       or ZOOM::_oops(ZOOM::Error::QUERY_PQF, $string);
+
+    return bless {
+       _query => $q,
+    }, $class;
+}
+
+
+# ----------------------------------------------------------------------------
+
 package ZOOM::ResultSet;
 
 sub new {
@@ -329,7 +464,12 @@ sub _new {
 
     return bless {
        conn => $conn,
-       query => $query,
+       query => $query,        # This is not currently used, which is
+                               # just as well since it could be
+                               # either a string (when the RS is
+                               # created with search_pqf()) or a
+                               # ZOOM::Query object (when it's
+                               # created with search())
        _rs => $_rs,
     }, $class;
 }