From 5f27e8a42f7ec9dd898c2208475ef5121df0a247 Mon Sep 17 00:00:00 2001
From: erickson <erickson@dcc99617-32d9-48b4-a31d-7c20da2025e4>
Date: Mon, 21 Nov 2005 19:36:53 +0000
Subject: [PATCH] batch authority method

git-svn-id: svn://svn.open-ils.org/ILS/trunk@2103 dcc99617-32d9-48b4-a31d-7c20da2025e4
---
 .../OpenILS/Application/Search/Authority.pm   | 119 +++++++++++++++++-
 1 file changed, 116 insertions(+), 3 deletions(-)

diff --git a/Open-ILS/src/perlmods/OpenILS/Application/Search/Authority.pm b/Open-ILS/src/perlmods/OpenILS/Application/Search/Authority.pm
index dec71fd07d..240d1a87fb 100644
--- a/Open-ILS/src/perlmods/OpenILS/Application/Search/Authority.pm
+++ b/Open-ILS/src/perlmods/OpenILS/Application/Search/Authority.pm
@@ -27,6 +27,15 @@ sub crossref_authority {
 
 	my $fr = $freq->gather(1);
 	my $al = $areq->gather(1);
+	$session->disconnect;
+
+	return _auth_flatten( $term, $fr, $al );
+}
+
+sub _auth_flatten {
+	my $term = shift;
+	my $fr = shift;
+	my $al = shift;
 
 	my %hash = ();
 	for my $x (@$fr) {
@@ -62,12 +71,10 @@ sub crossref_authority {
 	}
 	my $also = [ sort { $hash{$b} <=> $hash{$a} || $a cmp $b } keys %hash ];
 
-	$session->disconnect;
-
-	
 
 	return { from => $from, also => $also };
 }
+
 __PACKAGE__->register_method(
         method		=> "crossref_authority",
         api_name	=> "open-ils.search.authority.crossref",
@@ -75,5 +82,111 @@ __PACKAGE__->register_method(
         note		=> "Searches authority data for existing controlled terms and crossrefs",
 );              
 
+__PACKAGE__->register_method(
+	method		=> "crossref_authority_batch",
+   api_name	=> "open-ils.search.authority.crossref.batch",
+   argc		=> 1, 
+   note		=> <<"	NOTE");
+	Takes an array of class,term pair sub-arrays and performs an authority lookup for each
+
+	PARAMS( [ ["subject", "earth"], ["author","shakespeare"] ] );
+
+	Returns an object like so:
+	{
+		"classname" : {
+			"term" : { "from" : [ ...], "also" : [...] }
+			"term2" : { "from" : [ ...], "also" : [...] }
+		}
+	}
+	NOTE
+
+=head comment should work...
+sub crossref_authority_batch {
+	my( $self, $client, $reqs ) = @_;
+
+	my $appreqs = {};
+	for my $req (@$reqs) {
+
+		my $class = $req->[0];
+		my $term = $req->[1];
+		next unless $class and $term;
+		$appreqs->{$class} = {} unless exists $appreqs->{$class};
+		$appreqs->{$class}->{$term} = [];
+
+		warn "Sending auth request for $class : $term\n";
+		my $session = OpenSRF::AppSession->create("open-ils.storage");
+		my $freq = $session->request("open-ils.storage.authority.$class.see_from.controlled.atomic",$term);
+		my $areq = $session->request("open-ils.storage.authority.$class.see_also_from.controlled.atomic",$term);
+		$appreqs->{$class}->{$term}->[0] = $freq;
+		$appreqs->{$class}->{$term}->[1] = $areq;
+	}
+
+	my $response = {};
+	for my $class (keys %$appreqs) {
+		$response->{$class} = {} unless exists $response->{$class};
+		for my $term (keys %{$appreqs->{$class}}) {
+			warn "Receiving auth request for $class : $term\n";
+			my $fr = $appreqs->{$class}->{$term}->[0]->gather(1);
+			my $al = $appreqs->{$class}->{$term}->[1]->gather(1);
+			warn "Flattenting..\n";
+			$response->{$class}->{$term} = _auth_flatten( $term, $fr, $al );
+			warn "Done with $term\n";
+		}
+		warn "Done with $class\n";
+	}
+
+	use Data::Dumper;
+	warn "Returning responses: " . Dumper($response) . "\n";
+
+	return $response;
+}
+
+=cut
+
+sub crossref_authority_batch {
+	my( $self, $client, $reqs ) = @_;
+
+	my $response = {};
+	my $lastr = [];
+	my $session = OpenSRF::AppSession->create("open-ils.storage");
+
+	for my $req (@$reqs) {
+
+		my $class = $req->[0];
+		my $term = $req->[1];
+		next unless $class and $term;
+		warn "Sending authority request for $class : $term\n";
+		my $freq = $session->request("open-ils.storage.authority.$class.see_from.controlled.atomic",$term);
+		my $areq = $session->request("open-ils.storage.authority.$class.see_also_from.controlled.atomic",$term);
+
+		if( $lastr->[0] ) { #process old data while waiting on new data
+			my $cls = $lastr->[0];
+			my $trm = $lastr->[1];
+			my $fr	= $lastr->[2];
+			my $al	= $lastr->[3];
+			warn "Flattening $class : $term\n";
+			$response->{$cls} = {} unless exists $response->{$cls};
+			$response->{$cls}->{$trm} = _auth_flatten( $trm, $fr, $al );
+		}
+
+		$lastr->[0] = $class;
+		$lastr->[1] = $term; 
+		$lastr->[2] = $freq->gather(1);
+		$lastr->[3] = $areq->gather(1);
+	}
+
+	if( $lastr->[0] ) { #process old data while waiting on new data
+		my $cls = $lastr->[0];
+		my $trm = $lastr->[1];
+		my $fr	= $lastr->[2];
+		my $al	= $lastr->[3];
+		warn "Flattening $cls : $trm\n";
+		$response->{$cls} = {} unless exists $response->{$cls};
+		$response->{$cls}->{$trm} = _auth_flatten( $trm, $fr, $al );
+	}
+
+	return $response;
+}
+
 
 1;
-- 
2.43.2