add Automation360

Author: bilovol

README.md

@@ -1,15 +1,19 @@
 # SendPulse REST client library
+
 A simple SendPulse REST client library and example for PHP.
 
 API Documentation [https://sendpulse.com/api](https://sendpulse.com/api)
 
 ### Installing
+
 Via Composer:
+
 ```bash
 composer require sendpulse/rest-api
 ```
 
 ### Usage
+
 ```php
 <?php
 require 'vendor/autoload.php';
@@ -111,3 +115,28 @@ $additionalParams = array(
 var_dump($SPApiClient->createPushTask($task, $additionalParams));
 ```
 
+### Usage Automation360
+
+```php
+<?php
+
+require 'vendor/autoload.php';
+
+use Sendpulse\RestApi\Automation360;
+
+// https://login.sendpulse.com/emailservice/events/
+$eventHash = 'EVENT_HASH';
+$email = '[email protected]';
+$phone = '380931112233';
+$variables = [
+    'user_id' => 123123,
+    'event_date' => date('Y-m-d'),
+    'firstname' => 'Name',
+    'lastname' => 'Family',
+    'age' => 23
+];
+$automationClient =  new Automation360($eventHash);
+$result = $automationClient->sendEventToSendpulse($email, $phone, $variables);
+
+var_dump($result);
+```

example/index.php

@@ -13,6 +13,7 @@
 
 use Sendpulse\RestApi\ApiClient;
 use Sendpulse\RestApi\Storage\FileStorage;
+use Sendpulse\RestApi\Automation360;
 
 define('API_USER_ID', '');
 define('API_SECRET', '');
@@ -163,4 +164,22 @@
 var_dump($SPApiClient->getSmsCampaignCost($params));
 
 // Delete sms campaign
-var_dump($SPApiClient->deleteSmsCampaign(CAMPAIGN_ID));
+var_dump($SPApiClient->deleteSmsCampaign(CAMPAIGN_ID));
+
+
+// Send event
+$eventHash = 'EVENT_HASH';
+$email = '[email protected]';
+$phone = '380931112233';
+$variables = [
+    'user_id' => 123123,
+    'event_date' => date('Y-m-d'),
+    'firstname' => 'Name',
+    'lastname' => 'Family',
+    'age' => 23
+];
+
+$automationClient =  new Automation360($eventHash);
+$result = $automationClient->sendEventToSendpulse($email, $phone, $variables);
+
+var_dump($result);

src/Automation360.php

@@ -0,0 +1,88 @@
+<?php
+
+namespace Sendpulse\RestApi;
+
+use Exception;
+
+class Automation360
+{
+    /**
+     * @var string
+     */
+    private $eventHash;
+    /**
+     * @var string
+     */
+    private $eventDomain = 'https://events.sendpulse.com/events/id/';
+
+    /**
+     * Automation360 constructor.
+     * @param string $eventHash
+     * @throws Exception
+     */
+    public function __construct($eventHash)
+    {
+        if (!$eventHash) {
+            throw new Exception('Invalid parameter $eventHash', 500);
+        }
+        $this->eventHash = $eventHash;
+    }
+
+    /**
+     * One of the variables $email or $phone
+     * must necessarily contain the correct value
+     *
+     * @param null|string $email
+     * @param null|string $phone
+     * @param array $variables
+     * @return array
+     * @throws Exception
+     */
+    public function sendEventToSendpulse($email = null, $phone = null, array $variables = [])
+    {
+        if (!$email && !$phone) {
+            throw new \Exception('Variables $email and $phone is empty', 500);
+        }
+        if ($email) {
+            $variables['email'] = $email;
+        }
+        if ($phone) {
+            $variables['phone'] = $phone;
+        }
+        return $this->sendRequest($variables);
+    }
+
+    /**
+     * Send request to SendPulse with CURL
+     *
+     * @param array $variables
+     * @return array
+     */
+    private function sendRequest(array $variables)
+    {
+        $url = $this->eventDomain . $this->eventHash;
+
+        $curl = curl_init();
+        curl_setopt($curl, CURLOPT_POST, count($variables));
+        curl_setopt($curl, CURLOPT_POSTFIELDS, http_build_query($variables));
+        curl_setopt($curl, CURLOPT_URL, $url);
+        curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
+        curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
+        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
+        curl_setopt($curl, CURLOPT_HEADER, true);
+        curl_setopt($curl, CURLOPT_CONNECTTIMEOUT, 15);
+        curl_setopt($curl, CURLOPT_TIMEOUT, 15);
+        $response = curl_exec($curl);
+        $header_size = curl_getinfo($curl, CURLINFO_HEADER_SIZE);
+        $headerCode = curl_getinfo($curl, CURLINFO_HTTP_CODE);
+        $responseBody = substr($response, $header_size);
+        curl_close($curl);
+
+        $result = [
+            'http_code' => $headerCode,
+            'data' => json_decode($responseBody, true)
+        ];
+
+        return $result;
+    }
+}