Updating intercom functionality

application/classes/Ushahidi/Core.php

@@ -74,8 +74,8 @@ public static function init()
 		});
 
 		// Intercom config settings
-		$di->set('site.intercomAppToken', function() use ($di) {
-			return Kohana::$config->load('site.intercomAppToken');
+		$di->set('thirdparty.intercomAppToken', function() use ($di) {
+			return Kohana::$config->load('thirdparty.intercomAppToken');
 		});
 
 		// Roles config settings
@@ -680,18 +680,17 @@ public static function init()
 		// Add Intercom Listener to Config
 		$di->setter['Ushahidi_Repository_Config']['setEvent'] = 'ConfigUpdateEvent';
 		$di->setter['Ushahidi_Repository_Config']['setListener'] =
-			$di->lazyNew('Ushahidi_Listener_IntercomListener');
+			$di->lazyNew('Ushahidi_Listener_IntercomCompanyListener');
 
 		// Add Intercom Listener to Form
 		$di->setter['Ushahidi_Repository_Form']['setEvent'] = 'FormUpdateEvent';
 		$di->setter['Ushahidi_Repository_Form']['setListener'] =
-			$di->lazyNew('Ushahidi_Listener_IntercomListener');
+			$di->lazyNew('Ushahidi_Listener_IntercomCompanyListener');
 
 		// Add Intercom Listener to User
 		$di->setter['Ushahidi_Repository_User']['setEvent'] = 'UserGetAllEvent';
 		$di->setter['Ushahidi_Repository_User']['setListener'] =
-			$di->lazyNew('Ushahidi_Listener_IntercomListener');
-
+			$di->lazyNew('Ushahidi_Listener_IntercomAdminListener');
 
 		/**
 		 * 1. Load the plugins

application/classes/Ushahidi/Listener/IntercomAdminListener.php

@@ -0,0 +1,74 @@
+<?php defined('SYSPATH') or die('No direct script access');
+
+/**
+ * Ushahidi Intercom Listener
+ *
+ * Listens for new posts that are added to a set
+ *
+ * @author     Ushahidi Team <team@ushahidi.com>
+ * @package    Ushahidi\Application
+ * @copyright  2014 Ushahidi
+ * @license    https://www.gnu.org/licenses/agpl-3.0.html GNU Affero General Public License Version 3 (AGPL3)
+ */
+
+use League\Event\AbstractListener;
+use League\Event\EventInterface;
+
+use Intercom\IntercomClient;
+
+use GuzzleHttp\Exception\ClientException;
+
+class Ushahidi_Listener_IntercomAdminListener extends AbstractListener
+{
+
+  public function handle(EventInterface $event, $user = null)
+  {
+
+    $config = service('repository.config')->get('thirdparty');
+    $domain = Kohana::$config->load('site.client_url');
+
+		$intercomAppToken = $config->intercomAppToken;
+    $company = [
+      "id" => $config->intercomCompanyId
+    ];
+
+		if ($user && $config->intercomAppToken) {
+      $client = new IntercomClient($config->intercomAppToken, null);
+
+			try {
+        // Get Company if it already exists, if not create it
+        if (!$config->intercomCompanyId) {
+
+          $site_name = Kohana::$config->load('site.name') ?: 'Ushahidi';
+          $created = date("Y-m-d H:i:s");
+
+          $company = $client->companies->create([
+            "company_id" => $domain,
+            "name" => $site_name,
+            "custom_attributes" => [
+              "created" => $created
+            ]
+          ]);
+
+          $config->intercomCompanyId = $company->id;
+          service('repository.config')->update($config);
+        }
+
+				$client->users->update([
+					"email" => $user->email,
+          "created_at" => $user->created,
+          "user_id" => $domain . '_' . $user->id,
+          "realname" => $user->realname,
+          "last_login" => $user->last_login,
+          "role" => $user->role,
+          "language" => $user->language,
+          "companies" => [
+            $company
+          ]
+				]);
+			} catch(ClientException $e) {
+				Kohana::$log->add(Log::ERROR, print_r($e,true));
+			}
+		}
+  }
+}

application/classes/Ushahidi/Listener/IntercomCompanyListener.php

@@ -0,0 +1,65 @@
+<?php defined('SYSPATH') or die('No direct script access');
+
+/**
+ * Ushahidi Intercom Listener
+ *
+ * Listens for new posts that are added to a set
+ *
+ * @author     Ushahidi Team <team@ushahidi.com>
+ * @package    Ushahidi\Application
+ * @copyright  2014 Ushahidi
+ * @license    https://www.gnu.org/licenses/agpl-3.0.html GNU Affero General Public License Version 3 (AGPL3)
+ */
+
+use League\Event\AbstractListener;
+use League\Event\EventInterface;
+
+use Intercom\IntercomClient;
+
+use GuzzleHttp\Exception\ClientException;
+
+class Ushahidi_Listener_IntercomCompanyListener extends AbstractListener
+{
+  protected $config_repo;
+
+  public function setConfigRepo(ConfigRepository $config_repo)
+  {
+  		$this->config_repo = $config_repo;
+  }
+
+  public function handle(EventInterface $event, $data = null)
+  {
+
+    $config = service('repository.config')->get('thirdparty');
+    $company = [
+      "company_id" => $config->intercomCompanyId
+    ];
+
+    Kohana::$log->add(Log::ERROR, print_r($config));
+
+		if ($config->intercomAppToken) {
+
+      $client = new IntercomClient($config->intercomAppToken, null);
+
+			try {
+        // Create company with current date if it does not already exist
+        if (!$config->intercomCompanyId) {
+          $company->name = Kohana::$config->load('site.name') ?: 'Ushahidi';
+          $config->intercomCompanyId = Kohana::$config->load('site.client_url');
+
+          service('repository.config')->update($config);
+          $company->company_id = $config->intercomCompanyId;
+
+          $data['created'] = date("Y-m-d H:i:s");
+        }
+
+        $company->custom_attributes = $data;
+        // Update company
+        $client->companies->create($company);
+
+			} catch(ClientException $e) {
+				Kohana::$log->add(Log::ERROR, print_r($e,true));
+			}
+		}
+  }
+}

application/classes/Ushahidi/Repository/Config.php

@@ -97,8 +97,7 @@ public function update(Entity $entity)
 		}
 
 		if ($intercom_data) {
-			$user = service('session.user');
-			$this->emit($this->event, $user->email, $intercom_data);
+			$this->emit($this->event, $intercom_data);
 		}
 	}
 
