@@ -115,7 +115,7 @@ public function end() {
115115
116116 public function invoke ($ lambda , $ event , $ context ) {
117117 try {
118- $ this ->request = $ this ->api ->request ("invocation/ {$ context ->awsRequestId }/response " );
118+ $ this ->request = $ this ->api ->request (' POST ' , "invocation/ {$ context ->awsRequestId }/response " );
119119 $ lambda ($ event , $ this , $ context );
120120 $ this ->end ();
121121 return $ this ->response ;
@@ -182,14 +182,15 @@ public function error($e) {
182182 }
183183
184184 /**
185- * Creates a POST request for a given endpoint
185+ * Creates a request for a given endpoint
186186 *
187+ * @param string $method
187188 * @param string $endpoint
188189 * @return peer.http.HttpRequest
189190 */
190- public function request ($ endpoint ) {
191+ public function request ($ method , $ endpoint ) {
191192 $ request = $ this ->conn ->create (new HttpRequest ());
192- $ request ->setMethod (' POST ' );
193+ $ request ->setMethod ($ method );
193194 $ request ->setTarget ("/ {$ this ->version }/runtime/ {$ endpoint }" );
194195 return $ request ;
195196 }
@@ -201,10 +202,7 @@ public function request($endpoint) {
201202 * @return peer.http.HttpResponse
202203 */
203204 public function receive ($ endpoint ) {
204- $ request = $ this ->conn ->create (new HttpRequest ());
205- $ request ->setMethod ('GET ' );
206- $ request ->setTarget ("/ {$ this ->version }/runtime/ {$ endpoint }" );
207- return $ this ->conn ->send ($ request );
205+ return $ this ->conn ->send ($ this ->request ('GET ' , $ endpoint ));
208206 }
209207
210208 /**
@@ -215,9 +213,7 @@ public function receive($endpoint) {
215213 * @return peer.http.HttpResponse
216214 */
217215 public function send ($ endpoint , $ result ) {
218- $ request = $ this ->conn ->create (new HttpRequest ());
219- $ request ->setMethod ('POST ' );
220- $ request ->setTarget ("/ {$ this ->version }/runtime/ {$ endpoint }" );
216+ $ request = $ this ->request ('POST ' , $ endpoint );
221217 $ request ->setHeader ('Content-Type ' , 'application/json ' );
222218 $ request ->setParameters (new RequestData (Json::of ($ result )));
223219 return $ this ->conn ->send ($ request );
0 commit comments