��ѧۧݧ�ӧ�� ާ֧ߧ֧էا֧�

��ѧۧݧ�ӧ�� ާ֧ߧ֧էا֧� - ��֧էѧܧ�ڧ��ӧѧ�� - /home/alphpwcp/public_html/us/alphachat/lib/core/lhxmp/lhxmp.php

��ѧ٧ѧ�
<?php class erLhcoreClassXMP { public static function sendTestXMP($userData) { $data = (array) erLhcoreClassModelChatConfig::fetch('xmp_data')->data; $templateMessage = 'xmp_message'; $conn = new XMPPHP_XMPP($data['host'], $data['port'], $data['username'], $data['password'], $data['resource'], $data['server'], $printlog = false, $loglevel = XMPPHP_Log::LEVEL_INFO); try { $conn->connect(); $conn->processUntil('session_start'); if (isset($data['test_group_recipients']) && $data['test_group_recipients'] != '') { $recipientsGroup = explode(',',$data['test_group_recipients']); foreach ($recipientsGroup as $groupRecipient) { $conn->presence(NULL, "available", $groupRecipient); } foreach ($recipientsGroup as $groupRecipient) { list($groupName) = explode('/',$groupRecipient); $conn->message($groupName, $data[$templateMessage], "groupchat"); } foreach ($recipientsGroup as $groupRecipient) { $conn->presence(NULL, "unavailable", $groupRecipient); } } if (isset($data['test_recipients']) && $data['test_recipients'] != '') { $recipientsUsers = explode(',',$data['test_recipients']); $conn->presence(); foreach ($recipientsUsers as $recipientsUser) { $conn->message($recipientsUser, $data[$templateMessage]); } } $conn->disconnect(); return true; } catch (Exception $e) { throw $e; } } public static function getAccessToken() { $xmpData = erLhcoreClassModelChatConfig::fetch('xmp_data'); $data = (array)$xmpData->data; if (isset($data['gtalk_client_token']) && $data['gtalk_client_token'] != '') { try { require_once 'lib/core/lhxmp/google/Google_Client.php'; $client = new Google_Client(); $client->setApplicationName('Live Helper Chat'); $client->setScopes(array("https://www.googleapis.com/auth/googletalk","https://www.googleapis.com/auth/userinfo.email")); $client->setClientId($data['gtalk_client_id']); $client->setClientSecret($data['gtalk_client_secret']); $client->setApprovalPrompt('force'); $client->setAccessType('offline'); $token = $data['gtalk_client_token']; $client->setAccessToken($data['gtalk_client_token']); // Refresh token if it's if ( $client->isAccessTokenExpired() ) { $tokenData = json_decode($token); $client->refreshToken($tokenData->refresh_token); $accessToken = $client->getAccessToken(); $data['gtalk_client_token'] = $accessToken; $xmpData->value = serialize($data); $xmpData->saveThis(); } if (($accessToken = $client->getAccessToken())) { $tokenData = json_decode($accessToken); return $tokenData->access_token; } } catch (Exception $e) { return false; } } return false; } public static function revokeAccessToken() { $xmpData = erLhcoreClassModelChatConfig::fetch('xmp_data'); $data = (array)$xmpData->data; try { if (isset($data['gtalk_client_token']) && $data['gtalk_client_token'] != '') { require_once 'lib/core/lhxmp/google/Google_Client.php'; $client = new Google_Client(); $client->setApplicationName('Live Helper Chat'); $client->setScopes(array("https://www.googleapis.com/auth/googletalk","https://www.googleapis.com/auth/userinfo.email")); $client->setClientId($data['gtalk_client_id']); $client->setClientSecret($data['gtalk_client_secret']); $client->setAccessType('offline'); $client->setApprovalPrompt('force'); $token = $data['gtalk_client_token']; $client->setAccessToken($data['gtalk_client_token']); // Refresh token if it's if ( $client->isAccessTokenExpired() ) { $tokenData = json_decode($token); $client->refreshToken($tokenData->refresh_token); $accessToken = $client->getAccessToken(); } if (($accessToken = $client->getAccessToken())) { $client->revokeToken(); } unset($data['gtalk_client_token']); $xmpData->value = serialize($data); $xmpData->saveThis(); } return true; } catch (Exception $e) { throw $e; } } public static function get_dns_srv($domain) { $rec = dns_get_record("_xmpp-client._tcp.".$domain, DNS_SRV); if(is_array($rec)) { if(sizeof($rec) == 0) return array($domain, 5222); if(sizeof($rec) > 0) return array($rec[0]['target'], $rec[0]['port']); } } public static function sendTestXMPGTalk($email) { $xmpData = erLhcoreClassModelChatConfig::fetch('xmp_data'); $data = (array)$xmpData->data; if (($accessToken = self::getAccessToken()) !== false) { $dataLogin = self::get_dns_srv('gmail.com'); $conn = new XMPPHP_XMPP($dataLogin[0], $dataLogin[1], $data['email_gtalk'], $accessToken, 'xmpphp', $dataLogin[0], $printlog = false, $loglevel = XMPPHP_Log::LEVEL_INFO, true); try { $conn->connect(); $conn->processUntil('session_start'); $conn->presence(); $conn->message($email, $data['xmp_message']); $conn->disconnect(); return true; } catch (Exception $e) { throw $e; } } else { throw new Exception('Invalid access token'); } } public static function getBaseHost() { if ( (!empty($_SERVER['HTTPS']) && strtolower($_SERVER['HTTPS']) !== 'off') \|\| ((!empty($_SERVER['HTTP_X_FORWARDED_PROTO']) && $_SERVER['HTTP_X_FORWARDED_PROTO'] == 'https') \|\| (!empty($_SERVER['HTTP_X_FORWARDED_SSL']) && $_SERVER['HTTP_X_FORWARDED_SSL'] == 'on'))){ return 'https://'; } return 'http://'; } public static function sendXMPMessage($chat, $params = array()) { $data = (array) erLhcoreClassModelChatConfig::fetch('xmp_data')->data; // Allows extension to override xmpp settings, let say disable it :) erLhcoreClassChatEventDispatcher::getInstance()->dispatch('xml.send_xmp_message',array('params' => & $data)); $templateMessage = 'xmp_message'; if (isset($params['template'])) { $templateMessage = $params['template']; } if (isset($data['use_xmp']) && $data['use_xmp'] == 1) { if ( (isset($data['use_standard_xmp']) && $data['use_standard_xmp'] == '0') \|\| !isset($data['use_standard_xmp']) ) { $conn = new XMPPHP_XMPP($data['host'], $data['port'], $data['username'], $data['password'], $data['resource'], $data['server'], $printlog = false, $loglevel = XMPPHP_Log::LEVEL_INFO); try { $conn->connect(); $conn->processUntil('session_start'); $emailRecipient = array(); // Email messages $groupRecipients = array(); // Group messages if ($chat->department !== false && $chat->department->xmpp_recipients != '') { // Perhaps department has assigned email $emailRecipient = explode(',',$chat->department->xmpp_recipients); } elseif (isset($data['recipients']) && $data['recipients'] != '') { $emailRecipient = explode(',', $data['recipients']); } $settingsXMPPGlobal = isset($params['recipients_setting']) ? $params['recipients_setting'] : 'xmp_users'; $optionsDepartment = array(); if ($chat->department !== false){ $optionsDepartment = $chat->department->inform_options_array; } if (in_array($settingsXMPPGlobal, $optionsDepartment)) { $db = ezcDbInstance::get(); $stmt = $db->prepare("SELECT xmpp_username FROM lh_users WHERE id IN (SELECT user_id FROM lh_userdep WHERE dep_id = 0 OR dep_id = :dep_id) AND xmpp_username != ''"); $stmt->bindValue( ':dep_id',$chat->dep_id,PDO::PARAM_INT); $stmt->execute(); $usersXMPPs = $stmt->fetchAll(PDO::FETCH_COLUMN); if (is_array($usersXMPPs)){ $emailRecipient = array_unique(array_merge($emailRecipient,$usersXMPPs)); } } if ($chat->department !== false && $chat->department->xmpp_group_recipients != '') { $groupRecipients = explode(',',$chat->department->xmpp_group_recipients); } // change status foreach($groupRecipients as $recipient){ $conn->presence(NULL,'available', $recipient); } if (!empty($emailRecipient)) { $conn->presence(); } $messages = array_reverse(erLhcoreClassModelmsg::getList(array('limit' => 5,'sort' => 'id DESC','filter' => array('chat_id' => $chat->id)))); $messagesContent = ''; foreach ($messages as $msg ) { if ($msg->user_id == -1) { $messagesContent .= date(erLhcoreClassModule::$dateDateHourFormat,$msg->time).' '. erTranslationClassLhTranslation::getInstance()->getTranslation('chat/syncadmin','System assistant').': '.htmlspecialchars($msg->msg)."\n"; } else { $messagesContent .= date(erLhcoreClassModule::$dateDateHourFormat,$msg->time).' '. ($msg->user_id == 0 ? htmlspecialchars($chat->nick) : htmlspecialchars($msg->name_support)).': '.htmlspecialchars($msg->msg)."\n"; } } $cfgSite = erConfigClassLhConfig::getInstance(); $secretHash = $cfgSite->getSetting( 'site', 'secrethash' ); foreach ($emailRecipient as $email) { $veryfyEmail = sha1(sha1($email.$secretHash).$secretHash); $messagesParsed = str_replace(array('{messages}','{url_accept}','{chat_id}','{user_name}','{department}'), array($messagesContent,erLhcoreClassSystem::getHost() . erLhcoreClassDesign::baseurl('chat/accept').'/'.erLhcoreClassModelChatAccept::generateAcceptLink($chat).'/'.$veryfyEmail.'/'.$email,$chat->id,$chat->user_name,(string)$chat->department),$data[$templateMessage]); $conn->message($email,$messagesParsed); } foreach ($groupRecipients as $email) { list($emailGroup) = explode('/',$email); $veryfyEmail = sha1(sha1($emailGroup.$secretHash).$secretHash); $messagesParsed = str_replace(array('{messages}','{url_accept}','{chat_id}','{user_name}','{department}'), array($messagesContent,erLhcoreClassSystem::getHost() . erLhcoreClassDesign::baseurl('chat/accept').'/'.erLhcoreClassModelChatAccept::generateAcceptLink($chat).'/'.$veryfyEmail.'/'.$emailGroup,$chat->id,$chat->user_name,(string)$chat->department),$data[$templateMessage]); $conn->message($emailGroup,$messagesParsed,'groupchat'); } foreach($groupRecipients as $recipient) { $conn->presence(NULL,'unavailable',$recipient); } $conn->disconnect(); return true; } catch (Exception $e) { throw $e; } } else { if (($accessToken = self::getAccessToken()) !== false) { $dataLogin = self::get_dns_srv('gmail.com'); $conn = new XMPPHP_XMPP($dataLogin[0], $dataLogin[1], $data['email_gtalk'], $accessToken, 'xmpphp', $dataLogin[0], $printlog = false, $loglevel = XMPPHP_Log::LEVEL_INFO, true); try { $conn->connect(); $conn->processUntil('session_start'); $conn->presence(); $emailRecipient = array(); if ($chat->department !== false && $chat->department->xmpp_recipients != '') { // Perhaps department has assigned email $emailRecipient = explode(',',$chat->department->xmpp_recipients); } elseif (isset($data['recipients']) && $data['recipients'] != '') { $emailRecipient = explode(',', $data['recipients']); } $settingsXMPPGlobal = isset($params['recipients_setting']) ? $params['recipients_setting'] : 'xmp_users'; $optionsDepartment = array(); if ($chat->department !== false){ $optionsDepartment = $chat->department->inform_options_array; } if (in_array($settingsXMPPGlobal, $optionsDepartment)) { $db = ezcDbInstance::get(); $stmt = $db->prepare("SELECT xmpp_username FROM lh_users WHERE id IN (SELECT user_id FROM lh_userdep WHERE dep_id = 0 OR dep_id = :dep_id) AND xmpp_username != ''"); $stmt->bindValue( ':dep_id',$chat->dep_id,PDO::PARAM_INT); $stmt->execute(); $usersXMPPs = $stmt->fetchAll(PDO::FETCH_COLUMN); if (is_array($usersXMPPs)){ $emailRecipient = array_unique(array_merge($emailRecipient,$usersXMPPs)); } } $messages = array_reverse(erLhcoreClassModelmsg::getList(array('limit' => 5,'sort' => 'id DESC','filter' => array('chat_id' => $chat->id)))); $messagesContent = ''; foreach ($messages as $msg ) { if ($msg->user_id == -1) { $messagesContent .= date(erLhcoreClassModule::$dateDateHourFormat,$msg->time).' '. erTranslationClassLhTranslation::getInstance()->getTranslation('chat/syncadmin','System assistant').': '.htmlspecialchars($msg->msg)."\n"; } else { $messagesContent .= date(erLhcoreClassModule::$dateDateHourFormat,$msg->time).' '. ($msg->user_id == 0 ? htmlspecialchars($chat->nick) : htmlspecialchars($msg->name_support)).': '.htmlspecialchars($msg->msg)."\n"; } } $cfgSite = erConfigClassLhConfig::getInstance(); $secretHash = $cfgSite->getSetting( 'site', 'secrethash' ); foreach ($emailRecipient as $email) { $veryfyEmail = sha1(sha1($email.$secretHash).$secretHash); $conn->message($email,str_replace(array('{messages}','{url_accept}','{chat_id}','{user_name}','{department}'), array($messagesContent,erLhcoreClassSystem::getHost() . erLhcoreClassDesign::baseurl('chat/accept').'/'.erLhcoreClassModelChatAccept::generateAcceptLink($chat).'/'.$veryfyEmail.'/'.$email, $chat->id,$chat->user_name,(string)$chat->department),$data[$templateMessage])); } $conn->disconnect(); return true; } catch (Exception $e) { throw $e; } } else { throw new Exception('Invalid access token'); } } } } } ?>

| ver. 1.4 | Github | . | PHP 8.2.30 | ��֧ߧ֧�ѧ�ڧ� ��ѧߧڧ��: 0 | proxy | phpinfo | ��ѧ��ۧܧ