|
|
@@ -0,0 +1,134 @@
|
|
|
+<?php defined('BX_DOL') or die('hack attempt');
|
|
|
+/**
|
|
|
+ * Copyright (c) UNA, Inc - https://una.io
|
|
|
+ * MIT License - https://opensource.org/licenses/MIT
|
|
|
+ *
|
|
|
+ * @defgroup UnaCore UNA Core
|
|
|
+ * @{
|
|
|
+ */
|
|
|
+
|
|
|
+class BxDolPushWonderPush extends BxDolPush
|
|
|
+{
|
|
|
+ protected $_sEndpoint;
|
|
|
+
|
|
|
+ protected $_sAppId;
|
|
|
+ protected $_sAcessToken;
|
|
|
+ protected $_sWebKey;
|
|
|
+
|
|
|
+ protected $_bCodeAdded;
|
|
|
+
|
|
|
+ protected function __construct($aObject, $oTemplate = null, $sDbClassName = '')
|
|
|
+ {
|
|
|
+ parent::__construct($aObject, $oTemplate, $sDbClassName);
|
|
|
+
|
|
|
+ $this->_sEndpoint = 'https://management-api.wonderpush.com/v1/deliveries';
|
|
|
+
|
|
|
+ $this->_sAppId = getParam('sys_push_wonderpush_app_id');
|
|
|
+ $this->_sAcessToken = getParam('sys_push_wonderpush_access_token');
|
|
|
+ $this->_sWebKey = getParam('sys_push_wonderpush_web_key');
|
|
|
+
|
|
|
+ $this->_bCodeAdded = false;
|
|
|
+ }
|
|
|
+
|
|
|
+ public function send($iProfileId, $aMessage, $bAddToQueue = false)
|
|
|
+ {
|
|
|
+ if(empty($this->_sAppId) || empty($this->_sAcessToken))
|
|
|
+ return false;
|
|
|
+
|
|
|
+ if($bAddToQueue && BxDolQueuePush::getInstance()->add($iProfileId, $aMessage))
|
|
|
+ return true;
|
|
|
+
|
|
|
+ // prepare params
|
|
|
+
|
|
|
+ $sUrlWeb = $sUrlApp = !empty($aMessage['url']) ? $aMessage['url'] : '';
|
|
|
+
|
|
|
+ if($this->_sApiUrlRootEmail !== false) {
|
|
|
+ if($sUrlWeb)
|
|
|
+ $sUrlWeb = str_replace(BX_DOL_URL_ROOT, $this->_sApiUrlRootEmail, $sUrlWeb);
|
|
|
+
|
|
|
+ if(!empty($aMessage['contents']) && is_array($aMessage['contents']))
|
|
|
+ foreach($aMessage['contents'] as $sKey => $sValue)
|
|
|
+ $aMessage['contents'][$sKey] = str_replace(BX_DOL_URL_ROOT, $this->_sApiUrlRootEmail, $sValue);
|
|
|
+ }
|
|
|
+
|
|
|
+ if($this->_sApiUrlRootPush !== false) {
|
|
|
+ if($sUrlApp)
|
|
|
+ $sUrlApp = str_replace(BX_DOL_URL_ROOT, $this->_sApiUrlRootPush, $sUrlApp);
|
|
|
+ }
|
|
|
+ else
|
|
|
+ $sUrlApp = $sUrlWeb;
|
|
|
+
|
|
|
+ if(empty($aMessage['icon']))
|
|
|
+ $aMessage['icon'] = BxTemplFunctions::getInstance()->getMainLogoUrl();
|
|
|
+
|
|
|
+ // construct notification object
|
|
|
+
|
|
|
+ $aFields = [
|
|
|
+ 'accessToken' => $this->_sAcessToken,
|
|
|
+ 'targetUserIds' => $iProfileId,
|
|
|
+ ];
|
|
|
+ $aNotification = [
|
|
|
+ 'alert' => [],
|
|
|
+ ];
|
|
|
+ if (!empty($aMessage['contents'])) {
|
|
|
+ $aNotification['alert']['text'] = is_array($aMessage['contents']) ? $aMessage['contents']['en'] : $aMessage['contents'];
|
|
|
+ }
|
|
|
+ if (!empty($aMessage['headings'])) {
|
|
|
+ $aNotification['alert']['title'] = is_array($aMessage['headings']) ? $aMessage['headings']['en'] : $aMessage['headings'];
|
|
|
+ }
|
|
|
+
|
|
|
+ if(!empty($aMessage['icon'])){
|
|
|
+ $aNotification['alert']['web'] = $aNotification['alert']['web'] ?? [];
|
|
|
+ $aNotification['alert']['web']['icon'] = $aMessage['icon'];
|
|
|
+
|
|
|
+ $aNotification['alert']['android'] = $aNotification['alert']['android'] ?? [];
|
|
|
+ $aNotification['alert']['android']['smallIcon'] = $aMessage['icon'];
|
|
|
+ }
|
|
|
+
|
|
|
+ if('on' == getParam('bx_nexus_option_push_notifications_count')) {
|
|
|
+ $iBadgeCount = $this->getNotificationsCount($iProfileId);
|
|
|
+ $aNotification['alert']['ios'] = $aNotification['alert']['ios'] ?? [];
|
|
|
+ $aNotification['alert']['ios']['badge'] = $iBadgeCount;
|
|
|
+ }
|
|
|
+
|
|
|
+ if (!empty($sUrlWeb)) {
|
|
|
+ $aNotification['alert']['targetUrl'] = $sUrlWeb;
|
|
|
+
|
|
|
+ $aFields['push'] = $aFields['push'] ?? [];
|
|
|
+ $aFields['push']['custom'] = $aFields['push']['custom'] ?? [];
|
|
|
+ $aFields['push']['custom']['url'] = $sUrlWeb;
|
|
|
+ }
|
|
|
+ if (!empty($sUrlApp)) {
|
|
|
+ // TODO: ??? https://docs.wonderpush.com/reference/notification
|
|
|
+ }
|
|
|
+
|
|
|
+ $aFields['notifications'] = json_encode($aNotification);
|
|
|
+
|
|
|
+ // send request
|
|
|
+
|
|
|
+ $oChannel = curl_init();
|
|
|
+ curl_setopt($oChannel, CURLOPT_URL, $this->_sEndpoint);
|
|
|
+ curl_setopt($oChannel, CURLOPT_HTTPHEADER, [
|
|
|
+ 'Content-Type: application/json; charset=utf-8',
|
|
|
+ ]);
|
|
|
+ curl_setopt($oChannel, CURLOPT_RETURNTRANSFER, true);
|
|
|
+ curl_setopt($oChannel, CURLOPT_HEADER, false);
|
|
|
+ curl_setopt($oChannel, CURLOPT_POST, true);
|
|
|
+ curl_setopt($oChannel, CURLOPT_POSTFIELDS, json_encode($aFields));
|
|
|
+ if (getParam('sys_curl_ssl_allow_untrusted') == 'on')
|
|
|
+ curl_setopt($oChannel, CURLOPT_SSL_VERIFYPEER, false);
|
|
|
+
|
|
|
+ $sResult = curl_exec($oChannel);
|
|
|
+ curl_close($oChannel);
|
|
|
+
|
|
|
+ $oResult = @json_decode($sResult, true);
|
|
|
+
|
|
|
+ if(isset($oResult['error'])) {
|
|
|
+ bx_log('sys_push', $sError . " Message:" . $oResult['error']['message'], BX_LOG_ERR);
|
|
|
+ }
|
|
|
+
|
|
|
+ return $sResult;
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+/** @} */
|
Aleksandr Trofimov