From 022f6482bfe0b1a3e4c651f2433c06a9e3c06a13 Mon Sep 17 00:00:00 2001
From: erickson <erickson@9efc2488-bf62-4759-914b-345cdb29e865>
Date: Wed, 20 Apr 2005 20:45:46 +0000
Subject: [PATCH] this is the code that has the 'failed' method as well as a
 utility method 'gather' that wraps up simple requests

git-svn-id: svn://svn.open-ils.org/OpenSRF/trunk@285 9efc2488-bf62-4759-914b-345cdb29e865
---
 src/perlmods/OpenSRF/AppSession.pm | 34 ++++++++++++++++++++++++++++++++--
 1 file changed, 32 insertions(+), 2 deletions(-)

diff --git a/src/perlmods/OpenSRF/AppSession.pm b/src/perlmods/OpenSRF/AppSession.pm
index 0aafffd..da3f4d6 100644
--- a/src/perlmods/OpenSRF/AppSession.pm
+++ b/src/perlmods/OpenSRF/AppSession.pm
@@ -176,8 +176,6 @@ sub last_sent_type {
 sub get_app_targets {
 	my $app = shift;
 
-#	my $config_client = OpenSRF::Utils::SettingsClient->new();
-
 	my $conf = OpenSRF::Utils::Config->current;
 	my $router_name = $conf->bootstrap->router_name;
 	my $routers = $conf->bootstrap->domains;
@@ -273,6 +271,7 @@ sub connect {
 	my $self = shift;
 	my $class = ref($self) || $self;
 
+
 	if ( ref( $self ) and  $self->state && $self->state == CONNECTED  ) {
 		$logger->transport("ABC AppSession already connected", DEBUG );
 	} else {
@@ -851,10 +850,20 @@ sub push_queue {
 	my $self = shift;
 	my $resp = shift;
 	if( !$resp ) { return 0; }
+	if( UNIVERSAL::isa($resp, "Error")) {
+		$self->{failed} = $resp;
+		$self->complete(1);
+		#return; eventually...
+	}
 	push @{ $self->{recv_queue} }, $resp;
 	OpenSRF::Utils::Logger->debug( "AppRequest pushed ".$resp->toString(), INTERNAL );
 }
 
+sub failed {
+	my $self = shift;
+	return $self->{failed};
+}
+
 sub queue_wait {
 	my $self = shift;
 	OpenSRF::Utils::Logger->debug( "Calling queue_wait(@_)", DEBUG );
@@ -866,6 +875,7 @@ sub payload { return shift()->{payload}; }
 sub resend {
 	my $self = shift;
 	return unless ($self and $self->session);
+	return if $self->complete;
 	OpenSRF::Utils::Logger->debug(
 		"I'm resending the request for threadTrace ". $self->threadTrace, DEBUG);
 	if($self->payload) {
@@ -924,6 +934,26 @@ sub register_death_callback {
 	$self->session->register_callback( death => $cb );
 }
 
+
+# utility method.  checks to see of the request failed.
+# if so, throws an OpenSRF::EX::ERROR. if everything is
+# ok, it returns the content of the request
+sub gather {
+	my $self = shift;
+	my $finish = shift;
+	$self->wait_complete;
+	my $resp = $self->recv;
+	if( $self->failed() ) { 
+		throw OpenSRF::EX::ERROR
+			($self->failed()->stringify());
+	}
+	if(!$resp) { return undef; }
+	my $content = $resp->content;
+	if($finish) { $self->finish();}
+	return $content;
+}
+
+
 package OpenSRF::AppSubrequest;
 
 sub respond {
-- 
2.11.0