From: erickson <erickson@dcc99617-32d9-48b4-a31d-7c20da2025e4>
Date: Mon, 5 Feb 2007 19:15:34 +0000 (+0000)
Subject: re-engineered the users_of_interest to use streaming calls and a longer timeout
X-Git-Url: https://old-git.evergreen-ils.org/?a=commitdiff_plain;h=eb66cecf6f5fc713b60f9086bccbdff7f9a5d754;p=Evergreen.git

re-engineered the users_of_interest to use streaming calls and a longer timeout


git-svn-id: svn://svn.open-ils.org/ILS/branches/rel_1_0@6880 dcc99617-32d9-48b4-a31d-7c20da2025e4
---

diff --git a/Open-ILS/src/perlmods/OpenILS/Application/Collections.pm b/Open-ILS/src/perlmods/OpenILS/Application/Collections.pm
index 0b03285b14..6c79a58836 100644
--- a/Open-ILS/src/perlmods/OpenILS/Application/Collections.pm
+++ b/Open-ILS/src/perlmods/OpenILS/Application/Collections.pm
@@ -40,6 +40,7 @@ __PACKAGE__->register_method(
 	api_name  => 'open-ils.collections.users_of_interest.retrieve',
 	api_level => 1,
 	argc      => 4,
+    stream    => 1,
 	signature => { 
 		desc     => q/
 			Returns an array of user information objects that the system 
@@ -107,34 +108,44 @@ sub users_of_interest {
 	# they need global perms to view users so no org is provided
 	return $e->event unless $e->allowed('VIEW_USER'); 
 
-	my $data = $U->storagereq(
-		'open-ils.storage.money.collections.users_of_interest.atomic', 
-		$age, $fine_level, $location);
-
-	return [] unless $data and @$data;
-
-	for (@$data) {
-		my $u = $e->retrieve_actor_user(
-			[
-				$_->{usr},
-				{
-					flesh				=> 1,
-					flesh_fields	=> {au => ["groups","profile", "card"]},
-					select			=> {au => ["profile","id","dob", "card"]}
-				}
-			]
-		) or return $e->event;
-
-		$_->{usr} = {
-			id			=> $u->id,
-			dob		=> $u->dob,
-			profile	=> $u->profile->name,
-			barcode	=> $u->card->barcode,
-			groups	=> [ map { $_->name } @{$u->groups} ],
-		};
-	}
-
-	return $data;
+   my $data = [];
+
+   my $ses = OpenSRF::AppSession->create('open-ils.storage');
+   my $req = $ses->request(
+      'open-ils.storage.money.collections.users_of_interest', 
+      $age, $fine_level, $location);
+
+   # let the client know we're still here
+   $conn->status( new OpenSRF::DomainObject::oilsContinueStatus );
+
+   while( my $resp = $req->recv(timeout => 600) ) {
+      return $req->failed if $req->failed;
+      my $hash = $resp->content;
+      next unless $hash;
+
+      my $u = $e->retrieve_actor_user(
+         [
+	         $hash->{usr},
+	         {
+		         flesh				=> 1,
+		         flesh_fields	=> {au => ["groups","profile", "card"]},
+		         #select			=> {au => ["profile","id","dob", "card"]}
+	         }
+         ]
+      ) or return $e->event;
+
+      $hash->{usr} = {
+         id			=> $u->id,
+         dob		=> $u->dob,
+         profile	=> $u->profile->name,
+         barcode	=> $u->card->barcode,
+         groups	=> [ map { $_->name } @{$u->groups} ],
+      };
+      
+      $conn->respond($hash);
+   }
+
+   return undef;
 }