From: erickson <erickson@dcc99617-32d9-48b4-a31d-7c20da2025e4>
Date: Wed, 21 Feb 2007 14:24:12 +0000 (+0000)
Subject: made users_of_interest streaming, sending a continue status directly after request
X-Git-Url: https://old-git.evergreen-ils.org/?a=commitdiff_plain;h=c5f60acb1ee583270681e7d2eecc17993558b335;p=Evergreen.git

made users_of_interest streaming, sending a continue status directly after request


git-svn-id: svn://svn.open-ils.org/ILS/trunk@6973 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 6c79a58836..0c53073a0b 100644
--- a/Open-ILS/src/perlmods/OpenILS/Application/Collections.pm
+++ b/Open-ILS/src/perlmods/OpenILS/Application/Collections.pm
@@ -111,6 +111,8 @@ sub users_of_interest {
    my $data = [];
 
    my $ses = OpenSRF::AppSession->create('open-ils.storage');
+
+   my $start = time;
    my $req = $ses->request(
       'open-ils.storage.money.collections.users_of_interest', 
       $age, $fine_level, $location);
@@ -118,34 +120,41 @@ sub users_of_interest {
    # let the client know we're still here
    $conn->status( new OpenSRF::DomainObject::oilsContinueStatus );
 
+   my $total;
    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} ],
-      };
+        return $req->failed if $req->failed;
+        my $hash = $resp->content;
+        next unless $hash;
+
+        unless($total) {
+            $total = time - $start;
+            $logger->info("collections: users_of_interest ".
+            "($age, $fine_level, $location) took $total seconds");
+        }
+
+        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);
-   }
+        $conn->respond($hash);
+    }
 
-   return undef;
+    return undef;
 }
 
 
@@ -154,6 +163,7 @@ __PACKAGE__->register_method(
 	api_name  => 'open-ils.collections.users_with_activity.retrieve',
 	api_level => 1,
 	argc      => 4,
+    stream    => 1,
 	signature => { 
 		desc     => q/
 			Returns an array of users that are already in collections 
@@ -200,11 +210,31 @@ sub users_with_activity {
 
 	my $org = $e->search_actor_org_unit({shortname => $location})
 		or return $e->event; $org = $org->[0];
-	return $e->event unless $e->allowed('VIEW_USER', $org->id);
+    return $e->event unless $e->allowed('VIEW_USER', $org->id);
 
-	return $U->storagereq(
+    my $ses = OpenSRF::AppSession->create('open-ils.storage');
+
+    my $start = time;
+    my $req = $ses->request(
 		'open-ils.storage.money.collections.users_with_activity.atomic', 
 		$start_date, $end_date, $location);
+
+    $conn->status( new OpenSRF::DomainObject::oilsContinueStatus );
+
+    my $total;
+    while( my $resp = $req->recv(timeout => 600) ) {
+
+        unless($total) {
+            $total = time - $start;
+            $logger->info("collections: users_with_activity search ".
+                "($start_date, $end_date, $location) took $total seconds");
+        }
+
+        return $req->failed if $req->failed;
+        $conn->respond($resp->content);
+   }
+
+    return undef;
 }