Job synchronize emails sf bong

composer.json

@@ -8,7 +8,7 @@
         "codeclimate/php-test-reporter": "dev-master"
     },
     "require": {
-        "php": ">=7.1",
+        "php": ">=7.0",
         "psr/http-message": "^1.0",
         "guzzlehttp/guzzle": "^6.3",
         "guzzlehttp/psr7": "^1.4"

src/Rest/GuzzleRestClient.php

@@ -1,8 +1,12 @@
 <?php
-namespace EventFarm\Restforce\Rest;
 
-use Psr\Http\Message\ResponseInterface;
+namespace EventFarm\Restforce\Rest;
 
+/**
+ * Class GuzzleRestClient
+ *
+ * @package EventFarm\Restforce\Rest
+ */
 class GuzzleRestClient implements RestClientInterface
 {
     const DEFAULT_TIMEOUT_SECONDS = 20.0;
@@ -12,6 +16,11 @@ class GuzzleRestClient implements RestClientInterface
     /** @var bool */
     private $enableDebugging;
 
+    /**
+     * GuzzleRestClient constructor.
+     * @param string $baseUri         base uri
+     * @param bool   $enableDebugging debugging status
+     */
     public function __construct(
         string $baseUri,
         bool $enableDebugging = false
@@ -20,7 +29,14 @@ public function __construct(
         $this->setBaseUriForRestClient($baseUri);
     }
 
-    public function setBaseUriForRestClient(string $baseUri): void
+    /**
+     * Set base uri for client
+     *
+     * @param string $baseUri base uri
+     *
+     * @return void
+     */
+    public function setBaseUriForRestClient(string $baseUri)
     {
         if (!$this->containsTrailingSlash($baseUri)) {
             $baseUri .= '/';
@@ -34,68 +50,136 @@ public function setBaseUriForRestClient(string $baseUri): void
         $this->client = new \GuzzleHttp\Client($config);
     }
 
+    /**
+     * Get method
+     *
+     * @param string     $path            path
+     * @param array      $queryParameters parameters
+     * @param array      $headers         headers
+     * @param float|null $timeoutSeconds  timeout
+     *
+     * @return mixed
+     * @throws \GuzzleHttp\Exception\GuzzleException
+     */
     public function get(
         string $path,
         array $queryParameters = [],
         array $headers = [],
-        ?float $timeoutSeconds = null
-    ): ResponseInterface {
+        float $timeoutSeconds = null
+    ) {
         return $this->client->request(
             'GET',
             $path,
             [
                 'timeout' => $timeoutSeconds,
                 'headers' => $headers,
-                'query' => $queryParameters,
-                'http_errors' => false,
+                'query' => $queryParameters
             ]
         );
     }
 
+    /**
+     * Post method
+     *
+     * @param string     $path           path
+     * @param array      $formParameters parameters
+     * @param array      $headers        headers
+     * @param float|null $timeoutSeconds timeout
+     *
+     * @return mixed
+     * @throws \GuzzleHttp\Exception\GuzzleException
+     */
     public function post(
         string $path,
         array $formParameters = [],
         array $headers = [],
-        ?float $timeoutSeconds = null
-    ): ResponseInterface {
+        float $timeoutSeconds = null
+    ) {
         return $this->client->request(
             'POST',
             $path,
             [
                 'timeout' => $timeoutSeconds,
                 'headers' => $headers,
-                'form_params' => $formParameters,
-                'http_errors' => false,
+                'form_params' => $formParameters
+            ]
+        );
+    }
+
+    /**
+     * Delete method
+     *
+     * @param string     $path           path
+     * @param array      $formParameters parameters
+     * @param array      $headers        headers
+     * @param float|null $timeoutSeconds timeout
+     *
+     * @return mixed
+     * @throws \GuzzleHttp\Exception\GuzzleException
+     */
+    public function delete(
+        string $path,
+        array $formParameters = [],
+        array $headers = [],
+        float $timeoutSeconds = null
+    ) {
+        return $this->client->request(
+            'DELETE',
+            $path,
+            [
+                'timeout' => $timeoutSeconds,
+                'headers' => $headers,
+                'form_params' => $formParameters
             ]
         );
     }
 
+    /**
+     * Post method JSON formatted
+     *
+     * @param string     $path           path
+     * @param array      $jsonArray      parameters
+     * @param array      $headers        headers
+     * @param float|null $timeoutSeconds timeout
+     *
+     * @return mixed
+     * @throws \GuzzleHttp\Exception\GuzzleException
+     */
     public function postJson(
         string $path,
         array $jsonArray = [],
         array $headers = [],
-        ?float $timeoutSeconds = null
-    ): ResponseInterface {
+        float $timeoutSeconds = null
+    ) {
         $headers['Content-Type'] = 'application/json';
-
         return $this->client->request(
             'POST',
             $path,
             [
                 'timeout' => $timeoutSeconds,
                 'headers' => $headers,
-                'json' => $jsonArray,
-                'http_errors' => false,
+                'json' => $jsonArray
             ]
         );
     }
 
+    /**
+     * Patch method JSON formatted
+     *
+     * @param string     $path           path
+     * @param array      $jsonArray      parameters
+     * @param array      $headers        headers
+     * @param float|null $timeoutSeconds timeout
+     *
+     * @return mixed
+     * @throws \GuzzleHttp\Exception\GuzzleException
+     */
     public function patchJson(
         string $path,
         array $jsonArray = [],
         array $headers = [],
-        ?float $timeoutSeconds = null
-    ): ResponseInterface {
+        float $timeoutSeconds = null
+    ) {
         $headers['Content-Type'] = 'application/json';
 
         return $this->client->request(
@@ -104,13 +188,49 @@ public function patchJson(
             [
                 'timeout' => $timeoutSeconds,
                 'headers' => $headers,
-                'json' => $jsonArray,
-                'http_errors' => false,
+                'json' => $jsonArray
+            ]
+        );
+    }
+
+    /**
+     * Put method CSV formatted
+     *
+     * @param string     $path           path
+     * @param string     $filePath       file path
+     * @param array      $headers        headers
+     * @param float|null $timeoutSeconds timeout
+     *
+     * @return mixed
+     * @throws \GuzzleHttp\Exception\GuzzleException
+     */
+    public function putCsv(
+        string $path,
+        string $filePath,
+        array $headers = [],
+        float $timeoutSeconds = null
+    ) {
+        $headers['Content-Type'] = 'text/csv';
+
+        return $this->client->request(
+            'PUT',
+            $path,
+            [
+                'timeout' => $timeoutSeconds,
+                'headers' => $headers,
+                'body' => fopen($filePath, 'r')
             ]
         );
     }
 
-    private function containsTrailingSlash(string $baseUri): bool
+    /**
+     * Check if contains trailing slash
+     *
+     * @param string $baseUri base uri
+     *
+     * @return bool
+     */
+    private function containsTrailingSlash(string $baseUri)
     {
         return substr($baseUri, -1) === '/';
     }

src/Rest/OAuthAccessToken.php

@@ -1,6 +1,11 @@
 <?php
 namespace EventFarm\Restforce\Rest;
 
+/**
+ * Class OAuthAccessToken
+ *
+ * @package EventFarm\Restforce\Rest
+ */
 class OAuthAccessToken
 {
     /** @var string */
@@ -16,13 +21,23 @@ class OAuthAccessToken
     /** @var int|null */
     private $expiresAt;
 
+    /**
+     * OAuthAccessToken constructor.
+     *
+     * @param string      $tokenType        token type (password, etc.)
+     * @param string      $accessToken      access token
+     * @param string      $instanceUrl      instance url
+     * @param string      $resourceOwnerUrl resource owner url
+     * @param string|null $refreshToken     refresh token
+     * @param int|null    $expiresAt        expires value
+     */
     public function __construct(
         string $tokenType,
         string $accessToken,
         string $instanceUrl,
         string $resourceOwnerUrl,
-        ?string $refreshToken = null,
-        ?int $expiresAt = null
+        string $refreshToken = null,
+        int $expiresAt = null
     ) {
         $this->tokenType = $tokenType;
         $this->accessToken = $accessToken;
@@ -32,42 +47,82 @@ public function __construct(
         $this->expiresAt = $expiresAt;
     }
 
-    public function getTokenType(): string
+    /**
+     * Get token type
+     *
+     * @return string
+     */
+    public function getTokenType()
     {
         return $this->tokenType;
     }
 
-    public function getAccessToken(): string
+    /**
+     * Get access token
+     *
+     * @return string
+     */
+    public function getAccessToken()
     {
         return $this->accessToken;
     }
 
-    public function getRefreshToken(): ?string
+    /**
+     * Get refresh token
+     *
+     * @return null|string
+     */
+    public function getRefreshToken()
     {
         return $this->refreshToken;
     }
 
-    public function getInstanceUrl(): string
+    /**
+     * Get instance url
+     *
+     * @return string
+     */
+    public function getInstanceUrl()
     {
         return $this->instanceUrl;
     }
 
-    public function getHeaderString(): string
+    /**
+     * Get header string
+     *
+     * @return string
+     */
+    public function getHeaderString()
     {
         return $this->tokenType . ' ' . $this->accessToken;
     }
 
-    public function getResourceOwnerUrl(): string
+    /**
+     * Get resource owner url
+     *
+     * @return string
+     */
+    public function getResourceOwnerUrl()
     {
         return $this->resourceOwnerUrl;
     }
 
-    public function getExpiresAt(): ?int
+    /**
+     * Get expires at value
+     *
+     * @return int|null
+     */
+    public function getExpiresAt()
     {
         return $this->expiresAt;
     }
 
-    public function isExpired(): bool
+    /**
+     * Check if expired
+     *
+     * @return bool
+     */
+    public function isExpired()
     {
         if ($this->expiresAt === null) {
             return false;