Add pusher integration.

app/templates/client/app/index.html

@@ -70,6 +70,8 @@ <h3>Login with demo / 1234</h3>
     <script src="bower_components/angular-ui-router/release/angular-ui-router.js"></script>
     <script src="bower_components/angular-local-storage/dist/angular-local-storage.js"></script>
     <script src="bower_components/angular-loading-bar/build/loading-bar.js"></script>
+    <script src="bower_components/pusher-angular/lib/pusher-angular.js"></script>
+    <script src="bower_components/pusher/dist/pusher.js"></script>
     <!-- endbower -->
     <!-- endbuild -->
 
@@ -87,6 +89,7 @@ <h3>Login with demo / 1234</h3>
         <script src="scripts/services/companies.js"></script>
         <script src="scripts/services/map.js"></script>
         <script src="scripts/services/marker.js"></script>
+        <script src="scripts/services/pusher.js"></script>
         <script src="scripts/controllers/dashboard.js"></script>
         <script src="scripts/directives/spinner.js"></script>
         <script src="scripts/directives/loadingbartext.js"></script>

app/templates/client/app/scripts/app.js

@@ -16,6 +16,7 @@ angular
     'config',
     'leaflet-directive',
     'LocalStorageModule',
+    'pusher-angular',
     'ui.router',
     'angular-loading-bar'
   ])

app/templates/client/app/scripts/controllers/events.js

@@ -8,7 +8,7 @@
  * Controller of the clientApp
  */
 angular.module('clientApp')