@@ -160,4 +159,3 @@ public function all(Array $groups = null)
 		return $result;
 	}
 }
-

application/classes/Ushahidi/Repository/Form.php

@@ -87,8 +87,7 @@ public function update(Entity $entity)
         // If orignal Form update Intercom if Name changed
         if ($entity->id === 1) {
           foreach ($entity->getChanged() as $key => $val) {
-            $user = service('session.user');
-            $key === 'name' ? $this->emit($this->event, $user->email, ['primary_survey_name' => $val]) : null;
+            $key === 'name' ? $this->emit($this->event, ['primary_survey_name' => $val]) : null;
           }
         }
 

application/classes/Ushahidi/Repository/User.php

@@ -64,7 +64,11 @@ public function create(Entity $entity)
 			'created'  => time(),
 			'password' => $this->hasher->hash($entity->password),
 		];
-		return parent::create($entity->setState($state));
+		$entity->setState($state);
+		if ($entity->role === 'admin') {
+				$this->updateIntercomAdminUsers($entity);
+		}
+		return parent::create($entity);
 	}
 
 	// CreateRepository
@@ -73,8 +77,12 @@ public function createWithHash(Entity $entity)
 		$state = [
 			'created'  => time()
 		];
+		$entity->setState($state);
+		if ($entity->role === 'admin') {
+				$this->updateIntercomAdminUsers($state);
+		}
 
-		return parent::create($entity->setState($state));
+		return parent::create($entity);
 	}
 
 	// UpdateRepository
@@ -139,8 +147,6 @@ public function isUniqueEmail($email)
 	public function register(Entity $entity)
 	{
 
-		$this->updateIntercomUserCount(1);
-
 		return $this->executeInsert([
 			'realname' => $entity->realname,
 			'email'    => $entity->email,
@@ -213,7 +219,9 @@ public function getTotalCount(Array $where = [])
 
 	// DeleteRepository
 	public function delete(Entity $entity) {
-		$this->updateIntercomUserCount(-1);
+		if ($entity->role === 'admin') {
+				$this->updateIntercomAdminUsers($entity);
+		}
 		return parent::delete($entity);
 	}
 
@@ -223,12 +231,8 @@ public function delete(Entity $entity) {
 	 * @param Integer $offset
 	 * @return void
 	 */
-	protected function updateIntercomUserCount($offset)
+	protected function updateIntercomAdminUsers($user)
 	{
-		$data = [
-			'total_users' => $this->getTotalCount() + $offset
-		];
-		$user = service('session.user');
-		$this->emit($this->event, $user->email, $data);
+		$this->emit($this->event, $user);
 	}
 }

application/config/site.php

@@ -22,7 +22,6 @@
  * - string   date_format   Set format in which to return dates. See http://php.net/manual/en/datetime.createfromformat.php
  */
 
-$intercomAppToken = getenv('INTERCOM_APP_TOKEN');
 
 $clientUrl = getenv('CLIENT_URL');
 
@@ -46,5 +45,4 @@
 	'first_login'   => true,
 	'tier'          => 'free',
 	'private'       => false,
-	'intercomAppToken' => $intercomAppToken,
 );

application/config/thirdparty.php

@@ -0,0 +1,30 @@
+  <?php defined('SYSPATH') OR die('No direct access allowed.');
+
+/**
+ * Kohana Site Config
+ *
+ * @author     Ushahidi Team <team@ushahidi.com>
+ * @package    Ushahidi\Application\Config
+ * @copyright  2013 Ushahidi
+ * @license    https://www.gnu.org/licenses/agpl-3.0.html GNU Affero General Public License Version 3 (AGPL3)
+ */
+
+/**
+ * Site settings
+ *
+ * The following options are available:
+ *
+ * - string   name          Display name of the site.
+ * - string   description   A brief description of the site.
+ * - string   email         Site contact email.
+ * - string   timezone      Default timezone for the site. See http://php.net/manual/en/timezones.php
+ * - string   language      Native language for the site in ISO 639-1 format. See http://en.wikipedia.org/wiki/ISO_639-1
+ * - string   date_format   Set format in which to return dates. See http://php.net/manual/en/datetime.createfromformat.php
+ */
+
+$intercomAppToken = getenv('INTERCOM_APP_TOKEN');
+
+return array(
+  'intercomCompanyId' => null
+	'intercomAppToken' => $intercomAppToken,
+);