Completed people & event producers.

src/Producers/Event.php

@@ -2,33 +2,47 @@
 
 namespace Mintance\Producers;
 
+use Mintance\Exceptions\Exception;
+
 class Event extends AbstractProducer {
 
 	public function track($name, array $params = []) {
+		$response = $this->_push($this->_buildEvent($name, 'custom-event', $params));
 
-		$event = $this->_buildEvent($name, 'custom-event', $params);
-
-		$this->_push($event);
+		if(!empty($response['event_id'])) {
+			return $response['event_id'];
+		} else {
+			throw new Exception('Event sending error.');
+		}
 	}
 
 	public function charge($amount, array $params = []) {
 
-		$event = $this->_buildEvent('Charge', 'charge', array_merge($params, [
+		$response = $this->_push($this->_buildEvent('Charge', 'charge', array_merge($params, [
 			'value' => $amount
-		]));
+		])));
 
-		$this->_push($event);
+		if(!empty($response['charge_id'])) {
+			return $response['charge_id'];
+		} else {
+			throw new Exception('Charge sending error.');
+		}
 	}
 
 	public function formSubmit(array $data) {
-		$event = array_merge(
+
+		$response = $this->_push(array_merge(
 			$this->_buildEvent('Form Submit', 'form-submit'),
 			[
 				'form_data' => $data
 			]
-		);
+		));
 
-		$this->_push($event);
+		if(!empty($response['event_id'])) {
+			return $response['event_id'];
+		} else {
+			throw new Exception('Charge sending error.');
+		}
 	}
 
 	protected function _buildEvent($name, $type, array $params = []) {
@@ -42,6 +56,6 @@ protected function _buildEvent($name, $type, array $params = []) {
 	protected function _push(array $event) {
 		$this->_transport->setEndpoint('events');
 
-		$this->_transport->execute($event);
+		return $this->_transport->execute($event);
 	}
 }

src/Producers/People.php

@@ -2,6 +2,7 @@
 
 namespace Mintance\Producers;
 
+use Mintance\Exceptions\Exception;
 use Mintance\Transport\AbstractTransport;
 
 class People extends AbstractProducer {
@@ -12,10 +13,16 @@ class People extends AbstractProducer {
 
 	protected $_people_id;
 
+	protected $_identifier;
+
 	protected $_type = 'visitor';
 
 	protected $_people = [];
 
+	protected $_default_fields = [
+		'name', 'first_name', 'last_name', 'email', 'phone'
+	];
+
 	public function __construct(AbstractTransport $transport) {
 		parent::__construct($transport);
 
@@ -24,16 +31,53 @@ public function __construct(AbstractTransport $transport) {
 		$this->_subscribe();
 	}
 
-	public function identify($identifier) {
+	public function setIdentifier($identifier) {
 
+		$this->_identifier = $identifier;
+
+		$this->_transport->register('execute:before', function (&$args) {
+			if(empty($this->_people_id)) {
+				$args['mintance_identifier'] = $this->_identifier;
+			}
+		});
 	}
 
-	public function set(array $args) {
+	public function identify($identifier) {
+
+		if(!empty($this->_people_id)) {
+			return $this->_people_id;
+		}
+
+		if(empty($this->_visitor_id)) {
+			throw new Exception('Empty visitor_id.');
+		}
 
+		$this->_transport->setEndpoint('people/identify');
+
+		$response = $this->_transport->execute([
+			'visitor_id' => $this->_visitor_id,
+			'identifier' => $identifier
+		]);
+
+		$this->_people = $response['people'];
+
+		$this->_type = 'people';
+
+		return $this->_people_id = $response['people_id'];
 	}
 
-	public function __set($key, $value) {
-		// TODO: Implement __set() method.
+	public function set(array $args) {
+		$data = [
+			'fields' => []
+		];
+
+		foreach ($args as $key => $value) {
+			if(in_array($key, $this->_default_fields)) {
+				$data[$key] = $value;
+			} else {
+				$data['fields'][$key] = $value;
+			}
+		}
 	}
 
 	public function get() {
@@ -44,10 +88,6 @@ public function get() {
 		]);
 	}
 
-	public function __get($key) {
-		// TODO: Implement __get() method.
-	}
-
 	protected function _subscribe() {
 		$this->_transport->register('execute:before', function (&$args) {
 			if(!empty($this->_people_id)) {