Revert "Async option for logging user actions on item events"
authorBen Wise <ben.wise@catchoftheday.com.au>
Thu, 24 Sep 2015 07:46:01 +0000 (17:46 +1000)
committerBen Wise <ben.wise@catchoftheday.com.au>
Thu, 24 Sep 2015 07:46:01 +0000 (17:46 +1000)
This reverts commit f5aaded3343e8bdbbd20cb87db77e389e48ddaaf.

src/predictionio/BaseClient.php
src/predictionio/EventClient.php

index 67173e0..13ef8d2 100644 (file)
@@ -4,7 +4,6 @@ namespace predictionio;
 
 use GuzzleHttp\Client;
 use GuzzleHttp\Exception\ClientException;
-use GuzzleHttp\Promise\PromiseInterface;
 
 /**
  * Base client for Event and Engine client
@@ -44,21 +43,17 @@ abstract class BaseClient {
    * @param string $method HTTP request method
    * @param string $url Relative or absolute url
    * @param string $body HTTP request body
-   * @param boolean $async Send request asynchronously and return a promise
-   * @return array|PromiseInterface JSON response
-   * @throws PredictionIOAPIError
+   *
+   * @return array JSON response
+   * @throws PredictionIOAPIError Request error
    */
-  protected function sendRequest($method, $url, $body, $async = false) {
+  protected function sendRequest($method, $url, $body) {
     $options = ['headers' => ['Content-Type' => 'application/json'],
                 'body' => $body]; 
 
     try {
-      if ($async) {
-        return $this->client->requestAsync($method, $url, $options);
-      } else {
-        $response = $this->client->request($method, $url, $options);
-        return json_decode($response->getBody(), true);
-      }
+      $response = $this->client->request($method, $url, $options);
+      return json_decode($response->getBody(), true);
     } catch (ClientException $e) {
       throw new PredictionIOAPIError($e->getMessage()); 
     }
index c037e38..df4286f 100644 (file)
@@ -3,8 +3,7 @@
 namespace predictionio;
 use GuzzleHttp\Client;
 use \DateTime;
-use GuzzleHttp\Promise\PromiseInterface;
-
 /**
  * Client for connecting to an Event Server
  *
@@ -212,14 +211,14 @@ class EventClient extends BaseClient {
    * @param string Time of the event in ISO 8601 format
    *               (e.g. 2014-09-09T16:17:42.937-08:00).
    *               Default is the current time.
-   * @param bool Send request asynchronously
-   * @return array|PromiseInterface JSON response or PromiseInterface object if async
+   *
+   * @return string JSON response
    * 
    * @throws PredictionIOAPIError Request error
    */
    public function recordUserActionOnItem($event, $uid, $iid, 
                                          array $properties=array(),
-                                         $eventTime=null, $async = false) {
+                                         $eventTime=null) {
     $eventTime = $this->getEventTime($eventTime);
     if (empty($properties)) $properties = (object)$properties;
     $json = json_encode([
@@ -232,7 +231,7 @@ class EventClient extends BaseClient {
         'eventTime' => $eventTime,
     ]);
 
-    return $this->sendRequest('POST', $this->eventUrl, $json, $async);
+    return $this->sendRequest('POST', $this->eventUrl, $json);
   }
 
   /**