From: miker <miker@9efc2488-bf62-4759-914b-345cdb29e865>
Date: Wed, 9 Feb 2005 19:24:00 +0000 (+0000)
Subject: adding subrequest support
X-Git-Tag: osrf_rel_2_0_1~1834
X-Git-Url: https://old-git.evergreen-ils.org/?a=commitdiff_plain;h=034468b781e02f73439646862f1054a07957e402;p=OpenSRF.git

adding subrequest support


git-svn-id: svn://svn.open-ils.org/OpenSRF/trunk@38 9efc2488-bf62-4759-914b-345cdb29e865
---

diff --git a/src/perlmods/OpenSRF/AppSession.pm b/src/perlmods/OpenSRF/AppSession.pm
index ff191fa..8aa275f 100644
--- a/src/perlmods/OpenSRF/AppSession.pm
+++ b/src/perlmods/OpenSRF/AppSession.pm
@@ -819,6 +819,24 @@ sub respond_complete {
 }
 
 
+package OpenSRF::AppSubrequest;
+
+sub respond {
+	my $self = shift;
+	my $resp = shift;
+	push @{$$self{resp}}, $resp;
+}
+
+sub new {
+	return bless({resp => []}, 'OpenSRF::AppSubrequest');
+}
+
+sub responses { @{$_[0]->{resp}} }
+
+sub status {}
+
+
+
 1;
 
 
diff --git a/src/perlmods/OpenSRF/Application.pm b/src/perlmods/OpenSRF/Application.pm
index 1adc67d..4648b6b 100644
--- a/src/perlmods/OpenSRF/Application.pm
+++ b/src/perlmods/OpenSRF/Application.pm
@@ -213,7 +213,20 @@ sub method_lookup {
 
 sub run {
 	my $self = shift;
-	$self->{code}->($self, @_);
+	my $req = shift;
+
+	unless ( ref($req) and UNIVERSAL::isa($req, 'OpenSRF::AppRequest') ) {
+		unshift @_, $req;
+		$req = OpenSRF::AppSubrequest->new;
+	}
+
+	my $resp = $self->{code}->($self, $req, @_);
+
+	if ( ref($req) and UNIVERSAL::isa($req, 'OpenSRF::AppSubrequest') ) {
+		return $req->responses;
+	}
+
+	return $resp;
 }
 
 1;