-  .controller('EventsCtrl', function ($scope, events, authors, mapConfig, $state, $stateParams, $log) {
+  .controller('EventsCtrl', function ($scope, events, authors, mapConfig, Events, $state, $stateParams, channelManager, $log) {
 
     // Initialize values.
     $scope.events = events;
@@ -44,6 +44,20 @@ angular.module('clientApp')
       selectedAuthorId($stateParams.userId);
     }
 
+    // Get list of chanels.
+    var channels = channelManager.getChannels();
+    angular.forEach(channels, function(channel, companyId) {
+      // Listen to event.
+      channel.bind('new-event', function(data) {
+        Events.get(companyId, data.userId).then(function(value) {
+          // Update events list of the company.
+          $scope.events = angular.extend($scope.events, value);
+          // Update user's events count.
+          $scope.authors[data.userId].count = Object.keys(value).length;
+        });
+      });
+    });
+
     // Select marker in the Map.
     $scope.$on('leafletDirectiveMarker.click', function(event, args) {
       var stateName = $stateParams.userId ? 'dashboard.byCompany.byUser.events.event' : 'dashboard.byCompany.events.event';

app/templates/client/app/scripts/services/account.js

@@ -8,7 +8,7 @@
  * Service in the clientApp.
  */
 angular.module('clientApp')
-  .service('Account', function ($q, $http, $timeout, Config, $rootScope, $log) {
+  .service('Account', function ($q, $http, $timeout, Config, $rootScope, channelManager, $log) {
 
     // A private cache key.
     var cache = {};
@@ -37,6 +37,7 @@ angular.module('clientApp')
         transformResponse: prepareResponse
       }).success(function(response) {
         setCache(response[0]);
+        setChannels(response[0].companies);
         deferred.resolve(response[0]);
       });
 
@@ -97,4 +98,24 @@ angular.module('clientApp')
       cache = {};
     });
 
+    /**
+     * Subscribe user to user's Pusher channel.
+     *
+     * @param int userId
+     *   The user id.
+     */
+    var setChannels = function(companies) {
+      if (!companies) {
+        // User doesn't have repositories yet.
+        return;
+      }
+
+      companies.forEach(function (company) {
+        if (!company.id) {
+          // repoId is null.
+          return;
+        }
+        channelManager.addChannel(company.id);
+      });
+    };
   });

app/templates/client/app/scripts/services/auth.js

@@ -51,6 +51,13 @@ angular.module('clientApp')
       return !!localStorageService.get('access_token');
     };
 
+    /**
+     * Returns access token.
+     */
+    this.getAccessToken = function() {
+      return localStorageService.get('access_token');
+    };
+
     /**
      * Authentication failed, set state to login.
      */

app/templates/client/app/scripts/services/pusher.js

@@ -0,0 +1,77 @@
+'use strict';
+
+/**
+ * @ngdoc service
+ * @name clientApp.account
+ * @description
+ * # account
+ * Service in the clientApp.
+ */
+angular.module('clientApp')
+  .service('channelManager', function ($q, $http, $timeout, $pusher, $log, Config, Auth) {
+
+    var channels = {};
+
+
+    this.pusher = null;
+
+    /**
+     * Get all pusher channels.
+     *
+     * @returns {{}}
+     *  Return list of existing channels.
+     */
+    this.getChannels =  function () {
+      return channels;
+    };
+
+    /**
+     * Get Company channel.
+     *
+     * @param companyId
+     *  Company id.
+     *
+     * @returns {*}
+     *  Return company's channel.
+     */
+    this.getChannel =  function (companyId) {
+      return (companyId in channels) ? channels[companyId] : null;
+    };
+
+    /**
+     * Add new company's chanel.
+     *
+     * @param companyId
+     *  User id.
+     *
+     * @returns {*}
+     *  Return new company's channel.
+     */
+    this.addChannel = function (companyId) {
+      if (!!channels[companyId]) {
+        // Already subscribed to channel.
+        return;
+      }
+      var pusher = $pusher(this.getClient());
+      channels[companyId] = pusher.subscribe('private-company-' + companyId);
+      return channels[companyId];
+    };
+
+    this.getClient = function() {
+      return this.pusher ? this.pusher : this.createNewPusher();
+    };
+
+    this.createNewPusher = function() {
+      var pusherConf = {
+        authEndpoint: Config.backend + '/api/v1.0/pusher_auth',
+        auth: {
+          headers: {
+            "access-token": Auth.getAccessToken()
+          }
+        }
+      };
+      this.pusher = new Pusher(Config.pusherKey, pusherConf);
+      return this.pusher;
+    };
+
+  });

app/templates/client/bower.json

@@ -12,7 +12,9 @@
     "angular-leaflet-directive": "~0.7.9",
     "angular-ui-router": "~0.2.13",
     "angular-local-storage": "~0.1.5",
-    "angular-loading-bar": "~0.6.0"
+    "angular-loading-bar": "~0.6.0",
+    "pusher-angular": "~0.1.5",
+    "pusher": "~2.2.4"
   },
   "devDependencies": {
     "angular-mocks": "~1.3.0",

app/templates/default.config.sh

@@ -68,10 +68,21 @@ MYSQL_DB_NAME="skeleton"
 ##
 
 # Post install script.
-# function post_install {}
+#function post_install {
+#  chmod 777 www/sites/default/settings.php
+#
+#  # Pusher integration.
+#  echo "\$conf['skeleton_pusher_app_key'] = '<your-app-key>';"  >> www/sites/default/settings.php
+#  echo "\$conf['skeleton_pusher_app_secret'] = '<your-app-secret>';"  >> www/sites/default/settings.php
+#  echo "\$conf['skeleton_pusher_app_id'] = '<your-app-id>';"  >> www/sites/default/settings.php
+#}
 
 # Post upgrade script.
-# function post_upgrade {}
+#function post_upgrade {
+#  post_install
+#}
 
 # Post reset script.
-# function post_reset {}
+#function post_reset {
+#  post_install
+#}

app/templates/install

@@ -137,6 +137,9 @@ symlink_externals
 # Install the Drupal profile as defined in the config.sh file.
 install_drupal_profile
 
+# Composer install
+composer_install
+
 # Setup the files directory.
 create_sites_default_files_directory
 

app/templates/scripts/helper-functions.sh

@@ -187,6 +187,18 @@ function install_drupal_profile {
   cd $ROOT
 }
 
+##
+# Composer install.
+##
+function composer_install {
+  echo -e "${LBLUE}> Composer install${RESTORE}"
+
+  cd $ROOT/www/sites/default/files/composer
+  composer install
+  echo
+
+  cd $ROOT
+}
 
 ##
 # Create (if not exists) and set the proper file permissions

app/templates/scripts/reset

@@ -142,6 +142,9 @@ delete_sites_default_content
 # Install the installation profile.
 install_drupal_profile
 
+# Composer install
+composer_install
+
 # Setup the files directory.
 create_sites_default_files_directory
 

app/templates/skeleton/drupal-org.make

@@ -8,6 +8,9 @@ projects[admin_menu][version] = "3.0-rc5"
 projects[admin_views][subdir] = "contrib"
 projects[admin_views][version] = "1.4"
 
+projects[composer_manager][subdir] = "contrib"
+projects[composer_manager][version] = "1.7"
+
 projects[ctools][subdir] = "contrib"
 projects[ctools][version] = "1.7"
 
@@ -105,4 +108,4 @@ projects[migrate][subdir] = "development"
 projects[migrate][version] = "2.7"
 
 projects[migrate_extras][subdir] = "development"
-projects[migrate_extras][version] = 2.5
+projects[migrate_extras][version] = 2.5

app/templates/skeleton/modules/custom/skeleton_event/skeleton_event.module

@@ -5,3 +5,20 @@
  */
 
 include_once 'skeleton_event.features.inc';
+
+/**
+ * Implement hook_node_insert().
+ */
+function skeleton_event_node_insert($node) {
+  if ($node->type != 'event') {
+    return;
+  }
+  $wrapper = entity_metadata_wrapper('node', $node);
+  $company_id = $wrapper->{OG_AUDIENCE_FIELD}->value(array('identifier' => TRUE));
+
+  $data = array(
+    'userId' => $node->uid,
+  );
+
+  skeleton_pusher_trigger_event($company_id, 'new-event', $data);
+}

app/templates/skeleton/modules/custom/skeleton_pusher/composer.json

@@ -0,0 +1,5 @@
+{
+  "require": {
+    "pusher/pusher-php-server": "2.2"
+  }
+}

app/templates/skeleton/modules/custom/skeleton_pusher/skeleton_pusher.info

@@ -0,0 +1,4 @@
+name = Skeleton Pusher
+core = 7.x
+package = Skeleton
+dependencies[] = composer_manager

app/templates/skeleton/modules/custom/skeleton_pusher/skeleton_pusher.module

@@ -0,0 +1,51 @@
+<?php
+/**
+ * @file
+ * Code for the Pusher API integration.
+ */
+
+
+/**
+ * Trigger a Pusher event.
+ *
+ * @param $company_id
+ *  Company ID.
+ * @param $event_name
+ *  Event name.
+ * @param array $data
+ *  Parameters that should be sent.
+ *
+ * @throws \PusherException
+ * @throws \RestfulServerConfigurationException
+ *
+ * @return bool
+ */
+function skeleton_pusher_trigger_event($company_id, $event_name, $data = array()) {
+  $pusher = skeleton_pusher_get_pusher();
+  return $pusher->trigger('private-company-' . $company_id, $event_name, $data);
+}
+
+/**
+ * Get a Pusher instance.
+ *
+ * @return \Pusher
+ *   The Pusher object.
+ *
+ * @throws \RestfulServerConfigurationException
+ */
+function skeleton_pusher_get_pusher() {
+  $pusher = &drupal_static(__FUNCTION__);
+  if ($pusher) {
+    return $pusher;
+  }
+
+  $app_key = variable_get('skeleton_pusher_app_key');
+  $app_secret = variable_get('skeleton_pusher_app_secret');
+  $app_id = variable_get('skeleton_pusher_app_id');
+
+  if (empty($app_key) || empty($app_secret) || empty($app_id)) {
+    throw new \RestfulServerConfigurationException('Pusher app is not configured properly.');
+  }
+
+  return new Pusher($app_key, $app_secret, $app_id);
+}