Sync messages instantly and Credis support through composer

Author: remdex

nodejshelper/.gitignore

@@ -2,4 +2,5 @@ node_modules
 serversc/lhc/node_modules
 serversc/lhc/node_modules
 settings/settings.ini.php
-package-lock.json
+package-lock.json
+composer.lock

nodejshelper/bootstrap/bootstrap.php

@@ -12,6 +12,16 @@ public function run() {
 
         $dispatcher = erLhcoreClassChatEventDispatcher::getInstance();
         $dispatcher->listen('onlineuser.proactive_send_invitation',array($this,'proactiveInvitationSend'));
+
+        $dispatcher->listen('chat.messages_added_fb', array($this,'messageReceived'));
+        $dispatcher->listen('chat.addmsguser', array( $this, 'messageReceived' ));
+        $dispatcher->listen('telegram.msg_received', array( $this, 'messageReceived' ));
+        $dispatcher->listen('twilio.sms_received', array( $this,'messageReceived' ));
+        $dispatcher->listen('chat.web_add_msg_admin', array( $this,'messageReceived' ));
+
+        // Chat was accepted.
+        $dispatcher->listen('chat.accept', array( $this,'statusChange' ));
+        $dispatcher->listen('chat.close', array( $this,'statusChange' ));
 	}
 
     public function __get($var)
@@ -59,6 +69,8 @@ public function getSettingVariable($var) {
 
     public function registerAutoload()
     {
+        include 'extension/nodejshelper/vendor/autoload.php';
+        
         spl_autoload_register(array(
             $this,
             'autoload'
@@ -81,6 +93,18 @@ public function proactiveInvitationSend($params)
         erLhcoreClassNodeJSRedis::instance()->publish('uo_' . $params['ou']->vid,'o:' . json_encode(array('op' => 'check_message')));
         //erLhcoreClassNodeJSRedis::instance()->publish('sample','o:' . json_encode(array('op' => 'check_message')));
     }
+    
+	public function messageReceived($params)
+    {
+        erLhcoreClassNodeJSRedis::instance()->publish('chat_' . $params['chat']->id,'o:' . json_encode(array('op' => 'cmsg')));
+    }
+
+	public function statusChange($params)
+    {
+        erLhcoreClassNodeJSRedis::instance()->publish('chat_' . $params['chat']->id,'o:' . json_encode(array('op' => 'schange')));
+    }
+
+
 }
 
 

nodejshelper/composer.json

@@ -0,0 +1,24 @@
+{
+    "name": "livehelperchat/nodejs",
+    "version": "1.0",
+    "description": "NodeJS support for Live Helper Chat",
+    "type": "project",
+    "homepage": "http://ivehelperchat.com",
+    "license": "Apache-2.0",
+    "authors": [
+        {
+            "name": "Live helper Chat",
+            "homepage": "http://ivehelperchat.com"
+        }
+    ],
+    "support": {
+        "email": "remdex@mgmail.com"      
+    },
+    "require": {       
+        "colinmollenhour/credis": "dev-master#215d287d49c4f2d97d6711e241e6478363cdf67a"
+    },
+    "minimum-stability": "dev",       
+    "config": {
+        "vendor-dir": "vendor"
+    }
+}

nodejshelper/design/nodejshelpertheme/js/customjs-admin.js

@@ -39,6 +39,8 @@ var channelList = [];
                         typingIndicator.text(op.msg).css('visibility','visible');
                     } else if (op.op == 'vts') { // Visitor typing stopped
                         typingIndicator.text(op.msg).css('visibility','hidden');
+                    } else if (op.op == 'cmsg') { // Visitor has send a message
+                        lhinst.syncadmincall();
                     }
                 });
             }
@@ -80,6 +82,8 @@ var channelList = [];
             ee.removeListener('operatorTyping', operatorTypingListener);
             ee.removeListener('removeSynchroChat', removeSynchroChatListener);
 
+            confLH.chat_message_sinterval = confLH.defaut_chat_message_sinterval;
+
         } catch (e) {
             console.log(e);
         }
@@ -97,6 +101,8 @@ var channelList = [];
             ee.addListener('chatTabLoaded', addChatToNodeJS);
             ee.addListener('operatorTyping', operatorTypingListener);
             ee.addListener('removeSynchroChat', removeSynchroChatListener);
+            
+            confLH.chat_message_sinterval = 15000;
         } catch (e) {
             console.log(e);
         }

nodejshelper/design/nodejshelpertheme/js/customjs-widget.js

@@ -41,6 +41,8 @@
 
         ee.removeListener('visitorTyping', visitorTypingListener);
         ee.removeListener('visitorTypingStopped', visitorTypingStoppedListener);
+
+        confLH.chat_message_sinterval = confLH.defaut_chat_message_sinterval;
     });
 
     socket.on('connect', function () {
@@ -61,6 +63,11 @@
                     } else {
                         instStatus.css('visibility','hidden');
                     }
+                } else if (op.op == 'cmsg') {
+                    lhinst.syncusercall();
+                } else if (op.op == 'schange') {
+                    lhinst.chatsyncuserpending();
+                    lhinst.syncusercall();
                 }
             });
 
@@ -69,6 +76,9 @@
 
             ee.addListener('visitorTyping', visitorTypingListener);
             ee.addListener('visitorTypingStopped', visitorTypingStoppedListener);
+
+            // Make larger sync interval
+            confLH.chat_message_sinterval = 15000;
         };
     });
 

nodejshelper/design/nodejshelpertheme/js/nodejshelper.admin.min.js

@@ -12,7 +12,7 @@
             'port':'<?php echo erLhcoreClassModule::getExtensionInstance('erLhcoreClassExtensionNodejshelper')->getSettingVariable('port')?>',
             'secure':'<?php echo erLhcoreClassModule::getExtensionInstance('erLhcoreClassExtensionNodejshelper')->getSettingVariable('secure')?>'
         };
-
+        confLH.defaut_chat_message_sinterval = confLH.chat_message_sinterval;
         <?php if (erLhcoreClassSystem::instance()->SiteAccess == 'site_admin' && erLhcoreClassUser::instance()->isLogged()) :
         $currentUser = erLhcoreClassUser::instance();
         $userData = $currentUser->getUserData(true); ?>

nodejshelper/design/nodejshelpertheme/js/nodejshelper.widget.min.js

@@ -14,6 +14,7 @@
     'port':'<?php echo erLhcoreClassModule::getExtensionInstance('erLhcoreClassExtensionNodejshelper')->getSettingVariable('port')?>',
     'secure':'<?php echo erLhcoreClassModule::getExtensionInstance('erLhcoreClassExtensionNodejshelper')->getSettingVariable('secure')?>',
 };
+confLH.defaut_chat_message_sinterval = confLH.chat_message_sinterval;
 </script>
 <script src="<?php echo erLhcoreClassDesign::designJS('js/nodejshelper.widget.min.js');?>"></script>
 <?php endif; ?>